builtin

Documentation

Index

• func CGoLogger(level int, msg string)
• type Builtin
  • func (binding *Builtin) AddIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error
  • func (binding *Builtin) BeginTx(ctx context.Context, namespace string) (txCtx bindings.TxCtx, err error)
  • func (binding *Builtin) Clone() bindings.RawBinding
  • func (binding *Builtin) CloseNamespace(ctx context.Context, namespace string) error
  • func (binding *Builtin) Commit(ctx context.Context, namespace string) error
  • func (binding *Builtin) CommitTx(txCtx *bindings.TxCtx) (bindings.RawBuffer, error)
  • func (binding *Builtin) DeleteQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)
  • func (binding *Builtin) DeleteQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error
  • func (binding *Builtin) DisableLogger()
  • func (binding *Builtin) DropIndex(ctx context.Context, namespace, index string) error
  • func (binding *Builtin) DropNamespace(ctx context.Context, namespace string) error
  • func (binding *Builtin) EnableLogger(log bindings.Logger)
  • func (binding *Builtin) EnableStorage(ctx context.Context, path string) error
  • func (binding *Builtin) Finalize() error
  • func (binding *Builtin) GetMeta(ctx context.Context, namespace, key string) (bindings.RawBuffer, error)
  • func (binding *Builtin) Init(u []url.URL, options ...interface{}) error
  • func (binding *Builtin) ModifyItem(ctx context.Context, nsHash int, namespace string, format int, data []byte, ...) (bindings.RawBuffer, error)
  • func (binding *Builtin) ModifyItemTx(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, ...) error
  • func (binding *Builtin) ModifyItemTxAsync(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, ...)
  • func (binding *Builtin) OpenNamespace(ctx context.Context, namespace string, enableStorage, dropOnFormatError bool) error
  • func (binding *Builtin) Ping(ctx context.Context) error
  • func (binding *Builtin) PutMeta(ctx context.Context, namespace, key, data string) error
  • func (binding *Builtin) RenameNamespace(ctx context.Context, srcNs string, dstNs string) error
  • func (binding *Builtin) ReopenLogFiles() error
  • func (binding *Builtin) RollbackTx(txCtx *bindings.TxCtx) error
  • func (binding *Builtin) Select(ctx context.Context, query string, asJson bool, ptVersions []int32, ...) (bindings.RawBuffer, error)
  • func (binding *Builtin) SelectQuery(ctx context.Context, data []byte, asJson bool, ptVersions []int32, ...) (bindings.RawBuffer, error)
  • func (binding *Builtin) SetSchema(ctx context.Context, namespace string, schema bindings.SchemaDef) error
  • func (binding *Builtin) StartWatchOnCtx(ctx context.Context) (CCtxWrapper, error)
  • func (binding *Builtin) Status(ctx context.Context) (status bindings.Status)
  • func (binding *Builtin) TruncateNamespace(ctx context.Context, namespace string) error
  • func (binding *Builtin) UpdateIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error
  • func (binding *Builtin) UpdateQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)
  • func (binding *Builtin) UpdateQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error
• type CCtxWrapper
• type CtxWatcher
  • func NewCtxWatcher(watchersPoolSize int, watchDelay time.Duration) *CtxWatcher
  • func (watcher *CtxWatcher) Finalize() error
  • func (watcher *CtxWatcher) StartWatchOnCtx(ctx context.Context) (CCtxWrapper, error)
  • func (watcher *CtxWatcher) StopWatchOnCtx(ctxInfo CCtxWrapper)
• type Logger
• type RawCBuffer
  • func (buf *RawCBuffer) Free()
  • func (buf *RawCBuffer) FreeFinalized()
  • func (buf *RawCBuffer) GetBuf() []byte

Functions

func CGoLogger

func CGoLogger(level int, msg string)

CGoLogger logger function for C

Types

type Builtin

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

func (*Builtin) AddIndex

func (binding *Builtin) AddIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error

func (*Builtin) BeginTx

func (binding *Builtin) BeginTx(ctx context.Context, namespace string) (txCtx bindings.TxCtx, err error)

func (*Builtin) Clone

func (binding *Builtin) Clone() bindings.RawBinding

func (*Builtin) CloseNamespace

func (binding *Builtin) CloseNamespace(ctx context.Context, namespace string) error

func (*Builtin) Commit

func (binding *Builtin) Commit(ctx context.Context, namespace string) error

func (*Builtin) CommitTx

func (binding *Builtin) CommitTx(txCtx *bindings.TxCtx) (bindings.RawBuffer, error)

func (*Builtin) DeleteQuery

func (binding *Builtin) DeleteQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)

func (*Builtin) DeleteQueryTx

func (binding *Builtin) DeleteQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error

