collector

Documentation

Index

• func BuildSnowplowPayload[T any](ctx context.Context, raw []byte) (*T, error)
• func GetHandler(p Params) echo.HandlerFunc
• func PostHandler(p Params) echo.HandlerFunc
• func RedirectHandler(p Params) echo.HandlerFunc
• type Params
• type SnowplowCollectorPayload

Functions

func BuildSnowplowPayload

func BuildSnowplowPayload[T any](ctx context.Context, raw []byte) (*T, error)

BuildSnowplowPayload parses a JSON payload into a generic type T.

ctx - The context for the operation. Currently unused. raw - The raw JSON payload bytes to decode.

Returns a pointer to a T instance containing the decoded payload, or an error if the JSON could not be decoded.

func GetHandler

func GetHandler(p Params) echo.HandlerFunc

func PostHandler

func PostHandler(p Params) echo.HandlerFunc

PostHandler handles incoming Snowplow collector payloads and sends them to Amazon Kinesis Firehose.

p - Handler parameters

Returns an HTTP 200 response with an "ok" message on success, or an error if the payload is invalid or failed to send.

func RedirectHandler

func RedirectHandler(p Params) echo.HandlerFunc

Types

type Params

type Params struct {
	Flags       flags.Service
	FirehoseSvc *firehose.Client
	SchemaStore *registry.SchemaStore
}

type SnowplowCollectorPayload

type SnowplowCollectorPayload struct {
	Schema string          `json:"schema"`
	Data   json.RawMessage `json:"data"`
}