pb

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files:

pkg/commandbus/pb/commandbus.proto

It has these top-level messages:

Command

Package pb is a generated protocol buffer package.

It is generated from these files:

pkg/commandbus/pb/reply.proto

It has these top-level messages:

Reply

Index

• Variables
• type Command
  • func (*Command) Descriptor() ([]byte, []int)
  • func (m *Command) GetCommandType() string
  • func (m *Command) GetHeader() map[string]string
  • func (m *Command) GetPayload() []byte
  • func (m *Command) GetStreamId() string
  • func (m *Command) GetStreamType() string
  • func (m *Command) Marshal() (dAtA []byte, err error)
  • func (m *Command) MarshalTo(dAtA []byte) (int, error)
  • func (*Command) ProtoMessage()
  • func (m *Command) Reset()
  • func (m *Command) Size() (n int)
  • func (m *Command) String() string
  • func (m *Command) Unmarshal(dAtA []byte) error
• type Reply
  • func (*Reply) Descriptor() ([]byte, []int)
  • func (m *Reply) GetCommandType() string
  • func (m *Reply) GetCorrelationId() string
  • func (m *Reply) GetError() string
  • func (m *Reply) GetPayload() []byte
  • func (m *Reply) GetReplyType() string
  • func (m *Reply) GetStreamId() string
  • func (m *Reply) GetStreamType() string
  • func (m *Reply) GetVersion() int64
  • func (m *Reply) Marshal() (dAtA []byte, err error)
  • func (m *Reply) MarshalTo(dAtA []byte) (int, error)
  • func (*Reply) ProtoMessage()
  • func (m *Reply) Reset()
  • func (m *Reply) Size() (n int)
  • func (m *Reply) String() string
  • func (m *Reply) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthCommand = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommand   = fmt.Errorf("proto: integer overflow")
)

var (
	ErrInvalidLengthReply = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReply   = fmt.Errorf("proto: integer overflow")
)

Types

type Command

type Command struct {
	StreamId    string            `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	StreamType  string            `protobuf:"bytes,4,opt,name=stream_type,json=streamType,proto3" json:"stream_type,omitempty"`
	CommandType string            `protobuf:"bytes,8,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`
	Payload     []byte            `protobuf:"bytes,12,opt,name=payload,proto3" json:"payload,omitempty"`
	Header      map[string]string `` /* 147-byte string literal not displayed */
}

func (*Command) Descriptor

func (*Command) Descriptor() ([]byte, []int)

func (*Command) GetCommandType

func (m *Command) GetCommandType() string

func (*Command) GetHeader

func (m *Command) GetHeader() map[string]string

func (*Command) GetPayload

func (m *Command) GetPayload() []byte

func (*Command) GetStreamId

func (m *Command) GetStreamId() string

func (*Command) GetStreamType

func (m *Command) GetStreamType() string

func (*Command) Marshal

func (m *Command) Marshal() (dAtA []byte, err error)

func (*Command) MarshalTo

func (m *Command) MarshalTo(dAtA []byte) (int, error)

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) Reset

func (m *Command) Reset()

func (*Command) Size

func (m *Command) Size() (n int)

func (*Command) String

func (m *Command) String() string

func (*Command) Unmarshal

func (m *Command) Unmarshal(dAtA []byte) error

type Reply

type Reply struct {
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	StreamType    string `protobuf:"bytes,4,opt,name=stream_type,json=streamType,proto3" json:"stream_type,omitempty"`
	StreamId      string `protobuf:"bytes,8,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ReplyType     string `protobuf:"bytes,12,opt,name=reply_type,json=replyType,proto3" json:"reply_type,omitempty"`
	CommandType   string `protobuf:"bytes,13,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`
	Payload       []byte `protobuf:"bytes,16,opt,name=payload,proto3" json:"payload,omitempty"`
	Error         string `protobuf:"bytes,20,opt,name=error,proto3" json:"error,omitempty"`
	Version       int64  `protobuf:"varint,24,opt,name=version,proto3" json:"version,omitempty"`
}

func (*Reply) Descriptor

func (*Reply) Descriptor() ([]byte, []int)

func (*Reply) GetCommandType

func (m *Reply) GetCommandType() string

func (*Reply) GetCorrelationId

func (m *Reply) GetCorrelationId() string

func (*Reply) GetError

func (m *Reply) GetError() string

func (*Reply) GetPayload

func (m *Reply) GetPayload() []byte

func (*Reply) GetReplyType

func (m *Reply) GetReplyType() string

func (*Reply) GetStreamId

func (m *Reply) GetStreamId() string

func (*Reply) GetStreamType

func (m *Reply) GetStreamType() string

func (*Reply) GetVersion

func (m *Reply) GetVersion() int64

func (*Reply) Marshal

func (m *Reply) Marshal() (dAtA []byte, err error)

func (*Reply) MarshalTo

func (m *Reply) MarshalTo(dAtA []byte) (int, error)

func (*Reply) ProtoMessage

func (*Reply) ProtoMessage()

func (*Reply) Reset

func (m *Reply) Reset()

func (*Reply) Size

func (m *Reply) Size() (n int)

func (*Reply) String

func (m *Reply) String() string

func (*Reply) Unmarshal

func (m *Reply) Unmarshal(dAtA []byte) error