protopb

package
v0.3.0-20261007222324-... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 7, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_batch_proto protoreflect.FileDescriptor
View Source
var File_cancel_proto protoreflect.FileDescriptor
View Source
var File_conclude_proto protoreflect.FileDescriptor
View Source
var File_dependencyanalysis_proto protoreflect.FileDescriptor
View Source
var File_speculate_proto protoreflect.FileDescriptor
View Source
var File_start_proto protoreflect.FileDescriptor
View Source
var File_submitqueuebuild_proto protoreflect.FileDescriptor
View Source
var File_submitqueuebuildsignal_proto protoreflect.FileDescriptor
View Source
var File_submitqueuemerge_proto protoreflect.FileDescriptor
View Source
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. Canonical positive decimal string; queue is carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Batch.ProtoReflect.Descriptor instead.

func (*Batch) GetId

func (x *Batch) GetId() string

func (*Batch) GetQueue

func (x *Batch) GetQueue() string

func (*Batch) ProtoMessage

func (*Batch) ProtoMessage()

func (*Batch) ProtoReflect

func (x *Batch) ProtoReflect() protoreflect.Message

func (*Batch) Reset

func (x *Batch) Reset()

func (*Batch) String

func (x *Batch) String() string

type Build

type Build struct {

	// id is the batch id whose speculated head should be built. Canonical positive decimal string; queue and kind are carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetId

func (x *Build) GetId() string

func (*Build) GetQueue

func (x *Build) GetQueue() string

func (*Build) ProtoMessage

func (*Build) ProtoMessage()

func (*Build) ProtoReflect

func (x *Build) ProtoReflect() protoreflect.Message

func (*Build) Reset

func (x *Build) Reset()

func (*Build) String

func (x *Build) String() string

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. Canonical positive decimal string; queue is carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Cancel.ProtoReflect.Descriptor instead.

func (*Cancel) GetId

func (x *Cancel) GetId() string

func (*Cancel) GetQueue

func (x *Cancel) GetQueue() string

func (*Cancel) GetReason

func (x *Cancel) GetReason() string

func (*Cancel) ProtoMessage

func (*Cancel) ProtoMessage()

func (*Cancel) ProtoReflect

func (x *Cancel) ProtoReflect() protoreflect.Message

func (*Cancel) Reset

func (x *Cancel) Reset()

func (*Cancel) String

func (x *Cancel) String() string

type Conclude

type Conclude struct {

	// id is the batch id to conclude. Canonical positive decimal string; queue and kind are carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Conclude.ProtoReflect.Descriptor instead.

func (*Conclude) GetId

func (x *Conclude) GetId() string

func (*Conclude) GetQueue

func (x *Conclude) GetQueue() string

func (*Conclude) ProtoMessage

func (*Conclude) ProtoMessage()

func (*Conclude) ProtoReflect

func (x *Conclude) ProtoReflect() protoreflect.Message

func (*Conclude) Reset

func (x *Conclude) Reset()

func (*Conclude) String

func (x *Conclude) String() string

type DependencyAnalysis

type DependencyAnalysis struct {

	// id is the batch id to analyze. Canonical positive decimal string; queue and kind are carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetEvent

func (x *Log) GetEvent() string

func (*Log) GetLastError

func (x *Log) GetLastError() string

func (*Log) GetMetadata

func (x *Log) GetMetadata() map[string]string

func (*Log) GetQueue

func (x *Log) GetQueue() string

func (*Log) GetRequestId

func (x *Log) GetRequestId() string

func (*Log) GetRequestVersion

func (x *Log) GetRequestVersion() int32

func (*Log) GetStatus

func (x *Log) GetStatus() string

func (*Log) GetTimestampMs

func (x *Log) GetTimestampMs() int64

func (*Log) GetType

func (x *Log) GetType() string

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

func (x *Log) ProtoReflect() protoreflect.Message

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

type Merge

type Merge struct {

	// id is the batch id to land. Canonical positive decimal string; queue and kind are carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Merge.ProtoReflect.Descriptor instead.

func (*Merge) GetId

func (x *Merge) GetId() string

func (*Merge) GetQueue

func (x *Merge) GetQueue() string

func (*Merge) ProtoMessage

func (*Merge) ProtoMessage()

func (*Merge) ProtoReflect

func (x *Merge) ProtoReflect() protoreflect.Message

func (*Merge) Reset

func (x *Merge) Reset()

func (*Merge) String

func (x *Merge) String() string

type Speculate

type Speculate struct {

	// id is the batch id to speculate. Canonical positive decimal string; queue and kind are carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Speculate.ProtoReflect.Descriptor instead.

func (*Speculate) GetId

func (x *Speculate) GetId() string

func (*Speculate) GetQueue

func (x *Speculate) GetQueue() string

func (*Speculate) ProtoMessage

func (*Speculate) ProtoMessage()

func (*Speculate) ProtoReflect

func (x *Speculate) ProtoReflect() protoreflect.Message

func (*Speculate) Reset

func (x *Speculate) Reset()

func (*Speculate) String

func (x *Speculate) String() string

type Start

type Start struct {

	// id is the minted request id. Canonical positive decimal string; queue is carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Start.ProtoReflect.Descriptor instead.

func (*Start) GetChange

func (x *Start) GetChange() *protopb.Change

func (*Start) GetId

func (x *Start) GetId() string

func (*Start) GetLandStrategy

func (x *Start) GetLandStrategy() protopb1.Strategy

func (*Start) GetQueue

func (x *Start) GetQueue() string

func (*Start) ProtoMessage

func (*Start) ProtoMessage()

func (*Start) ProtoReflect

func (x *Start) ProtoReflect() protoreflect.Message

func (*Start) Reset

func (x *Start) Reset()

func (*Start) String

func (x *Start) String() string

type Validate

type Validate struct {

	// id is the request id to validate. Canonical positive decimal string; queue is carried separately.
	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) Descriptor() ([]byte, []int)

Deprecated: Use Validate.ProtoReflect.Descriptor instead.

func (*Validate) GetId

func (x *Validate) GetId() string

func (*Validate) GetQueue

func (x *Validate) GetQueue() string

func (*Validate) ProtoMessage

func (*Validate) ProtoMessage()

func (*Validate) ProtoReflect

func (x *Validate) ProtoReflect() protoreflect.Message

func (*Validate) Reset

func (x *Validate) Reset()

func (*Validate) String

func (x *Validate) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL