v1

package
v0.3.8 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2022 License: MIT Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FilterOp_name = map[int32]string{
	0: "OP_EQUALS",
	1: "OP_STARTS_WITH",
	2: "OP_ENDS_WITH",
	3: "OP_CONTAINS",
	4: "OP_EXISTS",
}
View Source 
var FilterOp_value = map[string]int32{
	"OP_EQUALS":      0,
	"OP_STARTS_WITH": 1,
	"OP_ENDS_WITH":   2,
	"OP_CONTAINS":    3,
	"OP_EXISTS":      4,
}
View Source 
var JobPhase_name = map[int32]string{
	0: "PHASE_UNKNOWN",
	1: "PHASE_PREPARING",
	2: "PHASE_STARTING",
	3: "PHASE_RUNNING",
	4: "PHASE_DONE",
	5: "PHASE_CLEANUP",
	6: "PHASE_WAITING",
}
View Source 
var JobPhase_value = map[string]int32{
	"PHASE_UNKNOWN":   0,
	"PHASE_PREPARING": 1,
	"PHASE_STARTING":  2,
	"PHASE_RUNNING":   3,
	"PHASE_DONE":      4,
	"PHASE_CLEANUP":   5,
	"PHASE_WAITING":   6,
}
View Source 
var JobTrigger_name = map[int32]string{
	0: "TRIGGER_UNKNOWN",
	1: "TRIGGER_MANUAL",
	2: "TRIGGER_PUSH",
	3: "TRIGGER_DELETED",
}
View Source 
var JobTrigger_value = map[string]int32{
	"TRIGGER_UNKNOWN": 0,
	"TRIGGER_MANUAL":  1,
	"TRIGGER_PUSH":    2,
	"TRIGGER_DELETED": 3,
}
View Source 
var ListenRequestLogs_name = map[int32]string{
	0: "LOGS_DISABLED",
	1: "LOGS_UNSLICED",
	2: "LOGS_RAW",
	3: "LOGS_HTML",
}
View Source 
var ListenRequestLogs_value = map[string]int32{
	"LOGS_DISABLED": 0,
	"LOGS_UNSLICED": 1,
	"LOGS_RAW":      2,
	"LOGS_HTML":     3,
}
View Source 
var LogSliceType_name = map[int32]string{
	0: "SLICE_ABANDONED",
	1: "SLICE_PHASE",
	2: "SLICE_START",
	3: "SLICE_CONTENT",
	4: "SLICE_DONE",
	5: "SLICE_FAIL",
	6: "SLICE_RESULT",
}
View Source 
var LogSliceType_value = map[string]int32{
	"SLICE_ABANDONED": 0,
	"SLICE_PHASE":     1,
	"SLICE_START":     2,
	"SLICE_CONTENT":   3,
	"SLICE_DONE":      4,
	"SLICE_FAIL":      5,
	"SLICE_RESULT":    6,
}

Functions

func RegisterWerftServiceServer 

func RegisterWerftServiceServer(s *grpc.Server, srv WerftServiceServer)

func RegisterWerftUIServer 

func RegisterWerftUIServer(s *grpc.Server, srv WerftUIServer)

Types

type Annotation 

type Annotation struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Annotation) Descriptor 

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

func (*Annotation) GetKey 

func (m *Annotation) GetKey() string

func (*Annotation) GetValue 

func (m *Annotation) GetValue() string

func (*Annotation) ProtoMessage 

func (*Annotation) ProtoMessage()

func (*Annotation) Reset 

func (m *Annotation) Reset()

func (*Annotation) String 

func (m *Annotation) String() string

func (*Annotation) XXX_DiscardUnknown 

func (m *Annotation) XXX_DiscardUnknown()

func (*Annotation) XXX_Marshal 

func (m *Annotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Annotation) XXX_Merge 

func (m *Annotation) XXX_Merge(src proto.Message)

func (*Annotation) XXX_Size 

func (m *Annotation) XXX_Size() int

func (*Annotation) XXX_Unmarshal 

func (m *Annotation) XXX_Unmarshal(b []byte) error

type DesiredAnnotation 

type DesiredAnnotation struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Required             bool     `protobuf:"varint,2,opt,name=required,proto3" json:"required,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DesiredAnnotation describes an annotation a job should have

func (*DesiredAnnotation) Descriptor 

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

func (*DesiredAnnotation) GetDescription 

func (m *DesiredAnnotation) GetDescription() string

func (*DesiredAnnotation) GetName 

func (m *DesiredAnnotation) GetName() string

func (*DesiredAnnotation) GetRequired 

func (m *DesiredAnnotation) GetRequired() bool

func (*DesiredAnnotation) ProtoMessage 

func (*DesiredAnnotation) ProtoMessage()

func (*DesiredAnnotation) Reset 

func (m *DesiredAnnotation) Reset()

func (*DesiredAnnotation) String 

func (m *DesiredAnnotation) String() string

func (*DesiredAnnotation) XXX_DiscardUnknown 

func (m *DesiredAnnotation) XXX_DiscardUnknown()

func (*DesiredAnnotation) XXX_Marshal 

func (m *DesiredAnnotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DesiredAnnotation) XXX_Merge 

func (m *DesiredAnnotation) XXX_Merge(src proto.Message)

func (*DesiredAnnotation) XXX_Size 

func (m *DesiredAnnotation) XXX_Size() int

func (*DesiredAnnotation) XXX_Unmarshal 

func (m *DesiredAnnotation) XXX_Unmarshal(b []byte) error

type FilterExpression 

type FilterExpression struct {
	Terms                []*FilterTerm `protobuf:"bytes,1,rep,name=terms,proto3" json:"terms,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*FilterExpression) Descriptor 

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

func (*FilterExpression) GetTerms 

func (m *FilterExpression) GetTerms() []*FilterTerm

func (*FilterExpression) ProtoMessage 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) Reset 

func (m *FilterExpression) Reset()

func (*FilterExpression) String 

func (m *FilterExpression) String() string

func (*FilterExpression) XXX_DiscardUnknown 

func (m *FilterExpression) XXX_DiscardUnknown()

func (*FilterExpression) XXX_Marshal 

func (m *FilterExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilterExpression) XXX_Merge 

func (m *FilterExpression) XXX_Merge(src proto.Message)

func (*FilterExpression) XXX_Size 

func (m *FilterExpression) XXX_Size() int

func (*FilterExpression) XXX_Unmarshal 

func (m *FilterExpression) XXX_Unmarshal(b []byte) error

type FilterOp 

type FilterOp int32
const (
	FilterOp_OP_EQUALS      FilterOp = 0
	FilterOp_OP_STARTS_WITH FilterOp = 1
	FilterOp_OP_ENDS_WITH   FilterOp = 2
	FilterOp_OP_CONTAINS    FilterOp = 3
	FilterOp_OP_EXISTS      FilterOp = 4
)

func (FilterOp) EnumDescriptor 

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

func (FilterOp) String 

func (x FilterOp) String() string

type FilterTerm 

