offsetstore

Documentation

Overview

Package offsetstore provides implementations for storing the update offset.

Index

• type InMemoryOffsetStore
  • func NewInMemoryOffsetStore(initial int) *InMemoryOffsetStore
  • func (s *InMemoryOffsetStore) Load(_ context.Context) (int, error)
  • func (s *InMemoryOffsetStore) Save(_ context.Context, offset int) error

Types

type InMemoryOffsetStore

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

InMemoryOffsetStore is an in-memory implementation of OffsetStore.

func NewInMemoryOffsetStore

func NewInMemoryOffsetStore(initial int) *InMemoryOffsetStore

NewInMemoryOffsetStore creates a new InMemoryOffsetStore.

func (*InMemoryOffsetStore) Load

func (s *InMemoryOffsetStore) Load(_ context.Context) (int, error)

Load retrieves the current offset.

func (*InMemoryOffsetStore) Save

func (s *InMemoryOffsetStore) Save(_ context.Context, offset int) error

Save stores the new offset.