db

package
v2.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2021 License: Apache-2.0 Imports: 6 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrWait    = errx.New("Ошибка ожидания значения")
	ErrRead    = errx.New("Ошибка транзакции чтения")
	ErrWrite   = errx.New("Ошибка транзакции записи")
	ErrClear   = errx.New("Ошибка транзакции очистки")
	ErrConnect = errx.New("Ошибка подключения к FoundationDB")
)

Ошибки модуля

Functions

This section is empty.

Types

type Connection

type Connection struct {
	ID byte
	// contains filtered or unexported fields
}

func Connect added in v2.0.2

func Connect(id byte, opts ...Option) (cn Connection, err error)

Connect - создание нового подключения к серверу FDB и базе данных.

Идентификатор базы всего 1 байт, потому что пока не рассчитываем на то, что разных БД будет так много. Особое значение 0xFF (255) запрещено, т.к. с этого байта начинается служебная область видимости FDB.

Если указан путь к файлу, то подключается к нему. Иначе идет по стандартному (зависит от ОС).

Этот драйвер настроен на совместимость с конкретной версией клиента, с другими может не заработать.

func (Connection) Clear

func (cn Connection) Clear() error

func (Connection) Empty added in v2.0.2

func (cn Connection) Empty() bool

func (Connection) Read

func (cn Connection) Read(hdl ReadHandler) error

func (Connection) Write

func (cn Connection) Write(hdl WriteHandler) error

type Option

type Option func(*options) error

Option - метод для перегрузки некоторых свойств подключения

func ClusterFile

func ClusterFile(name string) Option

ClusterFile - нестандартный путь до кластер-файла FoundationDB

type ReadHandler

type ReadHandler func(Reader) error

ReadHandler - обработчик физической транзакции чтения, должен быть идемпотентным

type Reader

type Reader struct {
	Connection
	// contains filtered or unexported fields
}

func (Reader) Data

func (r Reader) Data(key fdb.Key) []byte

Получение объекта ожидания конкретного значения

func (Reader) Item added in v2.0.2

func (r Reader) Item(key fdb.Key) fdb.FutureByteSlice

Получение объекта ожидания конкретного значения

func (Reader) List

func (r Reader) List(from, last fdb.Key, limit uint64, reverse, skip bool) fdb.RangeResult

type Waiter added in v2.0.2

type Waiter interface {
	Resolve(ctx context.Context) (err error)
}

type WriteHandler

type WriteHandler func(Writer) error

WriteHandler - обработчик физической транзакции записи, должен быть идемпотентным

type Writer

type Writer struct {
	Reader
	// contains filtered or unexported fields
}

func (Writer) Delete

func (w Writer) Delete(key fdb.Key)

func (Writer) Erase

func (w Writer) Erase(from, to fdb.Key)

func (Writer) Increment

func (w Writer) Increment(key fdb.Key, delta int64)

func (Writer) Lock

func (w Writer) Lock(from, to fdb.Key)

func (Writer) Upsert

func (w Writer) Upsert(pairs ...fdb.KeyValue)

func (Writer) Watch

func (w Writer) Watch(key fdb.Key) Waiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL