validator

Documentation

Index

• Variables
• func GetSchemaContents(schemaName string, registry *registry.Registry) (exists bool, validationError envelope.ValidationError, contents []byte)
• func ValidatePayload(schemaName string, payload envelope.Payload, registry *registry.Registry) (isValid bool, validationError envelope.ValidationError, schema []byte)
• type InvalidMessage

Variables

var InvalidPayload = InvalidMessage{
	Type:       "invalid payload",
	Resolution: "publish a valid payload",
}

var InvalidSchema = InvalidMessage{
	Type:       "invalid schema",
	Resolution: "ensure schema is properly formatted",
}

var NoSchemaAssociated = InvalidMessage{
	Type:       "no schema associated",
	Resolution: "associate a schema with the event",
}

var NoSchemaInBackend = InvalidMessage{
	Type:       "schema not published to cache backend",
	Resolution: "publish schema to the cache backend",
}

var PayloadNotPresent = InvalidMessage{
	Type:       "payload not present",
	Resolution: "publish the event with a payload",
}

var UnknownSnowplowEventType = InvalidMessage{
	Type:       "unknown snowplow event type",
	Resolution: "event type should adhere to the snowplow tracker protocol",
}

Functions

func GetSchemaContents

func GetSchemaContents(schemaName string, registry *registry.Registry) (exists bool, validationError envelope.ValidationError, contents []byte)

func ValidatePayload

func ValidatePayload(schemaName string, payload envelope.Payload, registry *registry.Registry) (isValid bool, validationError envelope.ValidationError, schema []byte)

Types

type InvalidMessage

type InvalidMessage struct {
	Type       string `json:"type"`
	Resolution string `json:"resolution"`
}