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) DecodeNotification(data []byte) (*controlpb.Notification, error)
  • func (e *ProtobufDecoder) DecodeRefresh(data []byte) (*controlpb.Refresh, error)
  • func (e *ProtobufDecoder) DecodeSubscribe(data []byte) (*controlpb.Subscribe, error)
  • func (e *ProtobufDecoder) DecodeSurveyRequest(data []byte) (*controlpb.SurveyRequest, error)
  • func (e *ProtobufDecoder) DecodeSurveyResponse(data []byte) (*controlpb.SurveyResponse, 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) EncodeNotification(cmd *controlpb.Notification) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeRefresh(cmd *controlpb.Refresh) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeSubscribe(cmd *controlpb.Subscribe) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeSurveyRequest(cmd *controlpb.SurveyRequest) ([]byte, error)
  • func (e *ProtobufEncoder) EncodeSurveyResponse(cmd *controlpb.SurveyResponse) ([]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)
	DecodeSubscribe([]byte) (*controlpb.Subscribe, error)
	DecodeUnsubscribe([]byte) (*controlpb.Unsubscribe, error)
	DecodeDisconnect([]byte) (*controlpb.Disconnect, error)
	DecodeSurveyRequest([]byte) (*controlpb.SurveyRequest, error)
	DecodeSurveyResponse([]byte) (*controlpb.SurveyResponse, error)
	DecodeNotification([]byte) (*controlpb.Notification, error)
	DecodeRefresh([]byte) (*controlpb.Refresh, error)
}

Decoder ...

type Encoder

type Encoder interface {
	EncodeCommand(*controlpb.Command) ([]byte, error)
	EncodeNode(*controlpb.Node) ([]byte, error)
	EncodeSubscribe(*controlpb.Subscribe) ([]byte, error)
	EncodeUnsubscribe(*controlpb.Unsubscribe) ([]byte, error)
	EncodeDisconnect(*controlpb.Disconnect) ([]byte, error)
	EncodeSurveyRequest(request *controlpb.SurveyRequest) ([]byte, error)
	EncodeSurveyResponse(request *controlpb.SurveyResponse) ([]byte, error)
	EncodeNotification(request *controlpb.Notification) ([]byte, error)
	EncodeRefresh(refresh *controlpb.Refresh) ([]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) DecodeNotification

func (e *ProtobufDecoder) DecodeNotification(data []byte) (*controlpb.Notification, error)

DecodeNotification ...

func (*ProtobufDecoder) DecodeRefresh

func (e *ProtobufDecoder) DecodeRefresh(data []byte) (*controlpb.Refresh, error)

DecodeRefresh ...

func (*ProtobufDecoder) DecodeSubscribe

func (e *ProtobufDecoder) DecodeSubscribe(data []byte) (*controlpb.Subscribe, error)

DecodeUnsubscribe ...

func (*ProtobufDecoder) DecodeSurveyRequest

func (e *ProtobufDecoder) DecodeSurveyRequest(data []byte) (*controlpb.SurveyRequest, error)

DecodeSurveyRequest ...

func (*ProtobufDecoder) DecodeSurveyResponse

func (e *ProtobufDecoder) DecodeSurveyResponse(data []byte) (*controlpb.SurveyResponse, error)

DecodeSurveyResponse ...

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) EncodeNotification

func (e *ProtobufEncoder) EncodeNotification(cmd *controlpb.Notification) ([]byte, error)

EncodeNotification ...

func (*ProtobufEncoder) EncodeRefresh

func (e *ProtobufEncoder) EncodeRefresh(cmd *controlpb.Refresh) ([]byte, error)

EncodeRefresh ...

func (*ProtobufEncoder) EncodeSubscribe

func (e *ProtobufEncoder) EncodeSubscribe(cmd *controlpb.Subscribe) ([]byte, error)

EncodeSubscribe ...

func (*ProtobufEncoder) EncodeSurveyRequest

func (e *ProtobufEncoder) EncodeSurveyRequest(cmd *controlpb.SurveyRequest) ([]byte, error)

EncodeSurveyRequest ...

func (*ProtobufEncoder) EncodeSurveyResponse

func (e *ProtobufEncoder) EncodeSurveyResponse(cmd *controlpb.SurveyResponse) ([]byte, error)

EncodeSurveyRequest ...

func (*ProtobufEncoder) EncodeUnsubscribe

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

EncodeUnsubscribe ...