tcpcapnproto

Documentation

Index

• func NewConnectionTCPTLSCapnpDialer(self common.RMId, bootCount uint32, router *router.Router, ...)
• type Listener
  • func NewListener(listenPort uint16, rmId common.RMId, bootCount uint32, router *router.Router, ...) (*Listener, error)
• 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
  • func NewTLSCapnpHandshaker(dialer common.Dialer, logger log.Logger, count uint32, rmId common.RMId, ...) *TLSCapnpHandshaker
  • func (tch *TLSCapnpHandshaker) PerformHandshake(topology *configuration.Topology) (network.Protocol, error)
  • func (tch *TLSCapnpHandshaker) Restart() bool
  • func (tch *TLSCapnpHandshaker) String() string
• 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

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 (tcc *TLSCapnpClient) SubmissionOutcomeReceived(sender common.RMId, subId *common.TxnId, txn *txnreader.TxnReader, outcome *msgs.Outcome)

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