v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2022 License: MIT Imports: 9 Imported by: 4

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",
	}
	FilterOp_value = map[string]int32{
		"OP_EQUALS":      0,
		"OP_STARTS_WITH": 1,
		"OP_ENDS_WITH":   2,
		"OP_CONTAINS":    3,
		"OP_EXISTS":      4,
	}
)

Enum value maps for FilterOp.

View Source 
var (
	ListenRequestLogs_name = map[int32]string{
		0: "LOGS_DISABLED",
		1: "LOGS_UNSLICED",
		2: "LOGS_RAW",
		3: "LOGS_HTML",
	}
	ListenRequestLogs_value = map[string]int32{
		"LOGS_DISABLED": 0,
		"LOGS_UNSLICED": 1,
		"LOGS_RAW":      2,
		"LOGS_HTML":     3,
	}
)

Enum value maps for ListenRequestLogs.

View Source 
var (
	JobTrigger_name = map[int32]string{
		0: "TRIGGER_UNKNOWN",
		1: "TRIGGER_MANUAL",
		2: "TRIGGER_PUSH",
		3: "TRIGGER_DELETED",
	}
	JobTrigger_value = map[string]int32{
		"TRIGGER_UNKNOWN": 0,
		"TRIGGER_MANUAL":  1,
		"TRIGGER_PUSH":    2,
		"TRIGGER_DELETED": 3,
	}
)

Enum value maps for JobTrigger.

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",
	}
	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,
	}
)

Enum value maps for JobPhase.

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",
	}
	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,
	}
)

Enum value maps for LogSliceType.

View Source 
var File_piro_proto protoreflect.FileDescriptor
View Source 
var File_piro_ui_proto protoreflect.FileDescriptor
View Source 
var PiroService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.PiroService",
	HandlerType: (*PiroServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartGitHubJob",
			Handler:    _PiroService_StartGitHubJob_Handler,
		},
		{
			MethodName: "StartFromPreviousJob",
			Handler:    _PiroService_StartFromPreviousJob_Handler,
		},
		{
			MethodName: "StartJob",
			Handler:    _PiroService_StartJob_Handler,
		},
		{
			MethodName: "StartJob2",
			Handler:    _PiroService_StartJob2_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _PiroService_ListJobs_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _PiroService_GetJob_Handler,
		},
		{
			MethodName: "StopJob",
			Handler:    _PiroService_StopJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartLocalJob",
			Handler:       _PiroService_StartLocalJob_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _PiroService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _PiroService_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "piro.proto",
}

PiroService_ServiceDesc is the grpc.ServiceDesc for PiroService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var PiroUI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.PiroUI",
	HandlerType: (*PiroUIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReadOnly",
			Handler:    _PiroUI_IsReadOnly_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListJobSpecs",
			Handler:       _PiroUI_ListJobSpecs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "piro-ui.proto",
}

PiroUI_ServiceDesc is the grpc.ServiceDesc for PiroUI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPiroServiceServer 

func RegisterPiroServiceServer(s grpc.ServiceRegistrar, srv PiroServiceServer)

func RegisterPiroUIServer 

func RegisterPiroUIServer(s grpc.ServiceRegistrar, srv PiroUIServer)

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"`
	// contains filtered or unexported fields
}

func (*Annotation) Descriptor deprecated 

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

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetKey 

func (x *Annotation) GetKey() string

func (*Annotation) GetValue 

func (x *Annotation) GetValue() string

func (*Annotation) ProtoMessage 

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect 

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

func (*Annotation) Reset 

func (x *Annotation) Reset()

func (*Annotation) String 

func (x *Annotation) String() string

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"`
	// contains filtered or unexported fields
}

DesiredAnnotation describes an annotation a job should have

func (*DesiredAnnotation) Descriptor deprecated 

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

Deprecated: Use DesiredAnnotation.ProtoReflect.Descriptor instead.

func (*DesiredAnnotation) GetDescription 

func (x *DesiredAnnotation) GetDescription() string

func (*DesiredAnnotation) GetName 

func (x *DesiredAnnotation) GetName() string

func (*DesiredAnnotation) GetRequired 

func (x *DesiredAnnotation) GetRequired() bool

func (*DesiredAnnotation) ProtoMessage 

