integration

package

Go to main page

Versions in this module

v3

v3.65.0

Mar 7, 2022

v3.64.0

Feb 23, 2022

v3.63.0

Feb 8, 2022

v3.62.0

Jan 21, 2022

Changes in this version

type StreamTestDefinition

+ func StreamTestStreamSaturatedUnacked(n int) StreamTestDefinition

v3.61.0

Dec 28, 2021

Changes in this version

+ func GetFreePort() (int, error)

v3.60.1

Dec 3, 2021

v3.60.0

Dec 1, 2021

v3.59.0

Nov 22, 2021

Changes in this version

+ func CheckSkip(t *testing.T)

+ type CachePreTestFn func(t testing.TB, ctx context.Context, testID string, vars *CacheTestConfigVars)

+ type CacheTestConfigVars struct

+ ID string

+ Port string

+ Var1 string

+ type CacheTestDefinition struct

+ func CacheTestDelete() CacheTestDefinition

+ func CacheTestDoubleAdd() CacheTestDefinition

+ func CacheTestGetAndSet(n int) CacheTestDefinition

+ func CacheTestMissingKey() CacheTestDefinition

+ func CacheTestOpenClose() CacheTestDefinition

+ type CacheTestList []CacheTestDefinition

+ func CacheTests(tests ...CacheTestDefinition) CacheTestList

+ func (i CacheTestList) Run(t *testing.T, configTemplate string, opts ...CacheTestOptFunc)

+ type CacheTestOptFunc func(*cacheTestEnvironment)

+ func CacheTestOptLogging(level string) CacheTestOptFunc

+ func CacheTestOptPort(port string) CacheTestOptFunc

+ func CacheTestOptPreTest(fn CachePreTestFn) CacheTestOptFunc

+ func CacheTestOptTimeout(timeout time.Duration) CacheTestOptFunc

+ func CacheTestOptVarOne(v string) CacheTestOptFunc

+ type GetMessageFunc func(ctx context.Context, testID, messageID string) (string, []string, error)

+ type StreamBenchDefinition struct

+ func StreamBenchSend(batchSize, parallelism int) StreamBenchDefinition

+ func StreamBenchWrite(batchSize int) StreamBenchDefinition

+ type StreamBenchList []StreamBenchDefinition

+ func StreamBenchs(tests ...StreamBenchDefinition) StreamBenchList

+ func (i StreamBenchList) Run(b *testing.B, configTemplate string, opts ...StreamTestOptFunc)

+ type StreamPreTestFn func(t testing.TB, ctx context.Context, testID string, vars *StreamTestConfigVars)

+ type StreamTestConfigVars struct

+ ID string

+ InputBatchCount int

+ MaxInFlight int

+ OutputBatchCount int

+ OutputMetaExcludePrefix string

+ Var1 string

+ Var2 string

+ Var3 string

+ Var4 string

+ type StreamTestDefinition struct

+ func StreamTestAtLeastOnceDelivery() StreamTestDefinition

+ func StreamTestCheckpointCapture() StreamTestDefinition

+ func StreamTestMetadata() StreamTestDefinition

+ func StreamTestMetadataFilter() StreamTestDefinition

+ func StreamTestOpenClose() StreamTestDefinition

+ func StreamTestOpenCloseIsolated() StreamTestDefinition

+ func StreamTestOutputOnlyOverride(getFn GetMessageFunc) StreamTestDefinition

+ func StreamTestOutputOnlySendBatch(n int, getFn GetMessageFunc) StreamTestDefinition

+ func StreamTestOutputOnlySendSequential(n int, getFn GetMessageFunc) StreamTestDefinition

+ func StreamTestReceiveBatchCount(n int) StreamTestDefinition

+ func StreamTestSendBatch(n int) StreamTestDefinition

+ func StreamTestSendBatchCount(n int) StreamTestDefinition

+ func StreamTestSendBatchCountIsolated(n int) StreamTestDefinition

+ func StreamTestSendBatches(batchSize, batches, parallelism int) StreamTestDefinition

+ func StreamTestStreamIsolated(n int) StreamTestDefinition

+ func StreamTestStreamParallel(n int) StreamTestDefinition

+ func StreamTestStreamParallelLossy(n int) StreamTestDefinition

+ func StreamTestStreamParallelLossyThroughReconnect(n int) StreamTestDefinition

+ func StreamTestStreamSequential(n int) StreamTestDefinition

+ type StreamTestList []StreamTestDefinition

+ func StreamTests(tests ...StreamTestDefinition) StreamTestList

+ func (i StreamTestList) Run(t *testing.T, configTemplate string, opts ...StreamTestOptFunc)

+ func (i StreamTestList) RunSequentially(t *testing.T, configTemplate string, opts ...StreamTestOptFunc)

+ type StreamTestOptFunc func(*streamTestEnvironment)

+ func StreamTestOptAllowDupes() StreamTestOptFunc

+ func StreamTestOptLogging(level string) StreamTestOptFunc

+ func StreamTestOptMaxInFlight(n int) StreamTestOptFunc

+ func StreamTestOptPort(port string) StreamTestOptFunc

+ func StreamTestOptPortTwo(portTwo string) StreamTestOptFunc

+ func StreamTestOptPreTest(fn StreamPreTestFn) StreamTestOptFunc

+ func StreamTestOptSleepAfterInput(t time.Duration) StreamTestOptFunc

+ func StreamTestOptSleepAfterOutput(t time.Duration) StreamTestOptFunc

+ func StreamTestOptTimeout(timeout time.Duration) StreamTestOptFunc

+ func StreamTestOptVarOne(v string) StreamTestOptFunc

+ func StreamTestOptVarThree(v string) StreamTestOptFunc

+ func StreamTestOptVarTwo(v string) StreamTestOptFunc

v3.59.0-rc2

Nov 17, 2021

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