controlproto

Documentation

Index

• type Decoder
• type Encoder
• type ProtobufDecoder
  • func NewProtobufDecoder() *ProtobufDecoder
  • func (e *ProtobufDecoder) DecodeCommand(data []byte) (*controlpb.Command, error)
  • func (e *ProtobufDecoder) DecodeDisconnect(data []byte) (*controlpb.Disconnect, error)
  • func (e *ProtobufDecoder) DecodeNode(data []byte) (*controlpb.Node, error)
  • func (e *ProtobufDecoder) DecodeUnsubscribe(data []byte) (*controlpb.Unsubscribe, error)
• type ProtobufEncoder
  • func NewProtobufEncoder() *ProtobufEncoder
  • func (e *ProtobufEncoder) EncodeCommand(cmd *controlpb.Command) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeDisconnect(cmd *controlpb.Disconnect) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeNode(cmd *controlpb.Node) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeUnsubscribe(cmd *controlpb.Unsubscribe) ([]byte, error)

Types

type Decoder

type Decoder interface {
	DecodeCommand([]byte) (*controlpb.Command, error)
	DecodeNode([]byte) (*controlpb.Node, error)
	DecodeUnsubscribe([]byte) (*controlpb.Unsubscribe, error)
	DecodeDisconnect([]byte) (*controlpb.Disconnect, error)
}

Decoder ...

type Encoder

type Encoder interface {
	EncodeCommand(*controlpb.Command) ([]byte, error)
	EncodeNode(*controlpb.Node) ([]byte, error)
	EncodeUnsubscribe(*controlpb.Unsubscribe) ([]byte, error)
	EncodeDisconnect(*controlpb.Disconnect) ([]byte, error)
}

Encoder ...

type ProtobufDecoder

type ProtobufDecoder struct {
}

ProtobufDecoder ...

func NewProtobufDecoder

func NewProtobufDecoder() *ProtobufDecoder

NewProtobufDecoder ...

func (*ProtobufDecoder) DecodeCommand

func (e *ProtobufDecoder) DecodeCommand(data []byte) (*controlpb.Command, error)

DecodeCommand ...

func (*ProtobufDecoder) DecodeDisconnect

func (e *ProtobufDecoder) DecodeDisconnect(data []byte) (*controlpb.Disconnect, error)

DecodeDisconnect ...

func (*ProtobufDecoder) DecodeNode

func (e *ProtobufDecoder) DecodeNode(data []byte) (*controlpb.Node, error)

DecodeNode ...

func (*ProtobufDecoder) DecodeUnsubscribe

func (e *ProtobufDecoder) DecodeUnsubscribe(data []byte) (*controlpb.Unsubscribe, error)

DecodeUnsubscribe ...

type ProtobufEncoder

type ProtobufEncoder struct {
}

ProtobufEncoder ...

func NewProtobufEncoder

func NewProtobufEncoder() *ProtobufEncoder

NewProtobufEncoder ...

func (*ProtobufEncoder) EncodeCommand

func (e *ProtobufEncoder) EncodeCommand(cmd *controlpb.Command) ([]byte, error)

EncodeCommand ...

func (*ProtobufEncoder) EncodeDisconnect

func (e *ProtobufEncoder) EncodeDisconnect(cmd *controlpb.Disconnect) ([]byte, error)

EncodeDisconnect ...

func (*ProtobufEncoder) EncodeNode

func (e *ProtobufEncoder) EncodeNode(cmd *controlpb.Node) ([]byte, error)

EncodeNode ...

func (*ProtobufEncoder) EncodeUnsubscribe

func (e *ProtobufEncoder) EncodeUnsubscribe(cmd *controlpb.Unsubscribe) ([]byte, error)

EncodeUnsubscribe ...