func (*DesiredAnnotation) ProtoMessage()

func (*DesiredAnnotation) ProtoReflect 

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

func (*DesiredAnnotation) Reset 

func (x *DesiredAnnotation) Reset()

func (*DesiredAnnotation) String 

func (x *DesiredAnnotation) String() string

type FilterExpression 

type FilterExpression struct {
	Terms []*FilterTerm `protobuf:"bytes,1,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpression) Descriptor deprecated 

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

Deprecated: Use FilterExpression.ProtoReflect.Descriptor instead.

func (*FilterExpression) GetTerms 

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

func (*FilterExpression) ProtoMessage 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) ProtoReflect 

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

func (*FilterExpression) Reset 

func (x *FilterExpression) Reset()

func (*FilterExpression) String 

func (x *FilterExpression) String() string

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

func (FilterOp) Descriptor() protoreflect.EnumDescriptor

func (FilterOp) Enum 

func (x FilterOp) Enum() *FilterOp

func (FilterOp) EnumDescriptor deprecated 

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

Deprecated: Use FilterOp.Descriptor instead.

func (FilterOp) Number 

func (x FilterOp) Number() protoreflect.EnumNumber

func (FilterOp) String 

func (x FilterOp) String() string

func (FilterOp) Type 

func (FilterOp) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*FilterTerm) Descriptor deprecated 

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

Deprecated: Use FilterTerm.ProtoReflect.Descriptor instead.

func (*FilterTerm) GetField 

func (x *FilterTerm) GetField() string

func (*FilterTerm) GetNegate 

func (x *FilterTerm) GetNegate() bool

func (*FilterTerm) GetOperation 

func (x *FilterTerm) GetOperation() FilterOp

func (*FilterTerm) GetValue 

func (x *FilterTerm) GetValue() string

func (*FilterTerm) ProtoMessage 

func (*FilterTerm) ProtoMessage()

func (*FilterTerm) ProtoReflect 

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

func (*FilterTerm) Reset 

func (x *FilterTerm) Reset()

func (*FilterTerm) String 

func (x *FilterTerm) String() string

type GetJobRequest 

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

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetName 

func (x *GetJobRequest) GetName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {
	Result *JobStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetResult 

func (x *GetJobResponse) GetResult() *JobStatus

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type IsReadOnlyRequest 

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

func (*IsReadOnlyRequest) Descriptor deprecated 

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

Deprecated: Use IsReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*IsReadOnlyRequest) ProtoMessage 

func (*IsReadOnlyRequest) ProtoMessage()

func (*IsReadOnlyRequest) ProtoReflect 

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

func (*IsReadOnlyRequest) Reset 

func (x *IsReadOnlyRequest) Reset()

func (*IsReadOnlyRequest) String 

func (x *IsReadOnlyRequest) String() string

type IsReadOnlyResponse 

type IsReadOnlyResponse struct {
	Readonly bool `protobuf:"varint,1,opt,name=readonly,proto3" json:"readonly,omitempty"`
	// contains filtered or unexported fields
}

func (*IsReadOnlyResponse) Descriptor deprecated 

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

Deprecated: Use IsReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*IsReadOnlyResponse) GetReadonly 

func (x *IsReadOnlyResponse) GetReadonly() bool

func (*IsReadOnlyResponse) ProtoMessage 

func (*IsReadOnlyResponse) ProtoMessage()

func (*IsReadOnlyResponse) ProtoReflect 

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

func (*IsReadOnlyResponse) Reset 

func (x *IsReadOnlyResponse) Reset()

func (*IsReadOnlyResponse) String 

func (x *IsReadOnlyResponse) String() string

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    *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*JobConditions) Descriptor deprecated 

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

Deprecated: Use JobConditions.ProtoReflect.Descriptor instead.

func (*JobConditions) GetCanReplay 

func (x *JobConditions) GetCanReplay() bool

func (*JobConditions) GetDidExecute 

func (x *JobConditions) GetDidExecute() bool

func (*JobConditions) GetFailureCount 

func (x *JobConditions) GetFailureCount() int32

func (*JobConditions) GetSuccess 

func (x *JobConditions) GetSuccess() bool

func (*JobConditions) GetWaitUntil 

func (x *JobConditions) GetWaitUntil() *timestamppb.Timestamp

func (*JobConditions) ProtoMessage 

func (*JobConditions) ProtoMessage()

func (*JobConditions) ProtoReflect 

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

func (*JobConditions) Reset 

func (x *JobConditions) Reset()

func (*JobConditions) String 

func (x *JobConditions) String() string

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     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	Finished    *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*JobMetadata) Descriptor deprecated 

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

Deprecated: Use JobMetadata.ProtoReflect.Descriptor instead.

func (*JobMetadata) GetAnnotations 

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

func (*JobMetadata) GetCreated 

func (x *JobMetadata) GetCreated() *timestamppb.Timestamp

func (*JobMetadata) GetFinished 

func (x *JobMetadata) GetFinished() *timestamppb.Timestamp

func (*JobMetadata) GetJobSpecName 

func (x *JobMetadata) GetJobSpecName() string

func (*JobMetadata) GetOwner 

func (x *JobMetadata) GetOwner() string

func (*JobMetadata) GetRepository 

func (x *JobMetadata) GetRepository() *Repository

func (*JobMetadata) GetTrigger 

func (x *JobMetadata) GetTrigger() JobTrigger

func (*JobMetadata) ProtoMessage 

func (*JobMetadata) ProtoMessage()

func (*JobMetadata) ProtoReflect 

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

func (*JobMetadata) Reset 

func (x *JobMetadata) Reset()

func (*JobMetadata) String 

func (x *JobMetadata) String() string

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

func (JobPhase) Descriptor() protoreflect.EnumDescriptor

func (JobPhase) Enum 

func (x JobPhase) Enum() *JobPhase

func (JobPhase) EnumDescriptor deprecated 

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

Deprecated: Use JobPhase.Descriptor instead.

func (JobPhase) Number 

func (x JobPhase) Number() protoreflect.EnumNumber

func (JobPhase) String 

func (x JobPhase) String() string

func (JobPhase) Type 

func (JobPhase) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*JobResult) Descriptor deprecated 

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

Deprecated: Use JobResult.ProtoReflect.Descriptor instead.

func (*JobResult) GetChannels 

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

func (*JobResult) GetDescription 

func (x *JobResult) GetDescription() string

func (*JobResult) GetPayload 

func (x *JobResult) GetPayload() string

func (*JobResult) GetType 

func (x *JobResult) GetType() string

func (*JobResult) ProtoMessage 

func (*JobResult) ProtoMessage()

func (*JobResult) ProtoReflect 

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

func (*JobResult) Reset 

func (x *JobResult) Reset()

func (*JobResult) String 

func (x *JobResult) String() string

type JobSpec 

type JobSpec struct {

	// Types that are assignable 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"`
	// contains filtered or unexported fields
}

