tarantool

package module

Go to main page

Versions in this module

v1

v1.6.0

Apr 16, 2021

v1.5.3

Apr 16, 2021

v1.5.2

Apr 16, 2021

Changes in this version

+ type UUID uuid.UUID

+ func (u *UUID) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (u UUID) EncodeMsgpack(enc *msgpack.Encoder) error

v1.5.1

Apr 15, 2021

Changes in this version

+ const ExtUUID

+ var ErrUnexpectedExtension = errors.New("unexpected extension code")

+ func DecodeUUID(dec *msgpack.Decoder) (uuid.UUID, error)

+ func EncodeUUID(enc *msgpack.Encoder, value uuid.UUID) error

v1.5.0

Apr 15, 2021

v1.4.1

Apr 6, 2021

Changes in this version

+ func Skip(dec *msgpack.Decoder, num int) error

v1.4.0

Jan 14, 2021

Changes in this version

+ var ErrConnectionClosed = errors.New("connection closed")

+ var ErrExchangeNotFound = errors.WithMessage(ErrNotFound, "exchange")

+ var ErrGateInvalidState = errors.New("gate has invalid state")

+ var ErrIndexNotFound = errors.WithMessage(ErrNotFound, "index")

+ var ErrNotFound = errors.New("was not found")

+ var ErrSpaceNotFound = errors.WithMessage(ErrNotFound, "space")

+ type Decoder struct

+ func NewDecoder(exchange *Exchange) *Decoder

+ func (d *Decoder) Fill(r io.Reader, n uint64) error

+ func (d *Decoder) Packet() error

+ type Driver interface

+ Auth func(ctx context.Context, user, password string) error

+ Close func() error

+ Exec func(ctx context.Context, query Query) error

+ Indexes func(ctx context.Context) (Indexes, error)

+ Query func(ctx context.Context, query Query, result msgpack.CustomDecoder) error

+ Spaces func(ctx context.Context) (Spaces, error)

type Exchange

+ func (e *Exchange) Clear(err error)

+ func (e *Exchange) Pull(id uint64) *Gate

+ func (e *Exchange) Push(gate *Gate)

+ type Gate struct

+ func NewGate(code Code, result msgpack.CustomDecoder) (*Gate, error)

+ func (g *Gate) Free()

+ func (g *Gate) ID() uint64

+ func (g *Gate) Wait(ctx context.Context) error

type Index

+ func GetIndex(ctx context.Context, conn Driver, space *Space, name string) (*Index, error)

type Space

+ func GetSpace(ctx context.Context, conn Driver, name string) (*Space, error)

+ type Wrapper struct

+ Result interface{}

+ func NewWrapper(result interface{}) *Wrapper

+ func (w *Wrapper) DecodeMsgpack(dec *msgpack.Decoder) error

v1.3.0

Sep 25, 2020

Changes in this version

+ var ErrExchangeInvalidState = errors.New("exchange has invalid state")

+ var ErrUnexpectedGreeting = errors.New("unexpected tarantool server greeting message")

type Connection

+ ProtocolVersion string

+ SessionID string

+ func (c *Connection) ReloadSystemInfo(ctx context.Context) error

+ type Option func(*Options)

+ func BufferSize(size int) Option

+ func ReadBufferSize(size int) Option

+ func SlotSize(size int) Option

+ func WriteBufferSize(size int) Option

+ type Options struct

+ BufferSize struct{ ... }

+ SlotsSize int

+ func DefaultOptions() Options

+ type Proto uint8

+ const ProtoCode

+ const ProtoData

+ const ProtoDefTuple

+ const ProtoError

+ const ProtoError24

+ const ProtoExpression

+ const ProtoFunctionName

+ const ProtoIndexNo

+ const ProtoIterator

+ const ProtoKey

+ const ProtoLimit

+ const ProtoMetaData

+ const ProtoOffset

+ const ProtoOptions

+ const ProtoSQLBind

+ const ProtoSQLBindCount

+ const ProtoSQLBindMeta

+ const ProtoSQLInfo

+ const ProtoSQLStatement

+ const ProtoSQLText

+ const ProtoSchema

+ const ProtoSpaceNo

+ const ProtoSync

+ const ProtoTuple

+ const ProtoUserName

+ func (i *Proto) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (i Proto) EncodeMsgpack(enc *msgpack.Encoder) error

