gangway

type CreateJobExecutionRequest struct {
	JobName          string           `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	JobExecutionType JobExecutionType `` /* 134-byte string literal not displayed */
	Refs             *Refs            `protobuf:"bytes,3,opt,name=refs,proto3" json:"refs,omitempty"`
	PodSpecOptions   *PodSpecOptions  `protobuf:"bytes,4,opt,name=pod_spec_options,json=podSpecOptions,proto3" json:"pod_spec_options,omitempty"`
	// contains filtered or unexported fields
}

type Gangway struct {
	UnimplementedProwServer
	ConfigAgent        *config.Agent
	ProwJobClient      ProwJobClient
	InRepoConfigGetter config.InRepoConfigGetter
}

type GetJobExecutionRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type JobExecution struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	JobName        string                 `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	JobType        JobExecutionType       `protobuf:"varint,3,opt,name=job_type,json=jobType,proto3,enum=JobExecutionType" json:"job_type,omitempty"`
	JobStatus      JobExecutionStatus     `protobuf:"varint,4,opt,name=job_status,json=jobStatus,proto3,enum=JobExecutionStatus" json:"job_status,omitempty"`
	Refs           *Refs                  `protobuf:"bytes,5,opt,name=refs,proto3" json:"refs,omitempty"`
	PodSpecOptions *PodSpecOptions        `protobuf:"bytes,6,opt,name=pod_spec_options,json=podSpecOptions,proto3" json:"pod_spec_options,omitempty"`
	GcsPath        string                 `protobuf:"bytes,7,opt,name=gcs_path,json=gcsPath,proto3" json:"gcs_path,omitempty"`
	CreateTime     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CompletionTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=completion_time,json=completionTime,proto3" json:"completion_time,omitempty"`
	// contains filtered or unexported fields
}

type JobExecutionStatus int32

type JobExecutionType int32

type JobExecutions struct {
	JobExecution []*JobExecution `protobuf:"bytes,1,rep,name=job_execution,json=jobExecution,proto3" json:"job_execution,omitempty"`
	// contains filtered or unexported fields
}

type ListJobExecutionsRequest struct {
	JobName string             `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`         // Mapped to URL query parameter `job_name`.
	Status  JobExecutionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=JobExecutionStatus" json:"status,omitempty"` // Mapped to URL query parameter `status`.
	// contains filtered or unexported fields
}

type PodSpecOptions struct {
	Envs        map[string]string `` /* 149-byte string literal not displayed */
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ProwCfgAdapter struct {
	*config.Config
}

type ProwClient interface {
	// FIXME: In the future we can just return a unique token (only), in the same
	// way that GCB returns immediately with the globally-unique BuildId. That is,
	// in the future the response will be a union of either the full JobExecution
	// message or a single JobExecutionToken (string). See
	// https://docs.google.com/document/d/1v77jp1Nb5C2C2-PdV02SGViO9CyZ9SvNxCPOHyIUQeo/edit#bookmark=id.q68srxklvpt4.
	CreateJobExecution(ctx context.Context, in *CreateJobExecutionRequest, opts ...grpc.CallOption) (*JobExecution, error)
	GetJobExecution(ctx context.Context, in *GetJobExecutionRequest, opts ...grpc.CallOption) (*JobExecution, error)
	ListJobExecutions(ctx context.Context, in *ListJobExecutionsRequest, opts ...grpc.CallOption) (*JobExecutions, error)
}

type ProwJobClient interface {
	Create(context.Context, *prowcrd.ProwJob, metav1.CreateOptions) (*prowcrd.ProwJob, error)
	Get(context.Context, string, metav1.GetOptions) (*prowcrd.ProwJob, error)
}

type ProwServer interface {
	// FIXME: In the future we can just return a unique token (only), in the same
	// way that GCB returns immediately with the globally-unique BuildId. That is,
	// in the future the response will be a union of either the full JobExecution
	// message or a single JobExecutionToken (string). See
	// https://docs.google.com/document/d/1v77jp1Nb5C2C2-PdV02SGViO9CyZ9SvNxCPOHyIUQeo/edit#bookmark=id.q68srxklvpt4.
	CreateJobExecution(context.Context, *CreateJobExecutionRequest) (*JobExecution, error)
	GetJobExecution(context.Context, *GetJobExecutionRequest) (*JobExecution, error)
	ListJobExecutions(context.Context, *ListJobExecutionsRequest) (*JobExecutions, error)
	// contains filtered or unexported methods
}

type Pull struct {
	Number     int32  `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	Author     string `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	Sha        string `protobuf:"bytes,3,opt,name=sha,proto3" json:"sha,omitempty"`
	Title      string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	Ref        string `protobuf:"bytes,5,opt,name=ref,proto3" json:"ref,omitempty"`
	Link       string `protobuf:"bytes,6,opt,name=link,proto3" json:"link,omitempty"`
	CommitLink string `protobuf:"bytes,7,opt,name=commit_link,json=commitLink,proto3" json:"commit_link,omitempty"`
	AuthorLink string `protobuf:"bytes,8,opt,name=author_link,json=authorLink,proto3" json:"author_link,omitempty"`
	// contains filtered or unexported fields
}

type Refs struct {
	Org            string  `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	Repo           string  `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	RepoLink       string  `protobuf:"bytes,3,opt,name=repo_link,json=repoLink,proto3" json:"repo_link,omitempty"`
	BaseRef        string  `protobuf:"bytes,4,opt,name=base_ref,json=baseRef,proto3" json:"base_ref,omitempty"`
	BaseSha        string  `protobuf:"bytes,5,opt,name=base_sha,json=baseSha,proto3" json:"base_sha,omitempty"`
	BaseLink       string  `protobuf:"bytes,6,opt,name=base_link,json=baseLink,proto3" json:"base_link,omitempty"`
	Pulls          []*Pull `protobuf:"bytes,7,rep,name=pulls,proto3" json:"pulls,omitempty"`
	PathAlias      string  `protobuf:"bytes,8,opt,name=path_alias,json=pathAlias,proto3" json:"path_alias,omitempty"`
	WorkDir        bool    `protobuf:"varint,9,opt,name=work_dir,json=workDir,proto3" json:"work_dir,omitempty"`
	CloneUri       string  `protobuf:"bytes,10,opt,name=clone_uri,json=cloneUri,proto3" json:"clone_uri,omitempty"`
	SkipSubmodules bool    `protobuf:"varint,11,opt,name=skip_submodules,json=skipSubmodules,proto3" json:"skip_submodules,omitempty"`
	CloneDepth     int32   `protobuf:"varint,12,opt,name=clone_depth,json=cloneDepth,proto3" json:"clone_depth,omitempty"`
	SkipFetchHead  bool    `protobuf:"varint,13,opt,name=skip_fetch_head,json=skipFetchHead,proto3" json:"skip_fetch_head,omitempty"`
	// contains filtered or unexported fields
}

type ReporterFunc func(pj *prowcrd.ProwJob, state prowcrd.ProwJobState, err error)

type UnimplementedProwServer struct {
}

type UnsafeProwServer interface {
	// contains filtered or unexported methods
}