replication

type DB interface {
	protodb.DB
	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
	LoadDescriptors(ctx context.Context) error
	NewWriteBatchAt(readTs uint64) *badger.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

	StartOptions []raft.StartOption
	// 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 {
	Iterator(tx *badger.Txn, readTs uint64, opt badger.IteratorOptions) pending.Iterator
	New(ctx context.Context, readTs uint64) error
	Set(ctx context.Context, key, value []byte, expiresAt uint64) error
	Delete(ctx context.Context, key []byte) error
	Commit(ctx context.Context, at uint64) error
	Close(ctx context.Context) error
}