diff --git a/server/pkg/api/server.go b/server/pkg/api/server.go index a382e0d..5629b10 100644 --- a/server/pkg/api/server.go +++ b/server/pkg/api/server.go @@ -13,6 +13,7 @@ import ( "google.golang.org/grpc" ) +// ShoesLXDMultiServer implement gRPC server type ShoesLXDMultiServer struct { pb.UnimplementedShoesLXDMultiServer diff --git a/server/pkg/api/server_add_instance.go b/server/pkg/api/server_add_instance.go index 9eadb9e..0fac663 100644 --- a/server/pkg/api/server_add_instance.go +++ b/server/pkg/api/server_add_instance.go @@ -19,6 +19,7 @@ import ( "google.golang.org/grpc/status" ) +// AddInstance add instance to LXD server func (s *ShoesLXDMultiServer) AddInstance(ctx context.Context, req *pb.AddInstanceRequest) (*pb.AddInstanceResponse, error) { log.Printf("AddInstance req: %+v\n", req) if _, err := runner.ToUUID(req.RunnerName); err != nil { @@ -133,6 +134,7 @@ func (s *ShoesLXDMultiServer) scheduleHost(targetLXDHosts []lxdclient.LXDHost) ( } var ( + // ErrNoValidHost is not valid host in targets ErrNoValidHost = fmt.Errorf("no valid host in targets") ) diff --git a/server/pkg/api/server_delete_instance.go b/server/pkg/api/server_delete_instance.go index b41b0d7..122c5a6 100644 --- a/server/pkg/api/server_delete_instance.go +++ b/server/pkg/api/server_delete_instance.go @@ -12,6 +12,7 @@ import ( "google.golang.org/grpc/status" ) +// DeleteInstance delete instance to LXD server func (s *ShoesLXDMultiServer) DeleteInstance(ctx context.Context, req *pb.DeleteInstanceRequest) (*pb.DeleteInstanceResponse, error) { log.Printf("DeleteInstance req: %+v\n", req) if _, err := runner.ToUUID(req.CloudId); err != nil { diff --git a/server/pkg/config/config_hostconfig.go b/server/pkg/config/config_hostconfig.go index 41bddbd..0d0d84a 100644 --- a/server/pkg/config/config_hostconfig.go +++ b/server/pkg/config/config_hostconfig.go @@ -13,16 +13,20 @@ type HostConfigMap struct { s sync.Map } +// ErrHostNotFound is error message for host config is not found var ErrHostNotFound = fmt.Errorf("host config is not found") +// NewHostConfigMap create config map for host config func NewHostConfigMap() *HostConfigMap { return &HostConfigMap{} } +// Store host config func (s *HostConfigMap) Store(lxdAPIAddress string, hostConfig HostConfig) { s.s.Store(lxdAPIAddress, hostConfig) } +// Load host config func (s *HostConfigMap) Load(lxdAPIAddress string) (*HostConfig, error) { v, ok := s.s.Load(lxdAPIAddress) if !ok { @@ -37,6 +41,7 @@ func (s *HostConfigMap) Load(lxdAPIAddress string) (*HostConfig, error) { return &t, nil } +// Range host config func (s *HostConfigMap) Range(f func(key string, value HostConfig) bool) { s.s.Range(func(key, value interface{}) bool { k := key.(string) diff --git a/server/pkg/lxdclient/connect.go b/server/pkg/lxdclient/connect.go index d9ea4df..27e35da 100644 --- a/server/pkg/lxdclient/connect.go +++ b/server/pkg/lxdclient/connect.go @@ -38,6 +38,7 @@ func ConnectLXDs(hostConfigs []config.HostConfig) ([]LXDHost, error) { } var ( + // ErrTimeoutConnectLXD is error message for timeout of ConnectLXD ErrTimeoutConnectLXD = fmt.Errorf("timeout of ConnectLXD") ) diff --git a/shoes-lxd-multi/main.go b/shoes-lxd-multi/main.go index 97c51b0..152863d 100644 --- a/shoes-lxd-multi/main.go +++ b/shoes-lxd-multi/main.go @@ -17,7 +17,9 @@ import ( ) const ( - EnvTargetHosts = "LXD_MULTI_TARGET_HOSTS" + // EnvTargetHosts is list of target host + EnvTargetHosts = "LXD_MULTI_TARGET_HOSTS" + // EnvServerEndpoint is endpoint of server EnvServerEndpoint = "LXD_MULTI_SERVER_ENDPOINT" )