serializer

Documentation

Index

• type CloudEventsKafkaPayload
• type JSONSerializer
  • func NewJSONSerializer() JSONSerializer
  • func (s JSONSerializer) GetFormat() string
  • func (s JSONSerializer) GetKeySchemaId() int
  • func (s JSONSerializer) GetValueSchemaId() int
  • func (s JSONSerializer) SerializeKey(topic string, ev event.Event) ([]byte, error)
  • func (s JSONSerializer) SerializeValue(topic string, ev event.Event) ([]byte, error)
• type Serializer

Types

type CloudEventsKafkaPayload

type CloudEventsKafkaPayload struct {
	Id      string `json:"id"`
	Type    string `json:"type"`
	Source  string `json:"source"`
	Subject string `json:"subject"`
	// Note: By converting to unix timestamp we loose timezone information.
	Time int64  `json:"time"`
	Data string `json:"data"`
}

type JSONSerializer

type JSONSerializer struct{}

func NewJSONSerializer

func NewJSONSerializer() JSONSerializer

func (JSONSerializer) GetFormat

func (s JSONSerializer) GetFormat() string

func (JSONSerializer) GetKeySchemaId

func (s JSONSerializer) GetKeySchemaId() int

func (JSONSerializer) GetValueSchemaId

func (s JSONSerializer) GetValueSchemaId() int

func (JSONSerializer) SerializeKey

func (s JSONSerializer) SerializeKey(topic string, ev event.Event) ([]byte, error)

func (JSONSerializer) SerializeValue

func (s JSONSerializer) SerializeValue(topic string, ev event.Event) ([]byte, error)

type Serializer

type Serializer interface {
	SerializeKey(topic string, ev event.Event) ([]byte, error)
	SerializeValue(topic string, ev event.Event) ([]byte, error)
	GetFormat() string
	GetKeySchemaId() int
	GetValueSchemaId() int
}