admin

package
v0.0.0-...-3c039c4 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2025 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_driver_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_gerrit_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_launcher_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_reporter_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_tracker_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_tricium_api_admin_v1_workflow_proto protoreflect.FileDescriptor

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterDriverServer 

func RegisterDriverServer(s prpc.Registrar, srv DriverServer)

func RegisterGerritServer 

func RegisterGerritServer(s prpc.Registrar, srv GerritServer)

func RegisterLauncherServer 

func RegisterLauncherServer(s prpc.Registrar, srv LauncherServer)

func RegisterReporterServer 

func RegisterReporterServer(s prpc.Registrar, srv ReporterServer)

func RegisterTrackerServer 

func RegisterTrackerServer(s prpc.Registrar, srv TrackerServer)

Types

type CollectRequest 

type CollectRequest struct {
	RunId int64 `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Worker name of the worker to collect results for.
	Worker string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	// The Buildbucket build ID.
	//
	// Used to collect results from the completed buildbucket worker task.
	BuildId int64 `protobuf:"varint,5,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

CollectRequest contains the details needed to collect results from a worker.

func (*CollectRequest) Descriptor deprecated 

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

Deprecated: Use CollectRequest.ProtoReflect.Descriptor instead.

func (*CollectRequest) GetBuildId 

func (x *CollectRequest) GetBuildId() int64

func (*CollectRequest) GetRunId 

func (x *CollectRequest) GetRunId() int64

func (*CollectRequest) GetWorker 

func (x *CollectRequest) GetWorker() string

func (*CollectRequest) ProtoMessage 

func (*CollectRequest) ProtoMessage()

func (*CollectRequest) ProtoReflect 

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

func (*CollectRequest) Reset 

func (x *CollectRequest) Reset()

func (*CollectRequest) String 

func (x *CollectRequest) String() string

type CollectResponse 

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

func (*CollectResponse) Descriptor deprecated 

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

Deprecated: Use CollectResponse.ProtoReflect.Descriptor instead.

func (*CollectResponse) ProtoMessage 

func (*CollectResponse) ProtoMessage()

func (*CollectResponse) ProtoReflect 

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

func (*CollectResponse) Reset 

func (x *CollectResponse) Reset()

func (*CollectResponse) String 

func (x *CollectResponse) String() string

type DriverClient 

type DriverClient interface {
	// Trigger triggers a build for a Tricium worker.
	Trigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*TriggerResponse, error)
	// Collect collects results from a build running a Tricium worker.
	Collect(ctx context.Context, in *CollectRequest, opts ...grpc.CallOption) (*CollectResponse, error)
}

DriverClient is the client API for Driver service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDriverClient 

func NewDriverClient(cc grpc.ClientConnInterface) DriverClient

func NewDriverPRPCClient 

func NewDriverPRPCClient(client *prpc.Client) DriverClient

type DriverServer 

type DriverServer interface {
	// Trigger triggers a build for a Tricium worker.
	Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error)
	// Collect collects results from a build running a Tricium worker.
	Collect(context.Context, *CollectRequest) (*CollectResponse, error)
}

DriverServer is the server API for Driver service.

type GerritClient 

type GerritClient interface {
	// PollProject polls Gerrit for changes to analyze.
	PollProject(ctx context.Context, in *PollProjectRequest, opts ...grpc.CallOption) (*PollProjectResponse, error)
}

GerritClient is the client API for Gerrit service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGerritClient 

func NewGerritClient(cc grpc.ClientConnInterface) GerritClient

func NewGerritPRPCClient 

func NewGerritPRPCClient(client *prpc.Client) GerritClient

type GerritServer 

type GerritServer interface {
	// PollProject polls Gerrit for changes to analyze.
	PollProject(context.Context, *PollProjectRequest) (*PollProjectResponse, error)
}

GerritServer is the server API for Gerrit service.

type LaunchRequest 

