xtest

package
v3.95.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllowByFlag added in v3.37.8 

func AllowByFlag(t testing.TB, flag string)

func CallMethod added in v3.57.4 

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

func Context added in v3.38.0 

func Context(t testing.TB) context.Context

func ContextWithCommonTimeout added in v3.44.0 

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

func CurrentFileLine added in v3.54.0 

func CurrentFileLine() string

func FastClock added in v3.67.1 

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 added in v3.56.0 

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

func Must added in v3.77.0 

func Must[R any](res R, err error) R

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 added in v3.33.0 

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 added in v3.44.0 

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

SpinWaitProgress failed if result of progress func no changes without timeout

func SpinWaitProgressWithTimeout added in v3.44.0 

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 added in v3.60.0 

func ToJSON(v interface{}) string

func WaitChannelClosed 

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

func WaitChannelClosedWithTimeout added in v3.42.6 

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

func WaitGroup added in v3.42.6 

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

func WaitGroupWithTimeout added in v3.42.6 

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

Types

type GrpcLogger added in v3.37.4 

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 added in v3.37.4 

func NewGrpcLogger(t testing.TB) GrpcLogger

func (GrpcLogger) StreamClientInterceptor added in v3.37.4 

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 added in v3.37.4 

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

type SyncedTest added in v3.38.0 

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

func MakeSyncedTest added in v3.38.0 

func MakeSyncedTest(t *testing.T) *SyncedTest

func (*SyncedTest) Cleanup added in v3.38.0 

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

func (*SyncedTest) Error added in v3.38.0 

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

func (*SyncedTest) Errorf added in v3.38.0 

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

func (*SyncedTest) Fail added in v3.38.0 

func (s *SyncedTest) Fail()

func (*SyncedTest) FailNow added in v3.38.0 

func (s *SyncedTest) FailNow()

func (*SyncedTest) Failed added in v3.38.0 

func (s *SyncedTest) Failed() bool

func (*SyncedTest) Fatal added in v3.38.0 

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

func (*SyncedTest) Fatalf added in v3.38.0 

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

func (*SyncedTest) Log added in v3.38.0 

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

func (*SyncedTest) Logf added in v3.38.0 

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

func (*SyncedTest) Name added in v3.38.0 

func (s *SyncedTest) Name() string

func (*SyncedTest) Run added in v3.74.4 

func (s *SyncedTest) Run(name string, f func(t *testing.T)) bool

func (*SyncedTest) RunSynced added in v3.74.4 

func (s *SyncedTest) RunSynced(name string, f func(t *SyncedTest)) bool

func (*SyncedTest) Setenv added in v3.38.0 

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

func (*SyncedTest) Skip added in v3.38.0 

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

func (*SyncedTest) SkipNow added in v3.38.0 

func (s *SyncedTest) SkipNow()

func (*SyncedTest) Skipf added in v3.38.0 

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

func (*SyncedTest) Skipped added in v3.38.0 

func (s *SyncedTest) Skipped() bool

func (*SyncedTest) TempDir added in v3.38.0 

func (s *SyncedTest) TempDir() string

type TestFunc 

type TestFunc func(t testing.TB)

type TestManyTimesOption added in v3.32.0 

type TestManyTimesOption func(opts *testManyTimesOptions)

func StopAfter added in v3.33.0 

func StopAfter(stopAfter time.Duration) TestManyTimesOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.