Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + func CheckSkip(t testing.TB) + func CheckSkipExact(t testing.TB) + func GetFreePort() (int, error) + type CachePreTestFn func(t testing.TB, ctx context.Context, testID string, vars *CacheTestConfigVars) + type CacheTestConfigVars struct + ID string + Port string + Var1 string + Var2 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 + func CacheTestOptVarTwo(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 StreamTestStreamSaturatedUnacked(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) + 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 Other modules containing this package github.com/dafanshu/benthos/v3
Go to main page