func (*JobSpec) Descriptor deprecated 

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

Deprecated: Use JobSpec.ProtoReflect.Descriptor instead.

func (*JobSpec) GetDirectSideload 

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

func (*JobSpec) GetJobPath 

func (x *JobSpec) GetJobPath() string

func (*JobSpec) GetJobYaml 

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

func (*JobSpec) GetNameSuffix 

func (x *JobSpec) GetNameSuffix() string

func (*JobSpec) GetRepo 

func (x *JobSpec) GetRepo() *JobSpec_FromRepo

func (*JobSpec) GetRepoSideload 

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

func (*JobSpec) GetSource 

func (m *JobSpec) GetSource() isJobSpec_Source

func (*JobSpec) ProtoMessage 

func (*JobSpec) ProtoMessage()

func (*JobSpec) ProtoReflect 

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

func (*JobSpec) Reset 

func (x *JobSpec) Reset()

func (*JobSpec) String 

func (x *JobSpec) String() string

type JobSpec_FromRepo 

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"`
	// contains filtered or unexported fields
}

func (*JobSpec_FromRepo) Descriptor deprecated 

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

Deprecated: Use JobSpec_FromRepo.ProtoReflect.Descriptor instead.

func (*JobSpec_FromRepo) GetPath 

func (x *JobSpec_FromRepo) GetPath() string

func (*JobSpec_FromRepo) GetRepo 

func (x *JobSpec_FromRepo) GetRepo() *Repository

