tarantool

package module

Go to main page

Versions in this module

v1

v1.12.2

Jan 11, 2024

v1.12.1

Aug 7, 2023

v1.12.0

Jun 7, 2023

Changes in this version

type Connection

+ func (conn *Connection) CloseGraceful() error

v1.11.0

May 18, 2023

Changes in this version

+ const IterNeighbor

+ const IterOverlaps

+ const KeyAfterPos

+ const KeyAfterTuple

+ const KeyFetchPos

+ const KeyPos

+ type Conn interface

+ Close func() error

+ Flush func() error

+ Greeting func() Greeting

+ LocalAddr func() net.Addr

+ ProtocolInfo func() ProtocolInfo

+ Read func(b []byte) (int, error)

+ RemoteAddr func() net.Addr

+ Write func(b []byte) (int, error)

+ type DialOpts struct

+ Auth Auth

+ DialTimeout time.Duration

+ IoTimeout time.Duration

+ Password string

+ RequiredProtocol ProtocolInfo

+ Ssl SslOpts

+ Transport string

+ User string

+ type Dialer interface

+ Dial func(address string, opts DialOpts) (Conn, error)

type Opts

+ Dialer Dialer

type Response

+ Pos []byte

type SelectRequest

+ func (req *SelectRequest) After(after interface{}) *SelectRequest

+ func (req *SelectRequest) FetchPos(fetch bool) *SelectRequest

+ type TtDialer struct

+ func (t TtDialer) Dial(address string, opts DialOpts) (Conn, error)

v1.10.0

Dec 31, 2022

Changes in this version

+ const ErrConnectionShutdown

+ const EventCode

+ const IdRequestCode

+ const KeyAuthType

+ const KeyError24

+ const KeyEvent

+ const KeyEventData

+ const KeyFeatures

+ const KeyVersion

+ const LogWatchEventReadFailed

+ const Shutdown

+ const UnwatchRequestCode

+ const WatchRequestCode

+ type Auth int

+ const AutoAuth

+ const ChapSha1Auth

+ const PapSha256Auth

+ func (a Auth) String() string

type BeginRequest

+ func (req *BeginRequest) Async() bool

+ type BoxError struct

+ Code uint64

+ Errno uint64

+ Fields map[string]interface{}

+ File string

+ Line uint64

+ Msg string

+ Prev *BoxError

+ Type string

+ func (e *BoxError) Depth() int

+ func (e *BoxError) Error() string

+ func (e *BoxError) MarshalMsgpack() ([]byte, error)

+ func (e *BoxError) UnmarshalMsgpack(b []byte) error

+ type BroadcastRequest struct

+ func NewBroadcastRequest(key string) *BroadcastRequest

+ func (req *BroadcastRequest) Async() bool

+ func (req *BroadcastRequest) Body(res SchemaResolver, enc *encoder) error

+ func (req *BroadcastRequest) Code() int32

+ func (req *BroadcastRequest) Context(ctx context.Context) *BroadcastRequest

+ func (req *BroadcastRequest) Ctx() context.Context

+ func (req *BroadcastRequest) Value(value interface{}) *BroadcastRequest

type CallRequest

+ func (req *CallRequest) Async() bool

type CommitRequest

+ func (req *CommitRequest) Async() bool

type Connection

+ func (conn *Connection) ClientProtocolInfo() ProtocolInfo

+ func (conn *Connection) NewWatcher(key string, callback WatchCallback) (Watcher, error)

+ func (conn *Connection) ServerProtocolInfo() ProtocolInfo

type Connector

+ NewWatcher func(key string, callback WatchCallback) (Watcher, error)

type Error

+ ExtendedInfo *BoxError

type EvalRequest

+ func (req *EvalRequest) Async() bool

type ExecutePreparedRequest

+ func (req *ExecutePreparedRequest) Async() bool

type ExecuteRequest

+ func (req *ExecuteRequest) Async() bool

+ type IdRequest struct

+ func NewIdRequest(protocolInfo ProtocolInfo) *IdRequest

+ func (req *IdRequest) Async() bool

