MCPcopy Create free account
hub / github.com/AdRoll/baker / Process

Method Process

api.go:96–96  ·  view source on GitHub ↗

Process processes a single Record, and then optionally sends it to next filter in the chain. Process might mutate the Record, adding/modifying/removing fields, and might decide to throw it away, or pass it to next filter in chain by calling the next() function. In some cases, a filter might generate

(l Record, next func(Record))

Source from the content-addressed store, hash-verified

94 // it points to a function that wraps up the filtering chain and sends
95 // the Record to the output.
96 Process(l Record, next func(Record))
97
98 // Stats returns stats about the filter
99 Stats() FilterStats

Callers 3

NewTopologyFromConfigFunction · 0.65
testExternalMatchFilesFunction · 0.65

Implementers 15

LazyFilterexamples/filtering/filter.go
ExternalMatchfilter/external_match.go
Concatenatefilter/concatenate.go
ReplaceFieldsfilter/replace_fields.go
Timestampfilter/timestamp.go
SetStringFromURLfilter/set_string_from_url.go
ExpandJSONfilter/expand_json.go
Hashfilter/hash.go
Cryptfilter/crypt.go
URLParamfilter/url_param.go
ExpandListfilter/expand_list.go
ClearFieldsfilter/clear_fields.go

Calls

no outgoing calls

Tested by 2

testExternalMatchFilesFunction · 0.52