ackseq

Documentation

Index

• type S
  • func New(base uint64) *S
  • func (s *S) Ack(seqNum uint64) (int, error)
  • func (s *S) Next() uint64

Types

type S

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

S keeps track of the largest sequence number such that all sequence numbers in the range [0,v) have been acknowledged.

func New

func New(base uint64) *S

New creates a new acknowledged sequence tracker with the specified base sequence number. All of the sequence numbers in the range [0,base) are considered acknowledged. Next() will return base upon first call.

func (*S) Ack

func (s *S) Ack(seqNum uint64) (int, error)

Ack acknowledges the specified seqNum, adjusting base as necessary, returning the number of newly acknowledged sequence numbers.

func (*S) Next

func (s *S) Next() uint64

Next returns the next sequence number to use.