rpc

package
v0.0.0-...-13f153f Latest Latest
Warning

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

Go to latest
Published: May 3, 2024 License: BSD-3-Clause Imports: 38 Imported by: 0

Documentation

Overview

Package rpc is a generated twirp stub package. This code was generated with github.com/twitchtv/twirp/protoc-gen-twirp v7.1.0.

It is generated from these files:

rpc.proto

Index

Constants

View Source
const AutoRollServicePathPrefix = "/twirp/autoroll.rpc.AutoRollService/"

AutoRollServicePathPrefix is a convenience constant that could used to identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, that add a "/twirp" prefix by default, and use CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html

Variables

View Source
var (
	Mode_name = map[int32]string{
		0: "RUNNING",
		1: "STOPPED",
		2: "DRY_RUN",
		3: "OFFLINE",
	}
	Mode_value = map[string]int32{
		"RUNNING": 0,
		"STOPPED": 1,
		"DRY_RUN": 2,
		"OFFLINE": 3,
	}
)

Enum value maps for Mode.

View Source
var (
	Strategy_name = map[int32]string{
		0: "BATCH",
		1: "N_BATCH",
		2: "SINGLE",
	}
	Strategy_value = map[string]int32{
		"BATCH":   0,
		"N_BATCH": 1,
		"SINGLE":  2,
	}
)

Enum value maps for Strategy.

View Source
var (
	TryJob_Result_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "FAILURE",
		3: "CANCELED",
	}
	TryJob_Result_value = map[string]int32{
		"UNKNOWN":  0,
		"SUCCESS":  1,
		"FAILURE":  2,
		"CANCELED": 3,
	}
)

Enum value maps for TryJob_Result.

View Source
var (
	TryJob_Status_name = map[int32]string{
		0: "SCHEDULED",
		1: "STARTED",
		2: "COMPLETED",
	}
	TryJob_Status_value = map[string]int32{
		"SCHEDULED": 0,
		"STARTED":   1,
		"COMPLETED": 2,
	}
)

Enum value maps for TryJob_Status.

View Source
var (
	AutoRollCL_Result_name = map[int32]string{
		0: "IN_PROGRESS",
		1: "SUCCESS",
		2: "FAILURE",
		3: "DRY_RUN_IN_PROGRESS",
		4: "DRY_RUN_SUCCESS",
		5: "DRY_RUN_FAILURE",
	}
	AutoRollCL_Result_value = map[string]int32{
		"IN_PROGRESS":         0,
		"SUCCESS":             1,
		"FAILURE":             2,
		"DRY_RUN_IN_PROGRESS": 3,
		"DRY_RUN_SUCCESS":     4,
		"DRY_RUN_FAILURE":     5,
	}
)

Enum value maps for AutoRollCL_Result.

View Source
var (
	ManualRoll_Result_name = map[int32]string{
		0: "UNKNOWN",
		1: "FAILURE",
		2: "SUCCESS",
	}
	ManualRoll_Result_value = map[string]int32{
		"UNKNOWN": 0,
		"FAILURE": 1,
		"SUCCESS": 2,
	}
)

Enum value maps for ManualRoll_Result.

View Source
var (
	ManualRoll_Status_name = map[int32]string{
		0: "PENDING",
		1: "STARTED",
		2: "COMPLETED",
	}
	ManualRoll_Status_value = map[string]int32{
		"PENDING":   0,
		"STARTED":   1,
		"COMPLETED": 2,
	}
)

Enum value maps for ManualRoll_Status.

Functions

func WriteError

func WriteError(resp http.ResponseWriter, err error)

WriteError writes an HTTP response with a valid Twirp error format (code, msg, meta). Useful outside of the Twirp server (e.g. http middleware), but does not trigger hooks. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)

Types

type AutoRollCL

type AutoRollCL struct {

	// id is the unique identifier for the CL.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// result of the AutoRollCL.
	Result AutoRollCL_Result `protobuf:"varint,2,opt,name=result,proto3,enum=autoroll.rpc.AutoRollCL_Result" json:"result,omitempty"`
	// subject line of the commit message of the AutoRollCL.
	Subject string `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	// rolling_to is the ID of the revision being rolled.
	RollingTo string `protobuf:"bytes,4,opt,name=rolling_to,json=rollingTo,proto3" json:"rolling_to,omitempty"`
	// rolling_from is the ID of the currently-pinned revision.
	RollingFrom string `protobuf:"bytes,5,opt,name=rolling_from,json=rollingFrom,proto3" json:"rolling_from,omitempty"`
	// created is the timestamp at which the AutoRollCL was created.
	Created *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	// created is the timestamp at which the AutoRollCL was last modified.
	Modified *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=modified,proto3" json:"modified,omitempty"`
	// try_jobs contains results of any try jobs for the AutoRollCL.
	TryJobs []*TryJob `protobuf:"bytes,8,rep,name=try_jobs,json=tryJobs,proto3" json:"try_jobs,omitempty"`
	// contains filtered or unexported fields
}

AutoRoll CL describes a CL uploaded by the autoroller.

func (*AutoRollCL) Descriptor deprecated

func (*AutoRollCL) Descriptor() ([]byte, []int)

Deprecated: Use AutoRollCL.ProtoReflect.Descriptor instead.

func (*AutoRollCL) GetCreated

func (x *AutoRollCL) GetCreated() *timestamppb.Timestamp

func (*AutoRollCL) GetId

func (x *AutoRollCL) GetId() string

func (*AutoRollCL) GetModified

func (x *AutoRollCL) GetModified() *timestamppb.Timestamp

func (*AutoRollCL) GetResult

func (x *AutoRollCL) GetResult() AutoRollCL_Result

func (*AutoRollCL) GetRollingFrom

func (x *AutoRollCL) GetRollingFrom() string

func (*AutoRollCL) GetRollingTo

func (x *AutoRollCL) GetRollingTo() string

func (*AutoRollCL) GetSubject

func (x *AutoRollCL) GetSubject() string

func (*AutoRollCL) GetTryJobs

func (x *AutoRollCL) GetTryJobs() []*TryJob

func (*AutoRollCL) ProtoMessage

func (*AutoRollCL) ProtoMessage()

func (*AutoRollCL) ProtoReflect

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

func (*AutoRollCL) Reset

func (x *AutoRollCL) Reset()

func (*AutoRollCL) String

func (x *AutoRollCL) String() string

type AutoRollCL_Result

type AutoRollCL_Result int32

Result describes the possible results for an AutoRollCL.

const (
	// IN_PROGRESS indicates that the commit queue is still running for this
	// AutoRollCL.
	AutoRollCL_IN_PROGRESS AutoRollCL_Result = 0
	// SUCCESS indicates that this AutoRollCL landed successfully.
	AutoRollCL_SUCCESS AutoRollCL_Result = 1
	// FAILURE indicates that the commit queue failed for  this AutoRollCL.
	AutoRollCL_FAILURE AutoRollCL_Result = 2
	// DRY_RUN_IN_PROGRESS indicates that the commit queue dry run is still
	// running for this AutoRollCL.
	AutoRollCL_DRY_RUN_IN_PROGRESS AutoRollCL_Result = 3
	// DRY_RUN_SUCCESS indicates that the commit queue dry run succeeded for
	// this AutoRollCL.
	AutoRollCL_DRY_RUN_SUCCESS AutoRollCL_Result = 4
	// DRY_RUN_FAILURE indicates that the commit queue dry run failed for this
	// AutoRollCL.
	AutoRollCL_DRY_RUN_FAILURE AutoRollCL_Result = 5
)

