pps

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2015 License: Apache-2.0 Imports: 5 Imported by: 0

README

This is a work-in-progress package for our new PPS API.

Documentation

Overview

Package pps is a generated protocol buffer package.

It is generated from these files: 

pps.proto

It has these top-level messages: 

PipelineRunStatus
Input
Output
Node
DockerService
Element
Pipeline
GithubPipelineSource
PipelineSource
Version
GetVersionResponse
GetPipelineRequest
GetPipelineResponse
StartPipelineRunRequest
StartPipelineRunResponse
GetPipelineRunStatusRequest
GetPipelineRunStatusResponse

Index

Constants

This section is empty.

Variables

View Source 
var PipelineRunStatusType_name = map[int32]string{
	0: "PIPELINE_RUN_STATUS_TYPE_NONE",
	1: "PIPELINE_RUN_STATUS_TYPE_ADDED",
	2: "PIPELINE_RUN_STATUS_TYPE_STARTED",
	3: "PIPELINE_RUN_STATUS_TYPE_PIPELINE_RUNNING",
	4: "PIPELINE_RUN_STATUS_TYPE_DEAD",
	5: "PIPELINE_RUN_STATUS_TYPE_ERROR",
	6: "PIPELINE_RUN_STATUS_TYPE_SUCCESS",
}
View Source 
var PipelineRunStatusType_value = map[string]int32{
	"PIPELINE_RUN_STATUS_TYPE_NONE":             0,
	"PIPELINE_RUN_STATUS_TYPE_ADDED":            1,
	"PIPELINE_RUN_STATUS_TYPE_STARTED":          2,
	"PIPELINE_RUN_STATUS_TYPE_PIPELINE_RUNNING": 3,
	"PIPELINE_RUN_STATUS_TYPE_DEAD":             4,
	"PIPELINE_RUN_STATUS_TYPE_ERROR":            5,
	"PIPELINE_RUN_STATUS_TYPE_SUCCESS":          6,
}

Functions

func RegisterApiServer 

func RegisterApiServer(s *grpc.Server, srv ApiServer)

func VersionString 

func VersionString(version *Version) string

Types

type ApiClient 

type ApiClient interface {
	GetVersion(ctx context.Context, in *google_protobuf.Empty, opts ...grpc.CallOption) (*GetVersionResponse, error)
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error)
	StartPipelineRun(ctx context.Context, in *StartPipelineRunRequest, opts ...grpc.CallOption) (*StartPipelineRunResponse, error)
	GetPipelineRunStatus(ctx context.Context, in *GetPipelineRunStatusRequest, opts ...grpc.CallOption) (*GetPipelineRunStatusResponse, error)
}

func NewApiClient 

func NewApiClient(cc *grpc.ClientConn) ApiClient

type ApiServer 

type ApiServer interface {
	GetVersion(context.Context, *google_protobuf.Empty) (*GetVersionResponse, error)
	GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
	StartPipelineRun(context.Context, *StartPipelineRunRequest) (*StartPipelineRunResponse, error)
	GetPipelineRunStatus(context.Context, *GetPipelineRunStatusRequest) (*GetPipelineRunStatusResponse, error)
}

type DockerService 

type DockerService struct {
	Image      string `protobuf:"bytes,1,opt,name=image" json:"image,omitempty"`
	Build      string `protobuf:"bytes,2,opt,name=build" json:"build,omitempty"`
	Dockerfile string `protobuf:"bytes,3,opt,name=dockerfile" json:"dockerfile,omitempty"`
}

func (*DockerService) ProtoMessage 

func (*DockerService) ProtoMessage()

func (*DockerService) Reset 

func (m *DockerService) Reset()

func (*DockerService) String 

func (m *DockerService) String() string

type Element 

type Element struct {
	Name          string         `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Node          *Node          `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
	DockerService *DockerService `protobuf:"bytes,3,opt,name=docker_service" json:"docker_service,omitempty"`
}

func (*Element) GetDockerService 

func (m *Element) GetDockerService() *DockerService

func (*Element) GetNode 

func (m *Element) GetNode() *Node

func (*Element) ProtoMessage 

func (*Element) ProtoMessage()

func (*Element) Reset 

func (m *Element) Reset()

func (*Element) String 

func (m *Element) String() string

type GetPipelineRequest 