+ func (req *IdRequest) Body(res SchemaResolver, enc *encoder) error

+ func (req *IdRequest) Code() int32

+ func (req *IdRequest) Context(ctx context.Context) *IdRequest

+ func (req *IdRequest) Ctx() context.Context

type Opts

+ Auth Auth

+ RequiredProtocolInfo ProtocolInfo

+ func (opts Opts) Clone() Opts

type PingRequest

+ func (req *PingRequest) Async() bool

type PrepareRequest

+ func (req *PrepareRequest) Async() bool

+ type ProtocolFeature uint64

+ const ErrorExtensionFeature

+ const PaginationFeature

+ const StreamsFeature

+ const TransactionsFeature

+ const WatchersFeature

+ func (ftr ProtocolFeature) String() string

+ type ProtocolInfo struct

+ Auth Auth

+ Features []ProtocolFeature

+ Version ProtocolVersion

+ func (info ProtocolInfo) Clone() ProtocolInfo

+ type ProtocolVersion uint64

type Request

+ Async func() bool

type RollbackRequest

+ func (req *RollbackRequest) Async() bool

type UnprepareRequest

+ func (req *UnprepareRequest) Async() bool

+ type WatchCallback func(event WatchEvent)

+ type WatchEvent struct

+ Conn *Connection

+ Key string

+ Value interface{}

+ type Watcher interface

+ Unregister func()

v1.9.0

Nov 2, 2022

v1.8.0

Aug 17, 2022

Changes in this version

type Field

+ func (field *Field) DecodeMsgpack(d *decoder) error

type Index

+ SpaceId uint32

+ func (index *Index) DecodeMsgpack(d *decoder) error

type IndexField

+ func (indexField *IndexField) DecodeMsgpack(d *decoder) error

type Space

+ func (space *Space) DecodeMsgpack(d *decoder) error

v1.7.0

Aug 4, 2022

Changes in this version

+ const AuthRequestCode

+ const BeginRequestCode

+ const Call16RequestCode

+ const Call17RequestCode

+ const CallRequestCode

+ const CommitRequestCode

+ const DeleteRequestCode

+ const EvalRequestCode

+ const ExecuteRequestCode

+ const InsertRequestCode

+ const KeyBindCount

+ const KeyStmtID

+ const KeyStreamId

+ const KeyTimeout

+ const KeyTxnIsolation

+ const PingRequestCode

+ const PrepareRequestCode

+ const PushCode

+ const ReplaceRequestCode

+ const RollbackRequestCode

+ const SelectRequestCode

+ const SubscribeRequestCode

+ const UpdateRequestCode

+ const UpsertRequestCode

+ type BeginRequest struct

+ func NewBeginRequest() *BeginRequest

+ func (req *BeginRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *BeginRequest) Code() int32

+ func (req *BeginRequest) Context(ctx context.Context) *BeginRequest

+ func (req *BeginRequest) Ctx() context.Context

+ func (req *BeginRequest) Timeout(timeout time.Duration) *BeginRequest

+ func (req *BeginRequest) TxnIsolation(txnIsolation TxnIsolationLevel) *BeginRequest

type CallRequest

+ func NewCall16Request(function string) *CallRequest

+ func NewCall17Request(function string) *CallRequest

+ func NewCallRequest(function string) *CallRequest

+ func (req *CallRequest) Args(args interface{}) *CallRequest

+ func (req *CallRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *CallRequest) Code() int32

+ func (req *CallRequest) Context(ctx context.Context) *CallRequest

+ func (req *CallRequest) Ctx() context.Context

+ type CommitRequest struct

+ func NewCommitRequest() *CommitRequest

+ func (req *CommitRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *CommitRequest) Code() int32

+ func (req *CommitRequest) Context(ctx context.Context) *CommitRequest

+ func (req *CommitRequest) Ctx() context.Context

+ type ConnectedRequest interface

+ Conn func() *Connection

type Connection

+ func (conn *Connection) Call16(functionName string, args interface{}) (resp *Response, err error)

