manager

Oct 21, 2024

Changes in this version

type Config

+ MonitorError func(string, error)

Jan 27, 2023

Changes in this version

type Config

+ ReceiveTimeout time.Duration

Jan 26, 2023

Changes in this version

+ const AddrSeparator

+ const Address

+ const Addresses

+ const Password

+ const Target

+ const Username

+ var ErrPending = errors.New("subscription already pending")

+ var RetryBaseDelay = time.Second

+ var RetryMaxDelay = time.Minute

+ var RetryRandomization = 0.5

+ type Config struct

+ Connect func(string)

+ ConnectError func(string, error)

+ ConnectionManager ConnectionManager

+ Credentials CredentialsClient

+ Reset func(string)

+ Sync func(string)

+ Timeout time.Duration

+ Update func(string, *gpb.Notification)

+ type ConnectionManager interface

+ Connection func(ctx context.Context, addr, dialer string) (conn *grpc.ClientConn, done func(), err error)

+ type CredentialsClient interface

+ Lookup func(ctx context.Context, key string) (string, error)

+ type Manager struct

+ func NewManager(cfg Config) (*Manager, error)

+ func (m *Manager) Add(name string, t *tpb.Target, sr *gpb.SubscribeRequest) error

+ func (m *Manager) Reconnect(name string) error

+ func (m *Manager) Remove(name string) error