registry

Documentation

Index

• Variables
• func Register(initializers ...MessageUnmarshaller)
• func Unmarshal(typeName string, b []byte) (interface{}, error)
• type MessageType
• type MessageUnmarshaller
• type Named
• type Registry
  • func New() *Registry
  • func (reg *Registry) Marshal(msg interface{}) ([]byte, string, error)
  • func (reg *Registry) Register(initializers ...MessageUnmarshaller)
  • func (reg *Registry) ToMessage(r record.Record) (streams.Message, error)
  • func (reg *Registry) Unmarshal(typeName string, b []byte) (interface{}, error)

Variables

var DefaultRegistry = New()

Functions

func Register

func Register(initializers ...MessageUnmarshaller)

func Unmarshal

func Unmarshal(typeName string, b []byte) (interface{}, error)

Types

type MessageType

type MessageType interface {
}

type MessageUnmarshaller

type MessageUnmarshaller func(b []byte) (interface{}, error)

type Named

type Named interface {
	Name() string
}

type Registry

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

func New

func New() *Registry

func (*Registry) Marshal

func (reg *Registry) Marshal(msg interface{}) ([]byte, string, error)

func (*Registry) Register

func (reg *Registry) Register(initializers ...MessageUnmarshaller)

func (*Registry) ToMessage

func (reg *Registry) ToMessage(r record.Record) (streams.Message, error)

func (*Registry) Unmarshal

func (reg *Registry) Unmarshal(typeName string, b []byte) (interface{}, error)