+ func (conn *Connection) Call16Async(functionName string, args interface{}) *Future

+ func (conn *Connection) Call16Typed(functionName string, args interface{}, result interface{}) (err error)

+ func (conn *Connection) Do(req Request) *Future

+ func (conn *Connection) NewPrepared(expr string) (*Prepared, error)

+ func (conn *Connection) NewStream() (*Stream, error)

type Connector

+ Call16 func(functionName string, args interface{}) (resp *Response, err error)

+ Call16Async func(functionName string, args interface{}) *Future

+ Call16Typed func(functionName string, args interface{}, result interface{}) (err error)

+ Do func(req Request) (fut *Future)

+ ExecuteAsync func(expr string, args interface{}) *Future

+ ExecuteTyped func(expr string, args interface{}, result interface{}) (SQLInfo, []ColumnMetaData, error)

+ NewPrepared func(expr string) (*Prepared, error)

+ NewStream func() (*Stream, error)

type DeleteRequest

+ func NewDeleteRequest(space interface{}) *DeleteRequest

+ func (req *DeleteRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *DeleteRequest) Context(ctx context.Context) *DeleteRequest

+ func (req *DeleteRequest) Index(index interface{}) *DeleteRequest

+ func (req *DeleteRequest) Key(key interface{}) *DeleteRequest

type EvalRequest

+ func NewEvalRequest(expr string) *EvalRequest

+ func (req *EvalRequest) Args(args interface{}) *EvalRequest

+ func (req *EvalRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *EvalRequest) Code() int32

+ func (req *EvalRequest) Context(ctx context.Context) *EvalRequest

+ func (req *EvalRequest) Ctx() context.Context

+ type ExecutePreparedRequest struct

+ func NewExecutePreparedRequest(stmt *Prepared) *ExecutePreparedRequest

+ func (req *ExecutePreparedRequest) Args(args interface{}) *ExecutePreparedRequest

+ func (req *ExecutePreparedRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *ExecutePreparedRequest) Code() int32

+ func (req *ExecutePreparedRequest) Conn() *Connection

+ func (req *ExecutePreparedRequest) Context(ctx context.Context) *ExecutePreparedRequest

+ func (req *ExecutePreparedRequest) Ctx() context.Context

type ExecuteRequest

+ func NewExecuteRequest(expr string) *ExecuteRequest

+ func (req *ExecuteRequest) Args(args interface{}) *ExecuteRequest

+ func (req *ExecuteRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *ExecuteRequest) Code() int32

+ func (req *ExecuteRequest) Context(ctx context.Context) *ExecuteRequest

+ func (req *ExecuteRequest) Ctx() context.Context

type Future

+ func NewFuture() (fut *Future)

+ func (fut *Future) AppendPush(resp *Response)

+ func (fut *Future) GetIterator() (it TimeoutResponseIterator)

+ func (fut *Future) SetError(err error)

+ func (fut *Future) SetResponse(resp *Response)

type InsertRequest

+ func NewInsertRequest(space interface{}) *InsertRequest

+ func (req *InsertRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *InsertRequest) Context(ctx context.Context) *InsertRequest

+ func (req *InsertRequest) Tuple(tuple interface{}) *InsertRequest

+ type Operations struct

+ func NewOperations() *Operations

+ func (ops *Operations) Add(field int, arg interface{}) *Operations

+ func (ops *Operations) Assign(field int, arg interface{}) *Operations

+ func (ops *Operations) BitwiseAnd(field int, arg interface{}) *Operations

+ func (ops *Operations) BitwiseOr(field int, arg interface{}) *Operations

+ func (ops *Operations) BitwiseXor(field int, arg interface{}) *Operations

+ func (ops *Operations) Delete(field int, arg interface{}) *Operations

+ func (ops *Operations) Insert(field int, arg interface{}) *Operations

+ func (ops *Operations) Splice(field int, arg interface{}) *Operations

+ func (ops *Operations) Subtract(field int, arg interface{}) *Operations

type Opts

+ Ssl SslOpts

+ Transport string

type PingRequest

+ func NewPingRequest() *PingRequest