func (*Builtin) DisableLogger

func (binding *Builtin) DisableLogger()

func (*Builtin) DropIndex

func (binding *Builtin) DropIndex(ctx context.Context, namespace, index string) error

func (*Builtin) DropNamespace

func (binding *Builtin) DropNamespace(ctx context.Context, namespace string) error

func (*Builtin) EnableLogger

func (binding *Builtin) EnableLogger(log bindings.Logger)

func (*Builtin) EnableStorage

func (binding *Builtin) EnableStorage(ctx context.Context, path string) error

func (*Builtin) Finalize

func (binding *Builtin) Finalize() error

func (*Builtin) GetMeta

func (binding *Builtin) GetMeta(ctx context.Context, namespace, key string) (bindings.RawBuffer, error)

func (*Builtin) Init

func (binding *Builtin) Init(u []url.URL, options ...interface{}) error

func (*Builtin) ModifyItem

func (binding *Builtin) ModifyItem(ctx context.Context, nsHash int, namespace string, format int, data []byte, mode int, precepts []string, stateToken int) (bindings.RawBuffer, error)

func (*Builtin) ModifyItemTx

func (binding *Builtin) ModifyItemTx(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, stateToken int) error

func (*Builtin) ModifyItemTxAsync

func (binding *Builtin) ModifyItemTxAsync(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, stateToken int, cmpl bindings.RawCompletion)

ModifyItemTxAsync is not implemented for builtin binding

func (*Builtin) OpenNamespace

func (binding *Builtin) OpenNamespace(ctx context.Context, namespace string, enableStorage, dropOnFormatError bool) error

func (*Builtin) Ping

func (binding *Builtin) Ping(ctx context.Context) error

func (*Builtin) PutMeta

func (binding *Builtin) PutMeta(ctx context.Context, namespace, key, data string) error

func (*Builtin) RenameNamespace

func (binding *Builtin) RenameNamespace(ctx context.Context, srcNs string, dstNs string) error

func (*Builtin) ReopenLogFiles

func (binding *Builtin) ReopenLogFiles() error

func (*Builtin) RollbackTx

func (binding *Builtin) RollbackTx(txCtx *bindings.TxCtx) error

func (*Builtin) Select

func (binding *Builtin) Select(ctx context.Context, query string, asJson bool, ptVersions []int32, fetchCount int) (bindings.RawBuffer, error)

func (*Builtin) SelectQuery

func (binding *Builtin) SelectQuery(ctx context.Context, data []byte, asJson bool, ptVersions []int32, fetchCount int) (bindings.RawBuffer, error)

func (*Builtin) SetSchema

func (binding *Builtin) SetSchema(ctx context.Context, namespace string, schema bindings.SchemaDef) error

func (*Builtin) StartWatchOnCtx

func (binding *Builtin) StartWatchOnCtx(ctx context.Context) (CCtxWrapper, error)

func (*Builtin) Status

func (binding *Builtin) Status(ctx context.Context) (status bindings.Status)

func (*Builtin) TruncateNamespace

func (binding *Builtin) TruncateNamespace(ctx context.Context, namespace string) error

func (*Builtin) UpdateIndex

func (binding *Builtin) UpdateIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error

func (*Builtin) UpdateQuery

func (binding *Builtin) UpdateQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)

func (*Builtin) UpdateQueryTx

func (binding *Builtin) UpdateQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error

type CCtxWrapper

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

CCtxWrapper is a wrapper over C-context

type CtxWatcher

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

CtxWatcher perfomrs contexts canceling on expiration with some delay

func NewCtxWatcher

func NewCtxWatcher(watchersPoolSize int, watchDelay time.Duration) *CtxWatcher

NewCtxWatcher creates new CtxWatcher

func (*CtxWatcher) Finalize

func (watcher *CtxWatcher) Finalize() error

Finalize CtxWatcher

func (*CtxWatcher) StartWatchOnCtx

func (watcher *CtxWatcher) StartWatchOnCtx(ctx context.Context) (CCtxWrapper, error)

StartWatchOnCtx creates context wrapper and puts it to the watch queue

func (*CtxWatcher) StopWatchOnCtx

func (watcher *CtxWatcher) StopWatchOnCtx(ctxInfo CCtxWrapper)

StopWatchOnCtx removes context from watch queue

type Logger

type Logger interface {
	Printf(level int, fmt string, msg ...interface{})
}

Logger interface for reindexer

type RawCBuffer

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

func (*RawCBuffer) Free

func (buf *RawCBuffer) Free()

func (*RawCBuffer) FreeFinalized

func (buf *RawCBuffer) FreeFinalized()

func (*RawCBuffer) GetBuf

func (buf *RawCBuffer) GetBuf() []byte