+ func (i Proto) String() string

type QueryError

+ func (q QueryError) Cause() error

v1.2.1

Jun 23, 2020

v1.2.0

Jun 23, 2020

Changes in this version

+ const DefaultBufferSize

+ const KeyError24

+ const KeyMetaData

+ const KeyOptions

+ const KeySQLBind

+ const KeySQLBindCount

+ const KeySQLBindMeta

+ const KeySQLInfo

+ const KeySQLStatement

+ const KeySQLText

+ var ErrInvalidPackageSize = errors.New("invalid package size")

+ var ErrTooMachResults = errors.New("received too mach results")

+ var ErrUnexpectedServerVersion = errors.New("unexpected tarantool server version")

+ func NextStatementSequenceValue() uint64

+ func NextSyncSequenceValue() uint64

type Code

+ const CodeAuth

+ const CodeCall

+ const CodeDelete

+ const CodeEval

+ const CodeExecute

+ const CodeInsert

+ const CodeOK

+ const CodePing

+ const CodePrepare

+ const CodeReplace

+ const CodeSelect

+ const CodeUpdate

+ const CodeUpsert

+ type Error struct

+ ErrCode uint

+ ErrNo uint

+ Fields map[string]interface{}

+ File string

+ Line uint

+ Message string

+ Type string

+ func (e *Error) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (e Error) Error() string

+ type ErrorCode uint8

+ const ErrorErrCode

+ const ErrorErrNo

+ const ErrorFields

+ const ErrorFile

+ const ErrorLine

+ const ErrorMessage

+ const ErrorType

+ type Execute struct

+ func NewExecute(query string, arguments ...interface{}) *Execute

+ func (Execute) Code() Code

+ func (e *Execute) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Operations []Operation

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

+ type QueryError struct

+ Err error

+ Query Query

+ func NewQueryError(query Query, err error) *QueryError

+ func (q QueryError) Error() string

+ func (q QueryError) Unwrap() error

+ type SingleResult struct

+ Result interface{}

+ func NewSingleResult(result interface{}) *SingleResult

+ func (s *SingleResult) DecodeMsgpack(dec *msgpack.Decoder) error

+ type SliceUint8 []uint8

+ func (s SliceUint8) EncodeMsgpack(enc *msgpack.Encoder) error

v1.1.1

Dec 31, 2019

Changes in this version

+ var ErrUnknownHeaderCode = errors.New("received unknown header code")

type Code

+ func (i Code) String() string

v1.1.0

Dec 30, 2019

Changes in this version

+ const DefaultSlotsSize

+ const HeaderSize

+ const KeyCode

+ const KeyData

+ const KeyDefTuple

+ const KeyError

+ const KeyExpression

+ const KeyFunctionName

+ const KeyIndexNo

+ const KeyIterator

+ const KeyKey

+ const KeyLimit

+ const KeyOffset

+ const KeySchema

+ const KeySpaceNo

+ const KeySync

+ const KeyTuple

+ const KeyUserName

+ var ErrInvalidSaltSize = errors.New("invalid salt size")

+ var ErrNoConnectionSpecified = errors.New("no connection was specified")

+ func NextSequenceValue() uint64

+ type Auth struct

+ func NewAuth(user, password string) *Auth

+ func (Auth) Code() Code

+ func (a *Auth) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Call struct

+ func NewCall(function string, arguments ...interface{}) *Call

+ func NewEval(expression string, arguments ...interface{}) *Call

+ func (c *Call) Code() Code

+ func (c *Call) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Code uint

+ const AuthCode

+ const CallCode

+ const DeleteCode

+ const EvalCode

+ const InsertCode

+ const OKCode

+ const PingCode

+ const ReplaceCode

+ const SelectCode

+ const UpdateCode

+ const UpsertCode

+ func (c *Code) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (c Code) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Connection struct

+ func NewConnection(ctx context.Context, conn io.ReadWriteCloser, slotsSize int) (*Connection, error)

+ func NewDefaultConnection(ctx context.Context, conn io.ReadWriteCloser) (*Connection, error)

+ func (c *Connection) Auth(ctx context.Context, user, password string) error

+ func (c *Connection) Close() (err error)

+ func (c *Connection) Exec(ctx context.Context, query Query) error

+ func (c *Connection) Indexes() Indexes