+ func (req *PingRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *PingRequest) Code() int32

+ func (req *PingRequest) Context(ctx context.Context) *PingRequest

+ func (req *PingRequest) Ctx() context.Context

+ type PrepareRequest struct

+ func NewPrepareRequest(expr string) *PrepareRequest

+ func (req *PrepareRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *PrepareRequest) Code() int32

+ func (req *PrepareRequest) Context(ctx context.Context) *PrepareRequest

+ func (req *PrepareRequest) Ctx() context.Context

+ type Prepared struct

+ Conn *Connection

+ MetaData []ColumnMetaData

+ ParamCount uint64

+ StatementID PreparedID

+ func NewPreparedFromResponse(conn *Connection, resp *Response) (*Prepared, error)

+ type PreparedID uint64

type ReplaceRequest

+ func NewReplaceRequest(space interface{}) *ReplaceRequest

+ func (req *ReplaceRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *ReplaceRequest) Context(ctx context.Context) *ReplaceRequest

+ func (req *ReplaceRequest) Tuple(tuple interface{}) *ReplaceRequest

+ type Request interface

+ Body func(resolver SchemaResolver, enc *msgpack.Encoder) error

+ Code func() int32

+ Ctx func() context.Context

+ type ResponseIterator interface

+ Err func() error

+ Next func() bool

+ Value func() *Response

+ type RollbackRequest struct

+ func NewRollbackRequest() *RollbackRequest

+ func (req *RollbackRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *RollbackRequest) Code() int32

+ func (req *RollbackRequest) Context(ctx context.Context) *RollbackRequest

+ func (req *RollbackRequest) Ctx() context.Context

type Schema

+ func (schema *Schema) ResolveSpaceIndex(s interface{}, i interface{}) (spaceNo, indexNo uint32, err error)

+ type SchemaResolver interface

+ ResolveSpaceIndex func(s interface{}, i interface{}) (spaceNo, indexNo uint32, err error)

type SelectRequest

+ func NewSelectRequest(space interface{}) *SelectRequest

+ func (req *SelectRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *SelectRequest) Context(ctx context.Context) *SelectRequest

+ func (req *SelectRequest) Index(index interface{}) *SelectRequest

+ func (req *SelectRequest) Iterator(iterator uint32) *SelectRequest

+ func (req *SelectRequest) Key(key interface{}) *SelectRequest

+ func (req *SelectRequest) Limit(limit uint32) *SelectRequest

+ func (req *SelectRequest) Offset(offset uint32) *SelectRequest

+ type SslOpts struct

+ CaFile string

+ CertFile string

+ Ciphers string

+ KeyFile string

+ type Stream struct

+ Conn *Connection

+ Id uint64

+ func (s *Stream) Do(req Request) *Future

+ type TimeoutResponseIterator interface

+ WithTimeout func(timeout time.Duration) TimeoutResponseIterator

+ type TxnIsolationLevel uint

+ const BestEffortLevel

+ const DefaultIsolationLevel

+ const ReadCommittedLevel

+ const ReadConfirmedLevel

+ type UnprepareRequest struct

+ func NewUnprepareRequest(stmt *Prepared) *UnprepareRequest

+ func (req *UnprepareRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *UnprepareRequest) Code() int32

+ func (req *UnprepareRequest) Conn() *Connection

+ func (req *UnprepareRequest) Context(ctx context.Context) *UnprepareRequest

+ func (req *UnprepareRequest) Ctx() context.Context

type UpdateRequest

+ func NewUpdateRequest(space interface{}) *UpdateRequest

+ func (req *UpdateRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *UpdateRequest) Context(ctx context.Context) *UpdateRequest

+ func (req *UpdateRequest) Index(index interface{}) *UpdateRequest

+ func (req *UpdateRequest) Key(key interface{}) *UpdateRequest

+ func (req *UpdateRequest) Operations(ops *Operations) *UpdateRequest

type UpsertRequest

+ func NewUpsertRequest(space interface{}) *UpsertRequest

+ func (req *UpsertRequest) Body(res SchemaResolver, enc *msgpack.Encoder) error

