a bitmap is a bit array where bits correspond to cells, 0 indicates a free cell and 1 t a busy one.

FieldIndex is the index uniquely representing of a field in a Record.

errUnsupportedURLScheme is the error indicating a path has an invalid or unsupported URL scheme for the S3Input.

A location represents the location of an entry in the cache. It can either point to an entry in the hot or in the cold cache. The MSB indicates wheth

Base is a nop implementation of baker.Output useful to be embedded in tests and to redeclare one or more methods.

Base is a nop implementation of baker.Upload useful to be embedded in tests and to redeclare one or more methods.

Base is a nop implementation of baker.Filter useful to be embedded in tests and to redeclare one or more methods.

Base is a nop implementation of baker.Input useful to be embedded in tests and to redeclare one or more methods.

A BufferCache is like a map[string][]byte that is optimized for appending new bytes to the cache values.

Cache is a concurrent size-limited cache. If the cache size reaches maxCacheEntries all existing entries are removed. maxCacheEntries should effectiv

Cache is a per-record cache.

A Channel input is a Baker input used for testing. It's a channel tests can use to send record blobs (baker.Data)

Will real sum types ever make it to go? Validness of the fields in this structure depend on clauseType

ClauseFilterConfig describes the ClauseFilter filter config

ClearFields filter clears (i.e set to the empty string) a set of fields.

ClearFieldsConfig holds config parameters of the ClearFields filter.

Client allows to instrument code and export the metrics to a dogstatds client.

ComponentParams holds the common configuration parameters passed to components of all kinds.

Components holds the descriptions of all components one can use to build a topology.

CompressedInput is a base for creating input components that processes multiple gzip or zstd-compressed logs coming from arbitrary sources. This clas

Conf holds required configurations that are passed to NewServer to configure the Server

A Config specifies the configuration for a topology.

Config is the configuration of the Datadog metrics client.

Config configures a BufferCache.

ConfigCSV defines configuration for CSV records

ConfigFields specifies names for records fields. In addition of being a list of names, the position of each name in the slice also indicates the Field

ConfigFilter specifies the configuration for a single filter component.

ConfigFilterChain specifies the configuration for the whole fitler chain.

A ConfigGeneral specifies general configuration for the whole topology.

The configuration for the topology is parsed from TOML format. Each of Input, Filter, Output have a separate section (table) in the file containing a

ConfigMetrics holds metrics configuration.

ConfigOutput specifies the configuration for the output component.

ConfigUpload specifies the configuration for the upload component.

A ConfigUser defines a user-specific configuration entry.

ConfigValidation specifies regular expressions for field names, used to generate the Record validation function.

Data represents raw data consumed by a baker input, possibly containing multiple records before they're parsed.

DynamoDB is a class to do optimized batched writes to a single DynamoDB table with a fixed schema (same number of columns for all records).

ErrorRequiredField describes the absence of a required field in a component configuration.

Filter represents a data filter; a filter is a function that processes records. A filter can discard, transform, forward and even create records.

FilterDesc describes a Filter component to the topology.

FilterParams holds the parameters passed to Filter constructor.

FilterStats contains statistics about the filter components, ready for export to the metric client and to print debug info

HelpFormat represents the possible formats for baker help.

Input is an interface representing an object that produces (fetches) datas for the filter.

InputDesc describes an Input component to the topology.

InputParams holds the parameters passed to Input constructor.

InputStats contains statistics about the input component, ready for export to the metric client and to print debug info.

KCL is a Baker input reading from Kinesis with the KCL (Kinesis Client Library).

KCLConfig is the configuration for the KCL input.

for tests

LogLine represents a CSV text line using ASCII 30 as field separator. It implement Record.. In memory, it is kept in a format optimized for very fast

A LogLine input is a Baker input used for testing.

LogLineConfig holds the log lines to be fed to the Baker topology.

Metadata about the input data; each Input will directly populate this map as appropriate. Consumers (filters) will access via Get()

Metrics holds a snapshot of the performance counters of a BufferCache instance.

A MetricsBag is collection of metrics, those metrics are reported by every Baker components, through their Stats method. Stats() is called once per se

A MetricsClient allows to instrument components code and communicate the metrics to the metrics backend that is configured in Baker. New metrics back

MetricsDesc describes a Metrics interface to the topology.

MockMetrics is a metrics client to be used in tests only, which stores single calls made to the set of methods implementing the baker.MetricsClient in

NopMetrics implements a metrics.Client that does nothing.

NotNull is a baker filter that discards records having null fields.

NotNullConfig holds configuration parameters for the NotNull filter.