type LaunchRequest struct {

	// The run ID created by a Tricium.Analyze call.
	RunId int64 `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// The name of the project in luci-config.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// The full URL of the git repo used for this run.
	GitUrl string `protobuf:"bytes,3,opt,name=git_url,json=gitUrl,proto3" json:"git_url,omitempty"`
	// A git commit-ish, such as a Gerrit revision ref name like
	// "refs/changes/34/1234/1", or any other ref name or commit hash.
	// This is used in the GitFileDetails data type used to pull files.
	GitRef string `protobuf:"bytes,4,opt,name=git_ref,json=gitRef,proto3" json:"git_ref,omitempty"`
	// File metadata from the root of the Git repository.
	Files []*v1.Data_File `protobuf:"bytes,5,rep,name=files,proto3" json:"files,omitempty"`
	// Commit message text from Gerrit if available.
	//
	// If this launch request is not for Gerrit, this could be an empty string.
	CommitMessage string `protobuf:"bytes,6,opt,name=commit_message,json=commitMessage,proto3" json:"commit_message,omitempty"`
	// contains filtered or unexported fields
}

LaunchRequest contains the details needed to launch a workflow for an analysis request.

func (*LaunchRequest) Descriptor deprecated 

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

Deprecated: Use LaunchRequest.ProtoReflect.Descriptor instead.

func (*LaunchRequest) GetCommitMessage 

func (x *LaunchRequest) GetCommitMessage() string

func (*LaunchRequest) GetFiles 

func (x *LaunchRequest) GetFiles() []*v1.Data_File

func (*LaunchRequest) GetGitRef 

func (x *LaunchRequest) GetGitRef() string

func (*LaunchRequest) GetGitUrl 

func (x *LaunchRequest) GetGitUrl() string

func (*LaunchRequest) GetProject 

func (x *LaunchRequest) GetProject() string

func (*LaunchRequest) GetRunId 

func (x *LaunchRequest) GetRunId() int64

func (*LaunchRequest) ProtoMessage 

func (*LaunchRequest) ProtoMessage()

func (*LaunchRequest) ProtoReflect 

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

func (*LaunchRequest) Reset 

func (x *LaunchRequest) Reset()

func (*LaunchRequest) String 

func (x *LaunchRequest) String() string

type LaunchResponse 

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

func (*LaunchResponse) Descriptor deprecated 

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

Deprecated: Use LaunchResponse.ProtoReflect.Descriptor instead.

func (*LaunchResponse) ProtoMessage 

func (*LaunchResponse) ProtoMessage()

func (*LaunchResponse) ProtoReflect 

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

func (*LaunchResponse) Reset 

func (x *LaunchResponse) Reset()

func (*LaunchResponse) String 

func (x *LaunchResponse) String() string

type LauncherClient 

type LauncherClient interface {
	// Launch launches a workflow for provided request details.
	Launch(ctx context.Context, in *LaunchRequest, opts ...grpc.CallOption) (*LaunchResponse, error)
}

LauncherClient is the client API for Launcher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLauncherClient 

func NewLauncherClient(cc grpc.ClientConnInterface) LauncherClient

func NewLauncherPRPCClient 

func NewLauncherPRPCClient(client *prpc.Client) LauncherClient

type LauncherServer 

type LauncherServer interface {
	// Launch launches a workflow for provided request details.
	Launch(context.Context, *LaunchRequest) (*LaunchResponse, error)
}

LauncherServer is the server API for Launcher service.

type PollProjectRequest 

type PollProjectRequest struct {

	// The name of the project in luci-config.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

PollProjectRequest is a request to poll one project.

func (*PollProjectRequest) Descriptor deprecated 

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

Deprecated: Use PollProjectRequest.ProtoReflect.Descriptor instead.

func (*PollProjectRequest) GetProject 

func (x *PollProjectRequest) GetProject() string

func (*PollProjectRequest) ProtoMessage 

func (*PollProjectRequest) ProtoMessage()

func (*PollProjectRequest) ProtoReflect 

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

func (*PollProjectRequest) Reset 

func (x *PollProjectRequest) Reset()

func (*PollProjectRequest) String 

func (x *PollProjectRequest) String() string

type PollProjectResponse 

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

func (*PollProjectResponse) Descriptor deprecated 

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

Deprecated: Use PollProjectResponse.ProtoReflect.Descriptor instead.

func (*PollProjectResponse) ProtoMessage 

func (*PollProjectResponse) ProtoMessage()

func (*PollProjectResponse) ProtoReflect 

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

func (*PollProjectResponse) Reset 

func (x *PollProjectResponse) Reset()

func (*PollProjectResponse) String 

func (x *PollProjectResponse) String() string

type ReportResultsRequest 

type ReportResultsRequest struct {
	RunId    int64  `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Analyzer string `protobuf:"bytes,2,opt,name=analyzer,proto3" json:"analyzer,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportResultsRequest) Descriptor deprecated 

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

Deprecated: Use ReportResultsRequest.ProtoReflect.Descriptor instead.

func (*ReportResultsRequest) GetAnalyzer 

func (x *ReportResultsRequest) GetAnalyzer() string

func (*ReportResultsRequest) GetRunId 

func (x *ReportResultsRequest) GetRunId() int64

func (*ReportResultsRequest) ProtoMessage 

func (*ReportResultsRequest) ProtoMessage()

func (*ReportResultsRequest) ProtoReflect 

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

func (*ReportResultsRequest) Reset 

func (x *ReportResultsRequest) Reset()

func (*ReportResultsRequest) String 

func (x *ReportResultsRequest) String() string

type ReportResultsResponse 

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

func (*ReportResultsResponse) Descriptor deprecated 

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

Deprecated: Use ReportResultsResponse.ProtoReflect.Descriptor instead.

func (*ReportResultsResponse) ProtoMessage 

func (*ReportResultsResponse) ProtoMessage()

func (*ReportResultsResponse) ProtoReflect 

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

func (*ReportResultsResponse) Reset 

func (x *ReportResultsResponse) Reset()

func (*ReportResultsResponse) String 

func (x *ReportResultsResponse) String() string

type ReporterClient 

type ReporterClient interface {
	// ReportResults reports Tricium results.
	ReportResults(ctx context.Context, in *ReportResultsRequest, opts ...grpc.CallOption) (*ReportResultsResponse, error)
}

ReporterClient is the client API for Reporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReporterClient 

func NewReporterClient(cc grpc.ClientConnInterface) ReporterClient

func NewReporterPRPCClient 

func NewReporterPRPCClient(client *prpc.Client) ReporterClient

type ReporterServer 

type ReporterServer interface {
	// ReportResults reports Tricium results.
	ReportResults(context.Context, *ReportResultsRequest) (*ReportResultsResponse, error)
}

ReporterServer is the server API for Reporter service.

type TrackerClient 

type TrackerClient interface {
	// WorkflowLaunched marks the workflow as launched for a specified run.
	WorkflowLaunched(ctx context.Context, in *WorkflowLaunchedRequest, opts ...grpc.CallOption) (*WorkflowLaunchedResponse, error)
	// WorkerLaunched marks the specified worker as launched.
	WorkerLaunched(ctx context.Context, in *WorkerLaunchedRequest, opts ...grpc.CallOption) (*WorkerLaunchedResponse, error)
	// WorkerDone marks the specified worker as done.
	WorkerDone(ctx context.Context, in *WorkerDoneRequest, opts ...grpc.CallOption) (*WorkerDoneResponse, error)
}

TrackerClient is the client API for Tracker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTrackerClient 

func NewTrackerClient(cc grpc.ClientConnInterface) TrackerClient

func NewTrackerPRPCClient 

func NewTrackerPRPCClient(client *prpc.Client) TrackerClient

type TrackerServer 

type TrackerServer interface {
	// WorkflowLaunched marks the workflow as launched for a specified run.
	WorkflowLaunched(context.Context, *WorkflowLaunchedRequest) (*WorkflowLaunchedResponse, error)
	// WorkerLaunched marks the specified worker as launched.
	WorkerLaunched(context.Context, *WorkerLaunchedRequest) (*WorkerLaunchedResponse, error)
	// WorkerDone marks the specified worker as done.
	WorkerDone(context.Context, *WorkerDoneRequest) (*WorkerDoneResponse, error)
}

TrackerServer is the server API for Tracker service.

type TriggerRequest 

type TriggerRequest struct {
	RunId  int64  `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Worker string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

TriggerRequest contains the details for launching a build for a worker.

func (*TriggerRequest) Descriptor deprecated 

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

Deprecated: Use TriggerRequest.ProtoReflect.Descriptor instead.

func (*TriggerRequest) GetRunId 

func (x *TriggerRequest) GetRunId() int64

func (*TriggerRequest) GetWorker 

func (x *TriggerRequest) GetWorker() string

func (*TriggerRequest) ProtoMessage 

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) ProtoReflect 

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

