Documentation
¶
Index ¶
- Variables
- type Batch
- type Build
- type BuildSignal
- type Cancel
- type Conclude
- type DependencyAnalysis
- func (*DependencyAnalysis) Descriptor() ([]byte, []int)deprecated
- func (x *DependencyAnalysis) GetId() string
- func (x *DependencyAnalysis) GetQueue() string
- func (*DependencyAnalysis) ProtoMessage()
- func (x *DependencyAnalysis) ProtoReflect() protoreflect.Message
- func (x *DependencyAnalysis) Reset()
- func (x *DependencyAnalysis) String() string
- type Log
- func (*Log) Descriptor() ([]byte, []int)deprecated
- func (x *Log) GetEvent() string
- func (x *Log) GetLastError() string
- func (x *Log) GetMetadata() map[string]string
- func (x *Log) GetQueue() string
- func (x *Log) GetRequestId() string
- func (x *Log) GetRequestVersion() int32
- func (x *Log) GetStatus() string
- func (x *Log) GetTimestampMs() int64
- func (x *Log) GetType() string
- func (*Log) ProtoMessage()
- func (x *Log) ProtoReflect() protoreflect.Message
- func (x *Log) Reset()
- func (x *Log) String() string
- type Merge
- type Speculate
- type Start
- func (*Start) Descriptor() ([]byte, []int)deprecated
- func (x *Start) GetChange() *protopb.Change
- func (x *Start) GetId() string
- func (x *Start) GetLandStrategy() protopb1.Strategy
- func (x *Start) GetQueue() string
- func (*Start) ProtoMessage()
- func (x *Start) ProtoReflect() protoreflect.Message
- func (x *Start) Reset()
- func (x *Start) String() string
- type Validate
Constants ¶
This section is empty.
Variables ¶
var File_batch_proto protoreflect.FileDescriptor
var File_cancel_proto protoreflect.FileDescriptor
var File_conclude_proto protoreflect.FileDescriptor
var File_dependencyanalysis_proto protoreflect.FileDescriptor
var File_log_proto protoreflect.FileDescriptor
var File_speculate_proto protoreflect.FileDescriptor
var File_start_proto protoreflect.FileDescriptor
var File_submitqueuebuild_proto protoreflect.FileDescriptor
var File_submitqueuebuildsignal_proto protoreflect.FileDescriptor
var File_submitqueuemerge_proto protoreflect.FileDescriptor
var File_validate_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Batch ¶
type Batch struct {
// id is the request id to enroll in a batch. Format: "<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Batch is the payload mergeconflictsignal publishes to the batch stage: only the request id travels. batch reloads the Request from storage.
func (*Batch) Descriptor
deprecated
func (*Batch) ProtoMessage ¶
func (*Batch) ProtoMessage()
func (*Batch) ProtoReflect ¶
func (x *Batch) ProtoReflect() protoreflect.Message
type Build ¶
type Build struct {
// id is the batch id whose speculated head should be built. Format: "<queue>/batch/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Build is the payload speculate publishes to the build stage: the id is a batch id. build reloads the Batch from storage.
func (*Build) Descriptor
deprecated
func (*Build) ProtoMessage ¶
func (*Build) ProtoMessage()
func (*Build) ProtoReflect ¶
func (x *Build) ProtoReflect() protoreflect.Message
type BuildSignal ¶
type BuildSignal struct {
// id is the build id to poll.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
BuildSignal is the payload build publishes to the buildsignal stage: the id is a build id. buildsignal reloads the Build from storage.
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) GetQueue ¶
func (x *BuildSignal) GetQueue() 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 Cancel ¶
type Cancel struct {
// id is the request id to cancel. Format: "<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// reason is an optional free-form explanation of why cancellation was requested.
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
Cancel is the payload the gateway publishes to the cancel stage.
func (*Cancel) Descriptor
deprecated
func (*Cancel) ProtoMessage ¶
func (*Cancel) ProtoMessage()
func (*Cancel) ProtoReflect ¶
func (x *Cancel) ProtoReflect() protoreflect.Message
type Conclude ¶
type Conclude struct {
// id is the batch id to conclude. Format: "<queue>/batch/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Conclude is the payload published to the conclude stage: the id is a batch id. conclude reloads the Batch from storage. A failed batch's reason travels in message metadata, not this payload.
func (*Conclude) Descriptor
deprecated
func (*Conclude) ProtoMessage ¶
func (*Conclude) ProtoMessage()
func (*Conclude) ProtoReflect ¶
func (x *Conclude) ProtoReflect() protoreflect.Message
type DependencyAnalysis ¶
type DependencyAnalysis struct {
// id is the batch id to analyze. Format: "<queue>/batch/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
DependencyAnalysis is the payload batch publishes to the dependency-analysis stage: only the batch id travels. The consumer reloads the Batch from storage.
func (*DependencyAnalysis) Descriptor
deprecated
func (*DependencyAnalysis) Descriptor() ([]byte, []int)
Deprecated: Use DependencyAnalysis.ProtoReflect.Descriptor instead.
func (*DependencyAnalysis) GetId ¶
func (x *DependencyAnalysis) GetId() string
func (*DependencyAnalysis) GetQueue ¶
func (x *DependencyAnalysis) GetQueue() string
func (*DependencyAnalysis) ProtoMessage ¶
func (*DependencyAnalysis) ProtoMessage()
func (*DependencyAnalysis) ProtoReflect ¶
func (x *DependencyAnalysis) ProtoReflect() protoreflect.Message
func (*DependencyAnalysis) Reset ¶
func (x *DependencyAnalysis) Reset()
func (*DependencyAnalysis) String ¶
func (x *DependencyAnalysis) String() string
type Log ¶
type Log struct {
// request_id is the request this entry belongs to.
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// queue is the name of the queue processing the request.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// timestamp_ms is when this entry was created, milliseconds since Unix epoch.
TimestampMs int64 `protobuf:"varint,3,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
// type is "status" or "event". An empty type is treated as "status".
Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
// status is the request status this entry records. Set only when type is "status".
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
// event is the event this entry records. Set only when type is "event".
Event string `protobuf:"bytes,6,opt,name=event,proto3" json:"event,omitempty"`
// request_version is the request entity version at this entry, or zero.
RequestVersion int32 `protobuf:"varint,7,opt,name=request_version,json=requestVersion,proto3" json:"request_version,omitempty"`
// last_error is the last error message associated with the status, or empty.
LastError string `protobuf:"bytes,8,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
// metadata is free-form additional context.
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
Log is the payload orchestrator stages publish to the log stage: a full request-log entry. The gateway materializes it; the seam crosses services, so the entry travels in full. type, status, and event are open strings matching the domain vocabularies (not proto enums), so additive values do not break existing consumers.
func (*Log) Descriptor
deprecated
func (*Log) GetLastError ¶
func (*Log) GetMetadata ¶
func (*Log) GetRequestId ¶
func (*Log) GetRequestVersion ¶
func (*Log) GetTimestampMs ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) ProtoReflect ¶
func (x *Log) ProtoReflect() protoreflect.Message
type Merge ¶
type Merge struct {
// id is the batch id to land. Format: "<queue>/batch/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Merge is the payload speculate publishes to the internal land stage: the id is a batch id. land reloads the Batch from storage before handing work to Runway.
func (*Merge) Descriptor
deprecated
func (*Merge) ProtoMessage ¶
func (*Merge) ProtoMessage()
func (*Merge) ProtoReflect ¶
func (x *Merge) ProtoReflect() protoreflect.Message
type Speculate ¶
type Speculate struct {
// id is the batch id to speculate. Format: "<queue>/batch/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Speculate is the payload published to the speculate stage: only the batch id travels. speculate reloads the Batch from storage.
func (*Speculate) Descriptor
deprecated
func (*Speculate) ProtoMessage ¶
func (*Speculate) ProtoMessage()
func (*Speculate) ProtoReflect ¶
func (x *Speculate) ProtoReflect() protoreflect.Message
type Start ¶
type Start struct {
// id is the minted request id. Format: "<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing the land request.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// change is the set of code changes to land.
Change *protopb.Change `protobuf:"bytes,3,opt,name=change,proto3" json:"change,omitempty"`
// land_strategy is the source-control integration strategy for every URI of change.
LandStrategy protopb1.Strategy `` /* 136-byte string literal not displayed */
// contains filtered or unexported fields
}
Start is the payload the gateway publishes to the start stage: the gateway-owned land inputs and the minted request id. start persists a Request from these fields; producer and consumer do not share a store at this seam.
func (*Start) Descriptor
deprecated
func (*Start) GetLandStrategy ¶
func (*Start) ProtoMessage ¶
func (*Start) ProtoMessage()
func (*Start) ProtoReflect ¶
func (x *Start) ProtoReflect() protoreflect.Message
type Validate ¶
type Validate struct {
// id is the request id to validate. Format: "<queue>/<counter>".
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// queue is the name of the queue processing this work, carried so the
// consumer can route by queue without loading state first. Empty on
// payloads written before the field existed.
Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
// contains filtered or unexported fields
}
Validate is the payload start publishes to the validate stage: only the request id travels. validate reloads the Request from storage.
func (*Validate) Descriptor
deprecated
func (*Validate) ProtoMessage ¶
func (*Validate) ProtoMessage()
func (*Validate) ProtoReflect ¶
func (x *Validate) ProtoReflect() protoreflect.Message