clientprogress

Documentation

Index

• type ClientProgress
  • func FromPb(pb *trantorpb.ClientProgress, logger logging.Logger) *ClientProgress
  • func NewClientProgress(logger logging.Logger) *ClientProgress
  • func (cp *ClientProgress) Add(clID tt.ClientID, txNo tt.TxNo) bool
  • func (cp *ClientProgress) Contains(clID tt.ClientID, txNo tt.TxNo) bool
  • func (cp *ClientProgress) GarbageCollect() map[tt.ClientID]tt.TxNo
  • func (cp *ClientProgress) LoadPb(pb *trantorpb.ClientProgress)
  • func (cp *ClientProgress) Pb() *trantorpb.ClientProgress
• type DeliveredTXs
  • func DeliveredTXsFromPb(pb *trantorpb.DeliveredTXs, logger logging.Logger) *DeliveredTXs
  • func EmptyDeliveredTXs(logger logging.Logger) *DeliveredTXs
  • func (dt *DeliveredTXs) Add(txNo tt.TxNo) bool
  • func (dt *DeliveredTXs) Contains(txNo tt.TxNo) bool
  • func (dt *DeliveredTXs) GarbageCollect() tt.TxNo
  • func (dt *DeliveredTXs) Pb() *trantorpb.DeliveredTXs

Types

type ClientProgress

type ClientProgress struct {
	ClientTrackers map[tt.ClientID]*DeliveredTXs
	// contains filtered or unexported fields
}

ClientProgress tracks watermarks for all the clients.

func FromPb

func FromPb(pb *trantorpb.ClientProgress, logger logging.Logger) *ClientProgress

func NewClientProgress

func NewClientProgress(logger logging.Logger) *ClientProgress

func (*ClientProgress) Add

func (cp *ClientProgress) Add(clID tt.ClientID, txNo tt.TxNo) bool

func (*ClientProgress) Contains

func (cp *ClientProgress) Contains(clID tt.ClientID, txNo tt.TxNo) bool

func (*ClientProgress) GarbageCollect

func (cp *ClientProgress) GarbageCollect() map[tt.ClientID]tt.TxNo

func (*ClientProgress) LoadPb

func (cp *ClientProgress) LoadPb(pb *trantorpb.ClientProgress)

func (*ClientProgress) Pb

func (cp *ClientProgress) Pb() *trantorpb.ClientProgress

type DeliveredTXs

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

DeliveredTXs tracks the watermarks of delivered transactions for a single client.

func DeliveredTXsFromPb

func DeliveredTXsFromPb(pb *trantorpb.DeliveredTXs, logger logging.Logger) *DeliveredTXs

func EmptyDeliveredTXs

func EmptyDeliveredTXs(logger logging.Logger) *DeliveredTXs

EmptyDeliveredTXs allocates and returns a new DeliveredTXs.

func (*DeliveredTXs) Add

func (dt *DeliveredTXs) Add(txNo tt.TxNo) bool

Add adds a transaction number that is considered delivered to the DeliveredTXs. Returns true if the transaction number has been added now (after not being previously present). Returns false if the transaction number has already been added before the call to Add.

func (*DeliveredTXs) Contains

func (dt *DeliveredTXs) Contains(txNo tt.TxNo) bool

Contains returns true if the given txNo has already been added.

func (*DeliveredTXs) GarbageCollect

func (dt *DeliveredTXs) GarbageCollect() tt.TxNo

GarbageCollect reduces the memory footprint of the DeliveredTXs by deleting a contiguous prefix of delivered transaction numbers and increasing the low watermark accordingly. Returns the new low watermark.

func (*DeliveredTXs) Pb

func (dt *DeliveredTXs) Pb() *trantorpb.DeliveredTXs