func (*TriggerRequest) Reset 

func (x *TriggerRequest) Reset()

func (*TriggerRequest) String 

func (x *TriggerRequest) String() string

type TriggerResponse 

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

func (*TriggerResponse) Descriptor deprecated 

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

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) ProtoMessage 

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect 

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

func (*TriggerResponse) Reset 

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String 

func (x *TriggerResponse) String() string

type UnimplementedDriverServer 

type UnimplementedDriverServer struct {
}

UnimplementedDriverServer can be embedded to have forward compatible implementations.

func (*UnimplementedDriverServer) Collect 

func (*UnimplementedDriverServer) Collect(context.Context, *CollectRequest) (*CollectResponse, error)

func (*UnimplementedDriverServer) Trigger 

func (*UnimplementedDriverServer) Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error)

type UnimplementedGerritServer 

type UnimplementedGerritServer struct {
}

UnimplementedGerritServer can be embedded to have forward compatible implementations.

func (*UnimplementedGerritServer) PollProject 

func (*UnimplementedGerritServer) PollProject(context.Context, *PollProjectRequest) (*PollProjectResponse, error)

type UnimplementedLauncherServer 

type UnimplementedLauncherServer struct {
}

UnimplementedLauncherServer can be embedded to have forward compatible implementations.

func (*UnimplementedLauncherServer) Launch 

