diff --git a/pkg/transform/snowplow_json_to_collector_payload_thrift.go b/pkg/transform/snowplow_json_to_collector_payload_thrift.go index f0ddda21..8334510b 100644 --- a/pkg/transform/snowplow_json_to_collector_payload_thrift.go +++ b/pkg/transform/snowplow_json_to_collector_payload_thrift.go @@ -19,8 +19,8 @@ import ( collectorpayloadmodel1 "github.com/snowplow/snowbridge/third_party/snowplow/collectorpayload/gen-go/model1" ) -// JSONToCollectorPayloadThriftConfig is a configuration object for the spJSONToCollectorPayloadThrift transformation -type JSONToCollectorPayloadThriftConfig struct { +// jsonToCollectorPayloadThriftConfig is a configuration object for the spJSONToCollectorPayloadThrift transformation +type jsonToCollectorPayloadThriftConfig struct { } type jsonToCollectorPayloadThriftAdapter func(i interface{}) (interface{}, error) @@ -55,8 +55,8 @@ func jsonToCollectorPayloadThriftConfigFunction(c *JSONToCollectorPayloadThriftC return SpJSONToCollectorPayloadThrift, nil } -// JSONToCollectorPayloadThriftConfigPair is a configuration pair for the spJSONToCollectorPayloadThrift transformation -var JSONToCollectorPayloadThriftConfigPair = config.ConfigurationPair{ +// jsonToCollectorPayloadThriftConfigPair is a configuration pair for the spJSONToCollectorPayloadThrift transformation +var jsonToCollectorPayloadThriftConfigPair = config.ConfigurationPair{ Name: "spJSONToCollectorPayloadThrift", Handle: jsonToCollectorPayloadThriftAdapterGenerator(jsonToCollectorPayloadThriftConfigFunction), } diff --git a/pkg/transform/transformconfig/transform_config.go b/pkg/transform/transformconfig/transform_config.go index e7806c1f..66ac6341 100644 --- a/pkg/transform/transformconfig/transform_config.go +++ b/pkg/transform/transformconfig/transform_config.go @@ -24,7 +24,7 @@ var SupportedTransformations = []config.ConfigurationPair{ transform.SetPkConfigPair, transform.EnrichedToJSONConfigPair, transform.CollectorPayloadThriftToJSONConfigPair, - transform.JSONToCollectorPayloadThriftConfigPair, + transform.jsonToCollectorPayloadThriftConfigPair, engine.LuaConfigPair, engine.JSConfigPair, }