json32

Documentation

Index

• func NewHandler(in <-chan []byte, handler any) (bus.Listener, error)
• type Receiver
  • func NewReceiver(in <-chan []byte) *Receiver
• type Sender
  • func NewSender(out chan<- []byte) *Sender

Functions

func NewHandler

func NewHandler(in <-chan []byte, handler any) (bus.Listener, error)

NewHandler reads messages off the 'in' channel and sends them to the handler.

Types

type Receiver

type Receiver struct {
	*serialbus.Receiver
	TypeMap type32.TypeMap
	Out     <-chan interface{}
}

Receiver combines a serialbus.Receiver with a type32.TypeMap. It is setup to receive json serialized data with a type32 header.

func NewReceiver

func NewReceiver(in <-chan []byte) *Receiver

NewReceiver on the 'in' channel. It is setup to receive json serialized data with a type32 header.

type Sender

type Sender struct {
	type32.TypeMap
	*serialbus.Sender
}

Sender combines a type32.TypeMap and a serialbus.Sender. It is setup to send json serialized data with a type32 header.

func NewSender

func NewSender(out chan<- []byte) *Sender

NewSender that will write to 'out'. It is setup to use json.Serialize as the serializer.