Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_process_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ProcessRequest ¶
type ProcessRequest struct {
// id is the minted request id to process. Format: "request/<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
ProcessRequest is the payload ingest publishes to the process stage once it has accepted a new head: only the minted request id travels on the queue. process reloads the full Request from storage by this id (producer and consumer share the store, so the id is enough and redelivery stays idempotent).
func (*ProcessRequest) Descriptor
deprecated
func (*ProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProcessRequest.ProtoReflect.Descriptor instead.
func (*ProcessRequest) GetId ¶
func (x *ProcessRequest) GetId() string
func (*ProcessRequest) ProtoMessage ¶
func (*ProcessRequest) ProtoMessage()
func (*ProcessRequest) ProtoReflect ¶
func (x *ProcessRequest) ProtoReflect() protoreflect.Message
func (*ProcessRequest) Reset ¶
func (x *ProcessRequest) Reset()
func (*ProcessRequest) String ¶
func (x *ProcessRequest) String() string
Click to show internal directories.
Click to hide internal directories.