func (*JobSpec_FromRepo) ProtoMessage 

func (*JobSpec_FromRepo) ProtoMessage()

func (*JobSpec_FromRepo) ProtoReflect 

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

func (*JobSpec_FromRepo) Reset 

func (x *JobSpec_FromRepo) Reset()

func (*JobSpec_FromRepo) String 

func (x *JobSpec_FromRepo) String() string

type JobSpec_JobPath 

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

type JobSpec_JobYaml 

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

type JobSpec_Repo 

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"`
	// contains filtered or unexported fields
}

func (*JobStatus) Descriptor deprecated 

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

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetConditions 

func (x *JobStatus) GetConditions() *JobConditions

func (*JobStatus) GetDetails 

func (x *JobStatus) GetDetails() string

func (*JobStatus) GetMetadata 

func (x *JobStatus) GetMetadata() *JobMetadata

func (*JobStatus) GetName 

func (x *JobStatus) GetName() string

func (*JobStatus) GetPhase 

func (x *JobStatus) GetPhase() JobPhase

func (*JobStatus) GetResults 

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

func (*JobStatus) GetSpec 

func (x *JobStatus) GetSpec() *JobSpec

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

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

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) String 

func (x *JobStatus) String() string

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

func (JobTrigger) Descriptor() protoreflect.EnumDescriptor

func (JobTrigger) Enum 

func (x JobTrigger) Enum() *JobTrigger

func (JobTrigger) EnumDescriptor deprecated 

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

Deprecated: Use JobTrigger.Descriptor instead.

func (JobTrigger) Number 

func (x JobTrigger) Number() protoreflect.EnumNumber

func (JobTrigger) String 

func (x JobTrigger) String() string

func (JobTrigger) Type 

func (JobTrigger) Type() protoreflect.EnumType

type ListJobSpecsRequest 

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

func (*ListJobSpecsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobSpecsRequest.ProtoReflect.Descriptor instead.

func (*ListJobSpecsRequest) ProtoMessage 

func (*ListJobSpecsRequest) ProtoMessage()

func (*ListJobSpecsRequest) ProtoReflect 

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

func (*ListJobSpecsRequest) Reset 

func (x *ListJobSpecsRequest) Reset()

func (*ListJobSpecsRequest) String 

func (x *ListJobSpecsRequest) String() string

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 */
	// contains filtered or unexported fields
}