type GetPipelineRequest struct {
	PipelineSource *PipelineSource `protobuf:"bytes,1,opt,name=pipeline_source" json:"pipeline_source,omitempty"`
}

func (*GetPipelineRequest) GetPipelineSource 

func (m *GetPipelineRequest) GetPipelineSource() *PipelineSource

func (*GetPipelineRequest) ProtoMessage 

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) Reset 

func (m *GetPipelineRequest) Reset()

func (*GetPipelineRequest) String 

func (m *GetPipelineRequest) String() string

type GetPipelineResponse 

type GetPipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
}

func (*GetPipelineResponse) GetPipeline 

func (m *GetPipelineResponse) GetPipeline() *Pipeline

func (*GetPipelineResponse) ProtoMessage 

func (*GetPipelineResponse) ProtoMessage()

func (*GetPipelineResponse) Reset 

func (m *GetPipelineResponse) Reset()

func (*GetPipelineResponse) String 

func (m *GetPipelineResponse) String() string

type GetPipelineRunStatusRequest 

type GetPipelineRunStatusRequest struct {
	PipelineRunId string `protobuf:"bytes,1,opt,name=pipeline_run_id" json:"pipeline_run_id,omitempty"`
}

func (*GetPipelineRunStatusRequest) ProtoMessage 

func (*GetPipelineRunStatusRequest) ProtoMessage()

func (*GetPipelineRunStatusRequest) Reset 

func (m *GetPipelineRunStatusRequest) Reset()

func (*GetPipelineRunStatusRequest) String 

func (m *GetPipelineRunStatusRequest) String() string

type GetPipelineRunStatusResponse 

type GetPipelineRunStatusResponse struct {
	PipelineRunStatus *PipelineRunStatus `protobuf:"bytes,1,opt,name=pipeline_run_status" json:"pipeline_run_status,omitempty"`
}

func (*GetPipelineRunStatusResponse) GetPipelineRunStatus 

func (m *GetPipelineRunStatusResponse) GetPipelineRunStatus() *PipelineRunStatus

func (*GetPipelineRunStatusResponse) ProtoMessage 

func (*GetPipelineRunStatusResponse) ProtoMessage()

func (*GetPipelineRunStatusResponse) Reset 

func (m *GetPipelineRunStatusResponse) Reset()

func (*GetPipelineRunStatusResponse) String 

func (m *GetPipelineRunStatusResponse) String() string

type GetVersionResponse 

type GetVersionResponse struct {
	Version *Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

func (*GetVersionResponse) GetVersion 

func (m *GetVersionResponse) GetVersion() *Version

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) Reset 

func (m *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (m *GetVersionResponse) String() string

type GithubPipelineSource 

type GithubPipelineSource struct {
	ContextDir  string `protobuf:"bytes,1,opt,name=context_dir" json:"context_dir,omitempty"`
	User        string `protobuf:"bytes,2,opt,name=user" json:"user,omitempty"`
	Repository  string `protobuf:"bytes,3,opt,name=repository" json:"repository,omitempty"`
	Branch      string `protobuf:"bytes,4,opt,name=branch" json:"branch,omitempty"`
	AccessToken string `protobuf:"bytes,5,opt,name=access_token" json:"access_token,omitempty"`
}

func (*GithubPipelineSource) ProtoMessage 

func (*GithubPipelineSource) ProtoMessage()

func (*GithubPipelineSource) Reset 

func (m *GithubPipelineSource) Reset()

func (*GithubPipelineSource) String 

func (m *GithubPipelineSource) String() string

type Input 

type Input struct {
	Host map[string]string `` /* 128-byte string literal not displayed */
	Pfs  map[string]string `` /* 126-byte string literal not displayed */
}

func (*Input) GetHost 

func (m *Input) GetHost() map[string]string

func (*Input) GetPfs 

func (m *Input) GetPfs() map[string]string

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) Reset 

func (m *Input) Reset()

func (*Input) String 

func (m *Input) String() string

type Node 

type Node struct {
	Input  *Input   `protobuf:"bytes,1,opt,name=input" json:"input,omitempty"`
	Output *Output  `protobuf:"bytes,2,opt,name=output" json:"output,omitempty"`
	Run    []string `protobuf:"bytes,3,rep,name=run" json:"run,omitempty"`
}

func (*Node) GetInput 

func (m *Node) GetInput() *Input

func (*Node) GetOutput 

