rpc

package
v0.0.0-...-0851c09 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.

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 (*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 (*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

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

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

Jump to

Keyboard shortcuts

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