models

type ProcessingState int8

type ProcessingStatus struct {
	State     ProcessingState
	DropError error
}

type SinkMessage struct {
	Namespace    string
	KafkaMessage *kafka.Message
	Serialized   *serializer.CloudEventsKafkaPayload
	Status       ProcessingStatus
	// Meters contains the list of meters this message affects
	Meters []*meter.Meter
}