+ func (c *Connection) Query(ctx context.Context, query Query, result interface{}) error

+ func (c *Connection) ReloadIndexes(ctx context.Context) error

+ func (c *Connection) ReloadSpaces(ctx context.Context) error

+ func (c *Connection) Spaces() Spaces

+ type CounterBuffer struct

+ Bytes uint64

+ func NewCounterBuffer(r *bufio.Reader) *CounterBuffer

+ func (b *CounterBuffer) Read(p []byte) (n int, err error)

+ func (b *CounterBuffer) ReadByte() (byte, error)

+ func (b *CounterBuffer) UnreadByte() error

+ type Delete struct

+ Index *Index

+ Key Key

+ Space *Space

+ func NewDelete(space *Space, index *Index, key Key) *Delete

+ func (Delete) Code() Code

+ func (d *Delete) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Exchange struct

+ func NewExchange(code Code, result interface{}) (*Exchange, error)

+ func (e *Exchange) Done(err error)

+ func (e *Exchange) Free()

+ func (e *Exchange) ID() uint64

+ func (e *Exchange) Wait()

+ type Header struct

+ Code Code

+ Error error

+ HasData bool

+ Scheme uint64

+ Size uint64

+ Sync uint64

+ func (h *Header) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (h *Header) EncodeMsgpack(enc *msgpack.Encoder) error

+ func (h *Header) Reset()

+ type Index struct

+ ID uint

+ Name string

+ SpaceID uint

+ Type string

+ func (i *Index) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (i *Index) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Indexes []Index

+ func (i *Indexes) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (i Indexes) ByID(space *Space, id uint) *Index

+ func (i Indexes) ByName(space *Space, name string) *Index

+ type Insert struct

+ Data interface{}

+ Replace bool

+ Space *Space

+ func NewInsert(space *Space, data interface{}) *Insert

+ func NewReplace(space *Space, data interface{}) *Insert

+ func (i *Insert) Code() Code

+ func (i *Insert) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Iterator uint8

+ const IterateAll

+ const IterateBitsAllNotSet

+ const IterateBitsAllSet

+ const IterateBitsAnySet

+ const IterateEqual

+ const IterateGreaterThan

+ const IterateGreaterThanOrEqual

+ const IterateLessThan

+ const IterateLessThanOrEqual

+ const IterateReverseEqual

+ type Key []interface

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

+ type Operation struct

+ func BitAndOperation(field uint, argument uint) Operation

+ func BitOrOperation(field uint, argument uint) Operation

+ func BitXorOperation(field uint, argument uint) Operation

+ func InsertOperation(beforeField uint, argument interface{}) Operation

+ func RemoveOperation(field uint, num uint) Operation

+ func SetOperation(field uint, argument interface{}) Operation

+ func SubOperation(field uint, argument interface{}) Operation

+ func SumOperation(field uint, argument interface{}) Operation

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

+ type Ping struct

+ func NewPing() *Ping

+ func (Ping) Code() Code

+ func (Ping) EncodeMsgpack(*msgpack.Encoder) error

+ type Query interface

+ Code func() Code

+ type Select struct

+ Index *Index

+ Iterator Iterator

+ Key Key

+ Limit uint

+ Offset uint

+ Space *Space

+ func NewSelect(space *Space, key Key, limit uint) *Select

+ func NewSelectOne(space *Space, key interface{}) *Select

+ func (Select) Code() Code

+ func (query *Select) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Space struct

+ Engine string

+ FieldsCount uint

+ ID uint

+ Name string

+ Owner uint

+ func (s *Space) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (s *Space) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Spaces []Space

+ func (s *Spaces) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (s Spaces) ByID(id uint) *Space

+ func (s Spaces) ByName(name string) *Space

+ type Update struct

+ Index *Index

+ Key Key

+ Operations []Operation

+ Space *Space

+ func NewUpdate(space *Space, index *Index, key Key, operations []Operation) *Update

+ func (Update) Code() Code

+ func (u *Update) EncodeMsgpack(enc *msgpack.Encoder) error

+ type Upsert struct

+ Data interface{}

+ Operations []Operation

+ Space *Space

+ func NewUpsert(space *Space, data interface{}, operations []Operation) *Upsert

+ func (Upsert) Code() Code

+ func (u *Upsert) EncodeMsgpack(enc *msgpack.Encoder) error

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