replication

type DB interface {
	Path() string
	InMemory() bool
	MaxVersion() uint64
	SetVersion(v uint64)
	Drop() error
	Load(ctx context.Context, r io.Reader) (uint64, error)
	Stream(ctx context.Context, at, since uint64, w io.Writer) error
	NewWriteBatchAt(readTs uint64) WriteBatch

	ValueThreshold() int64
	MaxBatchCount() int64
	MaxBatchSize() int64
	Close() error
}

type Maybe struct {
	Tx
	DB
	// contains filtered or unexported fields
}

type Mode uint8

type Option func(o *Options)

type Options struct {
	Mode     Mode
	Name     string
	Addrs    []string
	GRPCPort int
	Tick     time.Duration

	GossipPort    int
	EncryptionKey string

	ExtraServices []func(registrar grpc.ServiceRegistrar)
	// contains filtered or unexported fields
}

type Replication interface {
	IsLeader() bool
	LeaderConn() (grpc.ClientConnInterface, bool)
	CurrentLeader() string
	Subscribe() <-chan string
	LinearizableReads() bool
	NewTx(ctx context.Context) (Tx, error)
	Close() error
}

type Tx interface {
	New(ctx context.Context, tx *badger.Txn) error
	Get(ctx context.Context, key []byte) (pending.Item, error)
	Set(ctx context.Context, key []byte, val []byte, expires uint64) error
	Delete(ctx context.Context, key []byte) error
	Commit(ctx context.Context, at uint64) error
	Iterator(opt badger.IteratorOptions) pending.Iterator
	Close(ctx context.Context) error
}

type WriteBatch interface {
	SetEntryAt(e *badger.Entry, ts uint64) error
	DeleteAt(key []byte, ts uint64) error
	Flush() error
	Cancel()
}