type FilterTerm struct {
	Field                string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Operation            FilterOp `protobuf:"varint,3,opt,name=operation,proto3,enum=v1.FilterOp" json:"operation,omitempty"`
	Negate               bool     `protobuf:"varint,4,opt,name=negate,proto3" json:"negate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterTerm) Descriptor 

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

func (*FilterTerm) GetField 

func (m *FilterTerm) GetField() string

func (*FilterTerm) GetNegate 

func (m *FilterTerm) GetNegate() bool

func (*FilterTerm) GetOperation 

func (m *FilterTerm) GetOperation() FilterOp

func (*FilterTerm) GetValue 

func (m *FilterTerm) GetValue() string

func (*FilterTerm) ProtoMessage 

func (*FilterTerm) ProtoMessage()

func (*FilterTerm) Reset 

func (m *FilterTerm) Reset()

func (*FilterTerm) String 

func (m *FilterTerm) String() string

func (*FilterTerm) XXX_DiscardUnknown 

func (m *FilterTerm) XXX_DiscardUnknown()

func (*FilterTerm) XXX_Marshal 

func (m *FilterTerm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilterTerm) XXX_Merge 

func (m *FilterTerm) XXX_Merge(src proto.Message)

func (*FilterTerm) XXX_Size 

func (m *FilterTerm) XXX_Size() int

func (*FilterTerm) XXX_Unmarshal 

func (m *FilterTerm) XXX_Unmarshal(b []byte) error

type GetJobRequest 

type GetJobRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetJobRequest) Descriptor 

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

func (*GetJobRequest) GetName 

func (m *GetJobRequest) GetName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown 

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal 

func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobRequest) XXX_Merge 

func (m *GetJobRequest) XXX_Merge(src proto.Message)

func (*GetJobRequest) XXX_Size 

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal 

func (m *GetJobRequest) XXX_Unmarshal(b []byte) error

type GetJobResponse 

type GetJobResponse struct {
	Result               *JobStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetJobResponse) Descriptor 

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

func (*GetJobResponse) GetResult 

func (m *GetJobResponse) GetResult() *JobStatus

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset 

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (m *GetJobResponse) String() string

func (*GetJobResponse) XXX_DiscardUnknown 

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal 

func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetJobResponse) XXX_Merge 

func (m *GetJobResponse) XXX_Merge(src proto.Message)

func (*GetJobResponse) XXX_Size 

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal 

func (m *GetJobResponse) XXX_Unmarshal(b []byte) error

type IsReadOnlyRequest added in v0.1.1 

type IsReadOnlyRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsReadOnlyRequest) Descriptor added in v0.1.1 

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

func (*IsReadOnlyRequest) ProtoMessage added in v0.1.1 

func (*IsReadOnlyRequest) ProtoMessage()

func (*IsReadOnlyRequest) Reset added in v0.1.1 

func (m *IsReadOnlyRequest) Reset()

func (*IsReadOnlyRequest) String added in v0.1.1 

func (m *IsReadOnlyRequest) String() string

func (*IsReadOnlyRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *IsReadOnlyRequest) XXX_DiscardUnknown()

func (*IsReadOnlyRequest) XXX_Marshal added in v0.1.1 

func (m *IsReadOnlyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsReadOnlyRequest) XXX_Merge added in v0.1.1 

func (m *IsReadOnlyRequest) XXX_Merge(src proto.Message)

func (*IsReadOnlyRequest) XXX_Size added in v0.1.1 

func (m *IsReadOnlyRequest) XXX_Size() int

func (*IsReadOnlyRequest) XXX_Unmarshal added in v0.1.1 

func (m *IsReadOnlyRequest) XXX_Unmarshal(b []byte) error

type IsReadOnlyResponse added in v0.1.1 

type IsReadOnlyResponse struct {
	Readonly             bool     `protobuf:"varint,1,opt,name=readonly,proto3" json:"readonly,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsReadOnlyResponse) Descriptor added in v0.1.1 

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

func (*IsReadOnlyResponse) GetReadonly added in v0.1.1 

func (m *IsReadOnlyResponse) GetReadonly() bool

func (*IsReadOnlyResponse) ProtoMessage added in v0.1.1 

func (*IsReadOnlyResponse) ProtoMessage()

func (*IsReadOnlyResponse) Reset added in v0.1.1 

func (m *IsReadOnlyResponse) Reset()

func (*IsReadOnlyResponse) String added in v0.1.1 

func (m *IsReadOnlyResponse) String() string

func (*IsReadOnlyResponse) XXX_DiscardUnknown added in v0.1.1 

func (m *IsReadOnlyResponse) XXX_DiscardUnknown()

func (*IsReadOnlyResponse) XXX_Marshal added in v0.1.1 

func (m *IsReadOnlyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsReadOnlyResponse) XXX_Merge added in v0.1.1 

func (m *IsReadOnlyResponse) XXX_Merge(src proto.Message)

func (*IsReadOnlyResponse) XXX_Size added in v0.1.1 

func (m *IsReadOnlyResponse) XXX_Size() int

func (*IsReadOnlyResponse) XXX_Unmarshal added in v0.1.1 

func (m *IsReadOnlyResponse) XXX_Unmarshal(b []byte) error

type JobConditions 

type JobConditions struct {
	Success              bool                 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	FailureCount         int32                `protobuf:"varint,2,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	CanReplay            bool                 `protobuf:"varint,3,opt,name=can_replay,json=canReplay,proto3" json:"can_replay,omitempty"`
	WaitUntil            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	DidExecute           bool                 `protobuf:"varint,5,opt,name=did_execute,json=didExecute,proto3" json:"did_execute,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*JobConditions) Descriptor 

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

func (*JobConditions) GetCanReplay 

func (m *JobConditions) GetCanReplay() bool

func (*JobConditions) GetDidExecute 

func (m *JobConditions) GetDidExecute() bool

func (*JobConditions) GetFailureCount 

func (m *JobConditions) GetFailureCount() int32

func (*JobConditions) GetSuccess 

func (m *JobConditions) GetSuccess() bool

func (*JobConditions) GetWaitUntil 

func (m *JobConditions) GetWaitUntil() *timestamp.Timestamp

func (*JobConditions) ProtoMessage 

func (*JobConditions) ProtoMessage()

func (*JobConditions) Reset 

func (m *JobConditions) Reset()

func (*JobConditions) String 

func (m *JobConditions) String() string

func (*JobConditions) XXX_DiscardUnknown 

func (m *JobConditions) XXX_DiscardUnknown()

func (*JobConditions) XXX_Marshal 

func (m *JobConditions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobConditions) XXX_Merge 

func (m *JobConditions) XXX_Merge(src proto.Message)

func (*JobConditions) XXX_Size 

func (m *JobConditions) XXX_Size() int

func (*JobConditions) XXX_Unmarshal 

func (m *JobConditions) XXX_Unmarshal(b []byte) error

type JobMetadata 

type JobMetadata struct {
	Owner                string               `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repository           *Repository          `protobuf:"bytes,2,opt,name=repository,proto3" json:"repository,omitempty"`
	Trigger              JobTrigger           `protobuf:"varint,3,opt,name=trigger,proto3,enum=v1.JobTrigger" json:"trigger,omitempty"`
	Created              *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	Finished             *timestamp.Timestamp `protobuf:"bytes,5,opt,name=finished,proto3" json:"finished,omitempty"`
	Annotations          []*Annotation        `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty"`
	JobSpecName          string               `protobuf:"bytes,7,opt,name=job_spec_name,json=jobSpecName,proto3" json:"job_spec_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*JobMetadata) Descriptor 

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

func (*JobMetadata) GetAnnotations 

func (m *JobMetadata) GetAnnotations() []*Annotation

func (*JobMetadata) GetCreated 

func (m *JobMetadata) GetCreated() *timestamp.Timestamp

func (*JobMetadata) GetFinished 

func (m *JobMetadata) GetFinished() *timestamp.Timestamp

func (*JobMetadata) GetJobSpecName added in v0.1.1 

func (m *JobMetadata) GetJobSpecName() string

func (*JobMetadata) GetOwner 

func (m *JobMetadata) GetOwner() string

func (*JobMetadata) GetRepository 

func (m *JobMetadata) GetRepository() *Repository

func (*JobMetadata) GetTrigger 

func (m *JobMetadata) GetTrigger() JobTrigger

func (*JobMetadata) ProtoMessage 

func (*JobMetadata) ProtoMessage()

func (*JobMetadata) Reset 

func (m *JobMetadata) Reset()

func (*JobMetadata) String 

func (m *JobMetadata) String() string

func (*JobMetadata) XXX_DiscardUnknown 

func (m *JobMetadata) XXX_DiscardUnknown()

func (*JobMetadata) XXX_Marshal 

func (m *JobMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobMetadata) XXX_Merge 

func (m *JobMetadata) XXX_Merge(src proto.Message)

func (*JobMetadata) XXX_Size 

func (m *JobMetadata) XXX_Size() int

func (*JobMetadata) XXX_Unmarshal 

func (m *JobMetadata) XXX_Unmarshal(b []byte) error

type JobPhase 

type JobPhase int32
const (
	// Unknown means we don't know what state the job is in
	JobPhase_PHASE_UNKNOWN JobPhase = 0
	// Preparing means the job hasn't started yet and isn't consuming resources in the system
	JobPhase_PHASE_PREPARING JobPhase = 1
	// Starting means the job has been scheduled and is waiting to run. Things that might prevent it
	// from running already are pod scheduling, image pull or container startup.
	JobPhase_PHASE_STARTING JobPhase = 2
	// Running means the job is actually running and doing work.
	JobPhase_PHASE_RUNNING JobPhase = 3
	// Done means the job has run and is finished
	JobPhase_PHASE_DONE JobPhase = 4
	// Cleaning means the job is in post-run cleanup
	JobPhase_PHASE_CLEANUP JobPhase = 5
	// Waiting means the job is waiting for its start time or some other condition to be met
	JobPhase_PHASE_WAITING JobPhase = 6
)

func (JobPhase) EnumDescriptor 

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

func (JobPhase) String 

func (x JobPhase) String() string

type JobResult 

type JobResult struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Payload              string   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Channels             []string `protobuf:"bytes,4,rep,name=channels,proto3" json:"channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobResult) Descriptor 

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

func (*JobResult) GetChannels 

func (m *JobResult) GetChannels() []string

func (*JobResult) GetDescription 

func (m *JobResult) GetDescription() string

func (*JobResult) GetPayload 

func (m *JobResult) GetPayload() string

func (*JobResult) GetType 

func (m *JobResult) GetType() string

func (*JobResult) ProtoMessage 

func (*JobResult) ProtoMessage()

func (*JobResult) Reset 

func (m *JobResult) Reset()

func (*JobResult) String 

func (m *JobResult) String() string

func (*JobResult) XXX_DiscardUnknown 

func (m *JobResult) XXX_DiscardUnknown()

func (*JobResult) XXX_Marshal 

func (m *JobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobResult) XXX_Merge 

func (m *JobResult) XXX_Merge(src proto.Message)

func (*JobResult) XXX_Size 

func (m *JobResult) XXX_Size() int

func (*JobResult) XXX_Unmarshal 

func (m *JobResult) XXX_Unmarshal(b []byte) error

type JobSpec added in v0.2.0 

type JobSpec struct {
	// Types that are valid to be assigned to Source:
	//	*JobSpec_JobYaml
	//	*JobSpec_JobPath
	//	*JobSpec_Repo
	Source               isJobSpec_Source    `protobuf_oneof:"source"`
	DirectSideload       []byte              `protobuf:"bytes,5,opt,name=direct_sideload,json=directSideload,proto3" json:"direct_sideload,omitempty"`
	RepoSideload         []*JobSpec_FromRepo `protobuf:"bytes,6,rep,name=repo_sideload,json=repoSideload,proto3" json:"repo_sideload,omitempty"`
	NameSuffix           string              `protobuf:"bytes,7,opt,name=name_suffix,json=nameSuffix,proto3" json:"name_suffix,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*JobSpec) Descriptor added in v0.2.0 

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

func (*JobSpec) GetDirectSideload added in v0.2.0 

func (m *JobSpec) GetDirectSideload() []byte

func (*JobSpec) GetJobPath added in v0.2.0 

func (m *JobSpec) GetJobPath() string

func (*JobSpec) GetJobYaml added in v0.2.0 

func (m *JobSpec) GetJobYaml() []byte

func (*JobSpec) GetNameSuffix added in v0.2.0 

func (m *JobSpec) GetNameSuffix() string

func (*JobSpec) GetRepo added in v0.2.0 

func (m *JobSpec) GetRepo() *JobSpec_FromRepo

func (*JobSpec) GetRepoSideload added in v0.2.0 

func (m *JobSpec) GetRepoSideload() []*JobSpec_FromRepo

func (*JobSpec) GetSource added in v0.2.0 

func (m *JobSpec) GetSource() isJobSpec_Source

func (*JobSpec) ProtoMessage added in v0.2.0 

func (*JobSpec) ProtoMessage()

func (*JobSpec) Reset added in v0.2.0 

func (m *JobSpec) Reset()

func (*JobSpec) String added in v0.2.0 

func (m *JobSpec) String() string

func (*JobSpec) XXX_DiscardUnknown added in v0.2.0 

func (m *JobSpec) XXX_DiscardUnknown()

func (*JobSpec) XXX_Marshal added in v0.2.0 

func (m *JobSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSpec) XXX_Merge added in v0.2.0 

func (m *JobSpec) XXX_Merge(src proto.Message)

func (*JobSpec) XXX_OneofWrappers added in v0.2.0 

func (*JobSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*JobSpec) XXX_Size added in v0.2.0 

func (m *JobSpec) XXX_Size() int

func (*JobSpec) XXX_Unmarshal added in v0.2.0 

func (m *JobSpec) XXX_Unmarshal(b []byte) error

type JobSpec_FromRepo added in v0.2.0 

type JobSpec_FromRepo struct {
	Repo                 *Repository `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Path                 string      `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*JobSpec_FromRepo) Descriptor added in v0.2.0 

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

func (*JobSpec_FromRepo) GetPath added in v0.2.0 

func (m *JobSpec_FromRepo) GetPath() string

func (*JobSpec_FromRepo) GetRepo added in v0.2.0 

func (m *JobSpec_FromRepo) GetRepo() *Repository

func (*JobSpec_FromRepo) ProtoMessage added in v0.2.0 

func (*JobSpec_FromRepo) ProtoMessage()

func (*JobSpec_FromRepo) Reset added in v0.2.0 

func (m *JobSpec_FromRepo) Reset()

func (*JobSpec_FromRepo) String added in v0.2.0 

func (m *JobSpec_FromRepo) String() string

func (*JobSpec_FromRepo) XXX_DiscardUnknown added in v0.2.0 

func (m *JobSpec_FromRepo) XXX_DiscardUnknown()

func (*JobSpec_FromRepo) XXX_Marshal added in v0.2.0 

func (m *JobSpec_FromRepo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSpec_FromRepo) XXX_Merge added in v0.2.0 

func (m *JobSpec_FromRepo) XXX_Merge(src proto.Message)

func (*JobSpec_FromRepo) XXX_Size added in v0.2.0 

func (m *JobSpec_FromRepo) XXX_Size() int

func (*JobSpec_FromRepo) XXX_Unmarshal added in v0.2.0 

func (m *JobSpec_FromRepo) XXX_Unmarshal(b []byte) error

type JobSpec_JobPath added in v0.2.0 

type JobSpec_JobPath struct {
	JobPath string `protobuf:"bytes,3,opt,name=job_path,json=jobPath,proto3,oneof"`
}

type JobSpec_JobYaml added in v0.2.0 

type JobSpec_JobYaml struct {
	JobYaml []byte `protobuf:"bytes,2,opt,name=job_yaml,json=jobYaml,proto3,oneof"`
}

type JobSpec_Repo added in v0.2.0 

type JobSpec_Repo struct {
	Repo *JobSpec_FromRepo `protobuf:"bytes,4,opt,name=repo,proto3,oneof"`
}

type JobStatus 

type JobStatus struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Metadata             *JobMetadata   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Phase                JobPhase       `protobuf:"varint,3,opt,name=phase,proto3,enum=v1.JobPhase" json:"phase,omitempty"`
	Conditions           *JobConditions `protobuf:"bytes,4,opt,name=conditions,proto3" json:"conditions,omitempty"`
	Details              string         `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Results              []*JobResult   `protobuf:"bytes,6,rep,name=results,proto3" json:"results,omitempty"`
	Spec                 *JobSpec       `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*JobStatus) Descriptor 

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

func (*JobStatus) GetConditions 

func (m *JobStatus) GetConditions() *JobConditions

func (*JobStatus) GetDetails 

func (m *JobStatus) GetDetails() string

func (*JobStatus) GetMetadata 

func (m *JobStatus) GetMetadata() *JobMetadata

func (*JobStatus) GetName 

func (m *JobStatus) GetName() string

func (*JobStatus) GetPhase 

func (m *JobStatus) GetPhase() JobPhase

func (*JobStatus) GetResults 

func (m *JobStatus) GetResults() []*JobResult

func (*JobStatus) GetSpec added in v0.2.0 

func (m *JobStatus) GetSpec() *JobSpec

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) Reset 

func (m *JobStatus) Reset()

func (*JobStatus) String 

func (m *JobStatus) String() string

func (*JobStatus) XXX_DiscardUnknown 

func (m *JobStatus) XXX_DiscardUnknown()

func (*JobStatus) XXX_Marshal 

func (m *JobStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatus) XXX_Merge 

func (m *JobStatus) XXX_Merge(src proto.Message)

func (*JobStatus) XXX_Size 

func (m *JobStatus) XXX_Size() int

func (*JobStatus) XXX_Unmarshal 

func (m *JobStatus) XXX_Unmarshal(b []byte) error

type JobTrigger 

type JobTrigger int32
const (
	JobTrigger_TRIGGER_UNKNOWN JobTrigger = 0
	JobTrigger_TRIGGER_MANUAL  JobTrigger = 1
	JobTrigger_TRIGGER_PUSH    JobTrigger = 2
	JobTrigger_TRIGGER_DELETED JobTrigger = 3
)

func (JobTrigger) EnumDescriptor 

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

func (JobTrigger) String 

func (x JobTrigger) String() string

type ListJobSpecsRequest 

type ListJobSpecsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListJobSpecsRequest) Descriptor 

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

func (*ListJobSpecsRequest) ProtoMessage 

func (*ListJobSpecsRequest) ProtoMessage()

func (*ListJobSpecsRequest) Reset 

func (m *ListJobSpecsRequest) Reset()

func (*ListJobSpecsRequest) String 

func (m *ListJobSpecsRequest) String() string

func (*ListJobSpecsRequest) XXX_DiscardUnknown 

func (m *ListJobSpecsRequest) XXX_DiscardUnknown()

func (*ListJobSpecsRequest) XXX_Marshal 

func (m *ListJobSpecsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobSpecsRequest) XXX_Merge 

func (m *ListJobSpecsRequest) XXX_Merge(src proto.Message)

func (*ListJobSpecsRequest) XXX_Size 

func (m *ListJobSpecsRequest) XXX_Size() int

func (*ListJobSpecsRequest) XXX_Unmarshal 

func (m *ListJobSpecsRequest) XXX_Unmarshal(b []byte) error

type ListJobSpecsResponse 

type ListJobSpecsResponse struct {
	Repo                 *Repository          `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Name                 string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Path                 string               `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Description          string               `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Arguments            []*DesiredAnnotation `protobuf:"bytes,5,rep,name=arguments,proto3" json:"arguments,omitempty"`
	Plugins              map[string]string    `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListJobSpecsResponse) Descriptor 

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

func (*ListJobSpecsResponse) GetArguments 

func (m *ListJobSpecsResponse) GetArguments() []*DesiredAnnotation

func (*ListJobSpecsResponse) GetDescription 

func (m *ListJobSpecsResponse) GetDescription() string

func (*ListJobSpecsResponse) GetName 

func (m *ListJobSpecsResponse) GetName() string

func (*ListJobSpecsResponse) GetPath 

func (m *ListJobSpecsResponse) GetPath() string

func (*ListJobSpecsResponse) GetPlugins added in v0.2.0 

func (m *ListJobSpecsResponse) GetPlugins() map[string]string

func (*ListJobSpecsResponse) GetRepo 

func (m *ListJobSpecsResponse) GetRepo() *Repository

func (*ListJobSpecsResponse) ProtoMessage 

func (*ListJobSpecsResponse) ProtoMessage()

func (*ListJobSpecsResponse) Reset 

func (m *ListJobSpecsResponse) Reset()

func (*ListJobSpecsResponse) String 

func (m *ListJobSpecsResponse) String() string

func (*ListJobSpecsResponse) XXX_DiscardUnknown 

func (m *ListJobSpecsResponse) XXX_DiscardUnknown()

func (*ListJobSpecsResponse) XXX_Marshal 

func (m *ListJobSpecsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobSpecsResponse) XXX_Merge 

func (m *ListJobSpecsResponse) XXX_Merge(src proto.Message)

func (*ListJobSpecsResponse) XXX_Size 

func (m *ListJobSpecsResponse) XXX_Size() int

func (*ListJobSpecsResponse) XXX_Unmarshal 

func (m *ListJobSpecsResponse) XXX_Unmarshal(b []byte) error

type ListJobsRequest 

type ListJobsRequest struct {
	Filter               []*FilterExpression `protobuf:"bytes,1,rep,name=filter,proto3" json:"filter,omitempty"`
	Order                []*OrderExpression  `protobuf:"bytes,2,rep,name=order,proto3" json:"order,omitempty"`
	Start                int32               `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	Limit                int32               `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ListJobsRequest) Descriptor 

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

func (*ListJobsRequest) GetFilter 

func (m *ListJobsRequest) GetFilter() []*FilterExpression

func (*ListJobsRequest) GetLimit 

func (m *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) GetOrder 

func (m *ListJobsRequest) GetOrder() []*OrderExpression

func (*ListJobsRequest) GetStart 

func (m *ListJobsRequest) GetStart() int32

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) Reset 

func (m *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (m *ListJobsRequest) String() string

func (*ListJobsRequest) XXX_DiscardUnknown 

func (m *ListJobsRequest) XXX_DiscardUnknown()

func (*ListJobsRequest) XXX_Marshal 

func (m *ListJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobsRequest) XXX_Merge 

func (m *ListJobsRequest) XXX_Merge(src proto.Message)

func (*ListJobsRequest) XXX_Size 

func (m *ListJobsRequest) XXX_Size() int

func (*ListJobsRequest) XXX_Unmarshal 

func (m *ListJobsRequest) XXX_Unmarshal(b []byte) error

type ListJobsResponse 

type ListJobsResponse struct {
	Total                int32        `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Result               []*JobStatus `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListJobsResponse) Descriptor 

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

func (*ListJobsResponse) GetResult 

func (m *ListJobsResponse) GetResult() []*JobStatus

func (*ListJobsResponse) GetTotal 

func (m *ListJobsResponse) GetTotal() int32

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) Reset 

func (m *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (m *ListJobsResponse) String() string

func (*ListJobsResponse) XXX_DiscardUnknown 

func (m *ListJobsResponse) XXX_DiscardUnknown()

func (*ListJobsResponse) XXX_Marshal 

func (m *ListJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListJobsResponse) XXX_Merge 

func (m *ListJobsResponse) XXX_Merge(src proto.Message)

func (*ListJobsResponse) XXX_Size 

func (m *ListJobsResponse) XXX_Size() int

func (*ListJobsResponse) XXX_Unmarshal 

func (m *ListJobsResponse) XXX_Unmarshal(b []byte) error

type ListenRequest 

type ListenRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Updates              bool              `protobuf:"varint,2,opt,name=updates,proto3" json:"updates,omitempty"`
	Logs                 ListenRequestLogs `protobuf:"varint,3,opt,name=logs,proto3,enum=v1.ListenRequestLogs" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetLogs 

func (m *ListenRequest) GetLogs() ListenRequestLogs

func (*ListenRequest) GetName 

func (m *ListenRequest) GetName() string

func (*ListenRequest) GetUpdates 

func (m *ListenRequest) GetUpdates() bool

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenRequest) XXX_Merge 

func (m *ListenRequest) XXX_Merge(src proto.Message)

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

func (m *ListenRequest) XXX_Unmarshal(b []byte) error

type ListenRequestLogs 

type ListenRequestLogs int32
const (
	ListenRequestLogs_LOGS_DISABLED ListenRequestLogs = 0
	ListenRequestLogs_LOGS_UNSLICED ListenRequestLogs = 1
	ListenRequestLogs_LOGS_RAW      ListenRequestLogs = 2
	ListenRequestLogs_LOGS_HTML     ListenRequestLogs = 3
)

func (ListenRequestLogs) EnumDescriptor 

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

func (ListenRequestLogs) String 

func (x ListenRequestLogs) String() string

type ListenResponse 

type ListenResponse struct {
	// Types that are valid to be assigned to Content:
	//	*ListenResponse_Update
	//	*ListenResponse_Slice
	Content              isListenResponse_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ListenResponse) Descriptor 

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

func (*ListenResponse) GetContent 

func (m *ListenResponse) GetContent() isListenResponse_Content

func (*ListenResponse) GetSlice 

func (m *ListenResponse) GetSlice() *LogSliceEvent

func (*ListenResponse) GetUpdate 

func (m *ListenResponse) GetUpdate() *JobStatus

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) String 

func (m *ListenResponse) String() string

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenResponse) XXX_Merge 

func (m *ListenResponse) XXX_Merge(src proto.Message)

func (*ListenResponse) XXX_OneofWrappers 

func (*ListenResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

func (m *ListenResponse) XXX_Unmarshal(b []byte) error

type ListenResponse_Slice 

type ListenResponse_Slice struct {
	Slice *LogSliceEvent `protobuf:"bytes,2,opt,name=slice,proto3,oneof"`
}

type ListenResponse_Update 

type ListenResponse_Update struct {
	Update *JobStatus `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type LogSliceEvent 

type LogSliceEvent struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 LogSliceType `protobuf:"varint,2,opt,name=type,proto3,enum=v1.LogSliceType" json:"type,omitempty"`
	Payload              string       `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*LogSliceEvent) Descriptor 

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

func (*LogSliceEvent) GetName 

func (m *LogSliceEvent) GetName() string

func (*LogSliceEvent) GetPayload 

func (m *LogSliceEvent) GetPayload() string

func (*LogSliceEvent) GetType 

func (m *LogSliceEvent) GetType() LogSliceType

func (*LogSliceEvent) ProtoMessage 

func (*LogSliceEvent) ProtoMessage()

func (*LogSliceEvent) Reset 

func (m *LogSliceEvent) Reset()

func (*LogSliceEvent) String 

func (m *LogSliceEvent) String() string

func (*LogSliceEvent) XXX_DiscardUnknown 

func (m *LogSliceEvent) XXX_DiscardUnknown()

func (*LogSliceEvent) XXX_Marshal 

func (m *LogSliceEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogSliceEvent) XXX_Merge 

func (m *LogSliceEvent) XXX_Merge(src proto.Message)

func (*LogSliceEvent) XXX_Size 

func (m *LogSliceEvent) XXX_Size() int

func (*LogSliceEvent) XXX_Unmarshal 

func (m *LogSliceEvent) XXX_Unmarshal(b []byte) error

type LogSliceType 

type LogSliceType int32
const (
	LogSliceType_SLICE_ABANDONED LogSliceType = 0
	LogSliceType_SLICE_PHASE     LogSliceType = 1
	LogSliceType_SLICE_START     LogSliceType = 2
	LogSliceType_SLICE_CONTENT   LogSliceType = 3
	LogSliceType_SLICE_DONE      LogSliceType = 4
	LogSliceType_SLICE_FAIL      LogSliceType = 5
	LogSliceType_SLICE_RESULT    LogSliceType = 6
)

func (LogSliceType) EnumDescriptor 

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

func (LogSliceType) String 

func (x LogSliceType) String() string

type OrderExpression 

type OrderExpression struct {
	Field                string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Ascending            bool     `protobuf:"varint,2,opt,name=ascending,proto3" json:"ascending,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OrderExpression) Descriptor 

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

func (*OrderExpression) GetAscending 

func (m *OrderExpression) GetAscending() bool

func (*OrderExpression) GetField 

func (m *OrderExpression) GetField() string

func (*OrderExpression) ProtoMessage 

func (*OrderExpression) ProtoMessage()

func (*OrderExpression) Reset 

func (m *OrderExpression) Reset()

func (*OrderExpression) String 

func (m *OrderExpression) String() string

func (*OrderExpression) XXX_DiscardUnknown 

func (m *OrderExpression) XXX_DiscardUnknown()

func (*OrderExpression) XXX_Marshal 

func (m *OrderExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderExpression) XXX_Merge 

func (m *OrderExpression) XXX_Merge(src proto.Message)

func (*OrderExpression) XXX_Size 

func (m *OrderExpression) XXX_Size() int

func (*OrderExpression) XXX_Unmarshal 

func (m *OrderExpression) XXX_Unmarshal(b []byte) error

type Repository 

type Repository struct {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Owner                string   `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string   `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	Ref                  string   `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
	Revision             string   `protobuf:"bytes,5,opt,name=revision,proto3" json:"revision,omitempty"`
	DefaultBranch        string   `protobuf:"bytes,6,opt,name=default_branch,json=defaultBranch,proto3" json:"default_branch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Repository) Descriptor 

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

func (*Repository) GetDefaultBranch added in v0.2.0 

func (m *Repository) GetDefaultBranch() string

func (*Repository) GetHost 

func (m *Repository) GetHost() string

func (*Repository) GetOwner 

func (m *Repository) GetOwner() string

func (*Repository) GetRef 

func (m *Repository) GetRef() string

func (*Repository) GetRepo 

func (m *Repository) GetRepo() string

func (*Repository) GetRevision 

func (m *Repository) GetRevision() string

func (*Repository) ProtoMessage 

func (*Repository) ProtoMessage()

func (*Repository) Reset 

func (m *Repository) Reset()

func (*Repository) String 

func (m *Repository) String() string

func (*Repository) XXX_DiscardUnknown 

func (m *Repository) XXX_DiscardUnknown()

func (*Repository) XXX_Marshal 

func (m *Repository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Repository) XXX_Merge 

func (m *Repository) XXX_Merge(src proto.Message)

func (*Repository) XXX_Size 

func (m *Repository) XXX_Size() int

func (*Repository) XXX_Unmarshal 

func (m *Repository) XXX_Unmarshal(b []byte) error

type StartFromPreviousJobRequest 

type StartFromPreviousJobRequest struct {
	PreviousJob          string               `protobuf:"bytes,1,opt,name=previous_job,json=previousJob,proto3" json:"previous_job,omitempty"`
	GithubToken          string               `protobuf:"bytes,2,opt,name=github_token,json=githubToken,proto3" json:"github_token,omitempty"`
	WaitUntil            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StartFromPreviousJobRequest) Descriptor 

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

func (*StartFromPreviousJobRequest) GetGithubToken 

func (m *StartFromPreviousJobRequest) GetGithubToken() string

func (*StartFromPreviousJobRequest) GetPreviousJob 

func (m *StartFromPreviousJobRequest) GetPreviousJob() string

func (*StartFromPreviousJobRequest) GetWaitUntil 

func (m *StartFromPreviousJobRequest) GetWaitUntil() *timestamp.Timestamp

func (*StartFromPreviousJobRequest) ProtoMessage 

func (*StartFromPreviousJobRequest) ProtoMessage()

func (*StartFromPreviousJobRequest) Reset 

func (m *StartFromPreviousJobRequest) Reset()

func (*StartFromPreviousJobRequest) String 

func (m *StartFromPreviousJobRequest) String() string

func (*StartFromPreviousJobRequest) XXX_DiscardUnknown 

func (m *StartFromPreviousJobRequest) XXX_DiscardUnknown()

func (*StartFromPreviousJobRequest) XXX_Marshal 

func (m *StartFromPreviousJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartFromPreviousJobRequest) XXX_Merge 

func (m *StartFromPreviousJobRequest) XXX_Merge(src proto.Message)

func (*StartFromPreviousJobRequest) XXX_Size 

func (m *StartFromPreviousJobRequest) XXX_Size() int

func (*StartFromPreviousJobRequest) XXX_Unmarshal 

func (m *StartFromPreviousJobRequest) XXX_Unmarshal(b []byte) error

type StartGitHubJobRequest 

type StartGitHubJobRequest struct {
	Metadata             *JobMetadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	JobPath              string               `protobuf:"bytes,2,opt,name=job_path,json=jobPath,proto3" json:"job_path,omitempty"`
	JobYaml              []byte               `protobuf:"bytes,3,opt,name=job_yaml,json=jobYaml,proto3" json:"job_yaml,omitempty"`
	GithubToken          string               `protobuf:"bytes,4,opt,name=github_token,json=githubToken,proto3" json:"github_token,omitempty"`
	Sideload             []byte               `protobuf:"bytes,5,opt,name=sideload,proto3" json:"sideload,omitempty"`
	WaitUntil            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	NameSuffix           string               `protobuf:"bytes,7,opt,name=name_suffix,json=nameSuffix,proto3" json:"name_suffix,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StartGitHubJobRequest) Descriptor 

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

func (*StartGitHubJobRequest) GetGithubToken 

func (m *StartGitHubJobRequest) GetGithubToken() string

func (*StartGitHubJobRequest) GetJobPath 

func (m *StartGitHubJobRequest) GetJobPath() string

func (*StartGitHubJobRequest) GetJobYaml 

func (m *StartGitHubJobRequest) GetJobYaml() []byte

func (*StartGitHubJobRequest) GetMetadata 

func (m *StartGitHubJobRequest) GetMetadata() *JobMetadata

func (*StartGitHubJobRequest) GetNameSuffix added in v0.1.1 

func (m *StartGitHubJobRequest) GetNameSuffix() string

func (*StartGitHubJobRequest) GetSideload 

func (m *StartGitHubJobRequest) GetSideload() []byte

func (*StartGitHubJobRequest) GetWaitUntil 

func (m *StartGitHubJobRequest) GetWaitUntil() *timestamp.Timestamp

func (*StartGitHubJobRequest) ProtoMessage 

func (*StartGitHubJobRequest) ProtoMessage()

func (*StartGitHubJobRequest) Reset 

func (m *StartGitHubJobRequest) Reset()

func (*StartGitHubJobRequest) String 

func (m *StartGitHubJobRequest) String() string

func (*StartGitHubJobRequest) XXX_DiscardUnknown 

func (m *StartGitHubJobRequest) XXX_DiscardUnknown()

func (*StartGitHubJobRequest) XXX_Marshal 

func (m *StartGitHubJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartGitHubJobRequest) XXX_Merge 

func (m *StartGitHubJobRequest) XXX_Merge(src proto.Message)

func (*StartGitHubJobRequest) XXX_Size 

func (m *StartGitHubJobRequest) XXX_Size() int

func (*StartGitHubJobRequest) XXX_Unmarshal 

func (m *StartGitHubJobRequest) XXX_Unmarshal(b []byte) error

type StartJobRequest added in v0.1.1 

type StartJobRequest struct {
	Metadata             *JobMetadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	JobPath              string               `protobuf:"bytes,2,opt,name=job_path,json=jobPath,proto3" json:"job_path,omitempty"`
	JobYaml              []byte               `protobuf:"bytes,3,opt,name=job_yaml,json=jobYaml,proto3" json:"job_yaml,omitempty"`
	Sideload             []byte               `protobuf:"bytes,4,opt,name=sideload,proto3" json:"sideload,omitempty"`
	WaitUntil            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	NameSuffix           string               `protobuf:"bytes,6,opt,name=name_suffix,json=nameSuffix,proto3" json:"name_suffix,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StartJobRequest) Descriptor added in v0.1.1 

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

func (*StartJobRequest) GetJobPath added in v0.1.1 

func (m *StartJobRequest) GetJobPath() string

func (*StartJobRequest) GetJobYaml added in v0.1.1 

func (m *StartJobRequest) GetJobYaml() []byte

func (*StartJobRequest) GetMetadata added in v0.1.1 

func (m *StartJobRequest) GetMetadata() *JobMetadata

func (*StartJobRequest) GetNameSuffix added in v0.1.1 

func (m *StartJobRequest) GetNameSuffix() string

func (*StartJobRequest) GetSideload added in v0.1.1 

func (m *StartJobRequest) GetSideload() []byte

func (*StartJobRequest) GetWaitUntil added in v0.1.1 

func (m *StartJobRequest) GetWaitUntil() *timestamp.Timestamp

func (*StartJobRequest) ProtoMessage added in v0.1.1 

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) Reset added in v0.1.1 

func (m *StartJobRequest) Reset()

func (*StartJobRequest) String added in v0.1.1 

func (m *StartJobRequest) String() string

func (*StartJobRequest) XXX_DiscardUnknown added in v0.1.1 

func (m *StartJobRequest) XXX_DiscardUnknown()

func (*StartJobRequest) XXX_Marshal added in v0.1.1 

func (m *StartJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartJobRequest) XXX_Merge added in v0.1.1 

func (m *StartJobRequest) XXX_Merge(src proto.Message)

func (*StartJobRequest) XXX_Size added in v0.1.1 

func (m *StartJobRequest) XXX_Size() int

func (*StartJobRequest) XXX_Unmarshal added in v0.1.1 

func (m *StartJobRequest) XXX_Unmarshal(b []byte) error

type StartJobRequest2 added in v0.2.0 

type StartJobRequest2 struct {
	Metadata             *JobMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec                 *JobSpec     `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StartJobRequest2) Descriptor added in v0.2.0 

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

func (*StartJobRequest2) GetMetadata added in v0.2.0 

func (m *StartJobRequest2) GetMetadata() *JobMetadata

func (*StartJobRequest2) GetSpec added in v0.2.0 

func (m *StartJobRequest2) GetSpec() *JobSpec

func (*StartJobRequest2) ProtoMessage added in v0.2.0 

func (*StartJobRequest2) ProtoMessage()

func (*StartJobRequest2) Reset added in v0.2.0 

func (m *StartJobRequest2) Reset()

func (*StartJobRequest2) String added in v0.2.0 

func (m *StartJobRequest2) String() string

func (*StartJobRequest2) XXX_DiscardUnknown added in v0.2.0 

func (m *StartJobRequest2) XXX_DiscardUnknown()

func (*StartJobRequest2) XXX_Marshal added in v0.2.0 

func (m *StartJobRequest2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartJobRequest2) XXX_Merge added in v0.2.0 

func (m *StartJobRequest2) XXX_Merge(src proto.Message)

func (*StartJobRequest2) XXX_Size added in v0.2.0 

func (m *StartJobRequest2) XXX_Size() int

func (*StartJobRequest2) XXX_Unmarshal added in v0.2.0 

func (m *StartJobRequest2) XXX_Unmarshal(b []byte) error

type StartJobResponse 

type StartJobResponse struct {
	Status               *JobStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*StartJobResponse) Descriptor 

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

func (*StartJobResponse) GetStatus 

func (m *StartJobResponse) GetStatus() *JobStatus

func (*StartJobResponse) ProtoMessage 

func (*StartJobResponse) ProtoMessage()

func (*StartJobResponse) Reset 

func (m *StartJobResponse) Reset()

func (*StartJobResponse) String 

func (m *StartJobResponse) String() string

func (*StartJobResponse) XXX_DiscardUnknown 

func (m *StartJobResponse) XXX_DiscardUnknown()

func (*StartJobResponse) XXX_Marshal 

func (m *StartJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartJobResponse) XXX_Merge 

func (m *StartJobResponse) XXX_Merge(src proto.Message)

func (*StartJobResponse) XXX_Size 

func (m *StartJobResponse) XXX_Size() int

func (*StartJobResponse) XXX_Unmarshal 

func (m *StartJobResponse) XXX_Unmarshal(b []byte) error

type StartLocalJobRequest 

type StartLocalJobRequest struct {
	// Types that are valid to be assigned to Content:
	//	*StartLocalJobRequest_Metadata
	//	*StartLocalJobRequest_ConfigYaml
	//	*StartLocalJobRequest_JobYaml
	//	*StartLocalJobRequest_WorkspaceTar
	//	*StartLocalJobRequest_WorkspaceTarDone
	Content              isStartLocalJobRequest_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*StartLocalJobRequest) Descriptor 

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

func (*StartLocalJobRequest) GetConfigYaml 

func (m *StartLocalJobRequest) GetConfigYaml() []byte

func (*StartLocalJobRequest) GetContent 

func (m *StartLocalJobRequest) GetContent() isStartLocalJobRequest_Content

func (*StartLocalJobRequest) GetJobYaml 

func (m *StartLocalJobRequest) GetJobYaml() []byte

func (*StartLocalJobRequest) GetMetadata 

func (m *StartLocalJobRequest) GetMetadata() *JobMetadata

func (*StartLocalJobRequest) GetWorkspaceTar 

func (m *StartLocalJobRequest) GetWorkspaceTar() []byte

func (*StartLocalJobRequest) GetWorkspaceTarDone 

func (m *StartLocalJobRequest) GetWorkspaceTarDone() bool

func (*StartLocalJobRequest) ProtoMessage 

func (*StartLocalJobRequest) ProtoMessage()

func (*StartLocalJobRequest) Reset 

func (m *StartLocalJobRequest) Reset()

func (*StartLocalJobRequest) String 

func (m *StartLocalJobRequest) String() string

func (*StartLocalJobRequest) XXX_DiscardUnknown 

func (m *StartLocalJobRequest) XXX_DiscardUnknown()

func (*StartLocalJobRequest) XXX_Marshal 

func (m *StartLocalJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartLocalJobRequest) XXX_Merge 

func (m *StartLocalJobRequest) XXX_Merge(src proto.Message)

func (*StartLocalJobRequest) XXX_OneofWrappers 

func (*StartLocalJobRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StartLocalJobRequest) XXX_Size 

func (m *StartLocalJobRequest) XXX_Size() int

func (*StartLocalJobRequest) XXX_Unmarshal 

func (m *StartLocalJobRequest) XXX_Unmarshal(b []byte) error

type StartLocalJobRequest_ConfigYaml 

type StartLocalJobRequest_ConfigYaml struct {
	ConfigYaml []byte `protobuf:"bytes,2,opt,name=config_yaml,json=configYaml,proto3,oneof"`
}

type StartLocalJobRequest_JobYaml 

type StartLocalJobRequest_JobYaml struct {
	JobYaml []byte `protobuf:"bytes,3,opt,name=job_yaml,json=jobYaml,proto3,oneof"`
}

type StartLocalJobRequest_Metadata 

type StartLocalJobRequest_Metadata struct {
	Metadata *JobMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}

type StartLocalJobRequest_WorkspaceTar 

type StartLocalJobRequest_WorkspaceTar struct {
	WorkspaceTar []byte `protobuf:"bytes,4,opt,name=workspace_tar,json=workspaceTar,proto3,oneof"`
}

type StartLocalJobRequest_WorkspaceTarDone 

type StartLocalJobRequest_WorkspaceTarDone struct {
	WorkspaceTarDone bool `protobuf:"varint,5,opt,name=workspace_tar_done,json=workspaceTarDone,proto3,oneof"`
}

type StopJobRequest 

type StopJobRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopJobRequest) Descriptor 

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

func (*StopJobRequest) GetName 

func (m *StopJobRequest) GetName() string

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) Reset 

func (m *StopJobRequest) Reset()

func (*StopJobRequest) String 

func (m *StopJobRequest) String() string

func (*StopJobRequest) XXX_DiscardUnknown 

func (m *StopJobRequest) XXX_DiscardUnknown()

func (*StopJobRequest) XXX_Marshal 

func (m *StopJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobRequest) XXX_Merge 

func (m *StopJobRequest) XXX_Merge(src proto.Message)

func (*StopJobRequest) XXX_Size 

func (m *StopJobRequest) XXX_Size() int

func (*StopJobRequest) XXX_Unmarshal 

func (m *StopJobRequest) XXX_Unmarshal(b []byte) error

type StopJobResponse 

type StopJobResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopJobResponse) Descriptor 

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

