protopb

package
v0.3.0-20260807201250-... Latest Latest
Warning

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

Go to latest
Published: Aug 7, 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_buildsignal_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 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"`
	// 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 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"`
	// 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:
	// "request/<queue>/<counter>" (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