rpc

package
v0.0.0-...-2b80fd9 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: BSD-3-Clause Imports: 33 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 TaskSchedulerServicePathPrefix = "/twirp/task_scheduler.rpc.TaskSchedulerService/"

TaskSchedulerServicePathPrefix 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 (
	TaskStatus_name = map[int32]string{
		0: "TASK_STATUS_PENDING",
		1: "TASK_STATUS_RUNNING",
		2: "TASK_STATUS_SUCCESS",
		3: "TASK_STATUS_FAILURE",
		4: "TASK_STATUS_MISHAP",
	}
	TaskStatus_value = map[string]int32{
		"TASK_STATUS_PENDING": 0,
		"TASK_STATUS_RUNNING": 1,
		"TASK_STATUS_SUCCESS": 2,
		"TASK_STATUS_FAILURE": 3,
		"TASK_STATUS_MISHAP":  4,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_IN_PROGRESS",
		1: "JOB_STATUS_SUCCESS",
		2: "JOB_STATUS_FAILURE",
		3: "JOB_STATUS_MISHAP",
		4: "JOB_STATUS_CANCELED",
		5: "JOB_STATUS_REQUESTED",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_IN_PROGRESS": 0,
		"JOB_STATUS_SUCCESS":     1,
		"JOB_STATUS_FAILURE":     2,
		"JOB_STATUS_MISHAP":      3,
		"JOB_STATUS_CANCELED":    4,
		"JOB_STATUS_REQUESTED":   5,
	}
)

Enum value maps for JobStatus.

View Source 
var File_rpc_proto protoreflect.FileDescriptor

Functions

func NewTaskSchedulerServer 

func NewTaskSchedulerServer(ctx context.Context, db db.DB, repos repograph.Map, skipTasks *skip_tasks.DB, taskCfgCache task_cfg_cache.TaskCfgCache, swarm swarmingv2.SwarmingV2Client, plogin alogin.Login) http.Handler

NewTaskSchedulerServer creates and returns a Twirp HTTP server.

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 AddSkipTaskRuleRequest 

