client

Documentation

Index

• func NewVersionCache(roots map[common.VarUUId]*common.Capability) versionCache
• type ClientTxnCompletionConsumer
• type ClientTxnSubmitter
  • func NewClientTxnSubmitter(rmId common.RMId, bootCount uint32, ...) *ClientTxnSubmitter
  • func (cts *ClientTxnSubmitter) Status(sc *server.StatusConsumer)
  • func (cts *ClientTxnSubmitter) SubmitClientTransaction(ctxnCap *cmsgs.ClientTxn, continuation ClientTxnCompletionConsumer) error
• type LocalConnection
  • func NewLocalConnection(rmId common.RMId, bootCount uint32, cm paxos.ConnectionManager) *LocalConnection
  • func (lc *LocalConnection) ConnectedRMs(servers map[common.RMId]paxos.Connection)
  • func (lc *LocalConnection) ConnectionEstablished(rmId common.RMId, conn paxos.Connection, ...)
  • func (lc *LocalConnection) ConnectionLost(rmId common.RMId, servers map[common.RMId]paxos.Connection)
  • func (lc *LocalConnection) NextVarUUId() *common.VarUUId
  • func (lc *LocalConnection) RunClientTransaction(txn *cmsgs.ClientTxn, varPosMap map[common.VarUUId]*common.Positions, ...) (*eng.TxnReader, *msgs.Outcome, error)
  • func (lc *LocalConnection) RunTransaction(txn *msgs.Txn, txnId *common.TxnId, backoff *server.BinaryBackoffEngine, ...) (*eng.TxnReader, *msgs.Outcome, error)
  • func (lc *LocalConnection) Shutdown(sync paxos.Blocking)
  • func (lc *LocalConnection) Status(sc *server.StatusConsumer)
  • func (lc *LocalConnection) SubmissionOutcomeReceived(sender common.RMId, txn *eng.TxnReader, outcome *msgs.Outcome)
  • func (lc *LocalConnection) TopologyChanged(topology *configuration.Topology, done func(bool))
• type SimpleTxnSubmitter
  • func NewSimpleTxnSubmitter(rmId common.RMId, bootCount uint32, connPub paxos.ServerConnectionPublisher) *SimpleTxnSubmitter
  • func (sts *SimpleTxnSubmitter) EnsurePositions(varPosMap map[common.VarUUId]*common.Positions)
  • func (sts *SimpleTxnSubmitter) IsIdle() bool
  • func (sts *SimpleTxnSubmitter) ServerConnectionsChanged(servers map[common.RMId]paxos.Connection) error
  • func (sts *SimpleTxnSubmitter) Shutdown()
  • func (sts *SimpleTxnSubmitter) Status(sc *server.StatusConsumer)
  • func (sts *SimpleTxnSubmitter) SubmissionOutcomeReceived(sender common.RMId, txn *eng.TxnReader, outcome *msgs.Outcome) error
  • func (sts *SimpleTxnSubmitter) SubmitClientTransaction(translationCallback eng.TranslationCallback, ctxnCap *cmsgs.ClientTxn, ...) error
  • func (sts *SimpleTxnSubmitter) SubmitTransaction(txnCap *msgs.Txn, txnId *common.TxnId, activeRMs []common.RMId, ...)
  • func (sts *SimpleTxnSubmitter) TopologyChanged(topology *configuration.Topology) error
• type TxnCompletionConsumer

Functions

func NewVersionCache

func NewVersionCache(roots map[common.VarUUId]*common.Capability) versionCache

Types

type ClientTxnCompletionConsumer

type ClientTxnCompletionConsumer func(*cmsgs.ClientTxnOutcome, error) error

type ClientTxnSubmitter

type ClientTxnSubmitter struct {
	*SimpleTxnSubmitter
	// contains filtered or unexported fields
}

func NewClientTxnSubmitter

func NewClientTxnSubmitter(rmId common.RMId, bootCount uint32, roots map[common.VarUUId]*common.Capability, cm paxos.ConnectionManager) *ClientTxnSubmitter

func (*ClientTxnSubmitter) Status

func (cts *ClientTxnSubmitter) Status(sc *server.StatusConsumer)