func (m *Node) GetOutput() *Output

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

type Output 

type Output struct {
	Host map[string]string `` /* 128-byte string literal not displayed */
	Pfs  map[string]string `` /* 126-byte string literal not displayed */
}

func (*Output) GetHost 

func (m *Output) GetHost() map[string]string

func (*Output) GetPfs 

func (m *Output) GetPfs() map[string]string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) Reset 

func (m *Output) Reset()

func (*Output) String 

func (m *Output) String() string

type Pipeline 

type Pipeline struct {
	NameToElement map[string]*Element `` /* 150-byte string literal not displayed */
}

func (*Pipeline) GetNameToElement 

func (m *Pipeline) GetNameToElement() map[string]*Element

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) String 

func (m *Pipeline) String() string

type PipelineRunStatus 

type PipelineRunStatus struct {
	PipelineRunStatusType PipelineRunStatusType       `` /* 126-byte string literal not displayed */
	Timestamp             *google_protobuf1.Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*PipelineRunStatus) GetTimestamp 

func (m *PipelineRunStatus) GetTimestamp() *google_protobuf1.Timestamp

func (*PipelineRunStatus) ProtoMessage 

func (*PipelineRunStatus) ProtoMessage()

func (*PipelineRunStatus) Reset 

func (m *PipelineRunStatus) Reset()

func (*PipelineRunStatus) String 

func (m *PipelineRunStatus) String() string

type PipelineRunStatusType 

type PipelineRunStatusType int32
const (
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_NONE             PipelineRunStatusType = 0
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_ADDED            PipelineRunStatusType = 1
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_STARTED          PipelineRunStatusType = 2
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_PIPELINE_RUNNING PipelineRunStatusType = 3
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_DEAD             PipelineRunStatusType = 4
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_ERROR            PipelineRunStatusType = 5
	PipelineRunStatusType_PIPELINE_RUN_STATUS_TYPE_SUCCESS          PipelineRunStatusType = 6
)

func (PipelineRunStatusType) String 

func (x PipelineRunStatusType) String() string

type PipelineSource 

type PipelineSource struct {
	GithubPipelineSource *GithubPipelineSource `protobuf:"bytes,1,opt,name=github_pipeline_source" json:"github_pipeline_source,omitempty"`
}

func (*PipelineSource) GetGithubPipelineSource 

func (m *PipelineSource) GetGithubPipelineSource() *GithubPipelineSource

func (*PipelineSource) ProtoMessage 

func (*PipelineSource) ProtoMessage()

func (*PipelineSource) Reset 

func (m *PipelineSource) Reset()

func (*PipelineSource) String 

func (m *PipelineSource) String() string

type StartPipelineRunRequest 

type StartPipelineRunRequest struct {
	PipelineSource *PipelineSource `protobuf:"bytes,1,opt,name=pipeline_source" json:"pipeline_source,omitempty"`
}

func (*StartPipelineRunRequest) GetPipelineSource 

func (m *StartPipelineRunRequest) GetPipelineSource() *PipelineSource

func (*StartPipelineRunRequest) ProtoMessage 

func (*StartPipelineRunRequest) ProtoMessage()

func (*StartPipelineRunRequest) Reset 

func (m *StartPipelineRunRequest) Reset()

func (*StartPipelineRunRequest) String 

func (m *StartPipelineRunRequest) String() string

type StartPipelineRunResponse 

type StartPipelineRunResponse struct {
	PipelineRunId string `protobuf:"bytes,1,opt,name=pipeline_run_id" json:"pipeline_run_id,omitempty"`
}

func (*StartPipelineRunResponse) ProtoMessage 

func (*StartPipelineRunResponse) ProtoMessage()

func (*StartPipelineRunResponse) Reset 

func (m *StartPipelineRunResponse) Reset()

func (*StartPipelineRunResponse) String 

func (m *StartPipelineRunResponse) String() string

type Version 

type Version struct {
	Major      uint32 `protobuf:"varint,1,opt,name=major" json:"major,omitempty"`
	Minor      uint32 `protobuf:"varint,2,opt,name=minor" json:"minor,omitempty"`
	Micro      uint32 `protobuf:"varint,3,opt,name=micro" json:"micro,omitempty"`
	Additional string `protobuf:"bytes,4,opt,name=additional" json:"additional,omitempty"`
}

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) String 

func (m *Version) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.