sequencer

Documentation

Index

• type Sequencer
  • func NewSequencer(conf *config.Config) *Sequencer
  • func (s *Sequencer) CreateTxn(ctx context.Context, req *pb.CreateTxnRequest) (*pb.CreateTxnResponse, error)
  • func (s *Sequencer) GetOrderedTxn()
  • func (s *Sequencer) Start()

Types

type Sequencer

type Sequencer struct {
	pb.UnimplementedSequencerServiceServer

	SeqCluster     string
	SeqClusterConn *nats.Conn
}

func NewSequencer

func NewSequencer(conf *config.Config) *Sequencer

func (*Sequencer) CreateTxn

func (s *Sequencer) CreateTxn(ctx context.Context, req *pb.CreateTxnRequest) (*pb.CreateTxnResponse, error)

func (*Sequencer) GetOrderedTxn

func (s *Sequencer) GetOrderedTxn()

func (*Sequencer) Start

func (s *Sequencer) Start()