func (*UnimplementedLauncherServer) Launch(context.Context, *LaunchRequest) (*LaunchResponse, error)

type UnimplementedReporterServer 

type UnimplementedReporterServer struct {
}

UnimplementedReporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedReporterServer) ReportResults 

func (*UnimplementedReporterServer) ReportResults(context.Context, *ReportResultsRequest) (*ReportResultsResponse, error)

type UnimplementedTrackerServer 

type UnimplementedTrackerServer struct {
}

UnimplementedTrackerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTrackerServer) WorkerDone 

func (*UnimplementedTrackerServer) WorkerDone(context.Context, *WorkerDoneRequest) (*WorkerDoneResponse, error)

func (*UnimplementedTrackerServer) WorkerLaunched 

func (*UnimplementedTrackerServer) WorkerLaunched(context.Context, *WorkerLaunchedRequest) (*WorkerLaunchedResponse, error)

func (*UnimplementedTrackerServer) WorkflowLaunched 

func (*UnimplementedTrackerServer) WorkflowLaunched(context.Context, *WorkflowLaunchedRequest) (*WorkflowLaunchedResponse, error)

type Worker 

type Worker struct {

	// Name of worker is combination of the function and platform name
	// for which results are provided, e.g "GitFileIsolator_LINUX".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Includes data dependencies for runtime type checking.
	// Platform-specific details are provided when required by the corresponding
	// data type.
	Needs               v1.Data_Type     `protobuf:"varint,2,opt,name=needs,proto3,enum=tricium.Data_Type" json:"needs,omitempty"`
	NeedsForPlatform    v1.Platform_Name `` /* 139-byte string literal not displayed */
	Provides            v1.Data_Type     `protobuf:"varint,4,opt,name=provides,proto3,enum=tricium.Data_Type" json:"provides,omitempty"`
	ProvidesForPlatform v1.Platform_Name `` /* 148-byte string literal not displayed */
	// Workers to run after this one.
	//
	// For recipe-based analyzers this should be empty.
	Next []string `protobuf:"bytes,6,rep,name=next,proto3" json:"next,omitempty"`
	// Name of the runtime platform configuration.
	RuntimePlatform v1.Platform_Name `` /* 134-byte string literal not displayed */
	// Types that are valid to be assigned to Impl:
	//
	//	*Worker_Recipe
	Impl isWorker_Impl `protobuf_oneof:"impl"`
	// contains filtered or unexported fields
}

A Tricium worker includes the details needed to execute an analyzer.

func (*Worker) Descriptor deprecated 

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetImpl 

func (x *Worker) GetImpl() isWorker_Impl

func (*Worker) GetName 

func (x *Worker) GetName() string

func (*Worker) GetNeeds 

func (x *Worker) GetNeeds() v1.Data_Type

func (*Worker) GetNeedsForPlatform 

func (x *Worker) GetNeedsForPlatform() v1.Platform_Name