+ func (req *UpsertRequest) Context(ctx context.Context) *UpsertRequest

+ func (req *UpsertRequest) Operations(ops *Operations) *UpsertRequest

+ func (req *UpsertRequest) Tuple(tuple interface{}) *UpsertRequest

v1.6.0

Jun 2, 2022

Changes in this version

+ const AuthRequest

+ const Call17Request

+ const CallRequest

+ const Closed

+ const Connected

+ const DeleteRequest

+ const Disconnected

+ const ErSpaceExistsCode

+ const ErrAccessDenied

+ const ErrActiveTransaction

+ const ErrAlterSpace

+ const ErrArgType

+ const ErrCantUpdatePrimaryKey

+ const ErrCfg

+ const ErrClusterIdIsRo

+ const ErrClusterIdMismatch

+ const ErrConnectionClosed

+ const ErrConnectionNotReady

+ const ErrCreateFunction

+ const ErrCreateRole

+ const ErrCreateSpace

+ const ErrCreateUser

+ const ErrCrossEngineTransaction

+ const ErrDropFunction

+ const ErrDropPrimaryKey

+ const ErrDropSpace

+ const ErrDropUser

+ const ErrExactMatch

+ const ErrFiberStack

+ const ErrFieldType

+ const ErrFieldTypeMismatch

+ const ErrFunctionAccessDenied

+ const ErrFunctionExists

+ const ErrFunctionLanguage

+ const ErrFunctionMax

+ const ErrGrant

+ const ErrGuestUserPassword

+ const ErrIdentifier

+ const ErrIllegalParams

+ const ErrIndexExists

+ const ErrIndexFieldCount

+ const ErrIndexType

+ const ErrInjection

+ const ErrInvalidMsgpack

+ const ErrInvalidOrder

+ const ErrInvalidUUID

+ const ErrInvalidXlog

+ const ErrInvalidXlogName

+ const ErrInvalidXlogOrder

+ const ErrIteratorType

+ const ErrKeyPartCount

+ const ErrKeyPartType

+ const ErrLastDrop

+ const ErrLoadFunction

+ const ErrLocalServerIsNotActive

+ const ErrMemoryIssue

+ const ErrMissingRequestField

+ const ErrMissingSnapshot

+ const ErrModifyIndex

+ const ErrMoreThanOneTuple

+ const ErrNoActiveTransaction

+ const ErrNoConnection

+ const ErrNoSuchEngine

+ const ErrNoSuchField

+ const ErrNoSuchFunction

+ const ErrNoSuchIndex

+ const ErrNoSuchProc

+ const ErrNoSuchRole

+ const ErrNoSuchSpace

+ const ErrNoSuchTrigger

+ const ErrNoSuchUser

+ const ErrNonmaster

+ const ErrPasswordMismatch

+ const ErrPrivGranted

+ const ErrPrivNotGranted

+ const ErrProcC

+ const ErrProcLua

+ const ErrProcRet

+ const ErrProtocol

+ const ErrProtocolError

+ const ErrRateLimited

+ const ErrReadonly

+ const ErrReloadCfg

+ const ErrReplicaMax

+ const ErrReserved66

+ const ErrRoleExists

+ const ErrRoleGranted

+ const ErrRoleLoop

+ const ErrRoleNotGranted

+ const ErrRtreeRect

+ const ErrServerIdIsReserved

+ const ErrSlabAllocMax

+ const ErrSophia

+ const ErrSpaceAccessDenied

+ const ErrSpaceExists

+ const ErrSpaceFieldCount

+ const ErrSplice

+ const ErrTimeout

+ const ErrTimeouted

+ const ErrTransactionConflict

+ const ErrTupleFormatLimit

+ const ErrTupleFound

+ const ErrTupleIsTooLong

+ const ErrTupleNotArray

+ const ErrTupleNotFound

+ const ErrTupleRefOverflow

+ const ErrUnknown

+ const ErrUnknownRequestType

+ const ErrUnknownRtreeIndexDistanceType

+ const ErrUnknownSchemaObject

