12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273 |
- package protobuf
- import (
- "errors"
- "github.com/golang/protobuf/proto"
- "github.com/nats-io/go-nats"
- )
- const (
- PROTOBUF_ENCODER = "protobuf"
- )
- func init() {
-
- nats.RegisterEncoder(PROTOBUF_ENCODER, &ProtobufEncoder{})
- }
- type ProtobufEncoder struct {
-
- }
- var (
- ErrInvalidProtoMsgEncode = errors.New("nats: Invalid protobuf proto.Message object passed to encode")
- ErrInvalidProtoMsgDecode = errors.New("nats: Invalid protobuf proto.Message object passed to decode")
- )
- func (pb *ProtobufEncoder) Encode(subject string, v interface{}) ([]byte, error) {
- if v == nil {
- return nil, nil
- }
- i, found := v.(proto.Message)
- if !found {
- return nil, ErrInvalidProtoMsgEncode
- }
- b, err := proto.Marshal(i)
- if err != nil {
- return nil, err
- }
- return b, nil
- }
- func (pb *ProtobufEncoder) Decode(subject string, data []byte, vPtr interface{}) error {
- if _, ok := vPtr.(*interface{}); ok {
- return nil
- }
- i, found := vPtr.(proto.Message)
- if !found {
- return ErrInvalidProtoMsgDecode
- }
- return proto.Unmarshal(data, i)
- }
|