func (AutoRollCL_Result) Descriptor

func (AutoRollCL_Result) Enum

func (AutoRollCL_Result) EnumDescriptor deprecated

func (AutoRollCL_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use AutoRollCL_Result.Descriptor instead.

func (AutoRollCL_Result) Number

func (AutoRollCL_Result) String

func (x AutoRollCL_Result) String() string

func (AutoRollCL_Result) Type

type AutoRollConfig

type AutoRollConfig struct {

	// child_bug_link is a link to file a bug for the child project.
	ChildBugLink string `protobuf:"bytes,5,opt,name=child_bug_link,json=childBugLink,proto3" json:"child_bug_link,omitempty"`
	// parent_bug_link is a link to file a bug for the parent project.
	ParentBugLink string `protobuf:"bytes,6,opt,name=parent_bug_link,json=parentBugLink,proto3" json:"parent_bug_link,omitempty"`
	// parent_waterfall is the URL of the CI display for the parent repo.
	ParentWaterfall string `protobuf:"bytes,1,opt,name=parent_waterfall,json=parentWaterfall,proto3" json:"parent_waterfall,omitempty"`
	// roller_id is the unique identifier for the roller.
	RollerId string `protobuf:"bytes,2,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// supports_manual_rolls indicates whether this autoroller supports manually-
	// triggered rolls.
	SupportsManualRolls bool `protobuf:"varint,3,opt,name=supports_manual_rolls,json=supportsManualRolls,proto3" json:"supports_manual_rolls,omitempty"`
	// time_window describes the limitations, if any, on when the autoroller is
	// allowed to upload roll CLs.
	TimeWindow string `protobuf:"bytes,4,opt,name=time_window,json=timeWindow,proto3" json:"time_window,omitempty"`
	// valid_modes lists the valid modes for the roller. If not specified, all
	// modes are allowed.
	ValidModes []Mode `protobuf:"varint,7,rep,packed,name=valid_modes,json=validModes,proto3,enum=autoroll.rpc.Mode" json:"valid_modes,omitempty"`
	// contains filtered or unexported fields
}

AutoRollConfig describes the configuration for a roller.

func (*AutoRollConfig) Descriptor deprecated

func (*AutoRollConfig) Descriptor() ([]byte, []int)

Deprecated: Use AutoRollConfig.ProtoReflect.Descriptor instead.

func (x *AutoRollConfig) GetChildBugLink() string
func (x *AutoRollConfig) GetParentBugLink() string

func (*AutoRollConfig) GetParentWaterfall

func (x *AutoRollConfig) GetParentWaterfall() string

func (*AutoRollConfig) GetRollerId

func (x *AutoRollConfig) GetRollerId() string

func (*AutoRollConfig) GetSupportsManualRolls

func (x *AutoRollConfig) GetSupportsManualRolls() bool

func (*AutoRollConfig) GetTimeWindow

func (x *AutoRollConfig) GetTimeWindow() string

func (*AutoRollConfig) GetValidModes

func (x *AutoRollConfig) GetValidModes() []Mode

func (*AutoRollConfig) ProtoMessage

func (*AutoRollConfig) ProtoMessage()

func (*AutoRollConfig) ProtoReflect

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

func (*AutoRollConfig) Reset

func (x *AutoRollConfig) Reset()

func (*AutoRollConfig) String

func (x *AutoRollConfig) String() string

type AutoRollMiniStatus

type AutoRollMiniStatus struct {

	// roller_id is the unique ID for this roller.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// child_name is the display name of the child.
	ChildName string `protobuf:"bytes,2,opt,name=child_name,json=childName,proto3" json:"child_name,omitempty"`
	// parent_name is the display name of the parent.
	ParentName string `protobuf:"bytes,3,opt,name=parent_name,json=parentName,proto3" json:"parent_name,omitempty"`
	// mode is the currently-set operating mode of the roller.
	Mode Mode `protobuf:"varint,4,opt,name=mode,proto3,enum=autoroll.rpc.Mode" json:"mode,omitempty"`
	// current_roll_rev is the ID of the child revision which is being rolled in
	// the active roll CL.
	CurrentRollRev string `protobuf:"bytes,5,opt,name=current_roll_rev,json=currentRollRev,proto3" json:"current_roll_rev,omitempty"`
	// last_roll_rev is the ID of the child revision which is currently pinned by
	// the parent.
	LastRollRev string `protobuf:"bytes,6,opt,name=last_roll_rev,json=lastRollRev,proto3" json:"last_roll_rev,omitempty"`
	// num_failed is the number of consecutive roll failures.
	NumFailed int32 `protobuf:"varint,7,opt,name=num_failed,json=numFailed,proto3" json:"num_failed,omitempty"`
	// num_behind is the number of not-yet-rolled revisions.
	NumBehind int32 `protobuf:"varint,8,opt,name=num_behind,json=numBehind,proto3" json:"num_behind,omitempty"`
	// timestamp is the time at which the roller last reported its status.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// last_successful_roll_timestamp is the time at which the roller last rolled
	// successfully.
	LastSuccessfulRollTimestamp *timestamppb.Timestamp `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

AutoRollMiniStatus contains a subset of the information of AutoRollStatus.

func (*AutoRollMiniStatus) Descriptor deprecated

func (*AutoRollMiniStatus) Descriptor() ([]byte, []int)

Deprecated: Use AutoRollMiniStatus.ProtoReflect.Descriptor instead.

func (*AutoRollMiniStatus) GetChildName

func (x *AutoRollMiniStatus) GetChildName() string

func (*AutoRollMiniStatus) GetCurrentRollRev

func (x *AutoRollMiniStatus) GetCurrentRollRev() string

func (*AutoRollMiniStatus) GetLastRollRev

func (x *AutoRollMiniStatus) GetLastRollRev() string

func (*AutoRollMiniStatus) GetLastSuccessfulRollTimestamp

func (x *AutoRollMiniStatus) GetLastSuccessfulRollTimestamp() *timestamppb.Timestamp

func (*AutoRollMiniStatus) GetMode

func (x *AutoRollMiniStatus) GetMode() Mode

func (*AutoRollMiniStatus) GetNumBehind

func (x *AutoRollMiniStatus) GetNumBehind() int32

func (*AutoRollMiniStatus) GetNumFailed

func (x *AutoRollMiniStatus) GetNumFailed() int32

func (*AutoRollMiniStatus) GetParentName

func (x *AutoRollMiniStatus) GetParentName() string

func (*AutoRollMiniStatus) GetRollerId

func (x *AutoRollMiniStatus) GetRollerId() string

func (*AutoRollMiniStatus) GetTimestamp

func (x *AutoRollMiniStatus) GetTimestamp() *timestamppb.Timestamp

func (*AutoRollMiniStatus) ProtoMessage

func (*AutoRollMiniStatus) ProtoMessage()

func (*AutoRollMiniStatus) ProtoReflect

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

func (*AutoRollMiniStatus) Reset

func (x *AutoRollMiniStatus) Reset()

func (*AutoRollMiniStatus) String

func (x *AutoRollMiniStatus) String() string

type AutoRollServer

type AutoRollServer struct {
	*twirp_auth2.AuthHelper
	// contains filtered or unexported fields
}

AutoRollServer implements AutoRollRPCs.

func NewAutoRollServer

func NewAutoRollServer(ctx context.Context, statusDB status.DB, configDB db.DB, rollsDB recent_rolls.DB, manualRollDB manual.DB, throttle unthrottle.Throttle, configRefreshInterval time.Duration, plogin alogin.Login) (*AutoRollServer, error)

NewAutoRollServer returns an AutoRollServer instance. If configRefreshInterval is zero, the configs are not refreshed.

func (*AutoRollServer) CreateManualRoll

CreateManualRoll implements AutoRollRPCs.

func (*AutoRollServer) GetHandler

func (s *AutoRollServer) GetHandler() http.Handler

GetHandler returns the http.Handler for this AutoRollServer.

func (*AutoRollServer) GetMiniStatus

GetMiniStatus implements AutoRollRPCs.

func (*AutoRollServer) GetModeHistory

GetModeHistory implements AutoRollRPCs.

func (*AutoRollServer) GetRoller

func (s *AutoRollServer) GetRoller(roller string) (*AutoRoller, error)

GetRoller retrieves the given roller.

func (*AutoRollServer) GetRollers

GetRollers implements AutoRollRPCs.

func (*AutoRollServer) GetRolls

GetRolls implements AutoRollRPCs.

func (*AutoRollServer) GetStatus

GetStatus implements AutoRollRPCs.

func (*AutoRollServer) GetStrategyHistory

GetStrategyHistory implements AutoRollRPCs.

func (*AutoRollServer) SetMode

SetMode implements AutoRollRPCs.

func (*AutoRollServer) SetStrategy

SetStrategy implements AutoRollRPCs.

func (*AutoRollServer) Unthrottle

Unthrottle implements AutoRollRPCs.

type AutoRollService

type AutoRollService interface {
	// GetRollers retrieves AutoRollMiniStatuses for all known rollers.
	GetRollers(context.Context, *GetRollersRequest) (*GetRollersResponse, error)

	// GetRolls retrieves rolls from the database.
	GetRolls(context.Context, *GetRollsRequest) (*GetRollsResponse, error)

	// GetMiniStatus retrieves the AutoRollMiniStatus for one roller.
	GetMiniStatus(context.Context, *GetMiniStatusRequest) (*GetMiniStatusResponse, error)

	// GetStatus retrieves the AutoRollStatus for one roller.
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

	// SetMode sets the mode for a roller.
	SetMode(context.Context, *SetModeRequest) (*SetModeResponse, error)

	// GetModeHistory retrieves mode change history for a roller.
	GetModeHistory(context.Context, *GetModeHistoryRequest) (*GetModeHistoryResponse, error)

	// SetStrategy sets the strategy for a roller.
	SetStrategy(context.Context, *SetStrategyRequest) (*SetStrategyResponse, error)

	// GetStrategyHistory retrieves strategy change history for a roller.
	GetStrategyHistory(context.Context, *GetStrategyHistoryRequest) (*GetStrategyHistoryResponse, error)

	// CreateManualRoll initiates the creation of a manual roll.
	CreateManualRoll(context.Context, *CreateManualRollRequest) (*CreateManualRollResponse, error)

	// Unthrottle clears any throttling of the roller, allowing it to roll again.
	Unthrottle(context.Context, *UnthrottleRequest) (*UnthrottleResponse, error)
}

AutoRollService provides interactions with the AutoRoll frontend.

func NewAutoRollServiceJSONClient

func NewAutoRollServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) AutoRollService

NewAutoRollServiceJSONClient creates a JSON client that implements the AutoRollService interface. It communicates using JSON and can be configured with a custom HTTPClient.

func NewAutoRollServiceProtobufClient

func NewAutoRollServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) AutoRollService

