cloudmap

Dec 9, 2022

Changes in this version

type OperationPoller

+ func NewOperationPoller(sdApi ServiceDiscoveryApi) OperationPoller

+ func NewOperationPollerWithConfig(pollInterval, pollTimeout time.Duration, sdApi ServiceDiscoveryApi) OperationPoller

+ Await func() (err error)

+ Submit func(ctx context.Context, opProvider func() (opId string, err error))

Apr 20, 2022

Changes in this version

type ServiceDiscoveryApi

+ GetNamespaceMap func(ctx context.Context) (namespaces map[string]*model.Namespace, err error)

+ GetServiceIdMap func(ctx context.Context, namespaceId string) (serviceIdMap map[string]string, err error)

type ServiceDiscoveryClientCache

+ CacheNamespaceMap func(namespaces map[string]*model.Namespace)

+ CacheServiceIdMap func(namespaceName string, serviceIdMap map[string]string)

+ EvictNamespaceMap func()

+ EvictServiceIdMap func(namespaceName string)

+ GetNamespaceMap func() (namespaces map[string]*model.Namespace, found bool)

+ GetServiceIdMap func(namespaceName string) (serviceIdMap map[string]string, found bool)

Nov 19, 2021

Changes in this version

type AwsFacade

+ DiscoverInstances func(context.Context, *sd.DiscoverInstancesInput, ...func(*sd.Options)) (*sd.DiscoverInstancesOutput, error)

+ type SdCacheConfig struct

+ EndptTTL time.Duration

+ NsTTL time.Duration

+ SvcTTL time.Duration

type ServiceDiscoveryApi

+ DiscoverInstances func(ctx context.Context, nsName string, svcName string) (insts []types.HttpInstanceSummary, err error)

type ServiceDiscoveryClient

+ func NewDefaultServiceDiscoveryClient(cfg *aws.Config) ServiceDiscoveryClient

+ func NewServiceDiscoveryClientWithCustomCache(cfg *aws.Config, cacheConfig *SdCacheConfig) ServiceDiscoveryClient

+ type ServiceDiscoveryClientCache interface

+ CacheEndpoints func(namespaceName string, serviceName string, endpoints []*model.Endpoint)

+ CacheNamespace func(namespace *model.Namespace)

+ CacheNilNamespace func(namespaceName string)

+ CacheServiceId func(namespaceName string, serviceName string, serviceId string)

+ EvictEndpoints func(namespaceName string, serviceName string)

+ GetEndpoints func(namespaceName string, serviceName string) (endpoints []*model.Endpoint, found bool)

+ GetNamespace func(namespaceName string) (namespace *model.Namespace, found bool)

+ GetServiceId func(namespaceName string, serviceName string) (serviceId string, found bool)

+ func NewDefaultServiceDiscoveryClientCache() ServiceDiscoveryClientCache

+ func NewServiceDiscoveryClientCache(cacheConfig *SdCacheConfig) ServiceDiscoveryClientCache

Nov 6, 2021

Changes in this version

+ func Itoa(i int64) string

+ func Now() int64

+ type AwsFacade interface

+ CreateHttpNamespace func(context.Context, *sd.CreateHttpNamespaceInput, ...func(*sd.Options)) (*sd.CreateHttpNamespaceOutput, error)

+ CreateService func(context.Context, *sd.CreateServiceInput, ...func(*sd.Options)) (*sd.CreateServiceOutput, error)

+ DeregisterInstance func(context.Context, *sd.DeregisterInstanceInput, ...func(*sd.Options)) (*sd.DeregisterInstanceOutput, error)

+ GetOperation func(context.Context, *sd.GetOperationInput, ...func(*sd.Options)) (*sd.GetOperationOutput, error)

+ ListInstances func(context.Context, *sd.ListInstancesInput, ...func(*sd.Options)) (*sd.ListInstancesOutput, error)

+ ListNamespaces func(context.Context, *sd.ListNamespacesInput, ...func(*sd.Options)) (*sd.ListNamespacesOutput, error)

+ ListOperations func(context.Context, *sd.ListOperationsInput, ...func(*sd.Options)) (*sd.ListOperationsOutput, error)

+ ListServices func(context.Context, *sd.ListServicesInput, ...func(options *sd.Options)) (*sd.ListServicesOutput, error)

+ RegisterInstance func(context.Context, *sd.RegisterInstanceInput, ...func(*sd.Options)) (*sd.RegisterInstanceOutput, error)

+ func NewAwsFacadeFromConfig(cfg *aws.Config) AwsFacade

+ type OperationCollector interface

+ Add func(operationProvider func() (operationId string, err error))

+ Collect func() []string

+ GetStartTime func() int64

+ IsAllOperationsCreated func() bool

+ func NewOperationCollector() OperationCollector

+ type OperationPoller interface

+ Poll func(ctx context.Context) error

+ func NewDeregisterInstancePoller(sdApi ServiceDiscoveryApi, serviceId string, opIds []string, startTime int64) OperationPoller

+ func NewRegisterInstancePoller(sdApi ServiceDiscoveryApi, serviceId string, opIds []string, startTime int64) OperationPoller

+ type ServiceDiscoveryApi interface

+ CreateHttpNamespace func(ctx context.Context, namespaceName string) (operationId string, err error)

+ CreateService func(ctx context.Context, namespace model.Namespace, serviceName string) (serviceId string, err error)

+ DeregisterInstance func(ctx context.Context, serviceId string, instanceId string) (operationId string, err error)

+ GetOperation func(ctx context.Context, operationId string) (operation *types.Operation, err error)

+ ListInstances func(ctx context.Context, serviceId string) ([]types.InstanceSummary, error)

+ ListNamespaces func(ctx context.Context) (namespaces []*model.Namespace, err error)

+ ListOperations func(ctx context.Context, opFilters []types.OperationFilter) (operationStatusMap map[string]types.OperationStatus, err error)

+ ListServices func(ctx context.Context, namespaceId string) (services []*model.Resource, err error)

+ PollNamespaceOperation func(ctx context.Context, operationId string) (namespaceId string, err error)

+ RegisterInstance func(ctx context.Context, serviceId string, instanceId string, ...) (operationId string, err error)

+ func NewServiceDiscoveryApiFromConfig(cfg *aws.Config) ServiceDiscoveryApi

Oct 8, 2021

Changes in this version

+ type EndpointManager interface

+ DeregisterEndpoints func(ctx context.Context, service *model.Service, serviceId string) error

+ ListEndpoints func(ctx context.Context, serviceId string) ([]*model.Endpoint, error)

+ RegisterEndpoints func(ctx context.Context, service *model.Service, serviceId string) error

+ func NewEndpointManager(cfg *aws.Config) EndpointManager

+ type ServiceDiscoveryClient interface

+ CreateService func(ctx context.Context, service *model.Service) error

+ DeleteEndpoints func(ctx context.Context, service *model.Service) error

+ GetService func(ctx context.Context, namespace string, name string) (*model.Service, error)

+ ListServices func(ctx context.Context, namespaceName string) ([]*model.Service, error)

+ RegisterEndpoints func(ctx context.Context, service *model.Service) error

+ func NewServiceDiscoveryClient(cfg *aws.Config) ServiceDiscoveryClient