Documentation
¶
Index ¶
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"`
// 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) 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"`
// 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) 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"`
// 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
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"`
// 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) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
Source Files