NewAutoRollServiceProtobufClient creates a Protobuf client that implements the AutoRollService interface. It communicates using Protobuf and can be configured with a custom HTTPClient.

type AutoRollStatus

type AutoRollStatus struct {

	// mini_status contains a subset of status information for the autoroller.
	MiniStatus *AutoRollMiniStatus `protobuf:"bytes,1,opt,name=mini_status,json=miniStatus,proto3" json:"mini_status,omitempty"`
	// status is the current status of the autoroller, as provided by the state
	// machine.
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// config provides configuration information for the autoroller.
	Config *AutoRollConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// full_history_url is the URL where the autoroller's history may be viewed.
	FullHistoryUrl string `protobuf:"bytes,4,opt,name=full_history_url,json=fullHistoryUrl,proto3" json:"full_history_url,omitempty"`
	// issue_url_base provides a base URL which can be used to construct URLs for
	// individual AutoRollCLs.
	IssueUrlBase string `protobuf:"bytes,5,opt,name=issue_url_base,json=issueUrlBase,proto3" json:"issue_url_base,omitempty"`
	// mode is the current operating mode of the autoroller.
	Mode *ModeChange `protobuf:"bytes,6,opt,name=mode,proto3" json:"mode,omitempty"`
	// strategy for choosing the next revision to roll.
	Strategy *StrategyChange `protobuf:"bytes,7,opt,name=strategy,proto3" json:"strategy,omitempty"`
	// not_rolled_revisions are the revisions of the Child which have not yet been
	// rolled.
	NotRolledRevisions []*Revision `protobuf:"bytes,8,rep,name=not_rolled_revisions,json=notRolledRevisions,proto3" json:"not_rolled_revisions,omitempty"`
	// current_roll is the active roll CL, if any.
	CurrentRoll *AutoRollCL `protobuf:"bytes,9,opt,name=current_roll,json=currentRoll,proto3" json:"current_roll,omitempty"`
	// last_roll is the previous roll CL.
	LastRoll *AutoRollCL `protobuf:"bytes,10,opt,name=last_roll,json=lastRoll,proto3" json:"last_roll,omitempty"`
	// recent_rolls contains a list of recent roll CLs.
	RecentRolls []*AutoRollCL `protobuf:"bytes,11,rep,name=recent_rolls,json=recentRolls,proto3" json:"recent_rolls,omitempty"`
	// manual_rolls contains a list of recent ManualRolls.
	ManualRolls []*ManualRoll `protobuf:"bytes,12,rep,name=manual_rolls,json=manualRolls,proto3" json:"manual_rolls,omitempty"`
	// error contains a detailed message if the autoroller is in an error state.
	Error string `protobuf:"bytes,13,opt,name=error,proto3" json:"error,omitempty"`
	// throttled_until is the timestamp at which the autoroller will no longer be
	// throttled, if the autoroller is currently throttled.
	ThrottledUntil *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=throttled_until,json=throttledUntil,proto3" json:"throttled_until,omitempty"`
	// contains filtered or unexported fields
}

AutoRollStatus describes the overall status of an autoroller.

func (*AutoRollStatus) Descriptor deprecated

func (*AutoRollStatus) Descriptor() ([]byte, []int)

Deprecated: Use AutoRollStatus.ProtoReflect.Descriptor instead.

func (*AutoRollStatus) GetConfig

func (x *AutoRollStatus) GetConfig() *AutoRollConfig

func (*AutoRollStatus) GetCurrentRoll

func (x *AutoRollStatus) GetCurrentRoll() *AutoRollCL

func (*AutoRollStatus) GetError

