MCPcopy Create free account

hub / github.com/AdRoll/baker / functions

Functions846 in github.com/AdRoll/baker

⨍ Functions 846◇ Types & classes 221
MethodStats
()
filter/url_escape.go:70
MethodStats
Stats returns filter statistics.
filter/regex_match.go:64
MethodStats
()
filter/partial_clone.go:47
MethodStats
Stats implements baker.Filter.
filter/timestamp_range.go:83
MethodStats
()
filter/count_and_tag.go:66
MethodStats
()
filter/metadata_lastmodified.go:42
MethodStats
Stats returns filter statistics.
filter/string_match.go:57
MethodStats
()
filter/dedup.go:75
MethodStats
()
filter/metadata_url.go:53
MethodStats
Stats implements baker.Filter.
filter/slice.go:85
MethodStats
()
filter/format_time.go:109
MethodStats
Stats implements baker.Filter.
filter/notnull.go:46
MethodStats
()
filter/clausefilter.go:137
MethodStats
()
filter/filtertest/base.go:10
MethodStats
()
filter/filtertest/passthrough.go:18
MethodStats
()
input/sqs.go:315
MethodStats
()
input/kinesis.go:211
MethodStats
Stats implements baker.Input
input/kcl.go:232
MethodStats
()
input/tcp.go:136
MethodStats
()
input/list.go:424
MethodStats
()
input/inputtest/records.go:51
MethodStats
()
input/inputtest/base.go:12
MethodStats
()
input/inputtest/random.go:83
MethodStats
()
input/inputtest/channel.go:33
MethodStats
()
input/inputtest/logline.go:52
MethodStats
()
input/inpututils/compressedstream.go:131
MethodStats
()
input/inpututils/compressedstream.go:376
MethodStop
Stop forces the upload to stop as cleanly as possible, which usually means to finish up all the existing downloads.
api.go:155
MethodStop
()
topology_test.go:19
MethodStop
()
upload/uploadtest/base.go:10
MethodStop
()
input/sqs.go:309
MethodStop
()
input/kinesis.go:187
MethodStop
Stop implements baker.Input
input/kcl.go:193
MethodStop
()
input/tcp.go:142
MethodStop
()
input/list.go:428
MethodStop
()
input/inputtest/records.go:49
MethodStop
()
input/inputtest/base.go:10
MethodStop
()
input/inputtest/random.go:81
MethodStop
()
input/inputtest/channel.go:31
MethodStop
()
input/inputtest/logline.go:50
MethodStop
()
input/inpututils/compressedstream.go:242
MethodString
()
pkg/buffercache/location.go:31
FunctionTestAllFiltersHaveConfigHelp
(t *testing.T)
help_test.go:42
FunctionTestAllInputsHaveConfigHelp
(t *testing.T)
help_test.go:36
FunctionTestAllOutputsHaveConfigHelp
(t *testing.T)
help_test.go:48
FunctionTestAllUploadsHaveConfigHelp
(t *testing.T)
help_test.go:54
FunctionTestBitMap_leadingZeros
(t *testing.T)
pkg/buffercache/bitmap_test.go:38
FunctionTestBufferCacheAutoFlushCold
(t *testing.T)
pkg/buffercache/cache_test.go:163
FunctionTestBufferCacheFlushAutoHotOnMaxBufferLength
(t *testing.T)
pkg/buffercache/cache_test.go:270
FunctionTestBufferCacheFlushAutoHotOnMaxCapacity
(t *testing.T)
pkg/buffercache/cache_test.go:297
FunctionTestBufferCacheMoveToHotCache
(t *testing.T)
pkg/buffercache/cache_test.go:241
FunctionTestBufferCachePutDestination
(t *testing.T)
pkg/buffercache/cold_test.go:49
FunctionTestBufferCache_PutAndFlush
(t *testing.T)
pkg/buffercache/cache_test.go:109
FunctionTestBufferCache_PutAndFlushCompressed
(t *testing.T)
pkg/buffercache/cache_test.go:55
FunctionTestBufferCache_size
(t *testing.T)
pkg/buffercache/cache_test.go:205
FunctionTestCache
(t *testing.T)
filter/metadata/cache_test.go:8
FunctionTestCheckRequiredFields
(t *testing.T)
config_api_test.go:62
FunctionTestClauseParser
(t *testing.T)
filter/clausefilter_test.go:20
FunctionTestClausesMatchCorrectly
(t *testing.T)
filter/clausefilter_test.go:32
FunctionTestClearFieldsFilter
(t *testing.T)
filter/clear_fields_test.go:10
FunctionTestClientMetrics
(t *testing.T)
metrics/datadog/client_test.go:19
FunctionTestCloseFiles
(t *testing.T)
pkg/splitwriter/split_writer_test.go:331
FunctionTestColdCacheFlushAuto
(t *testing.T)
pkg/buffercache/cold_test.go:125
FunctionTestColdCacheGet
(t *testing.T)
pkg/buffercache/cold_test.go:12
FunctionTestColdCacheGet_BadCell
(t *testing.T)
pkg/buffercache/cold_test.go:41
FunctionTestColdCacheMetrics
(t *testing.T)
pkg/buffercache/cold_test.go:175
FunctionTestColdCacheSortedBuckets
(t *testing.T)
pkg/buffercache/cold_test.go:160
FunctionTestCompDescEmptyConfig
(t *testing.T)
desc_test.go:25
FunctionTestConcatenateFilter
(t *testing.T)
filter/concatenate_test.go:10
FunctionTestCountAndTag
(t *testing.T)
filter/count_and_tag_test.go:11
FunctionTestCrypt
(t *testing.T)
filter/crypt_test.go:10
FunctionTestDedup
(t *testing.T)
filter/dedup_test.go:9
FunctionTestE2EFullTopology
(t *testing.T)
e2e_test.go:20
FunctionTestEnvVarBaseReplace
(t *testing.T)
config_test.go:69
FunctionTestExampleHelp
(t *testing.T)
e2e_test.go:11
FunctionTestExpandJSON
(t *testing.T)
filter/expand_json_test.go:10
FunctionTestExpandList
(t *testing.T)
filter/expand_list_test.go:9
FunctionTestExternalMatchConfigFillDefaults
(t *testing.T)
filter/external_match_test.go:13
FunctionTestExternalMatchConfig_evaluateURLs
(t *testing.T)
filter/external_match_test.go:120
FunctionTestExternalMatchDiscardOnMatch
(t *testing.T)
filter/external_match_test.go:245
FunctionTestExternalMatchKeepOnMatch
(t *testing.T)
filter/external_match_test.go:253
FunctionTestExternalMatchRefreshValues
(t *testing.T)
filter/external_match_test.go:262
FunctionTestFileWriterCompareInOut
(t *testing.T)
output/filewriter_test.go:216
FunctionTestFileWriterConfig
(t *testing.T)
output/filewriter_test.go:29
FunctionTestFileWriterDiscardEmptyFiles
(t *testing.T)
output/filewriter_test.go:652
FunctionTestFileWriterIntegrationFastRotation
(t *testing.T)
output/filewriter_test.go:453
FunctionTestFileWriterIntegrationField0
(t *testing.T)
output/filewriter_test.go:424
FunctionTestFileWriterIntegrationIndex
(t *testing.T)
output/filewriter_test.go:428
FunctionTestFileWriterIntegrationProcs
(t *testing.T)
output/filewriter_test.go:441
FunctionTestFileWriterIntegrationProcsFields0
(t *testing.T)
output/filewriter_test.go:447
FunctionTestFileWriterIntegrationRotationIndex
(t *testing.T)
output/filewriter_test.go:432
FunctionTestFileWriterIntegrationTimestamp
(t *testing.T)
output/filewriter_test.go:436
FunctionTestFileWriterIntegrationUUID
(t *testing.T)
output/filewriter_test.go:459
FunctionTestFileWriterRotateSize
(t *testing.T)
output/filewriter_test.go:559
FunctionTestFillCreateRecordDefault
(t *testing.T)
config_test.go:9
FunctionTestFlushUncompressedBlocks
(t *testing.T)
pkg/buffercache/cache_test.go:525
FunctionTestFormatTime
(t *testing.T)
filter/format_time_test.go:11
FunctionTestFormatTimeErrors
(t *testing.T)
filter/format_time_test.go:158
FunctionTestGenerateHelp
(t *testing.T)
help_config_test.go:96
FunctionTestGzReadErrorEmpty
(t *testing.T)
input/inpututils/fastgzreader_test.go:59
← previousnext →601–700 of 846, ranked by callers