type AddSkipTaskRuleRequest struct {

	// task_spec_patterns determines which tasks the rule applies to.
	TaskSpecPatterns []string `protobuf:"bytes,2,rep,name=task_spec_patterns,json=taskSpecPatterns,proto3" json:"task_spec_patterns,omitempty"`
	// commits determines which commits the rule applies to.
	Commits []string `protobuf:"bytes,3,rep,name=commits,proto3" json:"commits,omitempty"`
	// description provides a human-readable description of the rule, eg. to
	// provide a reason for skipping the task(s) and to indicate when the rule
	// may be removed.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// name is a brief descriptive name for the rule.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

AddSkipTaskRuleRequest is a request to AddSkipTaskRule.

func (*AddSkipTaskRuleRequest) Descriptor deprecated 

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

Deprecated: Use AddSkipTaskRuleRequest.ProtoReflect.Descriptor instead.

func (*AddSkipTaskRuleRequest) GetCommits 

func (x *AddSkipTaskRuleRequest) GetCommits() []string

func (*AddSkipTaskRuleRequest) GetDescription 

func (x *AddSkipTaskRuleRequest) GetDescription() string

func (*AddSkipTaskRuleRequest) GetName 

func (x *AddSkipTaskRuleRequest) GetName() string

func (*AddSkipTaskRuleRequest) GetTaskSpecPatterns 

func (x *AddSkipTaskRuleRequest) GetTaskSpecPatterns() []string

func (*AddSkipTaskRuleRequest) ProtoMessage 

func (*AddSkipTaskRuleRequest) ProtoMessage()

func (*AddSkipTaskRuleRequest) ProtoReflect 

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

func (*AddSkipTaskRuleRequest) Reset 

func (x *AddSkipTaskRuleRequest) Reset()

func (*AddSkipTaskRuleRequest) String 

func (x *AddSkipTaskRuleRequest) String() string

type AddSkipTaskRuleResponse 

type AddSkipTaskRuleResponse struct {
	Rules []*SkipTaskRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

AddSkipTaskRuleResponse is a response returned from AddSkipTaskRule.

func (*AddSkipTaskRuleResponse) Descriptor deprecated 

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

Deprecated: Use AddSkipTaskRuleResponse.ProtoReflect.Descriptor instead.

func (*AddSkipTaskRuleResponse) GetRules 

func (x *AddSkipTaskRuleResponse) GetRules() []*SkipTaskRule

func (*AddSkipTaskRuleResponse) ProtoMessage 

func (*AddSkipTaskRuleResponse) ProtoMessage()

func (*AddSkipTaskRuleResponse) ProtoReflect 

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

func (*AddSkipTaskRuleResponse) Reset 

func (x *AddSkipTaskRuleResponse) Reset()

func (*AddSkipTaskRuleResponse) String 

func (x *AddSkipTaskRuleResponse) String() string

type CancelJobRequest 

type CancelJobRequest struct {

	// ID of the job to cancel.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

CancelJobRequest is a request to CancelJob.

func (*CancelJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetId 

func (x *CancelJobRequest) GetId() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

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

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CancelJobResponse 

type CancelJobResponse struct {

	// job is the updated job after cancellation.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

CancelJobResponse is a response returned by CancelJob.

func (*CancelJobResponse) Descriptor deprecated 

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

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) GetJob 

func (x *CancelJobResponse) GetJob() *Job

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect 

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

func (*CancelJobResponse) Reset 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (x *CancelJobResponse) String() string

type DeleteSkipTaskRuleRequest 

type DeleteSkipTaskRuleRequest struct {

	// ID of the rule to delete.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // TODO(borenet): Where does this come from?
	// contains filtered or unexported fields
}

DeleteSkipTaskRuleRequest is a request to DeleteSkipTaskRule.

func (*DeleteSkipTaskRuleRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSkipTaskRuleRequest.ProtoReflect.Descriptor instead.

func (*DeleteSkipTaskRuleRequest) GetId 

func (x *DeleteSkipTaskRuleRequest) GetId() string

func (*DeleteSkipTaskRuleRequest) ProtoMessage 

func (*DeleteSkipTaskRuleRequest) ProtoMessage()

func (*DeleteSkipTaskRuleRequest) ProtoReflect 

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

func (*DeleteSkipTaskRuleRequest) Reset 

func (x *DeleteSkipTaskRuleRequest) Reset()

func (*DeleteSkipTaskRuleRequest) String 

func (x *DeleteSkipTaskRuleRequest) String() string

type DeleteSkipTaskRuleResponse 

type DeleteSkipTaskRuleResponse struct {
	Rules []*SkipTaskRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

DeleteSkipTaskRuleResponse is a response returned from DeleteSkipTaskRule.

func (*DeleteSkipTaskRuleResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSkipTaskRuleResponse.ProtoReflect.Descriptor instead.

func (*DeleteSkipTaskRuleResponse) GetRules 

func (x *DeleteSkipTaskRuleResponse) GetRules() []*SkipTaskRule

func (*DeleteSkipTaskRuleResponse) ProtoMessage 

func (*DeleteSkipTaskRuleResponse) ProtoMessage()

func (*DeleteSkipTaskRuleResponse) ProtoReflect 

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

func (*DeleteSkipTaskRuleResponse) Reset 

func (x *DeleteSkipTaskRuleResponse) Reset()

func (*DeleteSkipTaskRuleResponse) String 

func (x *DeleteSkipTaskRuleResponse) String() string

type GetJobRequest 

type GetJobRequest struct {

	// ID of the job to retrieve.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetJobRequest is a request to GetJob.

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {

	// job contains the core information about the job.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

GetJobResponse is a response returned from GetJob.

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type GetSkipTaskRulesRequest 

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

GetSkipTaskRulesRequest is a request to GetSkipTaskRules.

func (*GetSkipTaskRulesRequest) Descriptor deprecated 

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

Deprecated: Use GetSkipTaskRulesRequest.ProtoReflect.Descriptor instead.

func (*GetSkipTaskRulesRequest) ProtoMessage 

func (*GetSkipTaskRulesRequest) ProtoMessage()

func (*GetSkipTaskRulesRequest) ProtoReflect 

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

func (*GetSkipTaskRulesRequest) Reset 

func (x *GetSkipTaskRulesRequest) Reset()

func (*GetSkipTaskRulesRequest) String 

func (x *GetSkipTaskRulesRequest) String() string

type GetSkipTaskRulesResponse 

type GetSkipTaskRulesResponse struct {
	Rules []*SkipTaskRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

GetSkipTaskRulesResponse is a response returned from GetSkipTaskRules.

func (*GetSkipTaskRulesResponse) Descriptor deprecated 

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

Deprecated: Use GetSkipTaskRulesResponse.ProtoReflect.Descriptor instead.

func (*GetSkipTaskRulesResponse) GetRules 

func (x *GetSkipTaskRulesResponse) GetRules() []*SkipTaskRule

func (*GetSkipTaskRulesResponse) ProtoMessage 

func (*GetSkipTaskRulesResponse) ProtoMessage()

func (*GetSkipTaskRulesResponse) ProtoReflect 

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

func (*GetSkipTaskRulesResponse) Reset 

func (x *GetSkipTaskRulesResponse) Reset()

func (*GetSkipTaskRulesResponse) String 

func (x *GetSkipTaskRulesResponse) String() string

type GetTaskRequest 

type GetTaskRequest struct {

	// ID of the task to retrieve.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Whether or not to include statistics. This is expensive and should only
	// be set when needed.
	IncludeStats bool `protobuf:"varint,2,opt,name=include_stats,json=includeStats,proto3" json:"include_stats,omitempty"`
	// contains filtered or unexported fields
}

GetTaskRequest is a request to GetTask.

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetId 

func (x *GetTaskRequest) GetId() string

func (*GetTaskRequest) GetIncludeStats 

func (x *GetTaskRequest) GetIncludeStats() bool

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect 

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

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type GetTaskResponse 

type GetTaskResponse struct {

	// task is the requested task.
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

GetTaskResponse is a response returned from GetTask.

func (*GetTaskResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskResponse.ProtoReflect.Descriptor instead.

func (*GetTaskResponse) GetTask 

func (x *GetTaskResponse) GetTask() *Task

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) ProtoReflect 

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

func (*GetTaskResponse) Reset 

func (x *GetTaskResponse) Reset()

func (*GetTaskResponse) String 

func (x *GetTaskResponse) 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 Job 

type Job struct {

	// buildbucket_build_id is the ID of the Buildbucket build with which this
	// Job is associated, if one exists.
	BuildbucketBuildId string `protobuf:"bytes,1,opt,name=buildbucket_build_id,json=buildbucketBuildId,proto3" json:"buildbucket_build_id,omitempty"`
	// buildbucket_lease_key is the lease key for running a Buildbucket build.
	// TODO(borenet): Maybe this doesn't belong in the DB.
	BuildbucketLeaseKey string `protobuf:"bytes,2,opt,name=buildbucket_lease_key,json=buildbucketLeaseKey,proto3" json:"buildbucket_lease_key,omitempty"`
	// created_at is the creation timestamp. This property should never change
	// for a given Job instance.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// db_modified_at is the time of the last successful call to JobDB.PutJob/s
	// for this Job, or zero if the job is new.
	DbModifiedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=db_modified_at,json=dbModifiedAt,proto3" json:"db_modified_at,omitempty"`
	// dependencies maps out the DAG of TaskSpec names upon which this Job
	// depends. Keys are TaskSpec names and values are slices of TaskSpec
	// names indicating which TaskSpecs that TaskSpec depends on. This
	// property should never change for a given Job instance.
	Dependencies []*TaskDependencies `protobuf:"bytes,5,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// finished_at is the time at which all of the Job's dependencies finished,
	// successfully or not.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// id is a unique identifier for the Job. This property should never
	// change for a given Job instance, after its initial insertion into the
	// DB.
	Id string `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	// is_force indicates whether this is a manually-triggered Job, as
	// opposed to a normally scheduled one, or a try job.
	IsForce bool `protobuf:"varint,8,opt,name=is_force,json=isForce,proto3" json:"is_force,omitempty"`
	// name is a human-friendly descriptive name for the Job. All Jobs
	// generated from the same JobSpec have the same name. This property
	// should never change for a given Job instance.
	Name string `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	// priority is an indicator of the relative priority of this Job.
	Priority float32 `protobuf:"fixed32,10,opt,name=priority,proto3" json:"priority,omitempty"`
	// is the current state of the repository for this Job.
	RepoState *RepoState `protobuf:"bytes,11,opt,name=repo_state,json=repoState,proto3" json:"repo_state,omitempty"`
	// requested is the time at which this Job was requested. This is a
	// commit timestamp, tryjob request creation timestamp, time at which
	// the server received a force trigger job request, etc.
	RequestedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
	// started_at is the timestamp at which the Job first entered
	// JOB_STATUS_IN_PROGRESS.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// status is the current Job status, default JOB_STATUS_IN_PROGRESS.
	Status JobStatus `protobuf:"varint,13,opt,name=status,proto3,enum=task_scheduler.rpc.JobStatus" json:"status,omitempty"`
	// status_details provides additional details for the status of the Job,
	// including reasons it might have failed. This may be truncated due to
	// database storage limitations, so it should not include, for example, full
	// logs.
	StatusDetails string `protobuf:"bytes,16,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
	// tasks are the Task instances which satisfied the dependencies of
	// the Job. Keys are TaskSpec names and values are slices of TaskSummary
	// instances describing the Tasks.
	Tasks []*TaskSummaries `protobuf:"bytes,14,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// taskDimensions are the dimensions of the tasks needed by this job.
	TaskDimensions []*TaskDimensions `protobuf:"bytes,15,rep,name=task_dimensions,json=taskDimensions,proto3" json:"task_dimensions,omitempty"`
	// contains filtered or unexported fields
}

Job represents a set of Tasks which are executed as part of a larger effort. This must be kept in sync with types.Job.

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetBuildbucketBuildId 

func (x *Job) GetBuildbucketBuildId() string

func (*Job) GetBuildbucketLeaseKey 

func (x *Job) GetBuildbucketLeaseKey() string

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() *timestamppb.Timestamp

func (*Job) GetDbModifiedAt 

func (x *Job) GetDbModifiedAt() *timestamppb.Timestamp

func (*Job) GetDependencies 

func (x *Job) GetDependencies() []*TaskDependencies

func (*Job) GetFinishedAt 

func (x *Job) GetFinishedAt() *timestamppb.Timestamp

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetIsForce 

func (x *Job) GetIsForce() bool

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetPriority 

func (x *Job) GetPriority() float32

func (*Job) GetRepoState 

func (x *Job) GetRepoState() *RepoState

func (*Job) GetRequestedAt 

func (x *Job) GetRequestedAt() *timestamppb.Timestamp

func (*Job) GetStartedAt 

func (x *Job) GetStartedAt() *timestamppb.Timestamp

func (*Job) GetStatus 

func (x *Job) GetStatus() JobStatus

func (*Job) GetStatusDetails 

func (x *Job) GetStatusDetails() string

func (*Job) GetTaskDimensions 

func (x *Job) GetTaskDimensions() []*TaskDimensions

func (*Job) GetTasks 

func (x *Job) GetTasks() []*TaskSummaries

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobStatus 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_IN_PROGRESS JobStatus = 0
	JobStatus_JOB_STATUS_SUCCESS     JobStatus = 1
	JobStatus_JOB_STATUS_FAILURE     JobStatus = 2
	JobStatus_JOB_STATUS_MISHAP      JobStatus = 3
	JobStatus_JOB_STATUS_CANCELED    JobStatus = 4
	JobStatus_JOB_STATUS_REQUESTED   JobStatus = 5
)

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type RepoState 

type RepoState struct {

	// Patch information, optional.
	Patch *RepoState_Patch `protobuf:"bytes,1,opt,name=patch,proto3" json:"patch,omitempty"`
	// Repository URL.
	Repo string `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	// Revision ID, ie. commit hash.
	Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}
encapsulates all of the parameters which define the state of a

repo.

func (*RepoState) Descriptor deprecated 

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

Deprecated: Use RepoState.ProtoReflect.Descriptor instead.

func (*RepoState) GetPatch 

func (x *RepoState) GetPatch() *RepoState_Patch

func (*RepoState) GetRepo 

func (x *RepoState) GetRepo() string

func (*RepoState) GetRevision 

func (x *RepoState) GetRevision() string

func (*RepoState) ProtoMessage 

func (*RepoState) ProtoMessage()

func (*RepoState) ProtoReflect 

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

func (*RepoState) Reset 

func (x *RepoState) Reset()

func (*RepoState) String 

func (x *RepoState) String() string

type RepoState_Patch 

type RepoState_Patch struct {

	// Issue ID of the Patch.
	Issue string `protobuf:"bytes,1,opt,name=issue,proto3" json:"issue,omitempty"`
	// URL of the repository where this patch may be applied.
	PatchRepo string `protobuf:"bytes,2,opt,name=patch_repo,json=patchRepo,proto3" json:"patch_repo,omitempty"`
	// Patch set ID.
	Patchset string `protobuf:"bytes,3,opt,name=patchset,proto3" json:"patchset,omitempty"`
	// URL of the code review server.
	Server string `protobuf:"bytes,4,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

Patch describes a patch which may be applied to a code checkout.

func (*RepoState_Patch) Descriptor deprecated 

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

Deprecated: Use RepoState_Patch.ProtoReflect.Descriptor instead.

func (*RepoState_Patch) GetIssue 

func (x *RepoState_Patch) GetIssue() string

func (*RepoState_Patch) GetPatchRepo 

func (x *RepoState_Patch) GetPatchRepo() string

func (*RepoState_Patch) GetPatchset 

func (x *RepoState_Patch) GetPatchset() string

func (*RepoState_Patch) GetServer 

func (x *RepoState_Patch) GetServer() string

func (*RepoState_Patch) ProtoMessage 

func (*RepoState_Patch) ProtoMessage()

func (*RepoState_Patch) ProtoReflect 

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

func (*RepoState_Patch) Reset 

func (x *RepoState_Patch) Reset()

func (*RepoState_Patch) String 

func (x *RepoState_Patch) String() string

type SearchJobsRequest 

type SearchJobsRequest struct {
	BuildbucketBuildId    string                 `protobuf:"bytes,1,opt,name=buildbucket_build_id,json=buildbucketBuildId,proto3" json:"buildbucket_build_id,omitempty"`
	HasBuildbucketBuildId bool                   `` /* 129-byte string literal not displayed */
	IsForce               bool                   `protobuf:"varint,3,opt,name=is_force,json=isForce,proto3" json:"is_force,omitempty"`
	HasIsForce            bool                   `protobuf:"varint,4,opt,name=has_is_force,json=hasIsForce,proto3" json:"has_is_force,omitempty"`
	Issue                 string                 `protobuf:"bytes,5,opt,name=issue,proto3" json:"issue,omitempty"`
	HasIssue              bool                   `protobuf:"varint,6,opt,name=has_issue,json=hasIssue,proto3" json:"has_issue,omitempty"`
	Name                  string                 `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	HasName               bool                   `protobuf:"varint,8,opt,name=has_name,json=hasName,proto3" json:"has_name,omitempty"`
	Patchset              string                 `protobuf:"bytes,9,opt,name=patchset,proto3" json:"patchset,omitempty"`
	HasPatchset           bool                   `protobuf:"varint,10,opt,name=has_patchset,json=hasPatchset,proto3" json:"has_patchset,omitempty"`
	Repo                  string                 `protobuf:"bytes,11,opt,name=repo,proto3" json:"repo,omitempty"`
	HasRepo               bool                   `protobuf:"varint,12,opt,name=has_repo,json=hasRepo,proto3" json:"has_repo,omitempty"`
	Revision              string                 `protobuf:"bytes,13,opt,name=revision,proto3" json:"revision,omitempty"`
	HasRevision           bool                   `protobuf:"varint,14,opt,name=has_revision,json=hasRevision,proto3" json:"has_revision,omitempty"`
	Status                JobStatus              `protobuf:"varint,15,opt,name=status,proto3,enum=task_scheduler.rpc.JobStatus" json:"status,omitempty"`
	HasStatus             bool                   `protobuf:"varint,16,opt,name=has_status,json=hasStatus,proto3" json:"has_status,omitempty"`
	TimeStart             *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	HasTimeStart          bool                   `protobuf:"varint,18,opt,name=has_time_start,json=hasTimeStart,proto3" json:"has_time_start,omitempty"`
	TimeEnd               *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	HasTimeEnd            bool                   `protobuf:"varint,20,opt,name=has_time_end,json=hasTimeEnd,proto3" json:"has_time_end,omitempty"`
	// contains filtered or unexported fields
}

SearchJobsRequest is a request to SearchJobs.

func (*SearchJobsRequest) Descriptor deprecated 

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

Deprecated: Use SearchJobsRequest.ProtoReflect.Descriptor instead.

func (*SearchJobsRequest) GetBuildbucketBuildId 

func (x *SearchJobsRequest) GetBuildbucketBuildId() string

func (*SearchJobsRequest) GetHasBuildbucketBuildId 

func (x *SearchJobsRequest) GetHasBuildbucketBuildId() bool

func (*SearchJobsRequest) GetHasIsForce 

func (x *SearchJobsRequest) GetHasIsForce() bool

func (*SearchJobsRequest) GetHasIssue 

func (x *SearchJobsRequest) GetHasIssue() bool

func (*SearchJobsRequest) GetHasName 

func (x *SearchJobsRequest) GetHasName() bool

func (*SearchJobsRequest) GetHasPatchset 

func (x *SearchJobsRequest) GetHasPatchset() bool

func (*SearchJobsRequest) GetHasRepo 

func (x *SearchJobsRequest) GetHasRepo() bool

func (*SearchJobsRequest) GetHasRevision 

func (x *SearchJobsRequest) GetHasRevision() bool

func (*SearchJobsRequest) GetHasStatus 

func (x *SearchJobsRequest) GetHasStatus() bool

func (*SearchJobsRequest) GetHasTimeEnd 

func (x *SearchJobsRequest) GetHasTimeEnd() bool

func (*SearchJobsRequest) GetHasTimeStart 

func (x *SearchJobsRequest) GetHasTimeStart() bool

func (*SearchJobsRequest) GetIsForce 

func (x *SearchJobsRequest) GetIsForce() bool

func (*SearchJobsRequest) GetIssue 

func (x *SearchJobsRequest) GetIssue() string

func (*SearchJobsRequest) GetName 

func (x *SearchJobsRequest) GetName() string

func (*SearchJobsRequest) GetPatchset 

func (x *SearchJobsRequest) GetPatchset() string

func (*SearchJobsRequest) GetRepo 

func (x *SearchJobsRequest) GetRepo() string

func (*SearchJobsRequest) GetRevision 

func (x *SearchJobsRequest) GetRevision() string

func (*SearchJobsRequest) GetStatus 

func (x *SearchJobsRequest) GetStatus() JobStatus

func (*SearchJobsRequest) GetTimeEnd 

func (x *SearchJobsRequest) GetTimeEnd() *timestamppb.Timestamp

func (*SearchJobsRequest) GetTimeStart 

func (x *SearchJobsRequest) GetTimeStart() *timestamppb.Timestamp

func (*SearchJobsRequest) ProtoMessage 

func (*SearchJobsRequest) ProtoMessage()

func (*SearchJobsRequest) ProtoReflect 

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

func (*SearchJobsRequest) Reset 

func (x *SearchJobsRequest) Reset()

func (*SearchJobsRequest) String 

func (x *SearchJobsRequest) String() string

type SearchJobsResponse 

type SearchJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

SearchJobsRequest is a response returned by SearchJobs.

func (*SearchJobsResponse) Descriptor deprecated 

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

Deprecated: Use SearchJobsResponse.ProtoReflect.Descriptor instead.

func (*SearchJobsResponse) GetJobs 

func (x *SearchJobsResponse) GetJobs() []*Job

func (*SearchJobsResponse) ProtoMessage 

func (*SearchJobsResponse) ProtoMessage()

func (*SearchJobsResponse) ProtoReflect 

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

func (*SearchJobsResponse) Reset 

func (x *SearchJobsResponse) Reset()

func (*SearchJobsResponse) String 

func (x *SearchJobsResponse) String() string

type SearchTasksRequest 

type SearchTasksRequest struct {
	Attempt      int32                  `protobuf:"varint,1,opt,name=attempt,proto3" json:"attempt,omitempty"`
	HasAttempt   bool                   `protobuf:"varint,2,opt,name=has_attempt,json=hasAttempt,proto3" json:"has_attempt,omitempty"`
	Issue        string                 `protobuf:"bytes,3,opt,name=issue,proto3" json:"issue,omitempty"`
	HasIssue     bool                   `protobuf:"varint,4,opt,name=has_issue,json=hasIssue,proto3" json:"has_issue,omitempty"`
	Name         string                 `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	HasName      bool                   `protobuf:"varint,6,opt,name=has_name,json=hasName,proto3" json:"has_name,omitempty"`
	Patchset     string                 `protobuf:"bytes,7,opt,name=patchset,proto3" json:"patchset,omitempty"`
	HasPatchset  bool                   `protobuf:"varint,8,opt,name=has_patchset,json=hasPatchset,proto3" json:"has_patchset,omitempty"`
	Repo         string                 `protobuf:"bytes,9,opt,name=repo,proto3" json:"repo,omitempty"`
	HasRepo      bool                   `protobuf:"varint,10,opt,name=has_repo,json=hasRepo,proto3" json:"has_repo,omitempty"`
	Revision     string                 `protobuf:"bytes,11,opt,name=revision,proto3" json:"revision,omitempty"`
	HasRevision  bool                   `protobuf:"varint,12,opt,name=has_revision,json=hasRevision,proto3" json:"has_revision,omitempty"`
	Status       TaskStatus             `protobuf:"varint,13,opt,name=status,proto3,enum=task_scheduler.rpc.TaskStatus" json:"status,omitempty"`
	HasStatus    bool                   `protobuf:"varint,14,opt,name=has_status,json=hasStatus,proto3" json:"has_status,omitempty"`
	TimeStart    *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	HasTimeStart bool                   `protobuf:"varint,16,opt,name=has_time_start,json=hasTimeStart,proto3" json:"has_time_start,omitempty"`
	TimeEnd      *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	HasTimeEnd   bool                   `protobuf:"varint,18,opt,name=has_time_end,json=hasTimeEnd,proto3" json:"has_time_end,omitempty"`
	// contains filtered or unexported fields
}

SearchTasksRequest is a request to SearchTasks.

func (*SearchTasksRequest) Descriptor deprecated 

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

Deprecated: Use SearchTasksRequest.ProtoReflect.Descriptor instead.

func (*SearchTasksRequest) GetAttempt 

func (x *SearchTasksRequest) GetAttempt() int32

func (*SearchTasksRequest) GetHasAttempt 

func (x *SearchTasksRequest) GetHasAttempt() bool

func (*SearchTasksRequest) GetHasIssue 

func (x *SearchTasksRequest) GetHasIssue() bool

func (*SearchTasksRequest) GetHasName 

func (x *SearchTasksRequest) GetHasName() bool

func (*SearchTasksRequest) GetHasPatchset 

func (x *SearchTasksRequest) GetHasPatchset() bool

func (*SearchTasksRequest) GetHasRepo 

func (x *SearchTasksRequest) GetHasRepo() bool

func (*SearchTasksRequest) GetHasRevision 

func (x *SearchTasksRequest) GetHasRevision() bool

func (*SearchTasksRequest) GetHasStatus 

func (x *SearchTasksRequest) GetHasStatus() bool

func (*SearchTasksRequest) GetHasTimeEnd 

func (x *SearchTasksRequest) GetHasTimeEnd() bool

func (*SearchTasksRequest) GetHasTimeStart 

func (x *SearchTasksRequest) GetHasTimeStart() bool

func (*SearchTasksRequest) GetIssue 

func (x *SearchTasksRequest) GetIssue() string

func (*SearchTasksRequest) GetName 

func (x *SearchTasksRequest) GetName() string

func (*SearchTasksRequest) GetPatchset 

func (x *SearchTasksRequest) GetPatchset() string

func (*SearchTasksRequest) GetRepo 

func (x *SearchTasksRequest) GetRepo() string

func (*SearchTasksRequest) GetRevision 

func (x *SearchTasksRequest) GetRevision() string

func (*SearchTasksRequest) GetStatus 

func (x *SearchTasksRequest) GetStatus() TaskStatus

func (*SearchTasksRequest) GetTimeEnd 

func (x *SearchTasksRequest) GetTimeEnd() *timestamppb.Timestamp

func (*SearchTasksRequest) GetTimeStart 

func (x *SearchTasksRequest) GetTimeStart() *timestamppb.Timestamp

func (*SearchTasksRequest) ProtoMessage 

func (*SearchTasksRequest) ProtoMessage()

func (*SearchTasksRequest) ProtoReflect 

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

func (*SearchTasksRequest) Reset 

func (x *SearchTasksRequest) Reset()

func (*SearchTasksRequest) String 

func (x *SearchTasksRequest) String() string

type SearchTasksResponse 

type SearchTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

SearchTasksResponse is a response returned from SearchTasks.

func (*SearchTasksResponse) Descriptor deprecated 

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

Deprecated: Use SearchTasksResponse.ProtoReflect.Descriptor instead.

func (*SearchTasksResponse) GetTasks 

func (x *SearchTasksResponse) GetTasks() []*Task

func (*SearchTasksResponse) ProtoMessage 

func (*SearchTasksResponse) ProtoMessage()

func (*SearchTasksResponse) ProtoReflect 

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

func (*SearchTasksResponse) Reset 

func (x *SearchTasksResponse) Reset()

func (*SearchTasksResponse) String 

func (x *SearchTasksResponse) String() string

type SkipTaskRule 

type SkipTaskRule struct {

	// added_by is the email address of the user who added this rule.
	AddedBy string `protobuf:"bytes,1,opt,name=added_by,json=addedBy,proto3" json:"added_by,omitempty"`
	// task_spec_patterns determines which tasks the rule applies to.
	TaskSpecPatterns []string `protobuf:"bytes,2,rep,name=task_spec_patterns,json=taskSpecPatterns,proto3" json:"task_spec_patterns,omitempty"`
	// commits determines which commits the rule applies to.
	Commits []string `protobuf:"bytes,3,rep,name=commits,proto3" json:"commits,omitempty"`
	// description provides a human-readable description of the rule, eg. to
	// provide a reason for skipping the task(s) and to indicate when the rule
	// may be removed.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// name is a brief descriptive name for the rule.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

SkipTaskRule is a rule which dictates when to skip scheduling a task.

func (*SkipTaskRule) Descriptor deprecated 

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

Deprecated: Use SkipTaskRule.ProtoReflect.Descriptor instead.

func (*SkipTaskRule) GetAddedBy 

func (x *SkipTaskRule) GetAddedBy() string

func (*SkipTaskRule) GetCommits 

func (x *SkipTaskRule) GetCommits() []string

func (*SkipTaskRule) GetDescription 

func (x *SkipTaskRule) GetDescription() string

func (*SkipTaskRule) GetName 

func (x *SkipTaskRule) GetName() string

func (*SkipTaskRule) GetTaskSpecPatterns 

func (x *SkipTaskRule) GetTaskSpecPatterns() []string

func (*SkipTaskRule) ProtoMessage 

func (*SkipTaskRule) ProtoMessage()

func (*SkipTaskRule) ProtoReflect 

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

func (*SkipTaskRule) Reset 

func (x *SkipTaskRule) Reset()

func (*SkipTaskRule) String 

func (x *SkipTaskRule) String() string

type Task 

type Task struct {

	// attempt is the attempt number of this task, starting with zero.
	Attempt int32 `protobuf:"varint,1,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// commits are the commits which were tested in this Task. The list may
	// change due to backfilling/bisecting.
	Commits []string `protobuf:"bytes,2,rep,name=commits,proto3" json:"commits,omitempty"`
	// created is the creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// db_modified is the time of the last successful call to TaskDB.PutTask/s
	// for this Task, or zero if the task is new. It is not related to the
	// ModifiedTs time of the associated Swarming task.
	DbModifiedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=db_modified_at,json=dbModifiedAt,proto3" json:"db_modified_at,omitempty"`
	// finished is the time the task stopped running or expired from the queue, or
	// zero if the task is pending or running.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// id is a generated unique identifier for this Task instance. Must be
	// URL-safe.
	Id string `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	// isolated_output is the isolated hash of any outputs produced by this Task.
	// Filled in when the task is completed. This field will not be set if the
	// Task does not correspond to a Swarming task.
	IsolatedOutput string `protobuf:"bytes,7,opt,name=isolated_output,json=isolatedOutput,proto3" json:"isolated_output,omitempty"`
	// jobs are the IDs of all Jobs which utilized this Task.
	Jobs []string `protobuf:"bytes,8,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// max_attempts is the maximum number of attempts for this TaskSpec.
	MaxAttempts int32 `protobuf:"varint,9,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// parent_task_ids are IDs of tasks which satisfied this task's dependencies.
	ParentTaskIds []string `protobuf:"bytes,10,rep,name=parent_task_ids,json=parentTaskIds,proto3" json:"parent_task_ids,omitempty"`
	// properties contains key-value pairs from external sources. Both key and
	// value must be UTF-8 strings. Prefer a JavaScript identifier for key. Use
	// base64 encoding for binary data.
	Properties map[string]string `` /* 162-byte string literal not displayed */
	// retry_of is the ID of the task which this task is a retry of, if any.
	RetryOf string `protobuf:"bytes,12,opt,name=retry_of,json=retryOf,proto3" json:"retry_of,omitempty"`
	// started is the time the task started running, or zero if the task is
	// pending, or the same as Finished if the task never ran.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// status is the current task status, default TASK_STATUS_PENDING.
	Status TaskStatus `protobuf:"varint,14,opt,name=status,proto3,enum=task_scheduler.rpc.TaskStatus" json:"status,omitempty"`
	// swarming_bot_id is the ID of the Swarming bot that ran this task. This
	// field will not be set if the Task does not correspond to a Swarming task or
	// if the task is still pending.
	SwarmingBotId string `protobuf:"bytes,15,opt,name=swarming_bot_id,json=swarmingBotId,proto3" json:"swarming_bot_id,omitempty"`
	// swarming_task_id is the Swarming task ID. This field will not be set if the
	// Task does not correspond to a Swarming task.
	SwarmingTaskId string `protobuf:"bytes,16,opt,name=swarming_task_id,json=swarmingTaskId,proto3" json:"swarming_task_id,omitempty"`
	// task_key is a struct which describes aspects of the Task related
	// to the current state of the repo when it ran, and about the Task
	// itself.
	TaskKey *TaskKey `protobuf:"bytes,17,opt,name=task_key,json=taskKey,proto3" json:"task_key,omitempty"`
	// stats provides statistics about the task.
	Stats *TaskStats `protobuf:"bytes,18,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

Task describes a single task. This must be kept in sync with types.Task.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetAttempt 

func (x *Task) GetAttempt() int32

func (*Task) GetCommits 

func (x *Task) GetCommits() []string

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetDbModifiedAt 

func (x *Task) GetDbModifiedAt() *timestamppb.Timestamp

func (*Task) GetFinishedAt 

func (x *Task) GetFinishedAt() *timestamppb.Timestamp

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetIsolatedOutput 

func (x *Task) GetIsolatedOutput() string

func (*Task) GetJobs 

func (x *Task) GetJobs() []string

func (*Task) GetMaxAttempts 

func (x *Task) GetMaxAttempts() int32

func (*Task) GetParentTaskIds 

func (x *Task) GetParentTaskIds() []string

func (*Task) GetProperties 

func (x *Task) GetProperties() map[string]string

func (*Task) GetRetryOf 

func (x *Task) GetRetryOf() string

func (*Task) GetStartedAt 

func (x *Task) GetStartedAt() *timestamppb.Timestamp

func (*Task) GetStats 

func (x *Task) GetStats() *TaskStats

func (*Task) GetStatus 

func (x *Task) GetStatus() TaskStatus

func (*Task) GetSwarmingBotId 

func (x *Task) GetSwarmingBotId() string

func (*Task) GetSwarmingTaskId 

func (x *Task) GetSwarmingTaskId() string

func (*Task) GetTaskKey 

func (x *Task) GetTaskKey() *TaskKey

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskDependencies 

type TaskDependencies struct {

	// Name of the task.
	Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// Names of the tasks which this task depends on.
	Dependencies []string `protobuf:"bytes,2,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

TaskDependencies represents dependencies of a task.

func (*TaskDependencies) Descriptor deprecated 

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

Deprecated: Use TaskDependencies.ProtoReflect.Descriptor instead.

func (*TaskDependencies) GetDependencies 

func (x *TaskDependencies) GetDependencies() []string

func (*TaskDependencies) GetTask 

func (x *TaskDependencies) GetTask() string

func (*TaskDependencies) ProtoMessage 

func (*TaskDependencies) ProtoMessage()

func (*TaskDependencies) ProtoReflect 

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

func (*TaskDependencies) Reset 

func (x *TaskDependencies) Reset()

func (*TaskDependencies) String 

func (x *TaskDependencies) String() string

type TaskDimensions 

type TaskDimensions struct {

	// task_name is the name of the task.
	TaskName string `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// dimensions are the Swarming bot dimensions requested by the task.
	Dimensions []string `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// contains filtered or unexported fields
}

TaskDimensions contains the dimensions required for a given task.

func (*TaskDimensions) Descriptor deprecated 

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

Deprecated: Use TaskDimensions.ProtoReflect.Descriptor instead.

func (*TaskDimensions) GetDimensions 

func (x *TaskDimensions) GetDimensions() []string

func (*TaskDimensions) GetTaskName 

func (x *TaskDimensions) GetTaskName() string

func (*TaskDimensions) ProtoMessage 

func (*TaskDimensions) ProtoMessage()

func (*TaskDimensions) ProtoReflect 

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

func (*TaskDimensions) Reset 

func (x *TaskDimensions) Reset()

func (*TaskDimensions) String 

func (x *TaskDimensions) String() string

type TaskKey 

type TaskKey struct {

	// State of the repository for this task.
	RepoState *RepoState `protobuf:"bytes,1,opt,name=repo_state,json=repoState,proto3" json:"repo_state,omitempty"`
	// Name of the task.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// If this task is part of a force-triggered job, ID of the job.
	ForcedJobId string `protobuf:"bytes,3,opt,name=forced_job_id,json=forcedJobId,proto3" json:"forced_job_id,omitempty"`
	// contains filtered or unexported fields
}

TaskKey is a struct used for identifying a Task instance. Note that more than one Task may have the same TaskKey, eg. in the case of retries.

func (*TaskKey) Descriptor deprecated 

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

Deprecated: Use TaskKey.ProtoReflect.Descriptor instead.

func (*TaskKey) GetForcedJobId 

func (x *TaskKey) GetForcedJobId() string

func (*TaskKey) GetName 

func (x *TaskKey) GetName() string

func (*TaskKey) GetRepoState 

func (x *TaskKey) GetRepoState() *RepoState

func (*TaskKey) ProtoMessage 

func (*TaskKey) ProtoMessage()

func (*TaskKey) ProtoReflect 

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

func (*TaskKey) Reset 

func (x *TaskKey) Reset()

func (*TaskKey) String 

func (x *TaskKey) String() string

type TaskSchedulerService 

type TaskSchedulerService interface {
	// TriggerJobs triggers the given jobs.
	TriggerJobs(context.Context, *TriggerJobsRequest) (*TriggerJobsResponse, error)

	// GetJob returns the given job.
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)

	// CancelJob cancels the given job.
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)

	// SearchJobs searches the DB and returns jobs matching the given criteria.
	SearchJobs(context.Context, *SearchJobsRequest) (*SearchJobsResponse, error)

	// GetTask returns the given task.
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)

	// SearchTasks searches the DB and returns tasks matching the given
	// criteria.
	SearchTasks(context.Context, *SearchTasksRequest) (*SearchTasksResponse, error)

	// GetSkipTaskRules returns all active rules for skipping tasks.
	GetSkipTaskRules(context.Context, *GetSkipTaskRulesRequest) (*GetSkipTaskRulesResponse, error)

	// AddSkipTaskRule adds a rule for skipping tasks.
	AddSkipTaskRule(context.Context, *AddSkipTaskRuleRequest) (*AddSkipTaskRuleResponse, error)

	// DeleteSkipTaskRule deletes the given rule for skipping tasks.
	DeleteSkipTaskRule(context.Context, *DeleteSkipTaskRuleRequest) (*DeleteSkipTaskRuleResponse, error)
}

TaskSchedulerService provides interactions with the Task Scheduler frontend.

func NewTaskSchedulerServiceJSONClient 

func NewTaskSchedulerServiceJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) TaskSchedulerService

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

func NewTaskSchedulerServiceProtobufClient 

func NewTaskSchedulerServiceProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) TaskSchedulerService

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

type TaskStats 

type TaskStats struct {

	// total_overhead_s is the total amount of overhead for the task.
	TotalOverheadS float32 `protobuf:"fixed32,1,opt,name=total_overhead_s,json=totalOverheadS,proto3" json:"total_overhead_s,omitempty"`
	// download_overhead_s is the number of seconds spent downloading assets
	// before running the task.
	DownloadOverheadS float32 `protobuf:"fixed32,2,opt,name=download_overhead_s,json=downloadOverheadS,proto3" json:"download_overhead_s,omitempty"`
	// upload_overhead_s is the number of seconds spent uploading assets
	// before running the task.
	UploadOverheadS float32 `protobuf:"fixed32,3,opt,name=upload_overhead_s,json=uploadOverheadS,proto3" json:"upload_overhead_s,omitempty"`
	// contains filtered or unexported fields
}

TaskStats provides statistics about a task.

func (*TaskStats) Descriptor deprecated 

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

Deprecated: Use TaskStats.ProtoReflect.Descriptor instead.

func (*TaskStats) GetDownloadOverheadS 

func (x *TaskStats) GetDownloadOverheadS() float32

func (*TaskStats) GetTotalOverheadS 

func (x *TaskStats) GetTotalOverheadS() float32

func (*TaskStats) GetUploadOverheadS 

func (x *TaskStats) GetUploadOverheadS() float32

func (*TaskStats) ProtoMessage 

func (*TaskStats) ProtoMessage()

func (*TaskStats) ProtoReflect 

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

func (*TaskStats) Reset 

func (x *TaskStats) Reset()

func (*TaskStats) String 

func (x *TaskStats) String() string

type TaskStatus 

type TaskStatus int32

TaskStatus indicates the status of a given task. Must be kept in sync with types.TaskStatus. 

const (
	// TASK_STATUS_PENDING indicates the task has not started. It is the empty
	// string so that it is the zero value of TaskStatus.
	TaskStatus_TASK_STATUS_PENDING TaskStatus = 0
	// TASK_STATUS_RUNNING indicates the task is in progress.
	TaskStatus_TASK_STATUS_RUNNING TaskStatus = 1
	// TASK_STATUS_SUCCESS indicates the task completed successfully.
	TaskStatus_TASK_STATUS_SUCCESS TaskStatus = 2
	// TASK_STATUS_FAILURE indicates the task completed with failures.
	TaskStatus_TASK_STATUS_FAILURE TaskStatus = 3
	// TASK_STATUS_MISHAP indicates the task exited early with an error, died
	// while in progress, was manually canceled, expired while waiting on the
	// queue, or timed out before completing.
	TaskStatus_TASK_STATUS_MISHAP TaskStatus = 4
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

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

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type TaskSummaries 

type TaskSummaries struct {
	Name  string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tasks []*TaskSummary `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

TODO: Make optional. TODO: Make optional. TaskSummaries groups TaskSummaries which have the same TaskSpec name.

func (*TaskSummaries) Descriptor deprecated 

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

Deprecated: Use TaskSummaries.ProtoReflect.Descriptor instead.

func (*TaskSummaries) GetName 

func (x *TaskSummaries) GetName() string

func (*TaskSummaries) GetTasks 

func (x *TaskSummaries) GetTasks() []*TaskSummary

func (*TaskSummaries) ProtoMessage 

func (*TaskSummaries) ProtoMessage()

func (*TaskSummaries) ProtoReflect 

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

func (*TaskSummaries) Reset 

func (x *TaskSummaries) Reset()

func (*TaskSummaries) String 

func (x *TaskSummaries) String() string

type TaskSummary 

type TaskSummary struct {
	Id             string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Attempt        int32      `protobuf:"varint,2,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaxAttempts    int32      `protobuf:"varint,3,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	Status         TaskStatus `protobuf:"varint,4,opt,name=status,proto3,enum=task_scheduler.rpc.TaskStatus" json:"status,omitempty"`
	SwarmingTaskId string     `protobuf:"bytes,5,opt,name=swarming_task_id,json=swarmingTaskId,proto3" json:"swarming_task_id,omitempty"`
	// contains filtered or unexported fields
}

TaskSummary provides a subset of the information of a Task.

func (*TaskSummary) Descriptor deprecated 

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

Deprecated: Use TaskSummary.ProtoReflect.Descriptor instead.

func (*TaskSummary) GetAttempt 

func (x *TaskSummary) GetAttempt() int32

func (*TaskSummary) GetId 

func (x *TaskSummary) GetId() string

func (*TaskSummary) GetMaxAttempts 

func (x *TaskSummary) GetMaxAttempts() int32

func (*TaskSummary) GetStatus 

func (x *TaskSummary) GetStatus() TaskStatus

func (*TaskSummary) GetSwarmingTaskId 

func (x *TaskSummary) GetSwarmingTaskId() string

func (*TaskSummary) ProtoMessage 

func (*TaskSummary) ProtoMessage()

func (*TaskSummary) ProtoReflect 

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

func (*TaskSummary) Reset 

func (x *TaskSummary) Reset()

func (*TaskSummary) String 

func (x *TaskSummary) String() string

type TriggerJob 

type TriggerJob struct {

	// job_name is the name of the job to trigger.
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// commit_hash is the hash of the commit at which the job should run.
	CommitHash string `protobuf:"bytes,2,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"`
	// contains filtered or unexported fields
}

TriggerJob represents a single job to trigger.

func (*TriggerJob) Descriptor deprecated 

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

Deprecated: Use TriggerJob.ProtoReflect.Descriptor instead.

func (*TriggerJob) GetCommitHash 

func (x *TriggerJob) GetCommitHash() string

func (*TriggerJob) GetJobName 

func (x *TriggerJob) GetJobName() string

func (*TriggerJob) ProtoMessage 

func (*TriggerJob) ProtoMessage()

func (*TriggerJob) ProtoReflect 

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

func (*TriggerJob) Reset 

func (x *TriggerJob) Reset()

func (*TriggerJob) String 

func (x *TriggerJob) String() string

type TriggerJobsRequest 

type TriggerJobsRequest struct {

	// jobs specifies which jobs to trigger.
	Jobs []*TriggerJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

TriggerJobsRequest is a request to TriggerJobs.

func (*TriggerJobsRequest) Descriptor deprecated 

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

Deprecated: Use TriggerJobsRequest.ProtoReflect.Descriptor instead.

func (*TriggerJobsRequest) GetJobs 

func (x *TriggerJobsRequest) GetJobs() []*TriggerJob

func (*TriggerJobsRequest) ProtoMessage 

func (*TriggerJobsRequest) ProtoMessage()

func (*TriggerJobsRequest) ProtoReflect 

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

func (*TriggerJobsRequest) Reset 

func (x *TriggerJobsRequest) Reset()

func (*TriggerJobsRequest) String 

func (x *TriggerJobsRequest) String() string

type TriggerJobsResponse 

type TriggerJobsResponse struct {

	// job_ids are the IDs of the jobs which were triggered, in the same order
	// as they were requested.
	JobIds []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds,proto3" json:"job_ids,omitempty"`
	// contains filtered or unexported fields
}

TriggerJobsResponse is a response returned by TriggerJobs.

func (*TriggerJobsResponse) Descriptor deprecated 

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

Deprecated: Use TriggerJobsResponse.ProtoReflect.Descriptor instead.

func (*TriggerJobsResponse) GetJobIds 

func (x *TriggerJobsResponse) GetJobIds() []string

func (*TriggerJobsResponse) ProtoMessage 

func (*TriggerJobsResponse) ProtoMessage()

func (*TriggerJobsResponse) ProtoReflect 

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

func (*TriggerJobsResponse) Reset 

func (x *TriggerJobsResponse) Reset()

func (*TriggerJobsResponse) String 

func (x *TriggerJobsResponse) String() string

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 NewTaskSchedulerServiceServer 

func NewTaskSchedulerServiceServer(svc TaskSchedulerService, opts ...interface{}) TwirpServer

NewTaskSchedulerServiceServer 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).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.