localconnection

Documentation

Index

• type LocalConnection
  • func NewLocalConnection(rmId common.RMId, bootCount uint32, cm connectionmanager.ConnectionManager, ...) *LocalConnection
  • func (lc *LocalConnection) ConnectedRMs(servers map[common.RMId]sconn.ServerConnection)
  • func (lc *LocalConnection) ConnectionEstablished(c sconn.ServerConnection, servers map[common.RMId]sconn.ServerConnection, ...)
  • func (lc *LocalConnection) ConnectionLost(rmId common.RMId, servers map[common.RMId]sconn.ServerConnection)
  • func (lc *LocalConnection) NextVarUUId() *common.VarUUId
  • func (lc *LocalConnection) RunClientTransaction(txn *cmsgs.ClientTxn, isTopologyTxn bool, ...) (*txnreader.TxnReader, *msgs.Outcome, error)
  • func (lc *LocalConnection) RunTransaction(txn *msgs.Txn, txnId *common.TxnId, ...) (*txnreader.TxnReader, *msgs.Outcome, error)
  • func (lc *LocalConnection) Status(sc *status.StatusConsumer)
  • func (lc *LocalConnection) SubmissionOutcomeReceived(sender common.RMId, subId *common.TxnId, txn *txnreader.TxnReader, ...)
  • func (lc *LocalConnection) TopologyChanged(topology *configuration.Topology, done func(bool))

Types

type LocalConnection

type LocalConnection struct {
	*actor.Mailbox
	*actor.BasicServerOuter
	// contains filtered or unexported fields
}

func NewLocalConnection

func NewLocalConnection(rmId common.RMId, bootCount uint32, cm connectionmanager.ConnectionManager, logger log.Logger) *LocalConnection

func (*LocalConnection) ConnectedRMs

func (lc *LocalConnection) ConnectedRMs(servers map[common.RMId]sconn.ServerConnection)

func (*LocalConnection) ConnectionEstablished

func (lc *LocalConnection) ConnectionEstablished(c sconn.ServerConnection, servers map[common.RMId]sconn.ServerConnection, done func())

func (*LocalConnection) ConnectionLost

func (lc *LocalConnection) ConnectionLost(rmId common.RMId, servers map[common.RMId]sconn.ServerConnection)

func (*LocalConnection) NextVarUUId

func (lc *LocalConnection) NextVarUUId() *common.VarUUId

func (*LocalConnection) RunClientTransaction

func (lc *LocalConnection) RunClientTransaction(txn *cmsgs.ClientTxn, isTopologyTxn bool, roots map[common.VarUUId]*types.PosCapVer, translationCallback loco.TranslationCallback) (*txnreader.TxnReader, *msgs.Outcome, error)

func (*LocalConnection) RunTransaction

func (lc *LocalConnection) RunTransaction(txn *msgs.Txn, txnId *common.TxnId, subscriptionConsumer client.SubscriptionConsumer, backoff *binarybackoff.BinaryBackoffEngine, activeRMs ...common.RMId) (*txnreader.TxnReader, *msgs.Outcome, error)

txn must be root in its segment

func (*LocalConnection) Status

func (lc *LocalConnection) Status(sc *status.StatusConsumer)

func (*LocalConnection) SubmissionOutcomeReceived

func (lc *LocalConnection) SubmissionOutcomeReceived(sender common.RMId, subId *common.TxnId, txn *txnreader.TxnReader, outcome *msgs.Outcome)

func (*LocalConnection) TopologyChanged

func (lc *LocalConnection) TopologyChanged(topology *configuration.Topology, done func(bool))