multi

package

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

v1.11.0

May 18, 2023

v1.10.0

Dec 31, 2022

Changes in this version

type ConnectionMulti

+ func (connMulti *ConnectionMulti) NewWatcher(key string, callback tarantool.WatchCallback) (tarantool.Watcher, error)

v1.9.0

Nov 2, 2022

v1.8.0

Aug 17, 2022

v1.7.0

Aug 4, 2022

Changes in this version

type ConnectionMulti

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

+ func (connMulti *ConnectionMulti) Call16Async(functionName string, args interface{}) *tarantool.Future

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

+ func (connMulti *ConnectionMulti) Do(req tarantool.Request) *tarantool.Future

+ func (connMulti *ConnectionMulti) ExecuteAsync(expr string, args interface{}) *tarantool.Future

+ func (connMulti *ConnectionMulti) ExecuteTyped(expr string, args interface{}, result interface{}) (tarantool.SQLInfo, []tarantool.ColumnMetaData, error)

+ func (connMulti *ConnectionMulti) NewPrepared(expr string) (*tarantool.Prepared, error)

+ func (connMulti *ConnectionMulti) NewStream() (*tarantool.Stream, error)

v1.6.0

Jun 2, 2022

Changes in this version

+ var ErrEmptyAddrs = errors.New("addrs should not be empty")

+ var ErrNoConnection = errors.New("no active connections")

+ var ErrWrongCheckTimeout = errors.New("wrong check timeout, must be greater than 0")

+ type ConnectionMulti struct

+ func Connect(addrs []string, connOpts tarantool.Opts) (connMulti *ConnectionMulti, err error)

+ func ConnectWithOpts(addrs []string, connOpts tarantool.Opts, opts OptsMulti) (connMulti *ConnectionMulti, err error)

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

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

+ func (connMulti *ConnectionMulti) Call17Async(functionName string, args interface{}) *tarantool.Future

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

+ func (connMulti *ConnectionMulti) CallAsync(functionName string, args interface{}) *tarantool.Future

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

+ func (connMulti *ConnectionMulti) Close() (err error)

+ func (connMulti *ConnectionMulti) ConfiguredTimeout() time.Duration

+ func (connMulti *ConnectionMulti) ConnectedNow() bool

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

+ func (connMulti *ConnectionMulti) DeleteAsync(space, index interface{}, key interface{}) *tarantool.Future

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

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

+ func (connMulti *ConnectionMulti) EvalAsync(expr string, args interface{}) *tarantool.Future

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

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

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

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

+ func (connMulti *ConnectionMulti) InsertAsync(space interface{}, tuple interface{}) *tarantool.Future

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

+ func (connMulti *ConnectionMulti) Ping() (resp *tarantool.Response, err error)

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

+ func (connMulti *ConnectionMulti) ReplaceAsync(space interface{}, tuple interface{}) *tarantool.Future

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

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

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

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

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

+ func (connMulti *ConnectionMulti) UpdateAsync(space, index interface{}, key, ops interface{}) *tarantool.Future

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

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

+ func (connMulti *ConnectionMulti) UpsertAsync(space interface{}, tuple interface{}, ops interface{}) *tarantool.Future

+ type OptsMulti struct

+ CheckTimeout time.Duration

+ ClusterDiscoveryTime time.Duration

+ NodesGetFunctionName string

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