fdbclient

Documentation

Index

• func SplitRangeOptions(opts []*RangeOptions) fdb.RangeOptions
• type Database
  • func NewDatabase(db fdb.Database) Database
• type RangeOptions
  • func (r *RangeOptions) SetLimit(limit int)
  • func (r *RangeOptions) SetMode(mode fdb.StreamingMode)
  • func (r *RangeOptions) SetReverse()
• type Transaction
  • func NewTransaction(ctx context.Context, db fdb.Database) (Transaction, error)

Functions

func SplitRangeOptions

func SplitRangeOptions(opts []*RangeOptions) fdb.RangeOptions

Types

type Database

type Database interface {
	NewTransaction(ctx context.Context) (Transaction, error)
	Clear(ctx context.Context, key []byte) error
}

func NewDatabase

func NewDatabase(db fdb.Database) Database

type RangeOptions

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

func (*RangeOptions) SetLimit

func (r *RangeOptions) SetLimit(limit int)

func (*RangeOptions) SetMode

func (r *RangeOptions) SetMode(mode fdb.StreamingMode)

func (*RangeOptions) SetReverse

func (r *RangeOptions) SetReverse()

type Transaction

type Transaction interface {
	Get(key []byte) (value []byte, err error)
	Set(key []byte, value []byte)
	Clear(key []byte)
	ClearRange(key []byte)
	Commit() (err error)
	GetRange(pr fdb.KeyRange, opts ...*RangeOptions) ([]fdb.KeyValue, error)
	GetIterator(pr fdb.KeyRange, opts ...*RangeOptions) *fdb.RangeIterator
}

func NewTransaction

func NewTransaction(ctx context.Context, db fdb.Database) (Transaction, error)