func (*ListJobSpecsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobSpecsResponse.ProtoReflect.Descriptor instead.

func (*ListJobSpecsResponse) GetArguments 

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

func (*ListJobSpecsResponse) GetDescription 

func (x *ListJobSpecsResponse) GetDescription() string

func (*ListJobSpecsResponse) GetName 

func (x *ListJobSpecsResponse) GetName() string

func (*ListJobSpecsResponse) GetPath 

func (x *ListJobSpecsResponse) GetPath() string

func (*ListJobSpecsResponse) GetPlugins 

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

func (*ListJobSpecsResponse) GetRepo 

func (x *ListJobSpecsResponse) GetRepo() *Repository

func (*ListJobSpecsResponse) ProtoMessage 

func (*ListJobSpecsResponse) ProtoMessage()

func (*ListJobSpecsResponse) ProtoReflect 

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

func (*ListJobSpecsResponse) Reset 

func (x *ListJobSpecsResponse) Reset()

func (*ListJobSpecsResponse) String 

func (x *ListJobSpecsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetFilter 

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

func (*ListJobsRequest) GetLimit 

func (x *ListJobsRequest) GetLimit() int32

func (*ListJobsRequest) GetOrder 

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

func (*ListJobsRequest) GetStart 

func (x *ListJobsRequest) GetStart() int32

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

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

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetResult 

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

func (*ListJobsResponse) GetTotal 

func (x *ListJobsResponse) GetTotal() int32

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

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

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor deprecated 

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetLogs 

func (x *ListenRequest) GetLogs() ListenRequestLogs

func (*ListenRequest) GetName 

func (x *ListenRequest) GetName() string

func (*ListenRequest) GetUpdates 

func (x *ListenRequest) GetUpdates() bool

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect 

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

func (*ListenRequest) Reset 

func (x *ListenRequest) Reset()

func (*ListenRequest) String 

func (x *ListenRequest) String() string

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

func (ListenRequestLogs) Descriptor() protoreflect.EnumDescriptor

func (ListenRequestLogs) Enum 

func (x ListenRequestLogs) Enum() *ListenRequestLogs

func (ListenRequestLogs) EnumDescriptor deprecated 

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

Deprecated: Use ListenRequestLogs.Descriptor instead.

func (ListenRequestLogs) Number 

func (x ListenRequestLogs) Number() protoreflect.EnumNumber

func (ListenRequestLogs) String 

func (x ListenRequestLogs) String() string

func (ListenRequestLogs) Type 

func (ListenRequestLogs) Type() protoreflect.EnumType

type ListenResponse 

type ListenResponse struct {

	// Types that are assignable to Content:
	//	*ListenResponse_Update
	//	*ListenResponse_Slice
	Content isListenResponse_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ListenResponse) Descriptor deprecated 

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

Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetContent 

func (m *ListenResponse) GetContent() isListenResponse_Content

func (*ListenResponse) GetSlice 

func (x *ListenResponse) GetSlice() *LogSliceEvent

func (*ListenResponse) GetUpdate 

func (x *ListenResponse) GetUpdate() *JobStatus

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect 

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

func (*ListenResponse) Reset 

func (x *ListenResponse) Reset()

func (*ListenResponse) String 

func (x *ListenResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*LogSliceEvent) Descriptor deprecated 

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

Deprecated: Use LogSliceEvent.ProtoReflect.Descriptor instead.

func (*LogSliceEvent) GetName 

func (x *LogSliceEvent) GetName() string

func (*LogSliceEvent) GetPayload 

func (x *LogSliceEvent) GetPayload() string

func (*LogSliceEvent) GetType 

func (x *LogSliceEvent) GetType() LogSliceType

func (*LogSliceEvent) ProtoMessage 

func (*LogSliceEvent) ProtoMessage()

func (*LogSliceEvent) ProtoReflect 

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

func (*LogSliceEvent) Reset 

func (x *LogSliceEvent) Reset()

func (*LogSliceEvent) String 

func (x *LogSliceEvent) String() string

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

func (LogSliceType) Descriptor() protoreflect.EnumDescriptor

func (LogSliceType) Enum 

func (x LogSliceType) Enum() *LogSliceType

func (LogSliceType) EnumDescriptor deprecated 

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

Deprecated: Use LogSliceType.Descriptor instead.

func (LogSliceType) Number 

func (x LogSliceType) Number() protoreflect.EnumNumber

func (LogSliceType) String 

func (x LogSliceType) String() string

func (LogSliceType) Type 

func (LogSliceType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*OrderExpression) Descriptor deprecated 

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

Deprecated: Use OrderExpression.ProtoReflect.Descriptor instead.

func (*OrderExpression) GetAscending 

func (x *OrderExpression) GetAscending() bool

func (*OrderExpression) GetField 

func (x *OrderExpression) GetField() string

func (*OrderExpression) ProtoMessage 

func (*OrderExpression) ProtoMessage()

func (*OrderExpression) ProtoReflect 

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

func (*OrderExpression) Reset 

func (x *OrderExpression) Reset()

func (*OrderExpression) String 

func (x *OrderExpression) String() string

type PiroServiceClient 

type PiroServiceClient interface {
	// StartLocalJob starts a Kubernetes Job by uploading Bhojpur.NET Platform
	// application content directly. The incoming requests are expected in the
	// following order:
	//   1. metadata
	//   2. all bytes constituting the piro/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 Bhojpur.NET Platform application tar stream
	//   5. the Bhojpur.NET Platform application tar stream done marker
	StartLocalJob(ctx context.Context, opts ...grpc.CallOption) (PiroService_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) (PiroService_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) (PiroService_ListenClient, error)
	// StopJob stops a currently running job
	StopJob(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*StopJobResponse, error)
}

PiroServiceClient is the client API for PiroService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPiroServiceClient 

func NewPiroServiceClient(cc grpc.ClientConnInterface) PiroServiceClient

type PiroServiceServer 

type PiroServiceServer interface {
	// StartLocalJob starts a Kubernetes Job by uploading Bhojpur.NET Platform
	// application content directly. The incoming requests are expected in the
	// following order:
	//   1. metadata
	//   2. all bytes constituting the piro/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 Bhojpur.NET Platform application tar stream
	//   5. the Bhojpur.NET Platform application tar stream done marker
	StartLocalJob(PiroService_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, PiroService_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, PiroService_ListenServer) error
	// StopJob stops a currently running job
	StopJob(context.Context, *StopJobRequest) (*StopJobResponse, error)
	// contains filtered or unexported methods
}

PiroServiceServer is the server API for PiroService service. All implementations must embed UnimplementedPiroServiceServer for forward compatibility

type PiroService_ListenClient 

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

type PiroService_ListenServer 

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

type PiroService_StartLocalJobClient 

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

type PiroService_StartLocalJobServer 

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

type PiroService_SubscribeClient 

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

type PiroService_SubscribeServer 

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

type PiroUIClient 

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

PiroUIClient is the client API for PiroUI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPiroUIClient 

func NewPiroUIClient(cc grpc.ClientConnInterface) PiroUIClient

type PiroUIServer 

type PiroUIServer interface {
	// ListJobSpecs returns a list of jobs that can be started through the UI.
	ListJobSpecs(*ListJobSpecsRequest, PiroUI_ListJobSpecsServer) error
	// IsReadOnly returns true if the UI is readonly.
	IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error)
	// contains filtered or unexported methods
}

PiroUIServer is the server API for PiroUI service. All implementations must embed UnimplementedPiroUIServer for forward compatibility

type PiroUI_ListJobSpecsClient 

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

type PiroUI_ListJobSpecsServer 

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

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"`
	// contains filtered or unexported fields
}

