partition

package
v5.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 10, 2022 License: BSD-2-Clause, BSD-2-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL