connections

Aug 20, 2020

Changes in this version

type ConnectionManager

+ Forwardable func(target string) bool

+ type ConnectionState struct

+ ConnectionLockAcquired bool

+ func (t *ConnectionState) Equal(other *targetpb.Target) bool

+ func (t *ConnectionState) InitializeMetrics()

+ func (t *ConnectionState) Seen(target string) bool

+ type ZookeeperConnectionManager struct

+ func NewZookeeperConnectionManagerDefault(config *configuration.GatewayConfig, zkConn *zk.Conn, zkEvents <-chan zk.Event) (*ZookeeperConnectionManager, error)

+ func (c *ZookeeperConnectionManager) Cache() *cache.Cache

+ func (c *ZookeeperConnectionManager) Forwardable(target string) bool

+ func (c *ZookeeperConnectionManager) ReloadTargets()

+ func (c *ZookeeperConnectionManager) Start() error

+ func (c *ZookeeperConnectionManager) TargetControlChan() chan<- *TargetConnectionControl

Jul 6, 2020

Changes in this version

+ func MakeTargetLockPath(prefix string, target string) string

+ type ConnectionManager struct

+ func NewConnectionManagerDefault(config *configuration.GatewayConfig, zkConn *zk.Conn) (*ConnectionManager, error)

+ func (c *ConnectionManager) Cache() *cache.Cache

+ func (c *ConnectionManager) HasTargetLock(target string) bool

+ func (c *ConnectionManager) ReloadTargets()

+ func (c *ConnectionManager) Start() error

+ func (c *ConnectionManager) TargetControlChan() chan<- *TargetConnectionControl

+ type TargetConnectionControl struct

+ Insert *targetpb.Configuration

+ Remove []string

+ func (t *TargetConnectionControl) InsertCount() int

+ func (t *TargetConnectionControl) RemoveCount() int

+ type TargetState struct

+ ConnectionLockAcquired bool

+ func (t *TargetState) Equal(other *targetpb.Target) bool