func (*ClientTxnSubmitter) SubmitClientTransaction

func (cts *ClientTxnSubmitter) SubmitClientTransaction(ctxnCap *cmsgs.ClientTxn, continuation ClientTxnCompletionConsumer) error

type LocalConnection

type LocalConnection struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLocalConnection

func NewLocalConnection(rmId common.RMId, bootCount uint32, cm paxos.ConnectionManager) *LocalConnection

func (*LocalConnection) ConnectedRMs

func (lc *LocalConnection) ConnectedRMs(servers map[common.RMId]paxos.Connection)

func (*LocalConnection) ConnectionEstablished

func (lc *LocalConnection) ConnectionEstablished(rmId common.RMId, conn paxos.Connection, servers map[common.RMId]paxos.Connection, done func())

func (*LocalConnection) ConnectionLost

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

func (*LocalConnection) NextVarUUId

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

func (*LocalConnection) RunClientTransaction

func (lc *LocalConnection) RunClientTransaction(txn *cmsgs.ClientTxn, varPosMap map[common.VarUUId]*common.Positions, translationCallback eng.TranslationCallback) (*eng.TxnReader, *msgs.Outcome, error)

func (*LocalConnection) RunTransaction

func (lc *LocalConnection) RunTransaction(txn *msgs.Txn, txnId *common.TxnId, backoff *server.BinaryBackoffEngine, activeRMs ...common.RMId) (*eng.TxnReader, *msgs.Outcome, error)

txn must be root in its segment

func (*LocalConnection) Shutdown

func (lc *LocalConnection) Shutdown(sync paxos.Blocking)

func (*LocalConnection) Status

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

func (*LocalConnection) SubmissionOutcomeReceived

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

func (*LocalConnection) TopologyChanged

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

type SimpleTxnSubmitter

type SimpleTxnSubmitter struct {
	// contains filtered or unexported fields
}

func NewSimpleTxnSubmitter

func NewSimpleTxnSubmitter(rmId common.RMId, bootCount uint32, connPub paxos.ServerConnectionPublisher) *SimpleTxnSubmitter

func (*SimpleTxnSubmitter) EnsurePositions

func (sts *SimpleTxnSubmitter) EnsurePositions(varPosMap map[common.VarUUId]*common.Positions)

func (*SimpleTxnSubmitter) IsIdle

func (sts *SimpleTxnSubmitter) IsIdle() bool

func (*SimpleTxnSubmitter) ServerConnectionsChanged

func (sts *SimpleTxnSubmitter) ServerConnectionsChanged(servers map[common.RMId]paxos.Connection) error

func (*SimpleTxnSubmitter) Shutdown

func (sts *SimpleTxnSubmitter) Shutdown()

func (*SimpleTxnSubmitter) Status

func (sts *SimpleTxnSubmitter) Status(sc *server.StatusConsumer)

func (*SimpleTxnSubmitter) SubmissionOutcomeReceived

func (sts *SimpleTxnSubmitter) SubmissionOutcomeReceived(sender common.RMId, txn *eng.TxnReader, outcome *msgs.Outcome) error

func (*SimpleTxnSubmitter) SubmitClientTransaction

func (sts *SimpleTxnSubmitter) SubmitClientTransaction(translationCallback eng.TranslationCallback, ctxnCap *cmsgs.ClientTxn, txnId *common.TxnId, continuation TxnCompletionConsumer, delay *server.BinaryBackoffEngine, useNextVersion bool, vc versionCache) error

func (*SimpleTxnSubmitter) SubmitTransaction

func (sts *SimpleTxnSubmitter) SubmitTransaction(txnCap *msgs.Txn, txnId *common.TxnId, activeRMs []common.RMId, continuation TxnCompletionConsumer, delay *server.BinaryBackoffEngine)

txnCap must be a root

func (*SimpleTxnSubmitter) TopologyChanged

func (sts *SimpleTxnSubmitter) TopologyChanged(topology *configuration.Topology) error

type TxnCompletionConsumer

type TxnCompletionConsumer func(*eng.TxnReader, *msgs.Outcome, error) error