unpacker

Documentation

Index

• type IncludeSchema
  • func NewIncludeSchema() *IncludeSchema
  • func (*IncludeSchema) Unpack(message []byte) ([]byte, []byte, error)
• type SchemaRegistry
  • func NewSchemaRegistry(srClient *confluent.SchemaRegistryClient) *SchemaRegistry
  • func (s *SchemaRegistry) Unpack(message []byte) ([]byte, []byte, error)
• type Unpacker
  • func NewMessageUnpacker(srClient *confluent.SchemaRegistryClient) Unpacker

Types

type IncludeSchema

type IncludeSchema struct {
}

func NewIncludeSchema

func NewIncludeSchema() *IncludeSchema

func (*IncludeSchema) Unpack

func (*IncludeSchema) Unpack(message []byte) ([]byte, []byte, error)

type SchemaRegistry

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

func NewSchemaRegistry

func NewSchemaRegistry(srClient *confluent.SchemaRegistryClient) *SchemaRegistry

func (*SchemaRegistry) Unpack

func (s *SchemaRegistry) Unpack(message []byte) ([]byte, []byte, error)

type Unpacker

type Unpacker interface {
	// Unpack schema and payload from message
	Unpack(message []byte) (schema []byte, payload []byte, err error)
}

func NewMessageUnpacker

func NewMessageUnpacker(srClient *confluent.SchemaRegistryClient) Unpacker