registry

Dec 19, 2024

Changes in this version

+ func WithContext(ctx context.Context) func(*getServicesOptions)

Dec 8, 2024

Changes in this version

+ var ErrNotImplemented = errors.New("not implemented")

+ func NoWait() func(*getServicesOptions)

+ func WithFilters(filters ...Filter) func(*getServicesOptions)

+ type RegistryMock struct

+ CloseImpl func() error

+ GetObservedServiceNamesImpl func() []string

+ GetRegisteredServicesImpl func() []Service

+ GetServiceImpl func(name string, filters ...Filter) (*Service, error)

+ GetServicesImpl func(name string) ([]Service, error)

+ ObserveImpl func(serviceName string) error

+ RegisterImpl func(s Service) (FnUnregister, error)

+ SetServiceStatusImpl func(s Service, status Status) error

+ SubscribersImpl func() []string

+ UnregisterImpl func(s Service) error

+ func (r *RegistryMock) Close() error

+ func (r *RegistryMock) GetObservedServiceNames() []string

+ func (r *RegistryMock) GetRegisteredServices() []Service

+ func (r *RegistryMock) GetService(name string, filters ...Filter) (*Service, error)

+ func (r *RegistryMock) GetServices(name string, opts ...func(*getServicesOptions)) ([]Service, error)

+ func (r *RegistryMock) Observe(serviceName string) error

+ func (r *RegistryMock) Register(s Service) (FnUnregister, error)

+ func (r *RegistryMock) SetServiceStatus(s Service, status Status) error

+ func (r *RegistryMock) Subscribers() []string

+ func (r *RegistryMock) Unregister(s Service) error

Mar 29, 2023

Changes in this version

+ type Configure interface

+ Configure func(*Options) error

type Options

+ KVOption map[string]interface{}

Jan 10, 2022

Changes in this version

+ func GetObservedServiceNames() []string

+ func Port(s Service) int

type Registry

+ GetObservedServiceNames func() []string

Nov 30, 2021

Changes in this version

+ func SetServiceStatus(s Service, status Status) error

type Registry

+ GetRegisteredServices func() []Service

type Service

+ func GetRegisteredServices() ([]Service, error)

Nov 29, 2021

Changes in this version

type Filter

+ func PassingFilter() Filter

type Pong

+ Status Status

type Registry

+ SetServiceStatus func(s Service, status Status) error

+ type Status int

+ const Critical

+ const Passing

+ const Warning

+ func (s *Status) FromString(status string) Status

+ func (s *Status) UnmarshalJSON(b []byte) error

+ func (s Status) MarshalJSON() ([]byte, error)

+ func (s Status) String() string

Dec 22, 2020

Changes in this version

type Service

+ KV map[string]string

Dec 8, 2020

Changes in this version

type Option

+ func WithLoglevel(level logrus.Level) Option

+ func WithMainTopic(topic string) Option

+ func WithObserverEvent(ev ObserverEvent) Option

+ func WithRegisterInterval(duration time.Duration) Option

+ func WithTimeout(timeout time.Duration) Option

Dec 6, 2020

Changes in this version

type Registry

+ func GetDefault() (r Registry, err error)

+ func SetDefault(opts ...Option) (r Registry, err error)

+ Subscribers func() []string

Nov 25, 2020

Changes in this version

+ var ErrNoDefaultInstance = errors.New("Default instance has not been set, call SetDefaultInstance before")

+ func Close() error

+ func Observe(name string) error

type Event

+ const EventRegister

+ const EventUnregister

type Registry

+ func NewRegistry(opts ...Option) (r Registry, err error)

+ func SetDefaultInstance(opts ...Option) (r Registry, err error)

type Service

+ func GetService(name string, f ...Filter) (*Service, error)

+ func GetServices(name string) ([]Service, error)

Nov 22, 2020

Changes in this version

+ var ErrNoFreePort = errors.New("No free port available")

+ func FindFreeLocalAddress(from, to int) (string, error)

+ func FindFreePort(from, to int) (freeport int, err error)

+ func FreePort() (freeport int, err error)

+ func LocalFreeAddr() (string, error)

+ func LocalFreeIPv6Addr() (string, error)

Nov 21, 2020

Changes in this version

+ type Event string

+ const Register

+ const Unregister

+ type ObserveFilter func(s *Pong) bool

+ func LocalhostOFilter() ObserveFilter

+ type ObserverEvent func(s Service, ev Event)

type Option

+ func AddObserveFilter(f ObserveFilter) Option

+ func SetObserverEvent(ev ObserverEvent) Option

+ func WithPubsub(pb Pubsub) Option

+ type Pubsub interface

+ Pub func(topic string, data []byte) error

+ Sub func(topic string, f func(m *PubsubMsg)) (Subscription, error)

+ type PubsubMsg struct

+ Data []byte

+ Subject string

type Registry

+ Unregister func(s Service) error

+ type Subscription interface

+ Subject func() string

+ Unsub func() error

Nov 7, 2020

Changes in this version

+ var DefaultCheckDueInterval = 200 * time.Millisecond

+ var DefaultDueDurationFactor = float32(1.5)

+ var DefaultMainTopic string

+ var DefaultRegisterInterval = 20 * time.Second

+ var DefaultTimeout = 100 * time.Millisecond

+ var ErrNotFound = errors.New("No service found")

+ func SetFlags()

+ type Filter func(services []*Pong) []*Pong

+ func LoadBalanceFilter() Filter

+ func LocalhostFilter() Filter

+ type FnUnregister func()

+ type Option func(opts *Options)

+ func AddFilter(f Filter) Option

+ func MainTopic(topic string) Option

+ func Nats(conn *nats.Conn) Option

+ func RegisterInterval(duration time.Duration) Option

+ func Timeout(timeout time.Duration) Option

+ type Options struct

+ type Pong struct

+ Timestamps *Timestamps

+ func (p Pong) String() string

+ type Registry interface

+ Close func() error

+ GetService func(name string, filters ...Filter) (*Service, error)

+ GetServices func(name string) ([]Service, error)

+ Observe func(serviceName string) error

+ Register func(s Service) (FnUnregister, error)

+ func Connect(opts ...Option) (r Registry, err error)

+ type Service struct

+ Address string

+ Host string

+ Name string

+ Network string

+ URL string

+ Version string

+ func (s Service) DueTime() time.Time

+ func (s Service) String() string

+ type Timestamps struct

+ Duration int

+ Registered int64