dynamic

Feb 14, 2022

Changes in this version

+ const DefaultGRPCTimeoutSeconds

+ var ErrNotAuthorized = errors.New("not authorized")

type Client

+ PlumberClusterID string

Feb 11, 2022

Changes in this version

type Client

+ func (d *Client) Close() error

type IDynamic

+ Close func() error

Dec 6, 2021

Changes in this version

+ const DefaultDynamicAddress

+ const ReconnectSleep

+ type Client struct

+ Client services.DProxyClient

+ Conn *grpc.ClientConn

+ MessageBus string

+ Options *opts.DynamicOptions

+ OutboundMessageCh chan *events.Outbound

+ Token string

+ func (d *Client) Read() chan *events.Outbound

+ func (d *Client) Start(bus string)

+ type IDynamic interface

+ Read func() chan *events.Outbound

+ Start func(bus string)

+ func New(opts *opts.DynamicOptions, bus string) (IDynamic, error)