fastfood

type CompareAndSetOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized
	// contains filtered or unexported fields
}

type DataStore interface {
	gluten.DisposableBean
	gluten.NamedBean

	Get(ctx context.Context) *GetOperation

	Set(ctx context.Context) *SetOperation

	// equivalent of i++ operation, always returns previous value
	Increment(ctx context.Context) *IncrementOperation

	CompareAndSet(ctx context.Context) *CompareAndSetOperation

	Remove(ctx context.Context) *RemoveOperation

	Enumerate(ctx context.Context) *EnumerateOperation

	GetRaw(ctx context.Context, key []byte, ttlPtr *int, versionPtr *int64, required bool) ([]byte, error)

	SetRaw(ctx context.Context, key, value []byte, ttlSeconds int) error

	CompareAndSetRaw(ctx context.Context, key, value []byte, ttlSeconds int, version int64) (bool, error)

	IncrementRaw(ctx context.Context, key []byte, initial, delta int64, ttlSeconds int) (int64, error)

	RemoveRaw(ctx context.Context, key []byte) error

	EnumerateRaw(ctx context.Context, prefix, seek []byte, batchSize int, onlyKeys bool, reverse bool, cb func(*RawEntry) bool) error
}

type DataStoreManager interface {
	Compact(discardRatio float64) error

	Backup(w io.Writer, since uint64) (uint64, error)

	Restore(r io.Reader) error

	DropAll() error

	DropWithPrefix(prefix []byte) error
}

type EnumerateOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized
	// contains filtered or unexported fields
}

type GetOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized
	// contains filtered or unexported fields
}

type IncrementOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized

	Initial int64
	Delta   int64 // should be initialized by 1
	// contains filtered or unexported fields
}

type ManagedDataStore interface {
	DataStore
	DataStoreManager

	Instance() interface{}
}

type ManagedTransactionalDataStore interface {
	DataStore
	DataStoreManager
	TransactionalManager
}

type ProtoEntry struct {
	Key     []byte
	Value   proto.Message
	Ttl     int
	Version int64
}

type RawEntry struct {
	Key     []byte
	Value   []byte
	Ttl     int
	Version int64
}

type RemoveOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized
	// contains filtered or unexported fields
}

type SetOperation struct {
	DataStore                 // should be initialized
	Context   context.Context // should be initialized
	// contains filtered or unexported fields
}

type Transaction interface {
	ReadOnly() bool

	Commit() error

	Rollback()

	Instance() interface{}
}

type TransactionalDataStore interface {
	DataStore
	TransactionalManager
}

type TransactionalManager interface {
	BeginTransaction(ctx context.Context, readOnly bool) context.Context

	// commit if errOps is nil or rollback otherwise
	EndTransaction(ctx context.Context, errOps error) error
}