logc

Documentation

Index

• Constants
• Variables
• type KV
  • func NewKV[K comparable, V any](dir string) (KV[K, V], error)
• type Message

Constants

const (
	OffsetInvalid = klevdb.OffsetInvalid
	OffsetOldest  = klevdb.OffsetOldest
	OffsetNewest  = klevdb.OffsetNewest
)

Variables

var ErrNotFound = klevdb.ErrNotFound

Types

type KV

type KV[K comparable, V any] interface {
	Put(k K, v V) error
	Del(k K) error

	Get(k K) (V, error)
	GetOrDefault(k K, v V) (V, error)
	GetOrInit(k K, fn func(K) (V, error)) (V, error)

	Consume(ctx context.Context, offset int64) ([]Message[K, V], int64, error)
	Snapshot() ([]Message[K, V], int64, error) // TODO this could possible return too much data

	Close() error
}

func NewKV

func NewKV[K comparable, V any](dir string) (KV[K, V], error)

type Message

type Message[K comparable, V any] struct {
	Offset int64
	Key    K
	Value  V
	Delete bool
}