protocol

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (this *Message) Equal(that interface{}) bool
  • func (m *Message) GetBody() *types.Any
  • func (m *Message) GetCommandIndex() int64
  • func (m *Message) GetEventId() int64
  • func (m *Message) GetId() string
  • func (m *Message) GetProtocolInstanceId() string
  • func (m *Message) GetSequencingId() isMessage_SequencingId
  • func (this *Message) GoString() string
  • func (m *Message) Marshal() (dAtA []byte, err error)
  • func (m *Message) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) Size() (n int)
  • func (this *Message) String() string
  • func (m *Message) Unmarshal(dAtA []byte) error
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (*Message) XXX_OneofWrappers() []interface{}
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type Message_CommandIndex
  • func (this *Message_CommandIndex) Equal(that interface{}) bool
  • func (this *Message_CommandIndex) GoString() string
  • func (m *Message_CommandIndex) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message_CommandIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Message_CommandIndex) Size() (n int)
  • func (this *Message_CommandIndex) String() string
• type Message_EventId
  • func (this *Message_EventId) Equal(that interface{}) bool
  • func (this *Message_EventId) GoString() string
  • func (m *Message_EventId) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message_EventId) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Message_EventId) Size() (n int)
  • func (this *Message_EventId) String() string

Variables

var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Types

type Message

type Message struct {
	// An ID for this specific message.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Identifies the specific instance of a protocol to which this message
	// belongs.
	ProtocolInstanceId string `protobuf:"bytes,2,opt,name=protocol_instance_id,json=protocolInstanceId,proto3" json:"protocol_instance_id,omitempty"`
	// The event ID or command ID after which this message can be delivered. The
	// effects of history up to and including this event ID should be visible to
	// the code that handles this message. Omit to opt out of sequencing.
	//
	// Types that are valid to be assigned to SequencingId:
	//	*Message_EventId
	//	*Message_CommandIndex
	SequencingId isMessage_SequencingId `protobuf_oneof:"sequencing_id"`
	// The opaque data carried by this message. The protocol type can be
	// extracted from the package name of the message carried inside the Any.
	Body *types.Any `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
}

(-- api-linter: core::0146::any=disabled

aip.dev/not-precedent: We want runtime extensibility for the body field --)

func (*Message) Descriptor

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

func (*Message) Equal

func (this *Message) Equal(that interface{}) bool

func (*Message) GetBody

func (m *Message) GetBody() *types.Any

func (*Message) GetCommandIndex

func (m *Message) GetCommandIndex() int64

func (*Message) GetEventId

func (m *Message) GetEventId() int64

func (*Message) GetId

func (m *Message) GetId() string

func (*Message) GetProtocolInstanceId

func (m *Message) GetProtocolInstanceId() string

func (*Message) GetSequencingId

func (m *Message) GetSequencingId() isMessage_SequencingId

func (*Message) GoString

func (this *Message) GoString() string

func (*Message) Marshal

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

func (*Message) MarshalTo

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

func (*Message) MarshalToSizedBuffer

func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

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

func (*Message) String

func (this *Message) String() string

func (*Message) Unmarshal

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

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_OneofWrappers

func (*Message) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

func (m *Message) XXX_Unmarshal(b []byte) error

type Message_CommandIndex

type Message_CommandIndex struct {
	CommandIndex int64 `protobuf:"varint,4,opt,name=command_index,json=commandIndex,proto3,oneof" json:"command_index,omitempty"`
}

func (*Message_CommandIndex) Equal

func (this *Message_CommandIndex) Equal(that interface{}) bool

func (*Message_CommandIndex) GoString

func (this *Message_CommandIndex) GoString() string

func (*Message_CommandIndex) MarshalTo

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

func (*Message_CommandIndex) MarshalToSizedBuffer

func (m *Message_CommandIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_CommandIndex) Size

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

func (*Message_CommandIndex) String

func (this *Message_CommandIndex) String() string

type Message_EventId

type Message_EventId struct {
	EventId int64 `protobuf:"varint,3,opt,name=event_id,json=eventId,proto3,oneof" json:"event_id,omitempty"`
}

func (*Message_EventId) Equal

func (this *Message_EventId) Equal(that interface{}) bool

func (*Message_EventId) GoString

func (this *Message_EventId) GoString() string

func (*Message_EventId) MarshalTo

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

func (*Message_EventId) MarshalToSizedBuffer

func (m *Message_EventId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Message_EventId) Size

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

func (*Message_EventId) String

func (this *Message_EventId) String() string