func (*StopJobResponse) ProtoMessage 

func (*StopJobResponse) ProtoMessage()

func (*StopJobResponse) Reset 

func (m *StopJobResponse) Reset()

func (*StopJobResponse) String 

func (m *StopJobResponse) String() string

func (*StopJobResponse) XXX_DiscardUnknown 

func (m *StopJobResponse) XXX_DiscardUnknown()

func (*StopJobResponse) XXX_Marshal 

func (m *StopJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopJobResponse) XXX_Merge 

func (m *StopJobResponse) XXX_Merge(src proto.Message)

func (*StopJobResponse) XXX_Size 

func (m *StopJobResponse) XXX_Size() int

func (*StopJobResponse) XXX_Unmarshal 

func (m *StopJobResponse) XXX_Unmarshal(b []byte) error

type SubscribeRequest 

type SubscribeRequest struct {
	Filter               []*FilterExpression `protobuf:"bytes,1,rep,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetFilter 

func (m *SubscribeRequest) GetFilter() []*FilterExpression

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge 

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type SubscribeResponse 

type SubscribeResponse struct {
	Result               *JobStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetResult 

func (m *SubscribeResponse) GetResult() *JobStatus

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeResponse) XXX_Merge 

func (m *SubscribeResponse) XXX_Merge(src proto.Message)

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error

type UnimplementedWerftServiceServer 

type UnimplementedWerftServiceServer struct {
}

UnimplementedWerftServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWerftServiceServer) GetJob 

func (*UnimplementedWerftServiceServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)

func (*UnimplementedWerftServiceServer) ListJobs 

func (*UnimplementedWerftServiceServer) ListJobs(ctx context.Context, req *ListJobsRequest) (*ListJobsResponse, error)

func (*UnimplementedWerftServiceServer) Listen 

func (*UnimplementedWerftServiceServer) Listen(req *ListenRequest, srv WerftService_ListenServer) error

func (*UnimplementedWerftServiceServer) StartFromPreviousJob 

func (*UnimplementedWerftServiceServer) StartFromPreviousJob(ctx context.Context, req *StartFromPreviousJobRequest) (*StartJobResponse, error)

func (*UnimplementedWerftServiceServer) StartGitHubJob 

func (*UnimplementedWerftServiceServer) StartGitHubJob(ctx context.Context, req *StartGitHubJobRequest) (*StartJobResponse, error)

func (*UnimplementedWerftServiceServer) StartJob added in v0.1.1 

func (*UnimplementedWerftServiceServer) StartJob(ctx context.Context, req *StartJobRequest) (*StartJobResponse, error)

func (*UnimplementedWerftServiceServer) StartJob2 added in v0.2.0 

func (*UnimplementedWerftServiceServer) StartJob2(ctx context.Context, req *StartJobRequest2) (*StartJobResponse, error)

func (*UnimplementedWerftServiceServer) StartLocalJob 

func (*UnimplementedWerftServiceServer) StartLocalJob(srv WerftService_StartLocalJobServer) error

func (*UnimplementedWerftServiceServer) StopJob 

func (*UnimplementedWerftServiceServer) StopJob(ctx context.Context, req *StopJobRequest) (*StopJobResponse, error)

func (*UnimplementedWerftServiceServer) Subscribe 

func (*UnimplementedWerftServiceServer) Subscribe(req *SubscribeRequest, srv WerftService_SubscribeServer) error

type UnimplementedWerftUIServer 

type UnimplementedWerftUIServer struct {
}

UnimplementedWerftUIServer can be embedded to have forward compatible implementations.

func (*UnimplementedWerftUIServer) IsReadOnly added in v0.1.1 

func (*UnimplementedWerftUIServer) IsReadOnly(ctx context.Context, req *IsReadOnlyRequest) (*IsReadOnlyResponse, error)

func (*UnimplementedWerftUIServer) ListJobSpecs 

func (*UnimplementedWerftUIServer) ListJobSpecs(req *ListJobSpecsRequest, srv WerftUI_ListJobSpecsServer) error

type WerftServiceClient 

type WerftServiceClient interface {
	// StartLocalJob starts a job by uploading the workspace content directly. The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the werft/config.yaml
	//   3. all bytes constituting the job YAML that will be executed (that the config.yaml points to)
	//   4. all bytes constituting the gzipped workspace tar stream
	//   5. the workspace tar stream done marker
	StartLocalJob(ctx context.Context, opts ...grpc.CallOption) (WerftService_StartLocalJobClient, error)
	// StartGitHubJob starts a job on a Git context, possibly with a custom job.
	StartGitHubJob(ctx context.Context, in *StartGitHubJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error)
	// StartFromPreviousJob starts a new job based on a previous one.
	// If the previous job does not have the can-replay condition set this call will result in an error.
	StartFromPreviousJob(ctx context.Context, in *StartFromPreviousJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error)
	// StartJobRequest starts a new job based on its specification.
	StartJob(ctx context.Context, in *StartJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error)
	// StartJob2 starts a new job based on its specification.
	StartJob2(ctx context.Context, in *StartJobRequest2, opts ...grpc.CallOption) (*StartJobResponse, error)
	// Searches for jobs known to this instance
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// Subscribe listens to new jobs/job updates
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (WerftService_SubscribeClient, error)
	// GetJob retrieves details of a single job
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	// Listen listens to job updates and log output of a running job
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (WerftService_ListenClient, error)
	// StopJob stops a currently running job
	StopJob(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*StopJobResponse, error)
}

WerftServiceClient is the client API for WerftService service.

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

func NewWerftServiceClient 

func NewWerftServiceClient(cc grpc.ClientConnInterface) WerftServiceClient

type WerftServiceServer 

type WerftServiceServer interface {
	// StartLocalJob starts a job by uploading the workspace content directly. The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the werft/config.yaml
	//   3. all bytes constituting the job YAML that will be executed (that the config.yaml points to)
	//   4. all bytes constituting the gzipped workspace tar stream
	//   5. the workspace tar stream done marker
	StartLocalJob(WerftService_StartLocalJobServer) error
	// StartGitHubJob starts a job on a Git context, possibly with a custom job.
	StartGitHubJob(context.Context, *StartGitHubJobRequest) (*StartJobResponse, error)
	// StartFromPreviousJob starts a new job based on a previous one.
	// If the previous job does not have the can-replay condition set this call will result in an error.
	StartFromPreviousJob(context.Context, *StartFromPreviousJobRequest) (*StartJobResponse, error)
	// StartJobRequest starts a new job based on its specification.
	StartJob(context.Context, *StartJobRequest) (*StartJobResponse, error)
	// StartJob2 starts a new job based on its specification.
	StartJob2(context.Context, *StartJobRequest2) (*StartJobResponse, error)
	// Searches for jobs known to this instance
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// Subscribe listens to new jobs/job updates
	Subscribe(*SubscribeRequest, WerftService_SubscribeServer) error
	// GetJob retrieves details of a single job
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// Listen listens to job updates and log output of a running job
	Listen(*ListenRequest, WerftService_ListenServer) error
	// StopJob stops a currently running job
	StopJob(context.Context, *StopJobRequest) (*StopJobResponse, error)
}

WerftServiceServer is the server API for WerftService service.

type WerftService_ListenClient 

type WerftService_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type WerftService_ListenServer 

type WerftService_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type WerftService_StartLocalJobClient 

type WerftService_StartLocalJobClient interface {
	Send(*StartLocalJobRequest) error
	CloseAndRecv() (*StartJobResponse, error)
	grpc.ClientStream
}

type WerftService_StartLocalJobServer 

type WerftService_StartLocalJobServer interface {
	SendAndClose(*StartJobResponse) error
	Recv() (*StartLocalJobRequest, error)
	grpc.ServerStream
}

type WerftService_SubscribeClient 

type WerftService_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type WerftService_SubscribeServer 

type WerftService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type WerftUIClient 

type WerftUIClient interface {
	// ListJobSpecs returns a list of jobs that can be started through the UI.
	ListJobSpecs(ctx context.Context, in *ListJobSpecsRequest, opts ...grpc.CallOption) (WerftUI_ListJobSpecsClient, error)
	// IsReadOnly returns true if the UI is readonly.
	IsReadOnly(ctx context.Context, in *IsReadOnlyRequest, opts ...grpc.CallOption) (*IsReadOnlyResponse, error)
}

WerftUIClient is the client API for WerftUI service.

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

func NewWerftUIClient 

func NewWerftUIClient(cc grpc.ClientConnInterface) WerftUIClient

type WerftUIServer 

type WerftUIServer interface {
	// ListJobSpecs returns a list of jobs that can be started through the UI.
	ListJobSpecs(*ListJobSpecsRequest, WerftUI_ListJobSpecsServer) error
	// IsReadOnly returns true if the UI is readonly.
	IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error)
}

WerftUIServer is the server API for WerftUI service.

type WerftUI_ListJobSpecsClient 

type WerftUI_ListJobSpecsClient interface {
	Recv() (*ListJobSpecsResponse, error)
	grpc.ClientStream
}

type WerftUI_ListJobSpecsServer 

type WerftUI_ListJobSpecsServer interface {
	Send(*ListJobSpecsResponse) error
	grpc.ServerStream
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.