+ const ErrUnknownServer

+ const ErrUnknownUpdateOp

+ const ErrUnsupported

+ const ErrUnsupportedRolePriv

+ const ErrUpdateField

+ const ErrUpdateIntegerOverflow

+ const ErrUpsertUniqueSecondaryKey

+ const ErrUserExists

+ const ErrUserMax

+ const ErrWalIo

+ const ErrWrongIndexOptions

+ const ErrWrongIndexParts

+ const ErrWrongIndexRecord

+ const ErrWrongSchemaVaersion

+ const ErrorCodeBit

+ const EvalRequest

+ const ExecuteRequest

+ const InsertRequest

+ const IterAll

+ const IterBitsAllNotSet

+ const IterBitsAllSet

+ const IterBitsAnySet

+ const IterEq

+ const IterGe

+ const IterGt

+ const IterLe

+ const IterLt

+ const IterReq

+ const IteratorCode

+ const KeyCode

+ const KeyData

+ const KeyDefTuple

+ const KeyError

+ const KeyExpression

+ const KeyFieldColl

+ const KeyFieldIsNullable

+ const KeyFieldName

+ const KeyFieldSpan

+ const KeyFieldType

+ const KeyFunctionName

+ const KeyIndexNo

+ const KeyIsAutoincrement

+ const KeyIterator

+ const KeyKey

+ const KeyLimit

+ const KeyMetaData

+ const KeyOffset

+ const KeySQLBind

+ const KeySQLInfo

+ const KeySQLInfoAutoincrementIds

+ const KeySQLInfoRowCount

+ const KeySQLText

+ const KeySpaceNo

+ const KeySync

+ const KeyTuple

+ const KeyUserName

+ const LogLastReconnectFailed

+ const LogReconnectFailed

+ const LogUnexpectedResultId

+ const OkCode

+ const PacketLengthBytes

+ const PingRequest

+ const RLimitDrop

+ const RLimitWait

+ const ReconnectFailed

+ const ReplaceRequest

+ const SelectRequest

+ const SubscribeRequest

+ const UpdateRequest

+ const UpsertRequest

+ type ClientError struct

+ Code uint32

+ Msg string

+ func (clierr ClientError) Error() string

+ func (clierr ClientError) Temporary() bool

+ type ColumnMetaData struct

+ FieldCollation string

+ FieldIsAutoincrement bool

+ FieldIsNullable bool

+ FieldName string

+ FieldSpan string

+ FieldType string

+ func (meta *ColumnMetaData) DecodeMsgpack(d *msgpack.Decoder) error

+ type ConnEvent struct

+ Conn *Connection

+ Kind ConnEventKind

+ When time.Time

+ type ConnEventKind int

+ type ConnLogKind int

+ type Connection struct

+ Greeting *Greeting

+ Schema *Schema

+ func Connect(addr string, opts Opts) (conn *Connection, err error)

+ func (conn *Connection) Addr() string

+ func (conn *Connection) Call(functionName string, args interface{}) (resp *Response, err error)

+ func (conn *Connection) Call17(functionName string, args interface{}) (resp *Response, err error)

+ func (conn *Connection) Call17Async(functionName string, args interface{}) *Future

+ func (conn *Connection) Call17Typed(functionName string, args interface{}, result interface{}) (err error)

+ func (conn *Connection) CallAsync(functionName string, args interface{}) *Future

+ func (conn *Connection) CallTyped(functionName string, args interface{}, result interface{}) (err error)

+ func (conn *Connection) Close() error

+ func (conn *Connection) ClosedNow() bool

+ func (conn *Connection) ConfiguredTimeout() time.Duration

+ func (conn *Connection) ConnectedNow() bool

+ func (conn *Connection) Delete(space, index interface{}, key interface{}) (resp *Response, err error)

+ func (conn *Connection) DeleteAsync(space, index interface{}, key interface{}) *Future

+ func (conn *Connection) DeleteTyped(space, index interface{}, key interface{}, result interface{}) (err error)

+ func (conn *Connection) Eval(expr string, args interface{}) (resp *Response, err error)

