db

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

type DB struct {
	QueryRowsLimit int
	// contains filtered or unexported fields
}

type DBLoader interface {
	AddOperations(ops *kvv1.KVOperations)
	AddOperation(op *kvv1.KVOperation)
	Flush(ctx context.Context, cursor *sink.Cursor) (count int, err error)
	GetCursor(ctx context.Context) (*sink.Cursor, error)
	WriteCursor(ctx context.Context, c *sink.Cursor) error
}

type DBReader interface {
	Get(ctx context.Context, key string) (value []byte, err error)
	GetMany(ctx context.Context, keys []string) (values [][]byte, err error)
	GetByPrefix(ctx context.Context, prefix string, limit int) (values []*kvv1.KV, limitReached bool, err error)
	Scan(ctx context.Context, start string, exclusiveEnd string, limit int) (values []*kvv1.KV, limitReached bool, err error)
}