storage

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

type Engine interface {
	Set(ctx context.Context, key, value string) error
	Get(ctx context.Context, key string) (string, error)
	Del(ctx context.Context, key string) error
}

type Option func(s *Storage)

type Replica interface {
	IsSlave() bool
	Shutdown(ctx context.Context) error
}

type SlaveReplica interface {
	StartHandle(fn func(cid compute.CommandID, args []string) error)
}

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

type WAL interface {
	Append(cid compute.CommandID, args []string) concurrency.FutureError
	Restore(fn func(cid compute.CommandID, args []string) error) error
	Shutdown(ctx context.Context) error
}