cproto

package
v2.6.4+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NetBuffer

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

func (*NetBuffer) Fetch

func (buf *NetBuffer) Fetch(ctx context.Context, offset, limit int, asJson bool) (err error)

func (*NetBuffer) Free

func (buf *NetBuffer) Free()

func (*NetBuffer) GetBuf

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

type NetCProto

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

func (*NetCProto) AddIndex

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

func (*NetCProto) BeginTx

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

func (*NetCProto) Clone

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

func (*NetCProto) CloseNamespace

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

func (*NetCProto) Commit

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

func (*NetCProto) CommitTx

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

func (*NetCProto) DeleteQuery

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

func (*NetCProto) DeleteQueryTx

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

func (*NetCProto) DisableLogger

func (binding *NetCProto) DisableLogger()

func (*NetCProto) DropIndex

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

func (*NetCProto) DropNamespace

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

func (*NetCProto) EnableLogger

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

func (*NetCProto) EnableStorage

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

func (*NetCProto) Finalize

func (binding *NetCProto) Finalize() error

func (*NetCProto) GetMeta

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

func (*NetCProto) Init

func (binding *NetCProto) Init(u *url.URL, options ...interface{}) (err error)

func (*NetCProto) ModifyItem

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

func (*NetCProto) ModifyItemTx

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

func (*NetCProto) ModifyItemTxAsync

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

func (*NetCProto) OnChangeCallback

func (binding *NetCProto) OnChangeCallback(f func())

func (*NetCProto) OpenNamespace

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

func (*NetCProto) Ping

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

func (*NetCProto) PutMeta

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

func (*NetCProto) RenameNamespace

func (binding *NetCProto) RenameNamespace(ctx context.Context, srcNamespace string, dstNamespace string) error

func (*NetCProto) RollbackTx

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

func (*NetCProto) Select

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

func (*NetCProto) SelectQuery

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

func (*NetCProto) Status

func (binding *NetCProto) Status(ctx context.Context) bindings.Status

func (*NetCProto) TruncateNamespace

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

func (*NetCProto) UpdateIndex

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

func (*NetCProto) UpdateQuery

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

func (*NetCProto) UpdateQueryTx

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

Jump to

Keyboard shortcuts

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