Documentation
¶
Index ¶
- Variables
- type BuildRequest
- func (*BuildRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BuildRequest) GetId() string
- func (x *BuildRequest) GetQueueName() string
- func (*BuildRequest) ProtoMessage()
- func (x *BuildRequest) ProtoReflect() protoreflect.Message
- func (x *BuildRequest) Reset()
- func (x *BuildRequest) String() string
- type BuildSignal
- func (*BuildSignal) Descriptor() ([]byte, []int)deprecated
- func (x *BuildSignal) GetId() string
- func (x *BuildSignal) GetQueueName() string
- func (*BuildSignal) ProtoMessage()
- func (x *BuildSignal) ProtoReflect() protoreflect.Message
- func (x *BuildSignal) Reset()
- func (x *BuildSignal) String() string
- type ProcessRequest
- func (*ProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessRequest) GetId() string
- func (x *ProcessRequest) GetQueueName() string
- func (*ProcessRequest) ProtoMessage()
- func (x *ProcessRequest) ProtoReflect() protoreflect.Message
- func (x *ProcessRequest) Reset()
- func (x *ProcessRequest) String() string
- type Record
Constants ¶
This section is empty.
Variables ¶
var File_build_proto protoreflect.FileDescriptor
var File_buildsignal_proto protoreflect.FileDescriptor
var File_process_proto protoreflect.FileDescriptor
var File_record_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BuildRequest ¶
type BuildRequest struct {
// id is the request id to build. Format: "request/<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue_name is the name of the queue processing the request, carried so
// the consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// contains filtered or unexported fields
}
BuildRequest is the payload process/analyze publishes to the build stage once the request's build scope (BuildStrategy/BaseURI) has been decided: only the request id travels on the queue. build reloads the full Request from storage by this id (producer and consumer share the store, so the id is enough and redelivery stays idempotent). See doc/rfc/stovepipe/steps/build.md.
func (*BuildRequest) Descriptor
deprecated
func (*BuildRequest) Descriptor() ([]byte, []int)
Deprecated: Use BuildRequest.ProtoReflect.Descriptor instead.
func (*BuildRequest) GetId ¶
func (x *BuildRequest) GetId() string
func (*BuildRequest) GetQueueName ¶
func (x *BuildRequest) GetQueueName() string
func (*BuildRequest) ProtoMessage ¶
func (*BuildRequest) ProtoMessage()
func (*BuildRequest) ProtoReflect ¶
func (x *BuildRequest) ProtoReflect() protoreflect.Message
func (*BuildRequest) Reset ¶
func (x *BuildRequest) Reset()
func (*BuildRequest) String ¶
func (x *BuildRequest) String() string
type BuildSignal ¶
type BuildSignal struct {
// id is the build id to poll: the runner-assigned id minted by
// BuildRunner.Trigger (entity.Build.ID / entity.BuildID.ID).
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue_name is the name of the queue processing the batch's request,
// carried so the consumer can route by queue without loading state first.
// Empty on payloads written before the field existed.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// contains filtered or unexported fields
}
BuildSignal is the payload build publishes to the buildsignal stage, and buildsignal re-publishes to itself while polling: only the build id travels on the queue. buildsignal reloads the full Build from storage by this id (producer and consumer share the store, so the id is enough and redelivery stays idempotent). See doc/rfc/stovepipe/steps/buildsignal.md.
func (*BuildSignal) Descriptor
deprecated
func (*BuildSignal) Descriptor() ([]byte, []int)
Deprecated: Use BuildSignal.ProtoReflect.Descriptor instead.
func (*BuildSignal) GetId ¶
func (x *BuildSignal) GetId() string
func (*BuildSignal) GetQueueName ¶
func (x *BuildSignal) GetQueueName() string
func (*BuildSignal) ProtoMessage ¶
func (*BuildSignal) ProtoMessage()
func (*BuildSignal) ProtoReflect ¶
func (x *BuildSignal) ProtoReflect() protoreflect.Message
func (*BuildSignal) Reset ¶
func (x *BuildSignal) Reset()
func (*BuildSignal) String ¶
func (x *BuildSignal) String() string
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"`
// queue_name is the name of the queue processing the request, carried so
// the consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,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) GetQueueName ¶
func (x *ProcessRequest) GetQueueName() 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
type Record ¶
type Record struct {
// id is the request id whose build reached a terminal status. Format:
// "request/<queue>/<counter>" (entity.Request.ID).
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue_name is the name of the queue processing the request, carried so
// the consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// contains filtered or unexported fields
}
Record is the payload buildsignal publishes once a request's build reaches a terminal status: only the request id travels on the queue. record reloads the full Request from storage by this id (producer and consumer share the store, so the id is enough and redelivery stays idempotent). The build's terminal status is projected onto Request.State before this is published, so record never reaches a Build. See doc/rfc/stovepipe/steps/buildsignal.md.
func (*Record) Descriptor
deprecated
func (*Record) GetQueueName ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message