partition

Documentation

Index

• type Store
  • func NewOrLoad(kv *versioned.KV) *Store
  • func (s *Store) Add(partner *id.ID, messageID uint64, partNum uint8, part []byte, ...) (receive.Message, e2e.KeyResidue, bool)
  • func (s *Store) AddFirst(partner *id.ID, mt catalog.MessageType, messageID uint64, ...) (receive.Message, e2e.KeyResidue, bool)

Types

type Store

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

func NewOrLoad

func NewOrLoad(kv *versioned.KV) *Store

func (*Store) Add

func (s *Store) Add(partner *id.ID, messageID uint64, partNum uint8,
	part []byte, relationshipFingerprint []byte) (
	receive.Message, e2e.KeyResidue, bool)

func (*Store) AddFirst

func (s *Store) AddFirst(partner *id.ID, mt catalog.MessageType,
	messageID uint64, partNum, numParts uint8, senderTimestamp,
	storageTimestamp time.Time, part []byte, relationshipFingerprint []byte,
	residue e2e.KeyResidue) (
	receive.Message, e2e.KeyResidue, bool)

AddFirst adds the first partition message to the Store object.