func (*Repository) Descriptor deprecated 

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

Deprecated: Use Repository.ProtoReflect.Descriptor instead.

func (*Repository) GetDefaultBranch 

func (x *Repository) GetDefaultBranch() string

func (*Repository) GetHost 

func (x *Repository) GetHost() string

func (*Repository) GetOwner 

func (x *Repository) GetOwner() string

func (*Repository) GetRef 

func (x *Repository) GetRef() string

func (*Repository) GetRepo 

func (x *Repository) GetRepo() string

func (*Repository) GetRevision 

func (x *Repository) GetRevision() string

func (*Repository) ProtoMessage 

func (*Repository) ProtoMessage()

func (*Repository) ProtoReflect 

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

func (*Repository) Reset 

func (x *Repository) Reset()

func (*Repository) String 

func (x *Repository) String() string

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   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	// contains filtered or unexported fields
}

func (*StartFromPreviousJobRequest) Descriptor deprecated 

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

Deprecated: Use StartFromPreviousJobRequest.ProtoReflect.Descriptor instead.

func (*StartFromPreviousJobRequest) GetGithubToken 

func (x *StartFromPreviousJobRequest) GetGithubToken() string

func (*StartFromPreviousJobRequest) GetPreviousJob 

func (x *StartFromPreviousJobRequest) GetPreviousJob() string

func (*StartFromPreviousJobRequest) GetWaitUntil 

func (x *StartFromPreviousJobRequest) GetWaitUntil() *timestamppb.Timestamp

func (*StartFromPreviousJobRequest) ProtoMessage 

func (*StartFromPreviousJobRequest) ProtoMessage()

func (*StartFromPreviousJobRequest) ProtoReflect 

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

func (*StartFromPreviousJobRequest) Reset 

func (x *StartFromPreviousJobRequest) Reset()

func (*StartFromPreviousJobRequest) String 

func (x *StartFromPreviousJobRequest) String() string

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   *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*StartGitHubJobRequest) Descriptor deprecated 

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

Deprecated: Use StartGitHubJobRequest.ProtoReflect.Descriptor instead.

func (*StartGitHubJobRequest) GetGithubToken 

func (x *StartGitHubJobRequest) GetGithubToken() string

func (*StartGitHubJobRequest) GetJobPath 

func (x *StartGitHubJobRequest) GetJobPath() string

func (*StartGitHubJobRequest) GetJobYaml 

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

func (*StartGitHubJobRequest) GetMetadata 

func (x *StartGitHubJobRequest) GetMetadata() *JobMetadata

