Documentation
¶
Index ¶
- func NewConnectionTCPTLSCapnpDialer(self common.RMId, bootCount uint32, router *router.Router, ...)
- type Listener
- type TLSCapnpClient
- func (tcc *TLSCapnpClient) ConnectedRMs(servers map[common.RMId]sconn.ServerConnection)
- func (tcc *TLSCapnpClient) ConnectionEstablished(c sconn.ServerConnection, servers map[common.RMId]sconn.ServerConnection, ...)
- func (tcc *TLSCapnpClient) ConnectionLost(rmId common.RMId, servers map[common.RMId]sconn.ServerConnection)
- func (tcc *TLSCapnpClient) InternalShutdown()
- func (tcc *TLSCapnpClient) ReadAndHandleOneMsg() error
- func (tcc *TLSCapnpClient) Restart() bool
- func (tcc *TLSCapnpClient) Run(conn *network.Connection) error
- func (tcc *TLSCapnpClient) String() string
- func (tcc *TLSCapnpClient) SubmissionOutcomeReceived(sender common.RMId, subId *common.TxnId, txn *txnreader.TxnReader, ...)
- func (tcc *TLSCapnpClient) TopologyChanged(tc *network.ConnectionMsgTopologyChanged) error
- type TLSCapnpHandshaker
- type TLSCapnpServer
- func (tcs *TLSCapnpServer) InternalShutdown()
- func (tcs *TLSCapnpServer) ReadAndHandleOneMsg() error
- func (tcs *TLSCapnpServer) Restart() bool
- func (tcs *TLSCapnpServer) Run(conn *network.Connection) error
- func (tcs *TLSCapnpServer) Send(msg []byte)
- func (tcs *TLSCapnpServer) String() string
- func (tcs *TLSCapnpServer) TopologyChanged(tc *network.ConnectionMsgTopologyChanged) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConnectionTCPTLSCapnpDialer ¶
func NewConnectionTCPTLSCapnpDialer(self common.RMId, bootCount uint32, router *router.Router, cm connectionmanager.ConnectionManager, serverRemote sconn.ServerConnection, logger log.Logger)
we are dialing out to someone else
Types ¶
type Listener ¶
type Listener struct {
*actor.Mailbox
*actor.BasicServerOuter
// contains filtered or unexported fields
}
func NewListener ¶
func NewListener(listenPort uint16, rmId common.RMId, bootCount uint32, router *router.Router, cm connectionmanager.ConnectionManager, localConnection localconnection.LocalConnection, logger log.Logger) (*Listener, error)
type TLSCapnpClient ¶
type TLSCapnpClient struct {
*TLSCapnpHandshaker
*network.Connection
// contains filtered or unexported fields
}
func (*TLSCapnpClient) ConnectedRMs ¶
func (tcc *TLSCapnpClient) ConnectedRMs(servers map[common.RMId]sconn.ServerConnection)
func (*TLSCapnpClient) ConnectionEstablished ¶
func (tcc *TLSCapnpClient) ConnectionEstablished(c sconn.ServerConnection, servers map[common.RMId]sconn.ServerConnection, done func())
func (*TLSCapnpClient) ConnectionLost ¶
func (tcc *TLSCapnpClient) ConnectionLost(rmId common.RMId, servers map[common.RMId]sconn.ServerConnection)
func (*TLSCapnpClient) InternalShutdown ¶
func (tcc *TLSCapnpClient) InternalShutdown()
func (*TLSCapnpClient) ReadAndHandleOneMsg ¶
func (tcc *TLSCapnpClient) ReadAndHandleOneMsg() error
func (*TLSCapnpClient) Restart ¶
func (tcc *TLSCapnpClient) Restart() bool
func (*TLSCapnpClient) Run ¶
func (tcc *TLSCapnpClient) Run(conn *network.Connection) error
func (*TLSCapnpClient) String ¶
func (tcc *TLSCapnpClient) String() string
func (*TLSCapnpClient) SubmissionOutcomeReceived ¶
func (*TLSCapnpClient) TopologyChanged ¶
func (tcc *TLSCapnpClient) TopologyChanged(tc *network.ConnectionMsgTopologyChanged) error
type TLSCapnpHandshaker ¶
type TLSCapnpHandshaker struct {
*common.TLSCapnpHandshakerBase
// contains filtered or unexported fields
}
func NewTLSCapnpHandshaker ¶
func NewTLSCapnpHandshaker(dialer common.Dialer, logger log.Logger, count uint32, rmId common.RMId, bootCount uint32, router *router.Router, cm connectionmanager.ConnectionManager, localConnection localconnection.LocalConnection, serverRemote sconn.ServerConnection) *TLSCapnpHandshaker
func (*TLSCapnpHandshaker) PerformHandshake ¶
func (tch *TLSCapnpHandshaker) PerformHandshake(topology *configuration.Topology) (network.Protocol, error)
func (*TLSCapnpHandshaker) Restart ¶
func (tch *TLSCapnpHandshaker) Restart() bool
func (*TLSCapnpHandshaker) String ¶
func (tch *TLSCapnpHandshaker) String() string
type TLSCapnpServer ¶
type TLSCapnpServer struct {
*TLSCapnpHandshaker
// contains filtered or unexported fields
}
func (*TLSCapnpServer) InternalShutdown ¶
func (tcs *TLSCapnpServer) InternalShutdown()
func (*TLSCapnpServer) ReadAndHandleOneMsg ¶
func (tcs *TLSCapnpServer) ReadAndHandleOneMsg() error
func (*TLSCapnpServer) Restart ¶
func (tcs *TLSCapnpServer) Restart() bool
func (*TLSCapnpServer) Run ¶
func (tcs *TLSCapnpServer) Run(conn *network.Connection) error
func (*TLSCapnpServer) Send ¶
func (tcs *TLSCapnpServer) Send(msg []byte)
func (*TLSCapnpServer) String ¶
func (tcs *TLSCapnpServer) String() string
func (*TLSCapnpServer) TopologyChanged ¶
func (tcs *TLSCapnpServer) TopologyChanged(tc *network.ConnectionMsgTopologyChanged) error
Source Files
Click to show internal directories.
Click to hide internal directories.