Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionManager ¶
type ConnectionManager interface { sconn.ServerConnectionPublisher topology.TopologyPublisher ClientEstablished(connNumber uint32, conn cconn.ClientConnection) (map[common.RMId]sconn.ServerConnection, *cconn.ClientTxnMetrics) ClientLost(connNumber uint32, conn cconn.ClientConnection) GetClient(bootNumber, connNumber uint32) cconn.ClientConnection ServerEstablished(server sconn.ServerConnection) ServerLost(server sconn.ServerConnection, restarting bool) LocalHost() string ServerConnectionFlushed(sender common.RMId) SetTopology(topology *configuration.Topology, callbacks map[topology.TopologyChangeSubscriberType]func(), localhost string, remoteHosts []string) NodeCertificatePrivateKeyPair() *certs.NodeCertificatePrivateKeyPair SetMetrics(client, server prometheus.Gauge, clientTxnMetrics *cconn.ClientTxnMetrics) }
Click to show internal directories.
Click to hide internal directories.