Base64Decode is a specific transformation implementation to transform good enriched data within a message to Json.

Base64Encode is a specific transformation implementation to transform good enriched data within a message to Json.

GojqTransformationFunction is a function returning another transformation function which allows us to do some GOJQ based mapping/filtering.

IntermediateAsSpEnrichedParsed returns the intermediate state as a ParsedEvent if valid or parses the message as an event.

NewSpEnrichedSetPkFunction returns a TransformationFunction which sets the partition key of a message to a field within a Snowplow enriched event.

NewTransformation constructs a function which applies all transformations to all messages, returning a TransformationResult.

SpEnrichedToJSON is a specific transformation implementation to transform good enriched data within a message to Json.

ValidateAtomicField is a helper function to allow us to fail invalid atomic fields on startup.

Base64DecodeConfigPair is a configuration pair for the Base64Decode transformation.

Base64EncodeConfigPair is a configuration pair for the Base64Encode transformation.

EnrichedToJSONConfigPair is a configuration pair for the spEnrichedToJson transformation.

GTMSSPreviewConfigPair is the configuration pair for the gtmss preview transformation.

JQMapperConfigPair is a configuration pair for the jq mapper transformation.

Messages contains a set of test Snowplow messages.

SetPkConfigPair is a configuration pair for the spEnrichedSetPk transformation.

SnowplowJSON1 another test data.

SnowplowTsv1 is test data.

SnowplowTsv2 is test data.

SnowplowTsv3 is test data.

SnowplowTsv4 is test data.

SpTsv1Parsed is test data.

SpTsv2Parsed is test data.

SpTsv3Parsed is test data.

Base64DecodeConfig is a configuration object for the base64Decode transformation.

Base64EncodeConfig is a configuration object for the base64Encode transformation.

EnrichedToJSONConfig is a configuration object for the spEnrichedToJson transformation.

GTMSSPreviewConfig is a configuration object for the spEnrichedToJson transformation.

JQMapperConfig represents the configuration for the JQ transformation.

SetPkConfig is a configuration object for the spEnrichedSetPk transformation.

JqCommandOutput is a type representing output after executing JQ command.

JqOutputHandler is a function which accepts JqCommandOutput and is response for doing something with it.

TransformationApplyFunction dereferences messages before running transformations, and returns a TransformationResult.

TransformationFunction takes a message and intermediateState, and returns a transformed message, a filtered message or an errored message, along with an intermediateState.

TransformationGenerator returns a TransformationApplyFunction from a provided set of TransformationFunctions.