func (*Worker) GetNext 

func (x *Worker) GetNext() []string

func (*Worker) GetProvides 

func (x *Worker) GetProvides() v1.Data_Type

func (*Worker) GetProvidesForPlatform 

func (x *Worker) GetProvidesForPlatform() v1.Platform_Name

func (*Worker) GetRecipe 

func (x *Worker) GetRecipe() *v1.Recipe

func (*Worker) GetRuntimePlatform 

func (x *Worker) GetRuntimePlatform() v1.Platform_Name

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect 

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

func (*Worker) Reset 

func (x *Worker) Reset()

func (*Worker) String 

func (x *Worker) String() string

type WorkerDoneRequest 

type WorkerDoneRequest struct {
	RunId             int64        `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Worker            string       `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Provides          v1.Data_Type `protobuf:"varint,4,opt,name=provides,proto3,enum=tricium.Data_Type" json:"provides,omitempty"`
	State             v1.State     `protobuf:"varint,5,opt,name=state,proto3,enum=tricium.State" json:"state,omitempty"`
	BuildbucketOutput string       `protobuf:"bytes,6,opt,name=buildbucket_output,json=buildbucketOutput,proto3" json:"buildbucket_output,omitempty"`
	// contains filtered or unexported fields
}

WorkerDoneRequest specifies details needed to mark a worker as done. This includes details useful for the tracking UI.

func (*WorkerDoneRequest) Descriptor deprecated 

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

Deprecated: Use WorkerDoneRequest.ProtoReflect.Descriptor instead.

func (*WorkerDoneRequest) GetBuildbucketOutput 

func (x *WorkerDoneRequest) GetBuildbucketOutput() string

func (*WorkerDoneRequest) GetProvides 

func (x *WorkerDoneRequest) GetProvides() v1.Data_Type

func (*WorkerDoneRequest) GetRunId 

func (x *WorkerDoneRequest) GetRunId() int64

func (*WorkerDoneRequest) GetState 

func (x *WorkerDoneRequest) GetState() v1.State

func (*WorkerDoneRequest) GetWorker 

func (x *WorkerDoneRequest) GetWorker() string

func (*WorkerDoneRequest) ProtoMessage 

func (*WorkerDoneRequest) ProtoMessage()

func (*WorkerDoneRequest) ProtoReflect 

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

func (*WorkerDoneRequest) Reset 

func (x *WorkerDoneRequest) Reset()

func (*WorkerDoneRequest) String 

func (x *WorkerDoneRequest) String() string

type WorkerDoneResponse 

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

func (*WorkerDoneResponse) Descriptor deprecated 

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

Deprecated: Use WorkerDoneResponse.ProtoReflect.Descriptor instead.

func (*WorkerDoneResponse) ProtoMessage 

func (*WorkerDoneResponse) ProtoMessage()

func (*WorkerDoneResponse) ProtoReflect 

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

func (*WorkerDoneResponse) Reset 

func (x *WorkerDoneResponse) Reset()

func (*WorkerDoneResponse) String 

func (x *WorkerDoneResponse) String() string

type WorkerLaunchedRequest 

