registry

Apr 13, 2021

Changes in this version

+ var WithClient = WithClientK8s

type Component

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

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

type Config

+ Scheme string

type Option

+ func WithKind(kind string) Option

+ func WithOnFailHandle(onFileHandle string) Option

+ func WithScheme(scheme string) Option

Mar 19, 2021

Changes in this version

+ type Component struct

+ func (reg *Component) Close() error

+ func (reg *Component) ListServices(ctx context.Context, addr string, scheme string) (services []*server.ServiceInfo, err error)

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

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

+ func (reg *Component) WatchServices(ctx context.Context, addr string, scheme string) (chan eregistry.Endpoints, error)

+ type Config struct

+ Kind string

+ OnFailHandle 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 WithClientK8s(k8s *ek8s.Component) Option