Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/AdRoll/baker
/ functions
Functions
846 in github.com/AdRoll/baker
⨍
Functions
846
◇
Types & classes
221
Function
BenchmarkFastGzip
(b *testing.B)
input/inpututils/fastgzreader_test.go:136
Function
BenchmarkFilesOutput
(b *testing.B)
output/bench_test.go:14
Function
BenchmarkGzip
(b *testing.B)
input/inpututils/fastgzreader_test.go:113
Function
BenchmarkHotPutNoFlush
(b *testing.B)
pkg/buffercache/bench_test.go:21
Function
BenchmarkLogLineCopy
(b *testing.B)
bench_test.go:227
Function
BenchmarkLogLineParse
(b *testing.B)
bench_test.go:134
Function
BenchmarkLogLineToTextFromParse
(b *testing.B)
bench_test.go:175
Function
BenchmarkLogLineToTextFromParseSet
(b *testing.B)
bench_test.go:197
Function
BenchmarkLogLineToTextFromSet
(b *testing.B)
bench_test.go:158
Function
BenchmarkTopology_NonRaw_NoSharding
(b *testing.B)
bench_test.go:16
Function
BenchmarkTopology_NonRaw_Sharding
(b *testing.B)
bench_test.go:17
Function
BenchmarkTopology_Raw_NoSharding
(b *testing.B)
bench_test.go:18
Function
BenchmarkTopology_Raw_Sharding
(b *testing.B)
bench_test.go:19
Function
BenchmarkUrlCopy
(b *testing.B)
filter/metadata_url_test.go:210
Function
BenchmarkUrlParse
(b *testing.B)
filter/metadata_url_test.go:192
Function
Benchmark_compressor
(b *testing.B)
pkg/buffercache/compressor_test.go:202
Function
Benchmark_decompressor
(b *testing.B)
pkg/buffercache/compressor_test.go:211
Method
BytesWritten
BytesWritten returns the number of bytes written into the underlying writer.
output/filewriter.go:496
Method
Cache
()
config_test.go:245
Method
Cache
Cache holds a cache which is local to the record. It may be used to speed up parsing of specific fields by caching the result. When accessing a field
record.go:71
Method
CanShard
()
output/sqlite.go:406
Method
CanShard
()
output/nop.go:24
Method
CanShard
()
output/filewriter.go:226
Method
CanShard
()
output/oplog.go:57
Method
CanShard
()
output/dyndb.go:416
Method
CanShard
CanShard implements baker.Output
output/stats.go:345
Method
CanShard
()
output/websocket.go:75
Method
CanShard
()
output/outputtest/base.go:10
Method
CanShard
CanShard implements baker.Output interface.
output/outputtest/recorder.go:47
Method
CanShard
()
upload/s3_integration_test.go:34
Method
CanShard
The output supports sharding
examples/sharding/output.go:31
Method
Clear
()
config_test.go:229
Method
Clear
Clear clears all the entries in the cache.
record.go:107
Method
Clear
Clear clears the logline.
logline.go:223
Method
Close
()
nop_metrics.go:20
Method
Close
Close closes the underlying connection with the Datadog client.
metrics/datadog/client.go:75
Method
Close
()
output/filewriter.go:419
Method
Close
()
output/filewriter.go:472
Method
Close
()
pkg/splitwriter/split_writer.go:80
Method
Close
()
testutil/mock_metrics.go:89
Method
Close
Close releases resources allocated by the metrics client such as connections or files and flushes potentially buffered data that has not been processe
examples/metrics/foobar.go:79
Method
Close
()
input/inpututils/fastreader_unix.go:82
Method
Close
()
input/inpututils/compressedstream.go:100
Method
Conn
()
output/websocket/client.go:92
Method
Copy
()
config_test.go:226
Method
CreateProcessor
CreateProcessor implements interfaces.IRecordProcessorFactory.
input/kcl.go:251
Method
DeltaCount
(name string, delta int64)
nop_metrics.go:14
Method
DeltaCount
DeltaCount increments the value of a metric of type counter by delta. delta must be positive.
metrics/datadog/client.go:87
Method
DeltaCount
(name string, delta int64)
testutil/mock_metrics.go:54
Method
DeltaCount
DeltaCount increments the value of a metric of type counter by delta. delta must be positive.
examples/metrics/foobar.go:52
Method
DeltaCountWithTags
(name string, delta int64, tags []string)
nop_metrics.go:15
Method
DeltaCountWithTags
DeltaCountWithTags increments the value of a metric or type counter and associates that value with a set of tags.
metrics/datadog/client.go:137
Method
DeltaCountWithTags
(name string, delta int64, tags []string)
testutil/mock_metrics.go:74
Method
DeltaCountWithTags
DeltaCountWithTags increments the value of a metric or type counter and associates that value with a set of tags.
examples/metrics/foobar.go:56
Method
Duration
(name string, value time.Duration)
nop_metrics.go:18
Method
Duration
Duration adds a duration to a metric of type histogram. A histogram samples observations and counts them in different 'buckets'. Duration is basically
metrics/datadog/client.go:125
Method
Duration
(name string, value time.Duration)
testutil/mock_metrics.go:60
Method
Duration
Duration adds a duration to a metric of type histogram. A histogram samples observations and counts them in different 'buckets'. Duration is basically
examples/metrics/foobar.go:70
Method
DurationWithTags
(name string, value time.Duration, tags []string)
nop_metrics.go:19
Method
DurationWithTags
DurationWithTags adds a duration to an histogram and associates that duration with a set of tags.
metrics/datadog/client.go:163
Method
DurationWithTags
(name string, value time.Duration, tags []string)
testutil/mock_metrics.go:84
Method
DurationWithTags
DurationWithTags adds a duration to an histogram and associates that duration with a set of tags.
examples/metrics/foobar.go:74
Method
Error
()
config.go:575
Method
Fire
(ent *log.Entry)
metrics/datadog/hook.go:41
Method
FreeMem
(data *Data)
topology_test.go:20
Method
FreeMem
(data *baker.Data)
input/sqs.go:319
Method
FreeMem
(data *baker.Data)
input/kinesis.go:217
Method
FreeMem
FreeMem implements baker.Input
input/kcl.go:243
Method
FreeMem
(data *baker.Data)
input/tcp.go:131
Method
FreeMem
(data *baker.Data)
input/list.go:420
Method
FreeMem
(data *baker.Data)
input/inputtest/records.go:50
Method
FreeMem
(*baker.Data)
input/inputtest/base.go:11
Method
FreeMem
(data *baker.Data)
input/inputtest/random.go:82
Method
FreeMem
(data *baker.Data)
input/inputtest/channel.go:32
Method
FreeMem
(data *baker.Data)
input/inputtest/logline.go:51
Method
FreeMem
(data *baker.Data)
input/inpututils/compressedstream.go:371
Method
Gauge
(name string, value float64)
nop_metrics.go:10
Method
Gauge
Gauge sets the value of a metric of type gauge. A Gauge represents a single numerical data point that can arbitrarily go up and down.
metrics/datadog/client.go:81
Method
Gauge
(name string, value float64)
testutil/mock_metrics.go:48
Method
Gauge
Gauge sets the value of a metric of type gauge. A Gauge represents a single numerical data point that can arbitrarily go up and down.
examples/metrics/foobar.go:35
Method
GaugeWithTags
(name string, value float64, tags []string)
nop_metrics.go:11
Method
GaugeWithTags
GaugeWithTags sets the value of a metric of type gauge and associates that value with a set of tags.
metrics/datadog/client.go:131
Method
GaugeWithTags
(name string, value float64, tags []string)
testutil/mock_metrics.go:64
Method
GaugeWithTags
GaugeWithTags sets the value of a metric of type gauge and associates that value with a set of tags.
examples/metrics/foobar.go:39
Method
Get
(i FieldIndex)
config_test.go:232
Method
Get
Get fetches the value with the given key. If the key is not present in the cache Get returns (nil, false).
record.go:79
Method
Get
(region string)
output/dyndb.go:51
Method
Histogram
(name string, value float64)
nop_metrics.go:16
Method
Histogram
Histogram adds a sample to a metric of type histogram. A histogram samples observations and counts them in different 'buckets' in order to track and s
metrics/datadog/client.go:114
Method
Histogram
(name string, value float64)
testutil/mock_metrics.go:57
Method
Histogram
Histogram adds a sample to a metric of type histogram. A histogram samples observations and counts them in different 'buckets' in order to track and s
examples/metrics/foobar.go:61
Method
HistogramWithTags
(name string, value float64, tags []string)
nop_metrics.go:17
Method
HistogramWithTags
HistogramWithTags adds a sample to an histogram and associates that sample with a set of tags.
metrics/datadog/client.go:157
Method
HistogramWithTags
(name string, value float64, tags []string)
testutil/mock_metrics.go:79
Method
HistogramWithTags
HistogramWithTags adds a sample to an histogram and associates that sample with a set of tags.
examples/metrics/foobar.go:65
Method
IncrBytesProcessed
(shard string, count int64)
input/kcl.go:373
Method
IncrRecordsProcessed
(shard string, count int)
input/kcl.go:369
Method
Init
(appname, streamname, workerID string)
input/kcl.go:358
Method
Initialize
Initialize is invoked by the Amazon Kinesis Client Library before data records are delivered to the RecordProcessor instance (via processRecords).
input/kcl.go:289
Method
LeaseGained
(shard string)
input/kcl.go:362
← previous
next →
401–500 of 846, ranked by callers