registry

Apr 20, 2022

Changes in this version

+ type Component struct

+ func (reg *Component) Close() error

+ func (reg *Component) IsValid(ctx context.Context) error

+ func (reg *Component) ListServices(ctx context.Context, t eregistry.Target) (services []*server.ServiceInfo, err error)

+ func (reg *Component) RegisterService(ctx context.Context, info *server.ServiceInfo) error

+ func (reg *Component) SyncServices(context.Context, eregistry.SyncServicesOptions) error

+ func (reg *Component) UnregisterService(ctx context.Context, info *server.ServiceInfo) error

+ func (reg *Component) WatchServices(ctx context.Context, t eregistry.Target) (chan eregistry.Endpoints, error)

+ type Config struct

+ Kind string

+ OnFailHandle string

+ Scheme string

+ func DefaultConfig() *Config

+ type Container struct

+ func DefaultContainer() *Container

+ func Load(key string) *Container

+ func (c *Container) Build(options ...Option) *Component

+ type Option func(c *Container)

+ func WithClient(k8s *ek8s.Component) Option

+ func WithKind(kind string) Option

+ func WithOnFailHandle(onFileHandle string) Option

+ func WithScheme(scheme string) Option