serializer

Documentation

Index

• type CloudEventsKafkaPayload
• type JSONSchemaSerializer
  • func NewJSONSchemaSerializer(schemaRegistry schemaregistry.Client) (*JSONSchemaSerializer, error)
  • func (s JSONSchemaSerializer) GetFormat() string
  • func (s JSONSchemaSerializer) GetKeySchemaId() int
  • func (s JSONSchemaSerializer) GetValueSchemaId() int
  • func (s JSONSchemaSerializer) SerializeKey(topic string, ev event.Event) ([]byte, error)
  • func (s JSONSchemaSerializer) SerializeValue(topic string, ev event.Event) ([]byte, error)
• 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 JSONSchemaSerializer

type JSONSchemaSerializer struct {
	// contains filtered or unexported fields
}

func NewJSONSchemaSerializer

func NewJSONSchemaSerializer(schemaRegistry schemaregistry.Client) (*JSONSchemaSerializer, error)

NewJSONSchemaSerializer initializes a new schema in the registry.

func (JSONSchemaSerializer) GetFormat

func (s JSONSchemaSerializer) GetFormat() string

func (JSONSchemaSerializer) GetKeySchemaId

func (s JSONSchemaSerializer) GetKeySchemaId() int

func (JSONSchemaSerializer) GetValueSchemaId

func (s JSONSchemaSerializer) GetValueSchemaId() int

func (JSONSchemaSerializer) SerializeKey

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

func (JSONSchemaSerializer) SerializeValue

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

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
}