Versions in this module Expand all Collapse all v1 v1.100.0 Sep 27, 2023 Changes in this version + func CheckEqualBoxErrors(t *testing.T, expected tarantool.BoxError, actual tarantool.BoxError) + func CheckPoolStatuses(args interface{}) error + func ConnectWithValidation(t testing.TB, server string, opts tarantool.Opts) *tarantool.Connection + func DeleteRecordByKey(t *testing.T, conn tarantool.Connector, space interface{}, index interface{}, ...) + func InsertOnInstance(server string, connOpts tarantool.Opts, space interface{}, tuple interface{}) error + func InsertOnInstances(servers []string, connOpts tarantool.Opts, space interface{}, ...) error + func IsTarantoolVersionLess(majorMin uint64, minorMin uint64, patchMin uint64) (bool, error) + func ProcessListenOnInstance(args interface{}) error + func RestartTarantool(inst *TarantoolInstance) error + func Retry(f func(interface{}) error, args interface{}, count int, timeout time.Duration) error + func SetClusterRO(servers []string, connOpts tarantool.Opts, roles []bool) error + func SetInstanceRO(server string, connOpts tarantool.Opts, isReplica bool) error + func SkipIfErrorExtendedInfoUnsupported(t *testing.T) + func SkipIfErrorMessagePackTypeUnsupported(t *testing.T) + func SkipIfFeatureDropped(t *testing.T, feature string, major, minor, patch uint64) + func SkipIfFeatureSupported(t *testing.T, feature string, major, minor, patch uint64) + func SkipIfFeatureUnsupported(t *testing.T, feature string, major, minor, patch uint64) + func SkipIfGreaterOrEqual(t *testing.T, reason string, major, minor, patch uint64) + func SkipIfIdSupported(t *testing.T) + func SkipIfIdUnsupported(t *testing.T) + func SkipIfLess(t *testing.T, reason string, major, minor, patch uint64) + func SkipIfSQLUnsupported(t testing.TB) + func SkipIfStreamsUnsupported(t *testing.T) + func SkipIfWatchersSupported(t *testing.T) + func SkipIfWatchersUnsupported(t *testing.T) + func StopTarantool(inst TarantoolInstance) + func StopTarantoolInstances(instances []TarantoolInstance) + func StopTarantoolWithCleanup(inst TarantoolInstance) + func WaitUntilReconnected(conn *tarantool.Connection, retries uint, timeout time.Duration) bool + type CheckStatusesArgs struct + ConnPool *connection_pool.ConnectionPool + ExpectedPoolStatus bool + ExpectedStatuses map[string]bool + Mode connection_pool.Mode + Servers []string + type ListenOnInstanceArgs struct + ConnPool *connection_pool.ConnectionPool + ExpectedPorts map[string]bool + Mode connection_pool.Mode + ServersNumber int + type StartOpts struct + Auth tarantool.Auth + ClientServer string + ClientSsl tarantool.SslOpts + ClientTransport string + ConnectRetry int + InitScript string + Listen string + MemtxUseMvccEngine bool + Pass string + RetryTimeout time.Duration + SslCertsDir string + User string + WaitStart time.Duration + WorkDir string + type StrangerRequest struct + func NewStrangerRequest() *StrangerRequest + func (sr *StrangerRequest) Async() bool + func (sr *StrangerRequest) Body(resolver tarantool.SchemaResolver, enc *encoder) error + func (sr *StrangerRequest) Code() int32 + func (sr *StrangerRequest) Conn() *tarantool.Connection + func (sr *StrangerRequest) Ctx() context.Context + type TarantoolInstance struct + Cmd *exec.Cmd + Opts StartOpts + func StartTarantool(startOpts StartOpts) (TarantoolInstance, error) + func StartTarantoolInstances(servers []string, workDirs []string, opts StartOpts) ([]TarantoolInstance, error)
Go to main page