models

Documentation

Index

• type ProcessingState
  • func (c ProcessingState) String() string
• type ProcessingStatus
• type SinkMessage

Types

type ProcessingState

type ProcessingState int8

const (
	OK ProcessingState = iota
	DROP
	INVALID
)

func (ProcessingState) String

func (c ProcessingState) String() string

type ProcessingStatus

type ProcessingStatus struct {
	State ProcessingState
	Error error
}

type SinkMessage

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