encoder

type EncoderInterface ¶

type EncoderInterface interface {
	Encode(msg interface{}) ([]byte, error)
}

EncoderInterface is an interface each Encoder will have to abide to it will be used by the publisher/producer object to marshal payloads check defualt implementation of JSONEncoder for more info Example for protobuf:

import "google.golang.org/protobuf/proto"

type ProtoEncoder struct{}

func (e *ProtoEncoder) Encode(msg interface{}) ([]byte, error) {
	return proto.Marshal(msg)
}

func NewProtoEncoder() EncoderInterface {
	return &ProtoEncoder{}
}

func NewJSONEncoder() EncoderInterface

type JSONEncoder ¶

type JSONEncoder struct{}

JSONEncoder is the default encoder for publihsers/producers it implements the EncoderInterface and simply marshals an interface to json

func (e *JSONEncoder) Encode(msg interface{}) ([]byte, error)