+ func (conn *Connection) EvalAsync(expr string, args interface{}) *Future

+ func (conn *Connection) EvalTyped(expr string, args interface{}, result interface{}) (err error)

+ func (conn *Connection) Execute(expr string, args interface{}) (resp *Response, err error)

+ func (conn *Connection) ExecuteAsync(expr string, args interface{}) *Future

+ func (conn *Connection) ExecuteTyped(expr string, args interface{}, result interface{}) (SQLInfo, []ColumnMetaData, error)

+ func (conn *Connection) GetTyped(space, index interface{}, key interface{}, result interface{}) (err error)

+ func (conn *Connection) Handle() interface{}

+ func (conn *Connection) Insert(space interface{}, tuple interface{}) (resp *Response, err error)

+ func (conn *Connection) InsertAsync(space interface{}, tuple interface{}) *Future

+ func (conn *Connection) InsertTyped(space interface{}, tuple interface{}, result interface{}) (err error)

+ func (conn *Connection) LocalAddr() string

+ func (conn *Connection) OverrideSchema(s *Schema)

+ func (conn *Connection) Ping() (resp *Response, err error)

+ func (conn *Connection) RemoteAddr() string

+ func (conn *Connection) Replace(space interface{}, tuple interface{}) (resp *Response, err error)

+ func (conn *Connection) ReplaceAsync(space interface{}, tuple interface{}) *Future

+ func (conn *Connection) ReplaceTyped(space interface{}, tuple interface{}, result interface{}) (err error)

+ func (conn *Connection) Select(space, index interface{}, offset, limit, iterator uint32, key interface{}) (resp *Response, err error)

+ func (conn *Connection) SelectAsync(space, index interface{}, offset, limit, iterator uint32, key interface{}) *Future

+ func (conn *Connection) SelectTyped(space, index interface{}, offset, limit, iterator uint32, key interface{}, ...) (err error)

+ func (conn *Connection) Update(space, index interface{}, key, ops interface{}) (resp *Response, err error)

+ func (conn *Connection) UpdateAsync(space, index interface{}, key, ops interface{}) *Future

+ func (conn *Connection) UpdateTyped(space, index interface{}, key, ops interface{}, result interface{}) (err error)

+ func (conn *Connection) Upsert(space interface{}, tuple, ops interface{}) (resp *Response, err error)

+ func (conn *Connection) UpsertAsync(space interface{}, tuple interface{}, ops interface{}) *Future

+ type Connector interface

+ Call func(functionName string, args interface{}) (resp *Response, err error)

+ Call17 func(functionName string, args interface{}) (resp *Response, err error)

+ Call17Async func(functionName string, args interface{}) *Future

+ Call17Typed func(functionName string, args interface{}, result interface{}) (err error)

+ CallAsync func(functionName string, args interface{}) *Future

+ CallTyped func(functionName string, args interface{}, result interface{}) (err error)

+ Close func() error

+ ConfiguredTimeout func() time.Duration

+ ConnectedNow func() bool

+ Delete func(space, index interface{}, key interface{}) (resp *Response, err error)

+ DeleteAsync func(space, index interface{}, key interface{}) *Future

+ DeleteTyped func(space, index interface{}, key interface{}, result interface{}) (err error)

+ Eval func(expr string, args interface{}) (resp *Response, err error)

+ EvalAsync func(expr string, args interface{}) *Future

+ EvalTyped func(expr string, args interface{}, result interface{}) (err error)

+ Execute func(expr string, args interface{}) (resp *Response, err error)

+ GetTyped func(space, index interface{}, key interface{}, result interface{}) (err error)

+ Insert func(space interface{}, tuple interface{}) (resp *Response, err error)

+ InsertAsync func(space interface{}, tuple interface{}) *Future

+ InsertTyped func(space interface{}, tuple interface{}, result interface{}) (err error)

+ Ping func() (resp *Response, err error)

+ Replace func(space interface{}, tuple interface{}) (resp *Response, err error)

+ ReplaceAsync func(space interface{}, tuple interface{}) *Future

