MCPcopy Create free account

hub / github.com/AdRoll/baker / functions

Functions846 in github.com/AdRoll/baker

⨍ Functions 846◇ Types & classes 221
↓ 1 callersFunctiondisplayProgramUsage
(components Components)
baker_cli.go:131
↓ 1 callersFunctiondoFirstSplit
doFirstSplit creates the first splits of f, at offset off. That is, from 'file' it creates both 'file.part-1' and 'file.part-2' and then removes 'file
pkg/splitwriter/split_writer.go:225
↓ 1 callersFunctiondoNextSplit
doNextSplit splits f at offset off, transfering the data to the next split. It returns the next split.
pkg/splitwriter/split_writer.go:189
↓ 1 callersMethoddoRequest
(inp *dynamodb.BatchWriteItemInput)
output/dyndb.go:111
↓ 1 callersMethoddoRun
(input <-chan baker.OutputRecord)
output/sqlite.go:334
↓ 1 callersFunctiondoSplit
(f *os.File, off int64)
pkg/splitwriter/split_writer.go:172
↓ 1 callersMethoderr
(err error)
output/websocket/server.go:55
↓ 1 callersFunctionexpectSplits
(t *testing.T, dir string, splits map[string]int)
pkg/splitwriter/split_writer_test.go:14
↓ 1 callersFunctionfileExists
fileExists reports whether fname exists and is a regular file.
pkg/splitwriter/split_writer.go:311
↓ 1 callersMethodfillDefault
()
filter/expand_list.go:49
↓ 1 callersMethodfillDefaults
()
config.go:162
↓ 1 callersMethodfillDefaults
()
output/filewriter.go:102
↓ 1 callersMethodfillDefaults
()
output/oplog.go:20
↓ 1 callersMethodfillDefaults
()
output/dyndb.go:178
↓ 1 callersMethodfillDefaults
()
output/stats.go:35
↓ 1 callersMethodfillDefaults
()
output/websocket.go:22
↓ 1 callersMethodfillDefaults
()
upload/s3.go:54
↓ 1 callersMethodfillDefaults
()
filter/external_match.go:55
↓ 1 callersMethodfillDefaults
()
filter/expand_json.go:46
↓ 1 callersMethodfillDefaults
()
filter/format_time.go:69
↓ 1 callersMethodfillDefaults
()
input/sqs.go:53
↓ 1 callersMethodfillDefaults
()
input/kinesis.go:34
↓ 1 callersMethodfillDefaults
()
input/kcl.go:63
↓ 1 callersMethodfillDefaults
()
input/tcp.go:44
↓ 1 callersMethodfillDefaults
()
input/list.go:64
↓ 1 callersMethodfillDefaults
()
input/inputtest/random.go:26
↓ 1 callersMethodfindSplitPoint
findSplitPoint searches for a suitable split point in f, which is the offset of the last line feed which is prior to the split size. A split offset of
pkg/splitwriter/split_writer.go:133
↓ 1 callersMethodflushCold
()
pkg/buffercache/cache.go:241
↓ 1 callersFunctiongenFilterMarkdown
(w io.Writer, doc filterDoc)
help_markdown.go:96
↓ 1 callersFunctiongenFilterText
(w io.Writer, doc filterDoc)
help_text.go:84
↓ 1 callersFunctiongenFormatFun
(format string)
filter/format_time.go:190
↓ 1 callersFunctiongenInputMarkdown
(w io.Writer, doc inputDoc)
help_markdown.go:81
↓ 1 callersFunctiongenInputText
(w io.Writer, doc inputDoc)
help_text.go:67
↓ 1 callersFunctiongenMetricsMarkdown
(w io.Writer, doc metricsDoc)
help_markdown.go:153
↓ 1 callersFunctiongenMetricsText
(w io.Writer, doc metricsDoc)
help_text.go:146
↓ 1 callersFunctiongenOutputMarkdown
(w io.Writer, doc outputDoc)
help_markdown.go:111
↓ 1 callersFunctiongenOutputText
(w io.Writer, doc outputDoc)
help_text.go:101
↓ 1 callersFunctiongenParseFun
(format string)
filter/format_time.go:152
↓ 1 callersFunctiongenUploadMarkdown
(w io.Writer, doc uploadDoc)
help_markdown.go:138
↓ 1 callersFunctiongenUploadText
(w io.Writer, doc uploadDoc)
help_text.go:129
↓ 1 callersFunctiongenerateWorkerID
generateWorkerID generates an unique ID for currrent worker, based off hostname and an UUID.
input/kcl.go:98
↓ 1 callersMethodget
(key string)
api.go:14
↓ 1 callersFunctiongetFieldIdInReturn
(name string, cfg Conf)
output/websocket/client.go:34
↓ 1 callersMethodgrow
()
pkg/buffercache/compressor.go:102
↓ 1 callersMethodhandleStream
(conn *net.TCPConn)
input/tcp.go:146
↓ 1 callersMethodincr
()
upload/s3.go:231
↓ 1 callersMethodisMatchAny
(l baker.Record)
filter/string_match.go:63
↓ 1 callersFunctionisPrintable
isPrintable reports whether a string contains only printable runes.
output/sqlite.go:203
↓ 1 callersFunctionlevelToAlertType
(level log.Level)
metrics/datadog/hook.go:65
↓ 1 callersMethodlistenRead
Listen read request via chanel
output/websocket/client.go:142
↓ 1 callersMethodlistenWrite
Listen write request via chanel
output/websocket/client.go:114
↓ 1 callersMethodmatch
(l baker.Record)
filter/regex_match.go:70
↓ 1 callersMethodmatchClause
(l baker.Record, clause *Clause)
filter/clausefilter.go:251
↓ 1 callersMethodmaybeTruncate
maybeTruncate truncates the table (if configured to do so)
output/sqlite.go:288
↓ 1 callersFunctionnewClient
Create new ws client.
output/websocket/client.go:45
↓ 1 callersFunctionnewCountingWriter
newCountingWriter function create new countingWriter
output/filewriter.go:485
↓ 1 callersFunctionnewDynamoProcess
(db *dynamodb.DynamoDB, region string, maxbackoff time.Duration)
output/dyndb.go:99
↓ 1 callersFunctionnewFastReader
(command []string, r io.Reader)
input/inpututils/fastreader_unix.go:37
↓ 1 callersFunctionnewHTTPFileServer
(tb testing.TB, files httpServerFiles)
input/list_test.go:502
↓ 1 callersFunctionnewHelpConfigKeyFromField
(f reflect.StructField)
help_config.go:146
↓ 1 callersFunctionnewInputStats
()
input/inpututils/compressedstream.go:116
↓ 1 callersFunctionnewMockedS3FromFS
(fs fs.FS)
input/sqs_test.go:532
↓ 1 callersFunctionnewWorker
(cfg *FileWriterConfig, tmpl *template.Template, replFieldValue string, index int, uid string, upch chan<- str
output/filewriter.go:246
↓ 1 callersMethodnumBuffers
numBuffers returns the number of buffers (i.e occupied cells) actually present in the bucket.
pkg/buffercache/cold.go:149
↓ 1 callersFunctionopenSplit
openSplit opens or creates the last split corresponding to fname and returns it. The last split can be fname itself.
pkg/splitwriter/split_writer.go:59
↓ 1 callersMethodparseClauseSexp
(node *sexp.Node)
filter/clausefilter.go:143
↓ 1 callersMethodparseConf
(map[string]string)
filter/crypt.go:42
↓ 1 callersMethodpollQueue
pollQueue polls the given queue as long as the given context is alive.
input/sqs.go:192
↓ 1 callersMethodpostProcessJSON
(r interface{})
filter/expand_json.go:130
↓ 1 callersMethodprepInsertStatement
prepInsertStatement prepares and returns the statement inserting records.
output/sqlite.go:258
↓ 1 callersMethodprocessJSON
(data []byte)
filter/expand_json.go:117
↓ 1 callersMethodprocessList
(fn string)
input/list.go:262
↓ 1 callersMethodprocessURL
(u string)
filter/external_match.go:175
↓ 1 callersMethodpush
Push a new record into DynamoDB. The record is first cached internally, then when the batch limit (25) is reached, it is actually written to DyanmoDB.
output/dyndb.go:307
↓ 1 callersMethodrefreshShards
()
input/kinesis.go:81
↓ 1 callersMethodremoveCold
removeCold removes all locations pointing to the given cold cache bucket.
pkg/buffercache/location.go:50
↓ 1 callersMethodremoveHot
removeHot removes all locations pointing to the hot cache.
pkg/buffercache/location.go:63
↓ 1 callersFunctionrenderSQLitePathString
(pathString string, shardID int, field string)
output/sqlite.go:85
↓ 1 callersMethodreset
()
pkg/buffercache/location.go:45
↓ 1 callersMethodrun
()
output/dyndb.go:148
↓ 1 callersFunctions3UploadFile
(uploader *s3manager.Uploader, bucket, prefix, localPath, fpath string)
upload/s3.go:289
↓ 1 callersMethodsendAll
(msg []string)
output/websocket/server.go:59
↓ 1 callersMethodsetDBSettings
(conn *sql.DB)
output/sqlite.go:271
↓ 1 callersMethodsetOutputChannel
(data chan<- *baker.Data)
input/tcp.go:120
↓ 1 callersMethodsetTimes
(start, end string)
filter/timestamp_range.go:56
↓ 1 callersMethodsetup
()
output/sqlite.go:163
↓ 1 callersMethodsetupTable
setupTable either creates the table or, in case it already exists and the config has Clear=true, we truncate the table.
output/sqlite.go:306
↓ 1 callersMethodshouldSend
(msg []string)
output/websocket/client.go:74
↓ 1 callersMethodsmallestFitBucket
smallestFitBucket returns the smallest bucket in which fits a buffer of length l or -1 if all buckets are too small.
pkg/buffercache/cold.go:48
↓ 1 callersFunctionsqsParseFunction
(cfg *SQSConfig)
input/sqs.go:145
↓ 1 callersFunctionterminalWidth
()
term.go:10
↓ 1 callersFunctiontestFileWriterCompareInOut
testFileWriterCompareInOut sends numRecords records and wait for the given duration between each send, to a FileWriter where PathString is set to the
output/filewriter_test.go:101
↓ 1 callersFunctiontestIntegrationSQS
(tc sqsIntegrationTestCase)
input/sqs_test.go:355
↓ 1 callersFunctionvaluesFromCSV
valuesFromCSV reads the CSV-formatted reader r and returns the set of values in the 0-based column index.. Note: rows not having enough columns to ex
filter/external_match.go:153
↓ 1 callersMethodvetIdentifiers
vetIdentifiers checks all identifiers respect some rule so that we can use them safely in queries.
output/sqlite.go:217
↓ 1 callersMethodworker
()
input/inpututils/compressedstream.go:188
↓ 1 callersFunctionwrapString
wrapString wraps the given string within lim width in characters. Source: https://github.com/mitchellh/go-wordwrap Wrapping is currently naive and on
help_text.go:191
↓ 1 callersMethodwrite
(req []byte)
output/filewriter.go:415
FunctionBenchmarkColdPutNoFlush
(b *testing.B)
pkg/buffercache/bench_test.go:61
FunctionBenchmarkExpandJSON
(b *testing.B)
filter/expand_json_test.go:198
← previousnext →301–400 of 846, ranked by callers