Documentation
¶
Index ¶
- Variables
- type BuildAnalysis
- func (*BuildAnalysis) Descriptor() ([]byte, []int)deprecated
- func (x *BuildAnalysis) GetId() string
- func (x *BuildAnalysis) GetQueueName() string
- func (*BuildAnalysis) ProtoMessage()
- func (x *BuildAnalysis) ProtoReflect() protoreflect.Message
- func (x *BuildAnalysis) Reset()
- func (x *BuildAnalysis) String() string
- 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 FixRequest
- type IssueTrack
- func (*IssueTrack) Descriptor() ([]byte, []int)deprecated
- func (x *IssueTrack) GetBuildId() string
- func (x *IssueTrack) GetFinalize() bool
- func (x *IssueTrack) GetQueueName() string
- func (*IssueTrack) ProtoMessage()
- func (x *IssueTrack) ProtoReflect() protoreflect.Message
- func (x *IssueTrack) Reset()
- func (x *IssueTrack) 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_buildanalysis_proto protoreflect.FileDescriptor
var File_buildsignal_proto protoreflect.FileDescriptor
var File_fix_proto protoreflect.FileDescriptor
var File_issuetrack_proto protoreflect.FileDescriptor
var File_process_proto protoreflect.FileDescriptor
var File_record_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BuildAnalysis ¶
type BuildAnalysis struct {
// id is the opaque runner-assigned build identifier.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue_name is the required queue namespace of the build.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// contains filtered or unexported fields
}
BuildAnalysis identifies a persisted build whose issues should be observed. The controller reloads build status on each delivery and holds between polls.
func (*BuildAnalysis) Descriptor
deprecated
func (*BuildAnalysis) Descriptor() ([]byte, []int)
Deprecated: Use BuildAnalysis.ProtoReflect.Descriptor instead.
func (*BuildAnalysis) GetId ¶
func (x *BuildAnalysis) GetId() string
func (*BuildAnalysis) GetQueueName ¶
func (x *BuildAnalysis) GetQueueName() string
func (*BuildAnalysis) ProtoMessage ¶
func (*BuildAnalysis) ProtoMessage()
func (*BuildAnalysis) ProtoReflect ¶
func (x *BuildAnalysis) ProtoReflect() protoreflect.Message
func (*BuildAnalysis) Reset ¶
func (x *BuildAnalysis) Reset()
func (*BuildAnalysis) String ¶
func (x *BuildAnalysis) String() string
type BuildRequest ¶
type BuildRequest struct {
// id is the request id to build. Canonical positive decimal string; queue is carried separately.
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 FixRequest ¶
type FixRequest struct {
// queue_name is the required queue namespace of the build.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// id is the opaque runner-assigned build identifier.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
FixRequest identifies a persisted build whose issues should be considered for repair.
func (*FixRequest) Descriptor
deprecated
func (*FixRequest) Descriptor() ([]byte, []int)
Deprecated: Use FixRequest.ProtoReflect.Descriptor instead.
func (*FixRequest) GetId ¶
func (x *FixRequest) GetId() string
func (*FixRequest) GetQueueName ¶
func (x *FixRequest) GetQueueName() string
func (*FixRequest) ProtoMessage ¶
func (*FixRequest) ProtoMessage()
func (*FixRequest) ProtoReflect ¶
func (x *FixRequest) ProtoReflect() protoreflect.Message
func (*FixRequest) Reset ¶
func (x *FixRequest) Reset()
func (*FixRequest) String ¶
func (x *FixRequest) String() string
type IssueTrack ¶
type IssueTrack struct {
// build_id is the required opaque identifier of the persisted build.
BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
// queue_name is the required queue namespace of the build.
QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
// finalize requests final reconciliation after successful terminal detection
// and persistence, including when no failures were detected.
// Otherwise the notification permits opening issues, not resolution by absence.
Finalize bool `protobuf:"varint,3,opt,name=finalize,proto3" json:"finalize,omitempty"`
// contains filtered or unexported fields
}
IssueTrack requests queue-scoped reconciliation of persisted build observations. Publish only after successful detection and observation persistence; partition by queue.
func (*IssueTrack) Descriptor
deprecated
func (*IssueTrack) Descriptor() ([]byte, []int)
Deprecated: Use IssueTrack.ProtoReflect.Descriptor instead.
func (*IssueTrack) GetBuildId ¶
func (x *IssueTrack) GetBuildId() string
func (*IssueTrack) GetFinalize ¶
func (x *IssueTrack) GetFinalize() bool
func (*IssueTrack) GetQueueName ¶
func (x *IssueTrack) GetQueueName() string
func (*IssueTrack) ProtoMessage ¶
func (*IssueTrack) ProtoMessage()
func (*IssueTrack) ProtoReflect ¶
func (x *IssueTrack) ProtoReflect() protoreflect.Message
func (*IssueTrack) Reset ¶
func (x *IssueTrack) Reset()
func (*IssueTrack) String ¶
func (x *IssueTrack) String() string
type ProcessRequest ¶
type ProcessRequest struct {
// id is the minted request id to process. Canonical positive decimal string; queue is carried separately.
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:
// a canonical positive decimal string (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