Documentation ¶
Index ¶
- type ConnectionManager
- func (cm *ConnectionManager) AddServerConnectionSubscriber(obs sconn.ServerConnectionSubscriber)
- func (cm *ConnectionManager) AddTopologySubscriber(subType topo.TopologyChangeSubscriberType, obs topo.TopologySubscriber) *configuration.Topology
- func (cm *ConnectionManager) ClientEstablished(connNumber uint32, conn cconn.ClientConnection) (map[common.RMId]sconn.ServerConnection, *cconn.ClientTxnMetrics)
- func (cm *ConnectionManager) ClientLost(connNumber uint32, conn cconn.ClientConnection)
- func (cm *ConnectionManager) GetClient(bootNumber, connNumber uint32) cconn.ClientConnection
- func (cm *ConnectionManager) LocalHost() string
- func (cm *ConnectionManager) NodeCertificatePrivateKeyPair() *certs.NodeCertificatePrivateKeyPair
- func (cm *ConnectionManager) RegisterSelf()
- func (cm *ConnectionManager) RemoveServerConnectionSubscriber(obs sconn.ServerConnectionSubscriber)
- func (cm *ConnectionManager) RemoveTopologySubscriberAsync(subType topo.TopologyChangeSubscriberType, obs topo.TopologySubscriber)
- func (cm *ConnectionManager) ServerConnectionFlushed(rmId common.RMId)
- func (cm *ConnectionManager) ServerEstablished(server sconn.ServerConnection)
- func (cm *ConnectionManager) ServerLost(server sconn.ServerConnection, restarting bool)
- func (cm *ConnectionManager) SetMetrics(client, server prometheus.Gauge, clientTxnMetrics *cconn.ClientTxnMetrics)
- func (cm *ConnectionManager) SetTopology(topology *configuration.Topology, ...)
- func (cm *ConnectionManager) Status(sc *status.StatusConsumer)
- type ShutdownSignaller
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionManager ¶
type ConnectionManager struct { *actor.Mailbox *actor.BasicServerOuter // contains filtered or unexported fields }
func NewConnectionManager ¶
func (*ConnectionManager) AddServerConnectionSubscriber ¶
func (cm *ConnectionManager) AddServerConnectionSubscriber(obs sconn.ServerConnectionSubscriber)
func (*ConnectionManager) AddTopologySubscriber ¶
func (cm *ConnectionManager) AddTopologySubscriber(subType topo.TopologyChangeSubscriberType, obs topo.TopologySubscriber) *configuration.Topology
func (*ConnectionManager) ClientEstablished ¶
func (cm *ConnectionManager) ClientEstablished(connNumber uint32, conn cconn.ClientConnection) (map[common.RMId]sconn.ServerConnection, *cconn.ClientTxnMetrics)
func (*ConnectionManager) ClientLost ¶
func (cm *ConnectionManager) ClientLost(connNumber uint32, conn cconn.ClientConnection)
func (*ConnectionManager) GetClient ¶
func (cm *ConnectionManager) GetClient(bootNumber, connNumber uint32) cconn.ClientConnection
func (*ConnectionManager) LocalHost ¶
func (cm *ConnectionManager) LocalHost() string
func (*ConnectionManager) NodeCertificatePrivateKeyPair ¶
func (cm *ConnectionManager) NodeCertificatePrivateKeyPair() *certs.NodeCertificatePrivateKeyPair
func (*ConnectionManager) RegisterSelf ¶
func (cm *ConnectionManager) RegisterSelf()
func (*ConnectionManager) RemoveServerConnectionSubscriber ¶
func (cm *ConnectionManager) RemoveServerConnectionSubscriber(obs sconn.ServerConnectionSubscriber)
func (*ConnectionManager) RemoveTopologySubscriberAsync ¶
func (cm *ConnectionManager) RemoveTopologySubscriberAsync(subType topo.TopologyChangeSubscriberType, obs topo.TopologySubscriber)
func (*ConnectionManager) ServerConnectionFlushed ¶
func (cm *ConnectionManager) ServerConnectionFlushed(rmId common.RMId)
func (*ConnectionManager) ServerEstablished ¶
func (cm *ConnectionManager) ServerEstablished(server sconn.ServerConnection)
func (*ConnectionManager) ServerLost ¶
func (cm *ConnectionManager) ServerLost(server sconn.ServerConnection, restarting bool)
func (*ConnectionManager) SetMetrics ¶
func (cm *ConnectionManager) SetMetrics(client, server prometheus.Gauge, clientTxnMetrics *cconn.ClientTxnMetrics)
func (*ConnectionManager) SetTopology ¶
func (cm *ConnectionManager) SetTopology(topology *configuration.Topology, callbacks map[topo.TopologyChangeSubscriberType]func(), localhost string, remotehosts []string)
func (*ConnectionManager) Status ¶
func (cm *ConnectionManager) Status(sc *status.StatusConsumer)
type ShutdownSignaller ¶
type ShutdownSignaller interface {
SignalShutdown()
}
Click to show internal directories.
Click to hide internal directories.