Help us shape the future of Go! Take the 2026 Go Developer Survey

protopb

package
v0.3.0-20261028150941-... Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_build_proto protoreflect.FileDescriptor
View Source
var File_buildanalysis_proto protoreflect.FileDescriptor
View Source
var File_buildsignal_proto protoreflect.FileDescriptor
View Source
var File_issuetrack_proto protoreflect.FileDescriptor
View Source
var File_process_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetId

func (x *Record) GetId() string

func (*Record) GetQueueName

func (x *Record) GetQueueName() string

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

Jump to

Keyboard shortcuts

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