sequencer

Documentation

Index

• type PartialSnapshotHandler
• type Sequencer
  • func NewSequencer(raftID uint64, txnBatchChan chan<- *pb.TransactionBatch, peers []raft.Peer, ...) *Sequencer
  • func (s *Sequencer) LogToJSON(out io.Writer, n int) error
  • func (s *Sequencer) Stop()
  • func (s *Sequencer) SubmitTransaction(txn *pb.Transaction)
• type SnapshotHandler

Types

type PartialSnapshotHandler

type PartialSnapshotHandler interface {
	Consume(partitionID int, snapshotData []byte) error
	Provide(partitionID int, lastSnapshot raftpb.Snapshot, entriesAppliedSinceLastSnapshot []raftpb.Entry) ([]byte, error)
}

type Sequencer

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

func NewSequencer

func NewSequencer(raftID uint64, txnBatchChan chan<- *pb.TransactionBatch, peers []raft.Peer, storeDir string, connCache util.ConnectionCache, cip util.ClusterInfoProvider, srvr *grpc.Server, snapshotHandler SnapshotHandler, logger *log.Entry) *Sequencer

func (*Sequencer) LogToJSON

func (s *Sequencer) LogToJSON(out io.Writer, n int) error

func (*Sequencer) Stop

func (s *Sequencer) Stop()

func (*Sequencer) SubmitTransaction

func (s *Sequencer) SubmitTransaction(txn *pb.Transaction)

type SnapshotHandler

type SnapshotHandler interface {
	Consume(snapshotData []byte) error
	Provide(lastSnapshot raftpb.Snapshot, entriesAppliedSinceLastSnapshot []raftpb.Entry) ([]byte, error)
}