package xtest

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/xtest"

Index ¶

• func AllowByFlag(t testing.TB, flag string)
• func CallMethod(object any, name string, args ...any) []any
• func Context(t testing.TB) context.Context
• func ContextWithCommonTimeout(ctx context.Context, t testing.TB) context.Context
• func CurrentFileLine() string
• func FastClock(t testing.TB) clockwork.FakeClock
• func GrpcMockTopicConnString(e fixenv.Env, topicServiceImpl Ydb_Topic_V1.TopicServiceServer) string
• func SpinWaitCondition(tb testing.TB, l sync.Locker, cond func() bool)
• func SpinWaitConditionWithTimeout(tb testing.TB, l sync.Locker, condWaitTimeout time.Duration, cond func() bool)
• func SpinWaitProgress(tb testing.TB, progress func() (progressValue interface{}, finished bool))
• func SpinWaitProgressWithTimeout( tb testing.TB, timeout time.Duration, progress func() (progressValue interface{}, finished bool), )
• func TestManyTimes(t testing.TB, test TestFunc, opts ...TestManyTimesOption)
• func TestManyTimesWithName(t *testing.T, name string, test TestFunc)
• func ToJSON(v interface{}) string
• func WaitChannelClosed(t testing.TB, ch <-chan struct{})
• func WaitChannelClosedWithTimeout(t testing.TB, ch <-chan struct{}, timeout time.Duration)
• func WaitGroup(tb testing.TB, wg *sync.WaitGroup)
• func WaitGroupWithTimeout(tb testing.TB, wg *sync.WaitGroup, timeout time.Duration)
• type GrpcLogger
• func NewGrpcLogger(t testing.TB) GrpcLogger
• func (l GrpcLogger) StreamClientInterceptor( ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption, ) (grpc.ClientStream, error)
• func (l GrpcLogger) UnaryClientInterceptor( ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption, ) error
• type SyncedTest
• func MakeSyncedTest(t testing.TB) *SyncedTest
• func (s *SyncedTest) Cleanup(f func())
• func (s *SyncedTest) Error(args ...interface{})
• func (s *SyncedTest) Errorf(format string, args ...interface{})
• func (s *SyncedTest) Fail()
• func (s *SyncedTest) FailNow()
• func (s *SyncedTest) Failed() bool
• func (s *SyncedTest) Fatal(args ...interface{})
• func (s *SyncedTest) Fatalf(format string, args ...interface{})
• func (s *SyncedTest) Log(args ...interface{})
• func (s *SyncedTest) Logf(format string, args ...interface{})
• func (s *SyncedTest) Name() string
• func (s *SyncedTest) Setenv(key, value string)
• func (s *SyncedTest) Skip(args ...interface{})
• func (s *SyncedTest) SkipNow()
• func (s *SyncedTest) Skipf(format string, args ...interface{})
• func (s *SyncedTest) Skipped() bool
• func (s *SyncedTest) TempDir() string
• type TestFunc
• type TestManyTimesOption
• func StopAfter(stopAfter time.Duration) TestManyTimesOption

Functions ¶

func AllowByFlag ¶

func AllowByFlag(t testing.TB, flag string)

func CallMethod ¶

func CallMethod(object any, name string, args ...any) []any

func Context ¶

func Context(t testing.TB) context.Context

func ContextWithCommonTimeout ¶

func ContextWithCommonTimeout(ctx context.Context, t testing.TB) context.Context

func CurrentFileLine ¶

func CurrentFileLine() string

func FastClock ¶

func FastClock(t testing.TB) clockwork.FakeClock

FastClock returns fake clock with very fast time speed advanced until end of test the clock stops advance at end of test

func GrpcMockTopicConnString ¶

func GrpcMockTopicConnString(e fixenv.Env, topicServiceImpl Ydb_Topic_V1.TopicServiceServer) string

func SpinWaitCondition ¶

func SpinWaitCondition(tb testing.TB, l sync.Locker, cond func() bool)

SpinWaitCondition wait while cond return true with check it in loop l can be nil - then locker use for check conditions

func SpinWaitConditionWithTimeout ¶

func SpinWaitConditionWithTimeout(tb testing.TB, l sync.Locker, condWaitTimeout time.Duration, cond func() bool)

SpinWaitConditionWithTimeout wait while cond return true with check it in loop l can be nil - then locker use for check conditions

func SpinWaitProgress ¶

func SpinWaitProgress(tb testing.TB, progress func() (progressValue interface{}, finished bool))

