Functions — github.com/AdRoll/baker

CodeHub MCPcopy Create free account

hub / github.com/AdRoll/baker / functions

Functions846 in github.com/AdRoll/baker

⨍ Functions 846◇ Types & classes 221

MethodLeaseLost

input/kcl.go:363

MethodLeaseRenewed

input/kcl.go:365

Listen Write and Read request via channel

output/websocket/client.go:108

config_test.go:242

MethodMillisBehindLatest

(shard string, ms float64)

input/kcl.go:377

FunctionNewDynamoDB

NewDynamoDB create a new DynamoDB output. TableName is the name of the DynamoDB table to be written. Columns is a slice listing the columns that will

output/dyndb.go:223

NewKCL creates a new KCL.

input/kcl.go:111

FunctionNewKinesis

NewKinesis creates a Kinesis tail, and immediately do a first connection to get the current shard list.

input/kinesis.go:58

FunctionNewLazyFilter

(cfg baker.FilterParams)

examples/filtering/filter.go:23

FunctionNewLogLine

NewLogLine creates a LogLine baker input.

input/inputtest/logline.go:26

FunctionNewLogLineFromMap

NewLogLineFromMap populates an baker.LogLine with the fields in m.

testutil/logline.go:6

(cfg baker.OutputParams)

output/nop.go:20

FunctionNewOpLog

(cfg baker.OutputParams)

output/oplog.go:29

FunctionNewRandom

NewRandom creates a Random baker input.

input/inputtest/random.go:39

FunctionNewRecorder

NewRecorder returns a new Recorder output.

output/outputtest/recorder.go:30

FunctionNewRecords

NewRecords creates a Records baker input.

input/inputtest/records.go:25

FunctionNewSetStringFromURL

(cfg baker.FilterParams)

filter/set_string_from_url.go:41

FunctionNewShardable

(cfg baker.OutputParams)

examples/sharding/output.go:24

FunctionNewStats

NewStats returns a new Stats Baker output.

output/stats.go:246

(cfg baker.InputParams)

input/tcp.go:59

FunctionNewWebSocket

(cfg baker.OutputParams)

output/websocket.go:33

MethodNumProcessedRecords

output/dyndb.go:298

([]byte, Metadata)

config_test.go:220

(l baker.Record, next func(baker.Record))

examples/filtering/filter.go:28

(l baker.Record, next func(baker.Record))

filter/external_match.go:253

(l baker.Record, next func(baker.Record))

filter/filtertest/base.go:9

(l baker.Record, next func(baker.Record))

filter/filtertest/passthrough.go:19

MethodProcessDirectory

(dir string, matchPath *regexp.Regexp)

input/list.go:166

MethodProcessDirectory

ProcessDirectory enqueues all files matching a specific prefix for processing by s3Input. If prefix is actually a s3 url use the bucket there instead

input/inpututils/s3.go:51

MethodProcessRecords

ProcessRecords process data records. vmware kcl will invoke this method to deliver data records. Upon fail over, the new instance will get records wi

input/kcl.go:306

(name string, value int64)

nop_metrics.go:12

RawCount sets the value of a metric of type counter. A counter is a cumulative metrics that can only increase. RawCount sets the current value of the

metrics/datadog/client.go:94

(name string, value int64)

testutil/mock_metrics.go:51

RawCount sets the value of a metric of type counter. A counter is a cumulative metrics that can only increase. RawCount sets the current value of the

examples/metrics/foobar.go:44

MethodRawCountWithTags

(name string, value int64, tags []string)

nop_metrics.go:13

MethodRawCountWithTags

RawCountWithTags sets the value of a metric or type counter and associates that value with a set of tags.

metrics/datadog/client.go:143

MethodRawCountWithTags

(name string, value int64, tags []string)

testutil/mock_metrics.go:69

MethodRawCountWithTags

RawCountWithTags sets the value of a metric or type counter and associates that value with a set of tags.

examples/metrics/foobar.go:48

MethodRecordGetRecordsTime

(shard string, ms float64)

input/kcl.go:381

MethodRecordProcessRecordsTime

(shard string, ms float64)

input/kcl.go:386

Run processes the OutputRecord data coming through a channel. Run must block until in channel has been closed and it has processed all records. It can

Run processes the output result as it comes through the channel. Run must block forever upch will receive filenames that Output wants to see uploaded.

(output chan<- *Data)

topology_test.go:13

(input <-chan baker.OutputRecord, upch chan<- string)

output/sqlite.go:236

(input <-chan baker.OutputRecord, upch chan<- string)

output/nop.go:26

(input <-chan baker.OutputRecord, _ chan<- string)

output/oplog.go:41

(input <-chan baker.OutputRecord, _ chan<- string)

output/dyndb.go:391

Run implements baker.Output

output/stats.go:294

websocket server

output/websocket.go:48

(_ <-chan baker.OutputRecord, _ chan<- string)

output/outputtest/base.go:9

Run implements baker.Output interface.

output/outputtest/recorder.go:35

(upch <-chan string)

upload/s3.go:126

(in <-chan baker.OutputRecord, upch chan<- string)

upload/s3_integration_test.go:36

(_ <-chan string)

upload/uploadtest/base.go:9

(input <-chan baker.OutputRecord, _ chan<- string)

examples/sharding/output.go:35

(inch chan<- *baker.Data)

input/sqs.go:248

(data chan<- *baker.Data)

input/kinesis.go:191

Run implements baker.Input.

input/kcl.go:198

(inch chan<- *baker.Data)

input/tcp.go:73

(output chan<- *baker.Data)

input/inputtest/records.go:35

(_ chan<- *baker.Data)

input/inputtest/base.go:9

(output chan<- *baker.Data)

input/inputtest/random.go:50

(output chan<- *baker.Data)

input/inputtest/channel.go:21

(output chan<- *baker.Data)

input/inputtest/logline.go:36

(i FieldIndex, b []byte)

config_test.go:239

Set assigns the given value to a specific key.

input/kcl.go:360

Stats returns stats about the filter

Stats returns stats about the output.

Stats returns stats about the upload process

stats_test.go:24

stats_test.go:41

stats_test.go:57

stats_test.go:75

topology_test.go:16

output/sqlite.go:400

output/nop.go:34

output/filewriter.go:220

output/oplog.go:51

output/dyndb.go:400

Stats implements baker.Output

output/stats.go:337

output/websocket.go:69

output/outputtest/base.go:11

Stats implements baker.Output interface.

output/outputtest/recorder.go:44

upload/s3.go:218

upload/s3_integration_test.go:33

upload/uploadtest/base.go:11

examples/filtering/filter.go:39

examples/sharding/output.go:46

filter/external_match.go:247

filter/concatenate.go:65

filter/replace_fields.go:111

Stats implements baker.Filter.

filter/timestamp.go:43

filter/set_string_from_url.go:57

filter/expand_json.go:99

filter/hash.go:98

filter/crypt.go:90

filter/url_param.go:71

filter/expand_list.go:108

Stats returns filter statistics.

filter/clear_fields.go:46

← previous next →501–600 of 846, ranked by callers