protocolv1

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetBody() *anypb.Any
  • func (x *Message) GetCommandIndex() int64
  • func (x *Message) GetEventId() int64
  • func (x *Message) GetId() string
  • func (x *Message) GetProtocolInstanceId() string
  • func (m *Message) GetSequencingId() isMessage_SequencingId
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Message_CommandIndex
• type Message_EventId

Variables

var File_temporal_api_protocol_v1_message_proto protoreflect.FileDescriptor

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 assignable 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 *anypb.Any `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody

func (x *Message) GetBody() *anypb.Any

func (*Message) GetCommandIndex

func (x *Message) GetCommandIndex() int64

func (*Message) GetEventId

func (x *Message) GetEventId() int64

func (*Message) GetId

func (x *Message) GetId() string

func (*Message) GetProtocolInstanceId

func (x *Message) GetProtocolInstanceId() string

func (*Message) GetSequencingId

func (m *Message) GetSequencingId() isMessage_SequencingId

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type Message_CommandIndex

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

type Message_EventId

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