func (*StartGitHubJobRequest) GetNameSuffix 

func (x *StartGitHubJobRequest) GetNameSuffix() string

func (*StartGitHubJobRequest) GetSideload 

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

func (*StartGitHubJobRequest) GetWaitUntil 

func (x *StartGitHubJobRequest) GetWaitUntil() *timestamppb.Timestamp

func (*StartGitHubJobRequest) ProtoMessage 

func (*StartGitHubJobRequest) ProtoMessage()

func (*StartGitHubJobRequest) ProtoReflect 

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

func (*StartGitHubJobRequest) Reset 

func (x *StartGitHubJobRequest) Reset()

func (*StartGitHubJobRequest) String 

func (x *StartGitHubJobRequest) String() string

type StartJobRequest 

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  *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*StartJobRequest) Descriptor deprecated 

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

Deprecated: Use StartJobRequest.ProtoReflect.Descriptor instead.

func (*StartJobRequest) GetJobPath 

func (x *StartJobRequest) GetJobPath() string

func (*StartJobRequest) GetJobYaml 

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

func (*StartJobRequest) GetMetadata 

func (x *StartJobRequest) GetMetadata() *JobMetadata

func (*StartJobRequest) GetNameSuffix 

func (x *StartJobRequest) GetNameSuffix() string

func (*StartJobRequest) GetSideload 

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

func (*StartJobRequest) GetWaitUntil 

func (x *StartJobRequest) GetWaitUntil() *timestamppb.Timestamp

func (*StartJobRequest) ProtoMessage 

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) ProtoReflect 

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

func (*StartJobRequest) Reset 

func (x *StartJobRequest) Reset()

func (*StartJobRequest) String 

func (x *StartJobRequest) String() string

type StartJobRequest2 

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"`
	// contains filtered or unexported fields
}

func (*StartJobRequest2) Descriptor deprecated 

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

Deprecated: Use StartJobRequest2.ProtoReflect.Descriptor instead.

func (*StartJobRequest2) GetMetadata 

func (x *StartJobRequest2) GetMetadata() *JobMetadata

func (*StartJobRequest2) GetSpec 

func (x *StartJobRequest2) GetSpec() *JobSpec

func (*StartJobRequest2) ProtoMessage 

func (*StartJobRequest2) ProtoMessage()

func (*StartJobRequest2) ProtoReflect 

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

func (*StartJobRequest2) Reset 

func (x *StartJobRequest2) Reset()

func (*StartJobRequest2) String 

func (x *StartJobRequest2) String() string

type StartJobResponse 

type StartJobResponse struct {
	Status *JobStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StartJobResponse) Descriptor deprecated 

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

Deprecated: Use StartJobResponse.ProtoReflect.Descriptor instead.

func (*StartJobResponse) GetStatus 

func (x *StartJobResponse) GetStatus() *JobStatus

func (*StartJobResponse) ProtoMessage 

func (*StartJobResponse) ProtoMessage()

func (*StartJobResponse) ProtoReflect 

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

func (*StartJobResponse) Reset 

func (x *StartJobResponse) Reset()

func (*StartJobResponse) String 

func (x *StartJobResponse) String() string

type StartLocalJobRequest 

type StartLocalJobRequest struct {

	// Types that are assignable to Content:
	//	*StartLocalJobRequest_Metadata
	//	*StartLocalJobRequest_ConfigYaml
	//	*StartLocalJobRequest_JobYaml
	//	*StartLocalJobRequest_WorkspaceTar
	//	*StartLocalJobRequest_WorkspaceTarDone
	Content isStartLocalJobRequest_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*StartLocalJobRequest) Descriptor deprecated 

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

Deprecated: Use StartLocalJobRequest.ProtoReflect.Descriptor instead.

func (*StartLocalJobRequest) GetConfigYaml 

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

func (*StartLocalJobRequest) GetContent 

func (m *StartLocalJobRequest) GetContent() isStartLocalJobRequest_Content

func (*StartLocalJobRequest) GetJobYaml 

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

func (*StartLocalJobRequest) GetMetadata 

func (x *StartLocalJobRequest) GetMetadata() *JobMetadata

func (*StartLocalJobRequest) GetWorkspaceTar 

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

