cproto

Documentation

Index

• type LoggerOwner
• type MockConnFactory
  • func NewMockConnFactory(t *testing.T) *MockConnFactory
• type MockConnection
  • func NewMockConnection(t *testing.T) *MockConnection
• type NetBuffer
  • func (buf *NetBuffer) Fetch(ctx context.Context, offset, limit int, asJson bool) (err error)
  • func (buf *NetBuffer) Free()
  • func (buf *NetBuffer) FreeNoReply(seq uint32)
  • func (buf *NetBuffer) GetBuf() []byte
• type NetCProto
  • func (binding *NetCProto) AddIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error
  • func (binding *NetCProto) BeginTx(ctx context.Context, namespace string) (txCtx bindings.TxCtx, err error)
  • func (binding *NetCProto) Clone() bindings.RawBinding
  • func (binding *NetCProto) CloseNamespace(ctx context.Context, namespace string) error
  • func (binding *NetCProto) Commit(ctx context.Context, namespace string) error
  • func (binding *NetCProto) CommitTx(txCtx *bindings.TxCtx) (bindings.RawBuffer, error)
  • func (binding *NetCProto) DeleteQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)
  • func (binding *NetCProto) DeleteQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error
  • func (binding *NetCProto) DisableLogger()
  • func (binding *NetCProto) DropIndex(ctx context.Context, namespace, index string) error
  • func (binding *NetCProto) DropNamespace(ctx context.Context, namespace string) error
  • func (binding *NetCProto) EnableLogger(log bindings.Logger)
  • func (binding *NetCProto) Finalize() error
  • func (binding *NetCProto) GetDSNs() []url.URL
  • func (binding *NetCProto) GetLogger() bindings.Logger
  • func (binding *NetCProto) GetMeta(ctx context.Context, namespace, key string) (bindings.RawBuffer, error)
  • func (binding *NetCProto) GetReplicationStat(f func(ctx context.Context) (*bindings.ReplicationStat, error))
  • func (binding *NetCProto) Init(u []url.URL, options ...interface{}) (err error)
  • func (binding *NetCProto) ModifyItem(ctx context.Context, nsHash int, namespace string, format int, data []byte, ...) (bindings.RawBuffer, error)
  • func (binding *NetCProto) ModifyItemTx(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, ...) error
  • func (binding *NetCProto) ModifyItemTxAsync(txCtx *bindings.TxCtx, format int, data []byte, mode int, precepts []string, ...)
  • func (binding *NetCProto) OnChangeCallback(f func())
  • func (binding *NetCProto) OpenNamespace(ctx context.Context, namespace string, enableStorage, dropOnFormatError bool) error
  • func (binding *NetCProto) Ping(ctx context.Context) error
  • func (binding *NetCProto) PutMeta(ctx context.Context, namespace, key, data string) error
  • func (binding *NetCProto) RenameNamespace(ctx context.Context, srcNamespace string, dstNamespace string) error
  • func (binding *NetCProto) ReopenLogFiles() error
  • func (binding *NetCProto) RollbackTx(txCtx *bindings.TxCtx) error
  • func (binding *NetCProto) Select(ctx context.Context, query string, asJson bool, ptVersions []int32, ...) (bindings.RawBuffer, error)
  • func (binding *NetCProto) SelectQuery(ctx context.Context, data []byte, asJson bool, ptVersions []int32, ...) (bindings.RawBuffer, error)
  • func (binding *NetCProto) SetSchema(ctx context.Context, namespace string, schema bindings.SchemaDef) error
  • func (binding *NetCProto) Status(ctx context.Context) bindings.Status
  • func (binding *NetCProto) TruncateNamespace(ctx context.Context, namespace string) error
  • func (binding *NetCProto) UpdateIndex(ctx context.Context, namespace string, indexDef bindings.IndexDef) error
  • func (binding *NetCProto) UpdateQuery(ctx context.Context, nsHash int, data []byte) (bindings.RawBuffer, error)
  • func (binding *NetCProto) UpdateQueryTx(txCtx *bindings.TxCtx, rawQuery []byte) error

Types

type LoggerOwner

type LoggerOwner interface {
	GetLogger() bindings.Logger
}

type MockConnFactory

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

func NewMockConnFactory

func NewMockConnFactory(t *testing.T) *MockConnFactory

type MockConnection

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

func NewMockConnection

func NewMockConnection(t *testing.T) *MockConnection

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) FreeNoReply

func (buf *NetBuffer) FreeNoReply(seq uint32)

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) Finalize

func (binding *NetCProto) Finalize() error

func (*NetCProto) GetDSNs

func (binding *NetCProto) GetDSNs() []url.URL

func (*NetCProto) GetLogger

func (binding *NetCProto) GetLogger() bindings.Logger

func (*NetCProto) GetMeta

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

func (*NetCProto) GetReplicationStat

func (binding *NetCProto) GetReplicationStat(f func(ctx context.Context) (*bindings.ReplicationStat, 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) ReopenLogFiles

func (binding *NetCProto) ReopenLogFiles() 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) SetSchema

func (binding *NetCProto) SetSchema(ctx context.Context, namespace string, schema bindings.SchemaDef) 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