func (x *AutoRollStatus) GetError() string

func (*AutoRollStatus) GetFullHistoryUrl

func (x *AutoRollStatus) GetFullHistoryUrl() string

func (*AutoRollStatus) GetIssueUrlBase

func (x *AutoRollStatus) GetIssueUrlBase() string

func (*AutoRollStatus) GetLastRoll

func (x *AutoRollStatus) GetLastRoll() *AutoRollCL

func (*AutoRollStatus) GetManualRolls

func (x *AutoRollStatus) GetManualRolls() []*ManualRoll

func (*AutoRollStatus) GetMiniStatus

func (x *AutoRollStatus) GetMiniStatus() *AutoRollMiniStatus

func (*AutoRollStatus) GetMode

func (x *AutoRollStatus) GetMode() *ModeChange

func (*AutoRollStatus) GetNotRolledRevisions

func (x *AutoRollStatus) GetNotRolledRevisions() []*Revision

func (*AutoRollStatus) GetRecentRolls

func (x *AutoRollStatus) GetRecentRolls() []*AutoRollCL

func (*AutoRollStatus) GetStatus

func (x *AutoRollStatus) GetStatus() string

func (*AutoRollStatus) GetStrategy

func (x *AutoRollStatus) GetStrategy() *StrategyChange

func (*AutoRollStatus) GetThrottledUntil

func (x *AutoRollStatus) GetThrottledUntil() *timestamppb.Timestamp

func (*AutoRollStatus) ProtoMessage

func (*AutoRollStatus) ProtoMessage()

func (*AutoRollStatus) ProtoReflect

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

func (*AutoRollStatus) Reset

func (x *AutoRollStatus) Reset()

func (*AutoRollStatus) String

func (x *AutoRollStatus) String() string

type AutoRoller

type AutoRoller struct {
	Cfg *config.Config

	// Interactions with the roller through the DB.
	Mode     modes.ModeHistory
	Status   *status.Cache
	Strategy strategy.StrategyHistory
}

AutoRoller provides interactions with a single roller.

type CreateManualRollRequest

type CreateManualRollRequest struct {

	// roller_id is the unique identifier of the autoroller which should create
	// the manual roll.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// revision is the ID of the revision to be rolled.
	Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	// dry_run flag controls whether the roll is a dry-run.
	DryRun bool `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

CreateManualRollRequest is a request to CreateManualRoll.

func (*CreateManualRollRequest) Descriptor deprecated

func (*CreateManualRollRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateManualRollRequest.ProtoReflect.Descriptor instead.

func (*CreateManualRollRequest) GetDryRun

func (x *CreateManualRollRequest) GetDryRun() bool

func (*CreateManualRollRequest) GetRevision

func (x *CreateManualRollRequest) GetRevision() string

func (*CreateManualRollRequest) GetRollerId

func (x *CreateManualRollRequest) GetRollerId() string

func (*CreateManualRollRequest) ProtoMessage

func (*CreateManualRollRequest) ProtoMessage()

func (*CreateManualRollRequest) ProtoReflect

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

func (*CreateManualRollRequest) Reset

func (x *CreateManualRollRequest) Reset()

func (*CreateManualRollRequest) String

func (x *CreateManualRollRequest) String() string

type CreateManualRollResponse

type CreateManualRollResponse struct {

	// roll is the manual roll which was created.
	Roll *ManualRoll `protobuf:"bytes,1,opt,name=roll,proto3" json:"roll,omitempty"`
	// contains filtered or unexported fields
}

CreateManualRollResponse is a response returned by CreateManualRoll.

func (*CreateManualRollResponse) Descriptor deprecated

func (*CreateManualRollResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateManualRollResponse.ProtoReflect.Descriptor instead.

func (*CreateManualRollResponse) GetRoll

func (x *CreateManualRollResponse) GetRoll() *ManualRoll

func (*CreateManualRollResponse) ProtoMessage

func (*CreateManualRollResponse) ProtoMessage()

func (*CreateManualRollResponse) ProtoReflect

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

func (*CreateManualRollResponse) Reset

func (x *CreateManualRollResponse) Reset()

func (*CreateManualRollResponse) String

func (x *CreateManualRollResponse) String() string

type GetMiniStatusRequest

type GetMiniStatusRequest struct {

	// roller_id is the unique identifier of the autoroller whose MiniStatus is to
	// be retrieved.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// contains filtered or unexported fields
}

GetMiniStatusRequest is a request to GetMiniStatus.

func (*GetMiniStatusRequest) Descriptor deprecated

func (*GetMiniStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMiniStatusRequest.ProtoReflect.Descriptor instead.

func (*GetMiniStatusRequest) GetRollerId

func (x *GetMiniStatusRequest) GetRollerId() string

func (*GetMiniStatusRequest) ProtoMessage

func (*GetMiniStatusRequest) ProtoMessage()

func (*GetMiniStatusRequest) ProtoReflect

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

func (*GetMiniStatusRequest) Reset

func (x *GetMiniStatusRequest) Reset()

func (*GetMiniStatusRequest) String

func (x *GetMiniStatusRequest) String() string

type GetMiniStatusResponse

type GetMiniStatusResponse struct {

	// status is a subset of status information for the autoroller in question.
	Status *AutoRollMiniStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

GetMiniStatusResponse is a response returned by GetMiniStatus.

func (*GetMiniStatusResponse) Descriptor deprecated

func (*GetMiniStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetMiniStatusResponse.ProtoReflect.Descriptor instead.

func (*GetMiniStatusResponse) GetStatus

func (x *GetMiniStatusResponse) GetStatus() *AutoRollMiniStatus

func (*GetMiniStatusResponse) ProtoMessage

func (*GetMiniStatusResponse) ProtoMessage()

func (*GetMiniStatusResponse) ProtoReflect

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

func (*GetMiniStatusResponse) Reset

func (x *GetMiniStatusResponse) Reset()

func (*GetMiniStatusResponse) String

func (x *GetMiniStatusResponse) String() string

type GetModeHistoryRequest

type GetModeHistoryRequest struct {
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	Offset   int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

GetModeHistoryRequest is a request to GetModeHistory.

func (*GetModeHistoryRequest) Descriptor deprecated

func (*GetModeHistoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetModeHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetModeHistoryRequest) GetOffset

func (x *GetModeHistoryRequest) GetOffset() int32

func (*GetModeHistoryRequest) GetRollerId

func (x *GetModeHistoryRequest) GetRollerId() string

func (*GetModeHistoryRequest) ProtoMessage

func (*GetModeHistoryRequest) ProtoMessage()

func (*GetModeHistoryRequest) ProtoReflect

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

func (*GetModeHistoryRequest) Reset

func (x *GetModeHistoryRequest) Reset()

func (*GetModeHistoryRequest) String

func (x *GetModeHistoryRequest) String() string

type GetModeHistoryResponse

type GetModeHistoryResponse struct {
	History    []*ModeChange `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
	NextOffset int32         `protobuf:"varint,2,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty"`
	// contains filtered or unexported fields
}

GetModeHistoryResponse is a response returned by GetModeHistory.

func (*GetModeHistoryResponse) Descriptor deprecated

func (*GetModeHistoryResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetModeHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetModeHistoryResponse) GetHistory

func (x *GetModeHistoryResponse) GetHistory() []*ModeChange

