store

package

v0.0.0-...-a26ebea Latest Latest Go to latest Published: Apr 7, 2022 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrStoreMapIsNil = validation.NewError(
	"offset_store_map_is_nil",
	"the offset store map must be allocated",
)

This section is empty.

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

Store holds mapping between topic partitions and offsets.

This is used to track highest/most-recent offsets for each topic partition as the flow through the system.

func Generate(rand *rand.Rand) *Store

Generate a random Header value.

func New() (*Store, validation.ErrorGroup)

New creates and validates a new Store.

func (s *Store) Check() validation.ErrorGroup

Check runs default validation checks for the store.

func (*Store) Generate(rand *rand.Rand, size int) reflect.Value

Generate random Store values.

Interface: quick.Generator

func (s *Store) Put(tp topic_partition.TopicPartition, offset offset.Offset) error

Put stores topic partition -> offset.

func (s *Store) PutParts(topic_ string, partition_ int32, offset_ int64) error

PutParts converts and stores primitive types to topic partition -> offset.

func (s *Store) String() string

String value of the Store.

Interface: fmt.Stringer.