type WorkerLaunchedRequest struct {
	RunId              int64  `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Worker             string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	BuildbucketBuildId int64  `protobuf:"varint,5,opt,name=buildbucket_build_id,json=buildbucketBuildId,proto3" json:"buildbucket_build_id,omitempty"`
	// contains filtered or unexported fields
}

WorkerLaunchedRequest specifies details needed to mark a worker as launched. This includes details useful for the tracking UI.

This message should be sent by the Driver after a Buildbucket build for the worker has been triggered.

func (*WorkerLaunchedRequest) Descriptor deprecated 

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

Deprecated: Use WorkerLaunchedRequest.ProtoReflect.Descriptor instead.

func (*WorkerLaunchedRequest) GetBuildbucketBuildId 

func (x *WorkerLaunchedRequest) GetBuildbucketBuildId() int64

func (*WorkerLaunchedRequest) GetRunId 

func (x *WorkerLaunchedRequest) GetRunId() int64

func (*WorkerLaunchedRequest) GetWorker 

func (x *WorkerLaunchedRequest) GetWorker() string

func (*WorkerLaunchedRequest) ProtoMessage 

func (*WorkerLaunchedRequest) ProtoMessage()

func (*WorkerLaunchedRequest) ProtoReflect 

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

func (*WorkerLaunchedRequest) Reset 

func (x *WorkerLaunchedRequest) Reset()

func (*WorkerLaunchedRequest) String 

func (x *WorkerLaunchedRequest) String() string

type WorkerLaunchedResponse 

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

func (*WorkerLaunchedResponse) Descriptor deprecated 

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

Deprecated: Use WorkerLaunchedResponse.ProtoReflect.Descriptor instead.

func (*WorkerLaunchedResponse) ProtoMessage 

func (*WorkerLaunchedResponse) ProtoMessage()

func (*WorkerLaunchedResponse) ProtoReflect 

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

func (*WorkerLaunchedResponse) Reset 

func (x *WorkerLaunchedResponse) Reset()

func (*WorkerLaunchedResponse) String 

func (x *WorkerLaunchedResponse) String() string

type Worker_Recipe 

type Worker_Recipe struct {
	// Recipe for recipe-based implementation.
	Recipe *v1.Recipe `protobuf:"bytes,12,opt,name=recipe,proto3,oneof"`
}

type Workflow 

type Workflow struct {
	Workers []*Worker `protobuf:"bytes,2,rep,name=workers,proto3" json:"workers,omitempty"`
	// Function definitions used for this workflow; these contain the function
	// owner and component, to be used when filling out a bug filing template.
	Functions             []*v1.Function `protobuf:"bytes,5,rep,name=functions,proto3" json:"functions,omitempty"`
	BuildbucketServerHost string         `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Tricium workflow configuration.

A Workflow is generated from a merged service and project config, and contains information required for one workflow run.

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetBuildbucketServerHost 

func (x *Workflow) GetBuildbucketServerHost() string

func (*Workflow) GetFunctions 

func (x *Workflow) GetFunctions() []*v1.Function

func (*Workflow) GetNext 

func (wf *Workflow) GetNext(cw string) []string

GetNext returns the names of successing workers of the given worker.

func (*Workflow) GetWithDescendants 

func (wf *Workflow) GetWithDescendants(cw string) []string

GetWithDescendants returns the provided worker and its descendant workers.

func (*Workflow) GetWorker 

func (wf *Workflow) GetWorker(name string) (*Worker, error)

GetWorker returns the worker matching the given name.

An unknown worker results in an error.

func (*Workflow) GetWorkers 

func (x *Workflow) GetWorkers() []*Worker

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

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

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) RootWorkers 

func (wf *Workflow) RootWorkers() []string

RootWorkers returns the list of root worker names.

Root workers are those workers in need of the initial Tricium data type, i.e., Git file details.

func (*Workflow) String 

func (x *Workflow) String() string

type WorkflowLaunchedRequest 

type WorkflowLaunchedRequest struct {
	RunId int64 `protobuf:"varint,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

WorkflowLaunchedRequest specified details need to mark a workflow as launched.

This message should be sent by the Launcher after a workflow has been launched.

func (*WorkflowLaunchedRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowLaunchedRequest.ProtoReflect.Descriptor instead.

func (*WorkflowLaunchedRequest) GetRunId 

func (x *WorkflowLaunchedRequest) GetRunId() int64

func (*WorkflowLaunchedRequest) ProtoMessage 

func (*WorkflowLaunchedRequest) ProtoMessage()

func (*WorkflowLaunchedRequest) ProtoReflect 

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

func (*WorkflowLaunchedRequest) Reset 

func (x *WorkflowLaunchedRequest) Reset()

func (*WorkflowLaunchedRequest) String 

func (x *WorkflowLaunchedRequest) String() string

type WorkflowLaunchedResponse 

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

func (*WorkflowLaunchedResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowLaunchedResponse.ProtoReflect.Descriptor instead.

func (*WorkflowLaunchedResponse) ProtoMessage 

func (*WorkflowLaunchedResponse) ProtoMessage()

func (*WorkflowLaunchedResponse) ProtoReflect 

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

func (*WorkflowLaunchedResponse) Reset 

func (x *WorkflowLaunchedResponse) Reset()

func (*WorkflowLaunchedResponse) String 

func (x *WorkflowLaunchedResponse) String() string

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.