func (*StartLocalJobRequest) GetWorkspaceTarDone 

func (x *StartLocalJobRequest) GetWorkspaceTarDone() bool

func (*StartLocalJobRequest) ProtoMessage 

func (*StartLocalJobRequest) ProtoMessage()

func (*StartLocalJobRequest) ProtoReflect 

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

func (*StartLocalJobRequest) Reset 

func (x *StartLocalJobRequest) Reset()

func (*StartLocalJobRequest) String 

func (x *StartLocalJobRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*StopJobRequest) Descriptor deprecated 

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

Deprecated: Use StopJobRequest.ProtoReflect.Descriptor instead.

func (*StopJobRequest) GetName 

func (x *StopJobRequest) GetName() string

func (*StopJobRequest) ProtoMessage 

func (*StopJobRequest) ProtoMessage()

func (*StopJobRequest) ProtoReflect 

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

func (*StopJobRequest) Reset 

func (x *StopJobRequest) Reset()

func (*StopJobRequest) String 

func (x *StopJobRequest) String() string

type StopJobResponse 

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

func (*StopJobResponse) Descriptor deprecated 

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

Deprecated: Use StopJobResponse.ProtoReflect.Descriptor instead.

func (*StopJobResponse) ProtoMessage 

func (*StopJobResponse) ProtoMessage()

func (*StopJobResponse) ProtoReflect 

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

func (*StopJobResponse) Reset 

func (x *StopJobResponse) Reset()

func (*StopJobResponse) String 

func (x *StopJobResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Filter []*FilterExpression `protobuf:"bytes,1,rep,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetFilter 

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

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {
	Result *JobStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetResult 

func (x *SubscribeResponse) GetResult() *JobStatus

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type UnimplementedPiroServiceServer 

type UnimplementedPiroServiceServer struct {
}

UnimplementedPiroServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPiroServiceServer) GetJob 

func (UnimplementedPiroServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)

func (UnimplementedPiroServiceServer) ListJobs 

func (UnimplementedPiroServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

func (UnimplementedPiroServiceServer) Listen 

func (UnimplementedPiroServiceServer) Listen(*ListenRequest, PiroService_ListenServer) error

func (UnimplementedPiroServiceServer) StartFromPreviousJob 

func (UnimplementedPiroServiceServer) StartFromPreviousJob(context.Context, *StartFromPreviousJobRequest) (*StartJobResponse, error)

func (UnimplementedPiroServiceServer) StartGitHubJob 

func (UnimplementedPiroServiceServer) StartGitHubJob(context.Context, *StartGitHubJobRequest) (*StartJobResponse, error)

func (UnimplementedPiroServiceServer) StartJob 

func (UnimplementedPiroServiceServer) StartJob(context.Context, *StartJobRequest) (*StartJobResponse, error)

func (UnimplementedPiroServiceServer) StartJob2 

func (UnimplementedPiroServiceServer) StartJob2(context.Context, *StartJobRequest2) (*StartJobResponse, error)

func (UnimplementedPiroServiceServer) StartLocalJob 

func (UnimplementedPiroServiceServer) StartLocalJob(PiroService_StartLocalJobServer) error

func (UnimplementedPiroServiceServer) StopJob 

func (UnimplementedPiroServiceServer) StopJob(context.Context, *StopJobRequest) (*StopJobResponse, error)

func (UnimplementedPiroServiceServer) Subscribe 

func (UnimplementedPiroServiceServer) Subscribe(*SubscribeRequest, PiroService_SubscribeServer) error

type UnimplementedPiroUIServer 

type UnimplementedPiroUIServer struct {
}

UnimplementedPiroUIServer must be embedded to have forward compatible implementations.

func (UnimplementedPiroUIServer) IsReadOnly 

func (UnimplementedPiroUIServer) IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error)

func (UnimplementedPiroUIServer) ListJobSpecs 

func (UnimplementedPiroUIServer) ListJobSpecs(*ListJobSpecsRequest, PiroUI_ListJobSpecsServer) error

type UnsafePiroServiceServer 

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

UnsafePiroServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PiroServiceServer will result in compilation errors.

type UnsafePiroUIServer 

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

UnsafePiroUIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PiroUIServer will result in compilation errors.

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.