discovery

Mar 15, 2020

Changes in this version

type Connector

+ IsFatal func(err error) bool

type Inspector

+ IsFatal func(err error) bool

Mar 9, 2020

Changes in this version

+ type Application struct

+ Client *Client

+ type ApplicationExecutor struct

+ Parent context.Context

+ Task ApplicationTask

+ func (e *ApplicationExecutor) ApplicationAvailable(a *Application)

+ func (e *ApplicationExecutor) ApplicationUnavailable(a *Application)

+ type ApplicationObserver interface

+ ApplicationAvailable func(*Application)

+ ApplicationUnavailable func(*Application)

+ type ApplicationObserverSet struct

+ func NewApplicationObserverSet(observers ...ApplicationObserver) *ApplicationObserverSet

+ func (s *ApplicationObserverSet) ApplicationAvailable(a *Application)

+ func (s *ApplicationObserverSet) ApplicationUnavailable(a *Application)

+ func (s *ApplicationObserverSet) RegisterApplicationObserver(o ApplicationObserver)

+ func (s *ApplicationObserverSet) UnregisterApplicationObserver(o ApplicationObserver)

+ type ApplicationTask func(context.Context, *Application)

type Client

+ Connection *grpc.ClientConn

+ type ClientExecutor struct

+ Parent context.Context

+ Task ClientTask

+ func (e *ClientExecutor) ClientConnected(c *Client)

+ func (e *ClientExecutor) ClientDisconnected(c *Client)

+ type ClientTask func(context.Context, *Client)

type Connector

+ Ignore func(*Target) bool

+ func (c *Connector) Run(ctx context.Context, t *Target) error

+ type Inspector struct

+ BackoffStrategy backoff.Strategy

+ Ignore func(configkit.Application) bool

+ Logger logging.Logger

+ Observer ApplicationObserver

+ func (i *Inspector) Run(ctx context.Context, c *Client) error

+ type TargetExecutor struct

+ Parent context.Context

+ Task TargetTask

+ func (e *TargetExecutor) TargetAvailable(t *Target)

+ func (e *TargetExecutor) TargetUnavailable(t *Target)

+ type TargetTask func(context.Context, *Target)

Mar 8, 2020

Changes in this version

+ func DefaultDialer(ctx context.Context, t *Target) (*grpc.ClientConn, error)

+ type Client struct

+ Target *Target

+ type ClientObserver interface

+ ClientConnected func(*Client)

+ ClientDisconnected func(*Client)

+ type ClientObserverSet struct

+ func NewClientObserverSet(observers ...ClientObserver) *ClientObserverSet

+ func (s *ClientObserverSet) ClientConnected(c *Client)

+ func (s *ClientObserverSet) ClientDisconnected(c *Client)

+ func (s *ClientObserverSet) RegisterClientObserver(o ClientObserver)

+ func (s *ClientObserverSet) UnregisterClientObserver(o ClientObserver)

+ type Connector struct

+ BackoffStrategy backoff.Strategy

+ Dial Dialer

+ Logger logging.Logger

+ Observer ClientObserver

+ func (c *Connector) TargetAvailable(t *Target)

+ func (c *Connector) TargetUnavailable(t *Target)

+ type Dialer func(context.Context, *Target) (*grpc.ClientConn, error)

+ type MetaData map[interface{}]interface

+ type Target struct

+ MetaData MetaData

+ Name string

+ Options []grpc.DialOption

+ type TargetObserver interface

+ TargetAvailable func(*Target)

+ TargetUnavailable func(*Target)

+ type TargetObserverSet struct

+ func NewTargetObserverSet(observers ...TargetObserver) *TargetObserverSet

+ func (s *TargetObserverSet) RegisterTargetObserver(o TargetObserver)

+ func (s *TargetObserverSet) TargetAvailable(t *Target)

+ func (s *TargetObserverSet) TargetUnavailable(t *Target)

+ func (s *TargetObserverSet) UnregisterTargetObserver(o TargetObserver)