func (*GetModeHistoryResponse) GetNextOffset

func (x *GetModeHistoryResponse) GetNextOffset() int32

func (*GetModeHistoryResponse) ProtoMessage

func (*GetModeHistoryResponse) ProtoMessage()

func (*GetModeHistoryResponse) ProtoReflect

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

func (*GetModeHistoryResponse) Reset

func (x *GetModeHistoryResponse) Reset()

func (*GetModeHistoryResponse) String

func (x *GetModeHistoryResponse) String() string

type GetRollersRequest

type GetRollersRequest struct {
	// contains filtered or unexported fields
}

GetRollersRequest is a request to GetRollers.

func (*GetRollersRequest) Descriptor deprecated

func (*GetRollersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRollersRequest.ProtoReflect.Descriptor instead.

func (*GetRollersRequest) ProtoMessage

func (*GetRollersRequest) ProtoMessage()

func (*GetRollersRequest) ProtoReflect

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

func (*GetRollersRequest) Reset

func (x *GetRollersRequest) Reset()

func (*GetRollersRequest) String

func (x *GetRollersRequest) String() string

type GetRollersResponse

type GetRollersResponse struct {

	// rollers contains status information for all known autorollers.
	Rollers []*AutoRollMiniStatus `protobuf:"bytes,1,rep,name=rollers,proto3" json:"rollers,omitempty"`
	// contains filtered or unexported fields
}

GetRollersResponse is a response returned by GetRollers.

func (*GetRollersResponse) Descriptor deprecated

func (*GetRollersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRollersResponse.ProtoReflect.Descriptor instead.

func (*GetRollersResponse) GetRollers

func (x *GetRollersResponse) GetRollers() []*AutoRollMiniStatus

func (*GetRollersResponse) ProtoMessage

func (*GetRollersResponse) ProtoMessage()

func (*GetRollersResponse) ProtoReflect

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

func (*GetRollersResponse) Reset

func (x *GetRollersResponse) Reset()

func (*GetRollersResponse) String

func (x *GetRollersResponse) String() string

type GetRollsRequest

type GetRollsRequest struct {

	// roller_id is the unique identifier of the autoroller whose rolls are to be
	// retrieved.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// cursor is a database-provided cursor used for pagination.
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

GetRollsRequest is a request to GetRolls.

func (*GetRollsRequest) Descriptor deprecated

func (*GetRollsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRollsRequest.ProtoReflect.Descriptor instead.

func (*GetRollsRequest) GetCursor

func (x *GetRollsRequest) GetCursor() string

func (*GetRollsRequest) GetRollerId

func (x *GetRollsRequest) GetRollerId() string

func (*GetRollsRequest) ProtoMessage

func (*GetRollsRequest) ProtoMessage()

func (*GetRollsRequest) ProtoReflect

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

func (*GetRollsRequest) Reset

func (x *GetRollsRequest) Reset()

func (*GetRollsRequest) String

func (x *GetRollsRequest) String() string

type GetRollsResponse

type GetRollsResponse struct {

	// rolls are the rolls retrieved from the database.
	Rolls []*AutoRollCL `protobuf:"bytes,1,rep,name=rolls,proto3" json:"rolls,omitempty"`
	// cursor is a database-provided cursor which can be provided to the next call
	// to GetRolls to load more rolls.
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

GetRollsResponse is a response returned by GetRolls.

func (*GetRollsResponse) Descriptor deprecated

func (*GetRollsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRollsResponse.ProtoReflect.Descriptor instead.

func (*GetRollsResponse) GetCursor

func (x *GetRollsResponse) GetCursor() string

func (*GetRollsResponse) GetRolls

func (x *GetRollsResponse) GetRolls() []*AutoRollCL

func (*GetRollsResponse) ProtoMessage

func (*GetRollsResponse) ProtoMessage()

func (*GetRollsResponse) ProtoReflect

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

func (*GetRollsResponse) Reset

func (x *GetRollsResponse) Reset()

func (*GetRollsResponse) String

func (x *GetRollsResponse) String() string

type GetStatusRequest

type GetStatusRequest struct {

	// roller_id is the unique identifier of the autoroller whose Status is to be
	// retrieved.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// contains filtered or unexported fields
}

GetStatusRequest is a request to GetStatus.

func (*GetStatusRequest) Descriptor deprecated

func (*GetStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) GetRollerId

func (x *GetStatusRequest) GetRollerId() string

func (*GetStatusRequest) ProtoMessage

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect

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

func (*GetStatusRequest) Reset

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String

func (x *GetStatusRequest) String() string

type GetStatusResponse

type GetStatusResponse struct {

	// status information about the autoroller in question.
	Status *AutoRollStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

GetStatusResponse is a response returned by GetStatus.

func (*GetStatusResponse) Descriptor deprecated

func (*GetStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetStatus

func (x *GetStatusResponse) GetStatus() *AutoRollStatus

func (*GetStatusResponse) ProtoMessage

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect

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

func (*GetStatusResponse) Reset

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String

func (x *GetStatusResponse) String() string

type GetStrategyHistoryRequest

type GetStrategyHistoryRequest struct {
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	Offset   int32  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

GetStrategyHistoryRequest is a request to GetStrategyHistory.

func (*GetStrategyHistoryRequest) Descriptor deprecated

func (*GetStrategyHistoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStrategyHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetStrategyHistoryRequest) GetOffset

func (x *GetStrategyHistoryRequest) GetOffset() int32

func (*GetStrategyHistoryRequest) GetRollerId

func (x *GetStrategyHistoryRequest) GetRollerId() string

func (*GetStrategyHistoryRequest) ProtoMessage

func (*GetStrategyHistoryRequest) ProtoMessage()

func (*GetStrategyHistoryRequest) ProtoReflect

func (*GetStrategyHistoryRequest) Reset

func (x *GetStrategyHistoryRequest) Reset()

func (*GetStrategyHistoryRequest) String

func (x *GetStrategyHistoryRequest) String() string

type GetStrategyHistoryResponse

type GetStrategyHistoryResponse struct {
	History    []*StrategyChange `protobuf:"bytes,1,rep,name=history,proto3" json:"history,omitempty"`
	NextOffset int32             `protobuf:"varint,2,opt,name=next_offset,json=nextOffset,proto3" json:"next_offset,omitempty"`
	// contains filtered or unexported fields
}

GetStrategyHistoryResponse is a response returned by GetStrategyHistory.

func (*GetStrategyHistoryResponse) Descriptor deprecated

func (*GetStrategyHistoryResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStrategyHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetStrategyHistoryResponse) GetHistory

func (x *GetStrategyHistoryResponse) GetHistory() []*StrategyChange

func (*GetStrategyHistoryResponse) GetNextOffset

func (x *GetStrategyHistoryResponse) GetNextOffset() int32

func (*GetStrategyHistoryResponse) ProtoMessage

func (*GetStrategyHistoryResponse) ProtoMessage()

func (*GetStrategyHistoryResponse) ProtoReflect

func (*GetStrategyHistoryResponse) Reset

func (x *GetStrategyHistoryResponse) Reset()

func (*GetStrategyHistoryResponse) String

func (x *GetStrategyHistoryResponse) String() string

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.

HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.

type ManualRoll

type ManualRoll struct {

	// id is the unique identifier for this ManualRoll.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// roller_id is the unique identifier for the autoroller on which this
	// ManualRoll was requested.
	RollerId string `protobuf:"bytes,2,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// revision is the ID of the revision to which this ManualRoll will roll.
	Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// requester is the email address of the person who requested the ManualRoll.
	Requester string `protobuf:"bytes,4,opt,name=requester,proto3" json:"requester,omitempty"`
	// result of the ManualRoll.
	Result ManualRoll_Result `protobuf:"varint,5,opt,name=result,proto3,enum=autoroll.rpc.ManualRoll_Result" json:"result,omitempty"`
	// status of the ManualRoll.
	Status ManualRoll_Status `protobuf:"varint,6,opt,name=status,proto3,enum=autoroll.rpc.ManualRoll_Status" json:"status,omitempty"`
	// timestamp at which the ManualRoll was created.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// url of the ManualRoll, if a roll has been uploaded.
	Url string `protobuf:"bytes,8,opt,name=url,proto3" json:"url,omitempty"`
	// dry_run indicates whether the ManualRoll should be performed as a dry run,
	// so that the commit queue runs but the CL is not landed.
	DryRun bool `protobuf:"varint,9,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// no_email specifies that the requester and reviewers should not receive
	// email related to this ManualRoll.
	NoEmail bool `protobuf:"varint,10,opt,name=no_email,json=noEmail,proto3" json:"no_email,omitempty"`
	// no_resolve_revision specifies that the autoroller should not attempt to
	// find the requested revision ID in the Child but should simply use it as
	// provided.
	NoResolveRevision bool `protobuf:"varint,11,opt,name=no_resolve_revision,json=noResolveRevision,proto3" json:"no_resolve_revision,omitempty"`
	// canary indicates that this manual roll was a canary request.
	Canary bool `protobuf:"varint,12,opt,name=canary,proto3" json:"canary,omitempty"`
	// contains filtered or unexported fields
}

ManualRoll describes a manually-triggered roll and its results.

func (*ManualRoll) Descriptor deprecated

func (*ManualRoll) Descriptor() ([]byte, []int)

Deprecated: Use ManualRoll.ProtoReflect.Descriptor instead.

func (*ManualRoll) GetCanary

func (x *ManualRoll) GetCanary() bool

func (*ManualRoll) GetDryRun

func (x *ManualRoll) GetDryRun() bool

func (*ManualRoll) GetId

func (x *ManualRoll) GetId() string

func (*ManualRoll) GetNoEmail

func (x *ManualRoll) GetNoEmail() bool

func (*ManualRoll) GetNoResolveRevision

func (x *ManualRoll) GetNoResolveRevision() bool

func (*ManualRoll) GetRequester

func (x *ManualRoll) GetRequester() string

func (*ManualRoll) GetResult

func (x *ManualRoll) GetResult() ManualRoll_Result

func (*ManualRoll) GetRevision

func (x *ManualRoll) GetRevision() string

func (*ManualRoll) GetRollerId

func (x *ManualRoll) GetRollerId() string

func (*ManualRoll) GetStatus

func (x *ManualRoll) GetStatus() ManualRoll_Status

func (*ManualRoll) GetTimestamp

func (x *ManualRoll) GetTimestamp() *timestamppb.Timestamp

func (*ManualRoll) GetUrl

func (x *ManualRoll) GetUrl() string

func (*ManualRoll) ProtoMessage

func (*ManualRoll) ProtoMessage()

func (*ManualRoll) ProtoReflect

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

func (*ManualRoll) Reset

func (x *ManualRoll) Reset()

func (*ManualRoll) String

func (x *ManualRoll) String() string

type ManualRoll_Result

type ManualRoll_Result int32

Result describes the possible results for a manual roll. These must be kept in sync with autoroll/go/manual/db.go.

const (
	// UNKNOWN indicates that the result of the ManualRoll is unknown, ie. it
	// has not yet finished.
	ManualRoll_UNKNOWN ManualRoll_Result = 0
	// FAILURE indicates that the ManualRoll has failed.
	ManualRoll_FAILURE ManualRoll_Result = 1
	// SUCCESS indicates that the ManualRoll landed successfully.
	ManualRoll_SUCCESS ManualRoll_Result = 2
)

func (ManualRoll_Result) Descriptor

func (ManualRoll_Result) Enum

func (ManualRoll_Result) EnumDescriptor deprecated

func (ManualRoll_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use ManualRoll_Result.Descriptor instead.

func (ManualRoll_Result) Number

func (ManualRoll_Result) String

func (x ManualRoll_Result) String() string

func (ManualRoll_Result) Type

type ManualRoll_Status

type ManualRoll_Status int32

Status describes the lifecycle states of a manual roll. These must be kept in sync with autoroll/go/manual/db.go.

const (
	// PENDING indicates that the ManualRoll has been requested but no CL has
	// been uploaded.
	ManualRoll_PENDING ManualRoll_Status = 0
	// STARTED indicates that a CL has been uploaded for this ManualRoll.
	ManualRoll_STARTED ManualRoll_Status = 1
	// COMPLETED indicates that the ManualRoll has finished and either landed
	// successfully or failed.
	ManualRoll_COMPLETED ManualRoll_Status = 2
)

func (ManualRoll_Status) Descriptor

func (ManualRoll_Status) Enum

func (ManualRoll_Status) EnumDescriptor deprecated

func (ManualRoll_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ManualRoll_Status.Descriptor instead.

func (ManualRoll_Status) Number

func (ManualRoll_Status) String

func (x ManualRoll_Status) String() string

func (ManualRoll_Status) Type

type Mode

type Mode int32

Mode describes the valid operating modes of an autoroller. These must be kept in sync with autoroll/go/modes/modes.go.

const (
	// RUNNING is the typical operating mode of the autoroller. It will upload and
	// land CLs as new revisions appear in the Child.
	Mode_RUNNING Mode = 0
	// STOPPED prevents the autoroller from uploading any CLs. The roller will
	// continue to update any local checkouts to prevent them from getting too far
	// out of date, and any requested manual rolls will be fulfilled.
	Mode_STOPPED Mode = 1
	// DRY_RUN is similar to RUNNING but does not land the roll CLs after the
	// commit queue finishes. Instead, the active roll is left open until new
	// revisions appear in the child, at which point the roll is closed and a new
	// one is uploaded.
	Mode_DRY_RUN Mode = 2
	// OFFLINE is similar to STOPPED, but the roller does not update its checkouts
	// and requests for manual rolls are ignored.
	Mode_OFFLINE Mode = 3
)

func (Mode) Descriptor

func (Mode) Descriptor() protoreflect.EnumDescriptor

func (Mode) Enum

func (x Mode) Enum() *Mode

func (Mode) EnumDescriptor deprecated

func (Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Mode.Descriptor instead.

func (Mode) Number

func (x Mode) Number() protoreflect.EnumNumber

func (Mode) String

func (x Mode) String() string

func (Mode) Type

func (Mode) Type() protoreflect.EnumType

type ModeChange

type ModeChange struct {

	// roller_id is the unique identifier for the autoroller.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// mode is the operating mode of the autoroller which was set in this
	// ModeChange.
	Mode Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=autoroll.rpc.Mode" json:"mode,omitempty"`
	// user is the email address of the user who created this ModeChange.
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// time is the timestamp at which the ModeChange was created.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// message is a user-created message which describes the reason for changing
	// the mode.
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ModeChange describes one instance of an autoroller's mode being changed.

func (*ModeChange) Descriptor deprecated

func (*ModeChange) Descriptor() ([]byte, []int)

Deprecated: Use ModeChange.ProtoReflect.Descriptor instead.

func (*ModeChange) GetMessage

func (x *ModeChange) GetMessage() string

func (*ModeChange) GetMode

func (x *ModeChange) GetMode() Mode

func (*ModeChange) GetRollerId

func (x *ModeChange) GetRollerId() string

func (*ModeChange) GetTime

func (x *ModeChange) GetTime() *timestamppb.Timestamp

func (*ModeChange) GetUser

func (x *ModeChange) GetUser() string

func (*ModeChange) ProtoMessage

func (*ModeChange) ProtoMessage()

func (*ModeChange) ProtoReflect

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

func (*ModeChange) Reset

func (x *ModeChange) Reset()

func (*ModeChange) String

func (x *ModeChange) String() string

type Revision

type Revision struct {

	// id is the unique identifier for the Revision.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// display is a human-friendly display name for the Revision.
	Display string `protobuf:"bytes,2,opt,name=display,proto3" json:"display,omitempty"`
	// description is a longer description of the Revision.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// time is the timestamp at which the Revision was created.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// url where more details can be found about the Revision.
	Url string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// invalid_reason, if set, indicates why this Revision is not valid.
	InvalidReason string `protobuf:"bytes,6,opt,name=invalid_reason,json=invalidReason,proto3" json:"invalid_reason,omitempty"`
	// contains filtered or unexported fields
}

Revision describes a single revision in a given Child. This may be a Git commit, CIPD package instance, a file uploaded to GCS, etc.

func (*Revision) Descriptor deprecated

func (*Revision) Descriptor() ([]byte, []int)

Deprecated: Use Revision.ProtoReflect.Descriptor instead.

func (*Revision) GetDescription

func (x *Revision) GetDescription() string

func (*Revision) GetDisplay

func (x *Revision) GetDisplay() string

func (*Revision) GetId

func (x *Revision) GetId() string

func (*Revision) GetInvalidReason

func (x *Revision) GetInvalidReason() string

func (*Revision) GetTime

func (x *Revision) GetTime() *timestamppb.Timestamp

func (*Revision) GetUrl

func (x *Revision) GetUrl() string

func (*Revision) ProtoMessage

func (*Revision) ProtoMessage()

func (*Revision) ProtoReflect

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

func (*Revision) Reset

func (x *Revision) Reset()

func (*Revision) String

func (x *Revision) String() string

type SetModeRequest

type SetModeRequest struct {

	// roller_id is the unique identifier of the autoroller whose mode is to be
	// changed.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// mode is the desired mode to set for the given autoroller.
	Mode Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=autoroll.rpc.Mode" json:"mode,omitempty"`
	// message describes the reason for changing the mode.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

SetModeRequest is a request to SetMode.

func (*SetModeRequest) Descriptor deprecated

func (*SetModeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetModeRequest.ProtoReflect.Descriptor instead.

func (*SetModeRequest) GetMessage

func (x *SetModeRequest) GetMessage() string

func (*SetModeRequest) GetMode

func (x *SetModeRequest) GetMode() Mode

func (*SetModeRequest) GetRollerId

func (x *SetModeRequest) GetRollerId() string

func (*SetModeRequest) ProtoMessage

func (*SetModeRequest) ProtoMessage()

func (*SetModeRequest) ProtoReflect

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

func (*SetModeRequest) Reset

func (x *SetModeRequest) Reset()

func (*SetModeRequest) String

func (x *SetModeRequest) String() string

type SetModeResponse

type SetModeResponse struct {

	// status is the updated status of the autoroller after changing its mode.
	Status *AutoRollStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SetModeResponse is a response returned by SetMode.

func (*SetModeResponse) Descriptor deprecated

func (*SetModeResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetModeResponse.ProtoReflect.Descriptor instead.

func (*SetModeResponse) GetStatus

func (x *SetModeResponse) GetStatus() *AutoRollStatus

func (*SetModeResponse) ProtoMessage

func (*SetModeResponse) ProtoMessage()

func (*SetModeResponse) ProtoReflect

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

func (*SetModeResponse) Reset

func (x *SetModeResponse) Reset()

func (*SetModeResponse) String

func (x *SetModeResponse) String() string

type SetStrategyRequest

type SetStrategyRequest struct {

	// roller_id is the unique identifier of the autoroller whose strategy is to
	// be changed.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// strategy is the desired strategy to set for the given autoroller.
	Strategy Strategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=autoroll.rpc.Strategy" json:"strategy,omitempty"`
	// message describes the reason for changing the strategy.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

SetStrategyRequest is a request to SetStrategy.

func (*SetStrategyRequest) Descriptor deprecated

func (*SetStrategyRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetStrategyRequest.ProtoReflect.Descriptor instead.

func (*SetStrategyRequest) GetMessage

func (x *SetStrategyRequest) GetMessage() string

func (*SetStrategyRequest) GetRollerId

func (x *SetStrategyRequest) GetRollerId() string

func (*SetStrategyRequest) GetStrategy

func (x *SetStrategyRequest) GetStrategy() Strategy

func (*SetStrategyRequest) ProtoMessage

func (*SetStrategyRequest) ProtoMessage()

func (*SetStrategyRequest) ProtoReflect

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

func (*SetStrategyRequest) Reset

func (x *SetStrategyRequest) Reset()

func (*SetStrategyRequest) String

func (x *SetStrategyRequest) String() string

type SetStrategyResponse

type SetStrategyResponse struct {

	// status is the updated status of the autoroller after changing its strategy.
	Status *AutoRollStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SetStrategyResponse is a response returned by SetStrategy.

func (*SetStrategyResponse) Descriptor deprecated

func (*SetStrategyResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetStrategyResponse.ProtoReflect.Descriptor instead.

func (*SetStrategyResponse) GetStatus

func (x *SetStrategyResponse) GetStatus() *AutoRollStatus

func (*SetStrategyResponse) ProtoMessage

func (*SetStrategyResponse) ProtoMessage()

func (*SetStrategyResponse) ProtoReflect

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

func (*SetStrategyResponse) Reset

func (x *SetStrategyResponse) Reset()

func (*SetStrategyResponse) String

func (x *SetStrategyResponse) String() string

type Strategy

type Strategy int32

Strategy describes the valid strategies for choosing the next revision to roll. These must be kept in sync with autoroll/go/strategy/strategies.go.

const (
	// BATCH indicates that all not-yet-rolled revisions should be rolled in a
	// single CL.
	Strategy_BATCH Strategy = 0
	// N_BATCH is similar to BATCH but puts a limit on the number of revisions in
	// a single CL.
	Strategy_N_BATCH Strategy = 1
	// SINGLE indicates that a single revision is rolled in each CL.
	Strategy_SINGLE Strategy = 2
)

func (Strategy) Descriptor

func (Strategy) Descriptor() protoreflect.EnumDescriptor

func (Strategy) Enum

func (x Strategy) Enum() *Strategy

func (Strategy) EnumDescriptor deprecated

func (Strategy) EnumDescriptor() ([]byte, []int)

Deprecated: Use Strategy.Descriptor instead.

func (Strategy) Number

func (x Strategy) Number() protoreflect.EnumNumber

func (Strategy) String

func (x Strategy) String() string

func (Strategy) Type

type StrategyChange

type StrategyChange struct {

	// roller_id is the unique identifier for the autoroller.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// strategy is the strategy for choosing the next revision to roll which was
	// set in this StrategyChange.
	Strategy Strategy `protobuf:"varint,2,opt,name=strategy,proto3,enum=autoroll.rpc.Strategy" json:"strategy,omitempty"`
	// user is the email address of the user who created this StrategyChange.
	User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// time is the timestamp at which the StrategyChange was created.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// message is a user-created message which describes the reason for changing
	// the strategy.
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

StrategyChange describes one instance of an autoroller's mode being changed.

func (*StrategyChange) Descriptor deprecated

func (*StrategyChange) Descriptor() ([]byte, []int)

Deprecated: Use StrategyChange.ProtoReflect.Descriptor instead.

func (*StrategyChange) GetMessage

func (x *StrategyChange) GetMessage() string

func (*StrategyChange) GetRollerId

func (x *StrategyChange) GetRollerId() string

func (*StrategyChange) GetStrategy

func (x *StrategyChange) GetStrategy() Strategy

func (*StrategyChange) GetTime

func (x *StrategyChange) GetTime() *timestamppb.Timestamp

func (*StrategyChange) GetUser

func (x *StrategyChange) GetUser() string

func (*StrategyChange) ProtoMessage

func (*StrategyChange) ProtoMessage()

func (*StrategyChange) ProtoReflect

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

func (*StrategyChange) Reset

func (x *StrategyChange) Reset()

func (*StrategyChange) String

func (x *StrategyChange) String() string

type TryJob

type TryJob struct {

	// name of the TryJob.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// status of the TryJob.
	Status TryJob_Status `protobuf:"varint,2,opt,name=status,proto3,enum=autoroll.rpc.TryJob_Status" json:"status,omitempty"`
	// result of the TryJob.
	Result TryJob_Result `protobuf:"varint,3,opt,name=result,proto3,enum=autoroll.rpc.TryJob_Result" json:"result,omitempty"`
	// url where more details can be found about the TryJob.
	Url string `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	// category of the TryJob, eg. "cq".
	Category string `protobuf:"bytes,5,opt,name=category,proto3" json:"category,omitempty"`
	// contains filtered or unexported fields
}

func (*TryJob) Descriptor deprecated

func (*TryJob) Descriptor() ([]byte, []int)

Deprecated: Use TryJob.ProtoReflect.Descriptor instead.

func (*TryJob) GetCategory

func (x *TryJob) GetCategory() string

func (*TryJob) GetName

func (x *TryJob) GetName() string

func (*TryJob) GetResult

func (x *TryJob) GetResult() TryJob_Result

func (*TryJob) GetStatus

func (x *TryJob) GetStatus() TryJob_Status

func (*TryJob) GetUrl

func (x *TryJob) GetUrl() string

func (*TryJob) ProtoMessage

func (*TryJob) ProtoMessage()

func (*TryJob) ProtoReflect

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

func (*TryJob) Reset

func (x *TryJob) Reset()

func (*TryJob) String

func (x *TryJob) String() string

type TryJob_Result

type TryJob_Result int32

Result describes the possible results for a TryJob. These must be kept in sync with go/autoroll/autoroll.go.

const (
	// UNKNOWN indicates that the result of the TryJob is unknown, ie. it has
	// not yet finished.
	TryJob_UNKNOWN TryJob_Result = 0
	// SUCCESS indicates that that TryJob completed successfully.
	TryJob_SUCCESS TryJob_Result = 1
	// FAILURE indicates that that TryJob failed.
	TryJob_FAILURE TryJob_Result = 2
	// CANCELED indicates that that TryJob was canceled.
	TryJob_CANCELED TryJob_Result = 3
)

func (TryJob_Result) Descriptor

func (TryJob_Result) Enum

func (x TryJob_Result) Enum() *TryJob_Result

func (TryJob_Result) EnumDescriptor deprecated

func (TryJob_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use TryJob_Result.Descriptor instead.

func (TryJob_Result) Number

func (TryJob_Result) String

func (x TryJob_Result) String() string

func (TryJob_Result) Type

type TryJob_Status

type TryJob_Status int32

Status describes the lifecycle states of a TryJob. These must be kept in sync with go/autoroll/autoroll.go.

const (
	// SCHEDULED indicates that the TryJob has been scheduled but has not yet
	// started.
	TryJob_SCHEDULED TryJob_Status = 0
	// STARTED indicates that the TryJob is currently running.
	TryJob_STARTED TryJob_Status = 1
	// COMPLETED indicates that the TryJob is finishes.
	TryJob_COMPLETED TryJob_Status = 2
)

func (TryJob_Status) Descriptor

func (TryJob_Status) Enum

func (x TryJob_Status) Enum() *TryJob_Status

func (TryJob_Status) EnumDescriptor deprecated

func (TryJob_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use TryJob_Status.Descriptor instead.

func (TryJob_Status) Number

func (TryJob_Status) String

func (x TryJob_Status) String() string

func (TryJob_Status) Type

type TwirpServer

type TwirpServer interface {
	http.Handler

	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// github.com/golang/protobuf/protoc-gen-go/descriptor.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)

	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string

	// PathPrefix returns the HTTP URL path prefix for all methods handled by this
	// service. This can be used with an HTTP mux to route Twirp requests.
	// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
	// that is, everything in a Twirp route except for the <Method> at the end.
	PathPrefix() string
}

TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.

func NewAutoRollServiceServer

func NewAutoRollServiceServer(svc AutoRollService, opts ...interface{}) TwirpServer

NewAutoRollServiceServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).

type UnthrottleRequest

type UnthrottleRequest struct {

	// roller_id is the unique identifier of the autoroller which should be
	// unthrottled.
	RollerId string `protobuf:"bytes,1,opt,name=roller_id,json=rollerId,proto3" json:"roller_id,omitempty"`
	// contains filtered or unexported fields
}

UnthrottleRequest is a request to Unthrottle.

func (*UnthrottleRequest) Descriptor deprecated

func (*UnthrottleRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnthrottleRequest.ProtoReflect.Descriptor instead.

func (*UnthrottleRequest) GetRollerId

func (x *UnthrottleRequest) GetRollerId() string

func (*UnthrottleRequest) ProtoMessage

func (*UnthrottleRequest) ProtoMessage()

func (*UnthrottleRequest) ProtoReflect

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

func (*UnthrottleRequest) Reset

func (x *UnthrottleRequest) Reset()

func (*UnthrottleRequest) String

func (x *UnthrottleRequest) String() string

type UnthrottleResponse

type UnthrottleResponse struct {
	// contains filtered or unexported fields
}

UnthrottleResponse is a response returned by Unthrottle.

func (*UnthrottleResponse) Descriptor deprecated

func (*UnthrottleResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnthrottleResponse.ProtoReflect.Descriptor instead.

func (*UnthrottleResponse) ProtoMessage

func (*UnthrottleResponse) ProtoMessage()

func (*UnthrottleResponse) ProtoReflect

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

func (*UnthrottleResponse) Reset

func (x *UnthrottleResponse) Reset()

func (*UnthrottleResponse) String

func (x *UnthrottleResponse) String() string

Jump to

Keyboard shortcuts

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