+ ReplaceTyped func(space interface{}, tuple interface{}, result interface{}) (err error)

+ Select func(space, index interface{}, offset, limit, iterator uint32, key interface{}) (resp *Response, err error)

+ SelectAsync func(space, index interface{}, offset, limit, iterator uint32, key interface{}) *Future

+ SelectTyped func(space, index interface{}, offset, limit, iterator uint32, key interface{}, ...) (err error)

+ Update func(space, index interface{}, key, ops interface{}) (resp *Response, err error)

+ UpdateAsync func(space, index interface{}, key, ops interface{}) *Future

+ UpdateTyped func(space, index interface{}, key, ops interface{}, result interface{}) (err error)

+ Upsert func(space interface{}, tuple, ops interface{}) (resp *Response, err error)

+ UpsertAsync func(space interface{}, tuple interface{}, ops interface{}) *Future

+ type DeadlineIO struct

+ func (d *DeadlineIO) Read(b []byte) (n int, err error)

+ func (d *DeadlineIO) Write(b []byte) (n int, err error)

+ type Error struct

+ Code uint32

+ Msg string

+ func (tnterr Error) Error() string

+ type Field struct

+ Id uint32

+ Name string

+ Type string

+ type Future struct

+ func NewErrorFuture(err error) *Future

+ func (fut *Future) Err() error

+ func (fut *Future) Get() (*Response, error)

+ func (fut *Future) GetTyped(result interface{}) error

+ func (fut *Future) WaitChan() <-chan struct{}

+ type Greeting struct

+ Version string

+ type Index struct

+ Fields []*IndexField

+ Id uint32

+ Name string

+ Type string

+ Unique bool

+ type IndexField struct

+ Id uint32

+ Type string

+ type IntIntKey struct

+ I1 int

+ I2 int

+ func (k IntIntKey) EncodeMsgpack(enc *msgpack.Encoder) error

+ type IntKey struct

+ I int

+ func (k IntKey) EncodeMsgpack(enc *msgpack.Encoder) error

+ type KeyValueBind struct

+ Key string

+ Value interface{}

+ type Logger interface

+ Report func(event ConnLogKind, conn *Connection, v ...interface{})

+ type Op struct

+ Arg interface{}

+ Field int

+ Op string

+ func (o Op) EncodeMsgpack(enc *msgpack.Encoder) error

+ type OpSplice struct

+ Field int

+ Len int

+ Op string

+ Pos int

+ Replace string

+ func (o OpSplice) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Opts struct

+ Concurrency uint32

+ Handle interface{}

+ Logger Logger

+ MaxReconnects uint

+ Notify chan<- ConnEvent

+ Pass string

+ RLimitAction uint

+ RateLimit uint

+ Reconnect time.Duration

+ SkipSchema bool

+ Timeout time.Duration

+ User string

+ type Response struct

+ Code uint32

+ Data []interface{}

+ Error string

+ MetaData []ColumnMetaData

+ RequestId uint32

+ SQLInfo SQLInfo

+ func (resp *Response) String() (str string)

+ func (resp *Response) Tuples() (res [][]interface{})

+ type SQLInfo struct

+ AffectedCount uint64

+ InfoAutoincrementIds []uint64

+ func (info *SQLInfo) DecodeMsgpack(d *msgpack.Decoder) error

+ type Schema struct

+ Spaces map[string]*Space

+ SpacesById map[uint32]*Space

+ Version uint

+ type Space struct

+ Engine string

+ Fields map[string]*Field

+ FieldsById map[uint32]*Field

+ FieldsCount uint32

+ Id uint32

+ Indexes map[string]*Index

+ IndexesById map[uint32]*Index

+ Name string

+ Temporary bool

+ type StringKey struct

+ S string

+ func (k StringKey) EncodeMsgpack(enc *msgpack.Encoder) error

+ type UintKey struct

+ I uint

+ func (k UintKey) EncodeMsgpack(enc *msgpack.Encoder) error

Other modules containing this package

github.com/tarantool/go-tarantool/v2

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