SpinWaitProgress failed if result of progress func no changes without timeout

func SpinWaitProgressWithTimeout ¶

func SpinWaitProgressWithTimeout(
	tb testing.TB,
	timeout time.Duration,
	progress func() (progressValue interface{}, finished bool),
)

func TestManyTimes ¶

func TestManyTimes(t testing.TB, test TestFunc, opts ...TestManyTimesOption)

func TestManyTimesWithName ¶

func TestManyTimesWithName(t *testing.T, name string, test TestFunc)

func ToJSON ¶

func ToJSON(v interface{}) string

func WaitChannelClosed ¶

func WaitChannelClosed(t testing.TB, ch <-chan struct{})

func WaitChannelClosedWithTimeout ¶

func WaitChannelClosedWithTimeout(t testing.TB, ch <-chan struct{}, timeout time.Duration)

func WaitGroup ¶

func WaitGroup(tb testing.TB, wg *sync.WaitGroup)

func WaitGroupWithTimeout ¶

func WaitGroupWithTimeout(tb testing.TB, wg *sync.WaitGroup, timeout time.Duration)

Types ¶

type GrpcLogger ¶

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

GrpcLogger use for log raw grpc messages

Usage:

	db, err := ydb.Open(context.Background(), connectionString,
     ...
		ydb.Change(config.WithGrpcOptions(grpc.WithChainUnaryInterceptor(xtest.NewGrpcLogger(t).UnaryClientInterceptor))),
	)

func NewGrpcLogger ¶

func NewGrpcLogger(t testing.TB) GrpcLogger

func (GrpcLogger) StreamClientInterceptor ¶

func (l GrpcLogger) StreamClientInterceptor(
	ctx context.Context,
	desc *grpc.StreamDesc,
	cc *grpc.ClientConn,
	method string,
	streamer grpc.Streamer,
	opts ...grpc.CallOption,
) (grpc.ClientStream, error)

func (GrpcLogger) UnaryClientInterceptor ¶

func (l GrpcLogger) UnaryClientInterceptor(
	ctx context.Context,
	method string,
	req, reply interface{},
	cc *grpc.ClientConn,
	invoker grpc.UnaryInvoker,
	opts ...grpc.CallOption,
) error

type SyncedTest ¶

type SyncedTest struct {
	testing.TB
	// contains filtered or unexported fields
}

func MakeSyncedTest ¶

func MakeSyncedTest(t testing.TB) *SyncedTest

func (*SyncedTest) Cleanup ¶

func (s *SyncedTest) Cleanup(f func())

func (*SyncedTest) Error ¶

func (s *SyncedTest) Error(args ...interface{})

func (*SyncedTest) Errorf ¶

func (s *SyncedTest) Errorf(format string, args ...interface{})

func (*SyncedTest) Fail ¶

func (s *SyncedTest) Fail()

func (*SyncedTest) FailNow ¶

func (s *SyncedTest) FailNow()

func (*SyncedTest) Failed ¶

func (s *SyncedTest) Failed() bool

func (*SyncedTest) Fatal ¶

func (s *SyncedTest) Fatal(args ...interface{})

func (*SyncedTest) Fatalf ¶

func (s *SyncedTest) Fatalf(format string, args ...interface{})

func (*SyncedTest) Log ¶

func (s *SyncedTest) Log(args ...interface{})

func (*SyncedTest) Logf ¶

func (s *SyncedTest) Logf(format string, args ...interface{})

func (*SyncedTest) Name ¶

func (s *SyncedTest) Name() string

func (*SyncedTest) Setenv ¶

func (s *SyncedTest) Setenv(key, value string)

func (*SyncedTest) Skip ¶

func (s *SyncedTest) Skip(args ...interface{})

func (*SyncedTest) SkipNow ¶

func (s *SyncedTest) SkipNow()

func (*SyncedTest) Skipf ¶

func (s *SyncedTest) Skipf(format string, args ...interface{})

func (*SyncedTest) Skipped ¶

func (s *SyncedTest) Skipped() bool

func (*SyncedTest) TempDir ¶

func (s *SyncedTest) TempDir() string

type TestFunc ¶

type TestFunc func(t testing.TB)

type TestManyTimesOption ¶

type TestManyTimesOption func(opts *testManyTimesOptions)

func StopAfter ¶

func StopAfter(stopAfter time.Duration) TestManyTimesOption

Source Files ¶

call_method.go clock.go context.go current_file_line.go grpclogger.go logger.go manytimes.go test_condition.go to_json.go waiters.go ydb_grpc_mocks.go