Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2022 Changes in this version + var File_piro_proto protoreflect.FileDescriptor + var File_piro_ui_proto protoreflect.FileDescriptor + var FilterOp_name = map[int32]string + var FilterOp_value = map[string]int32 + var JobPhase_name = map[int32]string + var JobPhase_value = map[string]int32 + var JobTrigger_name = map[int32]string + var JobTrigger_value = map[string]int32 + var ListenRequestLogs_name = map[int32]string + var ListenRequestLogs_value = map[string]int32 + var LogSliceType_name = map[int32]string + var LogSliceType_value = map[string]int32 + var PiroService_ServiceDesc = grpc.ServiceDesc + var PiroUI_ServiceDesc = grpc.ServiceDesc + func RegisterPiroServiceServer(s grpc.ServiceRegistrar, srv PiroServiceServer) + func RegisterPiroUIServer(s grpc.ServiceRegistrar, srv PiroUIServer) + type Annotation struct + Key string + Value string + func (*Annotation) Descriptor() ([]byte, []int) + func (*Annotation) ProtoMessage() + func (x *Annotation) GetKey() string + func (x *Annotation) GetValue() string + func (x *Annotation) ProtoReflect() protoreflect.Message + func (x *Annotation) Reset() + func (x *Annotation) String() string + type DesiredAnnotation struct + Description string + Name string + Required bool + func (*DesiredAnnotation) Descriptor() ([]byte, []int) + func (*DesiredAnnotation) ProtoMessage() + func (x *DesiredAnnotation) GetDescription() string + func (x *DesiredAnnotation) GetName() string + func (x *DesiredAnnotation) GetRequired() bool + func (x *DesiredAnnotation) ProtoReflect() protoreflect.Message + func (x *DesiredAnnotation) Reset() + func (x *DesiredAnnotation) String() string + type FilterExpression struct + Terms []*FilterTerm + func (*FilterExpression) Descriptor() ([]byte, []int) + func (*FilterExpression) ProtoMessage() + func (x *FilterExpression) GetTerms() []*FilterTerm + func (x *FilterExpression) ProtoReflect() protoreflect.Message + func (x *FilterExpression) Reset() + func (x *FilterExpression) String() string + type FilterOp int32 + const FilterOp_OP_CONTAINS + const FilterOp_OP_ENDS_WITH + const FilterOp_OP_EQUALS + const FilterOp_OP_EXISTS + const FilterOp_OP_STARTS_WITH + func (FilterOp) Descriptor() protoreflect.EnumDescriptor + func (FilterOp) EnumDescriptor() ([]byte, []int) + func (FilterOp) Type() protoreflect.EnumType + func (x FilterOp) Enum() *FilterOp + func (x FilterOp) Number() protoreflect.EnumNumber + func (x FilterOp) String() string + type FilterTerm struct + Field string + Negate bool + Operation FilterOp + Value string + func (*FilterTerm) Descriptor() ([]byte, []int) + func (*FilterTerm) ProtoMessage() + func (x *FilterTerm) GetField() string + func (x *FilterTerm) GetNegate() bool + func (x *FilterTerm) GetOperation() FilterOp + func (x *FilterTerm) GetValue() string + func (x *FilterTerm) ProtoReflect() protoreflect.Message + func (x *FilterTerm) Reset() + func (x *FilterTerm) String() string + type GetJobRequest struct + Name string + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetName() string + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type GetJobResponse struct + Result *JobStatus + func (*GetJobResponse) Descriptor() ([]byte, []int) + func (*GetJobResponse) ProtoMessage() + func (x *GetJobResponse) GetResult() *JobStatus + func (x *GetJobResponse) ProtoReflect() protoreflect.Message + func (x *GetJobResponse) Reset() + func (x *GetJobResponse) String() string + type IsReadOnlyRequest struct + func (*IsReadOnlyRequest) Descriptor() ([]byte, []int) + func (*IsReadOnlyRequest) ProtoMessage() + func (x *IsReadOnlyRequest) ProtoReflect() protoreflect.Message + func (x *IsReadOnlyRequest) Reset() + func (x *IsReadOnlyRequest) String() string + type IsReadOnlyResponse struct + Readonly bool + func (*IsReadOnlyResponse) Descriptor() ([]byte, []int) + func (*IsReadOnlyResponse) ProtoMessage() + func (x *IsReadOnlyResponse) GetReadonly() bool + func (x *IsReadOnlyResponse) ProtoReflect() protoreflect.Message + func (x *IsReadOnlyResponse) Reset() + func (x *IsReadOnlyResponse) String() string + type JobConditions struct + CanReplay bool + DidExecute bool + FailureCount int32 + Success bool + WaitUntil *timestamppb.Timestamp + func (*JobConditions) Descriptor() ([]byte, []int) + func (*JobConditions) ProtoMessage() + func (x *JobConditions) GetCanReplay() bool + func (x *JobConditions) GetDidExecute() bool + func (x *JobConditions) GetFailureCount() int32 + func (x *JobConditions) GetSuccess() bool + func (x *JobConditions) GetWaitUntil() *timestamppb.Timestamp + func (x *JobConditions) ProtoReflect() protoreflect.Message + func (x *JobConditions) Reset() + func (x *JobConditions) String() string + type JobMetadata struct + Annotations []*Annotation + Created *timestamppb.Timestamp + Finished *timestamppb.Timestamp + JobSpecName string + Owner string + Repository *Repository + Trigger JobTrigger + func (*JobMetadata) Descriptor() ([]byte, []int) + func (*JobMetadata) ProtoMessage() + func (x *JobMetadata) GetAnnotations() []*Annotation + func (x *JobMetadata) GetCreated() *timestamppb.Timestamp + func (x *JobMetadata) GetFinished() *timestamppb.Timestamp + func (x *JobMetadata) GetJobSpecName() string + func (x *JobMetadata) GetOwner() string + func (x *JobMetadata) GetRepository() *Repository + func (x *JobMetadata) GetTrigger() JobTrigger + func (x *JobMetadata) ProtoReflect() protoreflect.Message + func (x *JobMetadata) Reset() + func (x *JobMetadata) String() string + type JobPhase int32 + const JobPhase_PHASE_CLEANUP + const JobPhase_PHASE_DONE + const JobPhase_PHASE_PREPARING + const JobPhase_PHASE_RUNNING + const JobPhase_PHASE_STARTING + const JobPhase_PHASE_UNKNOWN + const JobPhase_PHASE_WAITING + func (JobPhase) Descriptor() protoreflect.EnumDescriptor + func (JobPhase) EnumDescriptor() ([]byte, []int) + func (JobPhase) Type() protoreflect.EnumType + func (x JobPhase) Enum() *JobPhase + func (x JobPhase) Number() protoreflect.EnumNumber + func (x JobPhase) String() string + type JobResult struct + Channels []string + Description string + Payload string + Type string + func (*JobResult) Descriptor() ([]byte, []int) + func (*JobResult) ProtoMessage() + func (x *JobResult) GetChannels() []string + func (x *JobResult) GetDescription() string + func (x *JobResult) GetPayload() string + func (x *JobResult) GetType() string + func (x *JobResult) ProtoReflect() protoreflect.Message + func (x *JobResult) Reset() + func (x *JobResult) String() string + type JobSpec struct + DirectSideload []byte + NameSuffix string + RepoSideload []*JobSpec_FromRepo + Source isJobSpec_Source + func (*JobSpec) Descriptor() ([]byte, []int) + func (*JobSpec) ProtoMessage() + func (m *JobSpec) GetSource() isJobSpec_Source + func (x *JobSpec) GetDirectSideload() []byte + func (x *JobSpec) GetJobPath() string + func (x *JobSpec) GetJobYaml() []byte + func (x *JobSpec) GetNameSuffix() string + func (x *JobSpec) GetRepo() *JobSpec_FromRepo + func (x *JobSpec) GetRepoSideload() []*JobSpec_FromRepo + func (x *JobSpec) ProtoReflect() protoreflect.Message + func (x *JobSpec) Reset() + func (x *JobSpec) String() string + type JobSpec_FromRepo struct + Path string + Repo *Repository + func (*JobSpec_FromRepo) Descriptor() ([]byte, []int) + func (*JobSpec_FromRepo) ProtoMessage() + func (x *JobSpec_FromRepo) GetPath() string + func (x *JobSpec_FromRepo) GetRepo() *Repository + func (x *JobSpec_FromRepo) ProtoReflect() protoreflect.Message + func (x *JobSpec_FromRepo) Reset() + func (x *JobSpec_FromRepo) String() string + type JobSpec_JobPath struct + JobPath string + type JobSpec_JobYaml struct + JobYaml []byte + type JobSpec_Repo struct + Repo *JobSpec_FromRepo + type JobStatus struct + Conditions *JobConditions + Details string + Metadata *JobMetadata + Name string + Phase JobPhase + Results []*JobResult + Spec *JobSpec + func (*JobStatus) Descriptor() ([]byte, []int) + func (*JobStatus) ProtoMessage() + func (x *JobStatus) GetConditions() *JobConditions + func (x *JobStatus) GetDetails() string + func (x *JobStatus) GetMetadata() *JobMetadata + func (x *JobStatus) GetName() string + func (x *JobStatus) GetPhase() JobPhase + func (x *JobStatus) GetResults() []*JobResult + func (x *JobStatus) GetSpec() *JobSpec + func (x *JobStatus) ProtoReflect() protoreflect.Message + func (x *JobStatus) Reset() + func (x *JobStatus) String() string + type JobTrigger int32 + const JobTrigger_TRIGGER_DELETED + const JobTrigger_TRIGGER_MANUAL + const JobTrigger_TRIGGER_PUSH + const JobTrigger_TRIGGER_UNKNOWN + func (JobTrigger) Descriptor() protoreflect.EnumDescriptor + func (JobTrigger) EnumDescriptor() ([]byte, []int) + func (JobTrigger) Type() protoreflect.EnumType + func (x JobTrigger) Enum() *JobTrigger + func (x JobTrigger) Number() protoreflect.EnumNumber + func (x JobTrigger) String() string + type ListJobSpecsRequest struct + func (*ListJobSpecsRequest) Descriptor() ([]byte, []int) + func (*ListJobSpecsRequest) ProtoMessage() + func (x *ListJobSpecsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobSpecsRequest) Reset() + func (x *ListJobSpecsRequest) String() string + type ListJobSpecsResponse struct + Arguments []*DesiredAnnotation + Description string + Name string + Path string + Plugins map[string]string + Repo *Repository + func (*ListJobSpecsResponse) Descriptor() ([]byte, []int) + func (*ListJobSpecsResponse) ProtoMessage() + func (x *ListJobSpecsResponse) GetArguments() []*DesiredAnnotation + func (x *ListJobSpecsResponse) GetDescription() string + func (x *ListJobSpecsResponse) GetName() string + func (x *ListJobSpecsResponse) GetPath() string + func (x *ListJobSpecsResponse) GetPlugins() map[string]string + func (x *ListJobSpecsResponse) GetRepo() *Repository + func (x *ListJobSpecsResponse) ProtoReflect() protoreflect.Message + func (x *ListJobSpecsResponse) Reset() + func (x *ListJobSpecsResponse) String() string + type ListJobsRequest struct + Filter []*FilterExpression + Limit int32 + Order []*OrderExpression + Start int32 + func (*ListJobsRequest) Descriptor() ([]byte, []int) + func (*ListJobsRequest) ProtoMessage() + func (x *ListJobsRequest) GetFilter() []*FilterExpression + func (x *ListJobsRequest) GetLimit() int32 + func (x *ListJobsRequest) GetOrder() []*OrderExpression + func (x *ListJobsRequest) GetStart() int32 + func (x *ListJobsRequest) ProtoReflect() protoreflect.Message + func (x *ListJobsRequest) Reset() + func (x *ListJobsRequest) String() string + type ListJobsResponse struct + Result []*JobStatus + Total int32 + func (*ListJobsResponse) Descriptor() ([]byte, []int) + func (*ListJobsResponse) ProtoMessage() + func (x *ListJobsResponse) GetResult() []*JobStatus + func (x *ListJobsResponse) GetTotal() int32 + func (x *ListJobsResponse) ProtoReflect() protoreflect.Message + func (x *ListJobsResponse) Reset() + func (x *ListJobsResponse) String() string + type ListenRequest struct + Logs ListenRequestLogs + Name string + Updates bool + func (*ListenRequest) Descriptor() ([]byte, []int) + func (*ListenRequest) ProtoMessage() + func (x *ListenRequest) GetLogs() ListenRequestLogs + func (x *ListenRequest) GetName() string + func (x *ListenRequest) GetUpdates() bool + func (x *ListenRequest) ProtoReflect() protoreflect.Message + func (x *ListenRequest) Reset() + func (x *ListenRequest) String() string + type ListenRequestLogs int32 + const ListenRequestLogs_LOGS_DISABLED + const ListenRequestLogs_LOGS_HTML + const ListenRequestLogs_LOGS_RAW + const ListenRequestLogs_LOGS_UNSLICED + func (ListenRequestLogs) Descriptor() protoreflect.EnumDescriptor + func (ListenRequestLogs) EnumDescriptor() ([]byte, []int) + func (ListenRequestLogs) Type() protoreflect.EnumType + func (x ListenRequestLogs) Enum() *ListenRequestLogs + func (x ListenRequestLogs) Number() protoreflect.EnumNumber + func (x ListenRequestLogs) String() string + type ListenResponse struct + Content isListenResponse_Content + func (*ListenResponse) Descriptor() ([]byte, []int) + func (*ListenResponse) ProtoMessage() + func (m *ListenResponse) GetContent() isListenResponse_Content + func (x *ListenResponse) GetSlice() *LogSliceEvent + func (x *ListenResponse) GetUpdate() *JobStatus + func (x *ListenResponse) ProtoReflect() protoreflect.Message + func (x *ListenResponse) Reset() + func (x *ListenResponse) String() string + type ListenResponse_Slice struct + Slice *LogSliceEvent + type ListenResponse_Update struct + Update *JobStatus + type LogSliceEvent struct + Name string + Payload string + Type LogSliceType + func (*LogSliceEvent) Descriptor() ([]byte, []int) + func (*LogSliceEvent) ProtoMessage() + func (x *LogSliceEvent) GetName() string + func (x *LogSliceEvent) GetPayload() string + func (x *LogSliceEvent) GetType() LogSliceType + func (x *LogSliceEvent) ProtoReflect() protoreflect.Message + func (x *LogSliceEvent) Reset() + func (x *LogSliceEvent) String() string + type LogSliceType int32 + const LogSliceType_SLICE_ABANDONED + const LogSliceType_SLICE_CONTENT + const LogSliceType_SLICE_DONE + const LogSliceType_SLICE_FAIL + const LogSliceType_SLICE_PHASE + const LogSliceType_SLICE_RESULT + const LogSliceType_SLICE_START + func (LogSliceType) Descriptor() protoreflect.EnumDescriptor + func (LogSliceType) EnumDescriptor() ([]byte, []int) + func (LogSliceType) Type() protoreflect.EnumType + func (x LogSliceType) Enum() *LogSliceType + func (x LogSliceType) Number() protoreflect.EnumNumber + func (x LogSliceType) String() string + type OrderExpression struct + Ascending bool + Field string + func (*OrderExpression) Descriptor() ([]byte, []int) + func (*OrderExpression) ProtoMessage() + func (x *OrderExpression) GetAscending() bool + func (x *OrderExpression) GetField() string + func (x *OrderExpression) ProtoReflect() protoreflect.Message + func (x *OrderExpression) Reset() + func (x *OrderExpression) String() string + type PiroServiceClient interface + GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) + ListJobs func(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) + Listen func(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (PiroService_ListenClient, error) + StartFromPreviousJob func(ctx context.Context, in *StartFromPreviousJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error) + StartGitHubJob func(ctx context.Context, in *StartGitHubJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error) + StartJob func(ctx context.Context, in *StartJobRequest, opts ...grpc.CallOption) (*StartJobResponse, error) + StartJob2 func(ctx context.Context, in *StartJobRequest2, opts ...grpc.CallOption) (*StartJobResponse, error) + StartLocalJob func(ctx context.Context, opts ...grpc.CallOption) (PiroService_StartLocalJobClient, error) + StopJob func(ctx context.Context, in *StopJobRequest, opts ...grpc.CallOption) (*StopJobResponse, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (PiroService_SubscribeClient, error) + func NewPiroServiceClient(cc grpc.ClientConnInterface) PiroServiceClient + type PiroServiceServer interface + GetJob func(context.Context, *GetJobRequest) (*GetJobResponse, error) + ListJobs func(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + Listen func(*ListenRequest, PiroService_ListenServer) error + StartFromPreviousJob func(context.Context, *StartFromPreviousJobRequest) (*StartJobResponse, error) + StartGitHubJob func(context.Context, *StartGitHubJobRequest) (*StartJobResponse, error) + StartJob func(context.Context, *StartJobRequest) (*StartJobResponse, error) + StartJob2 func(context.Context, *StartJobRequest2) (*StartJobResponse, error) + StartLocalJob func(PiroService_StartLocalJobServer) error + StopJob func(context.Context, *StopJobRequest) (*StopJobResponse, error) + Subscribe func(*SubscribeRequest, PiroService_SubscribeServer) error + type PiroService_ListenClient interface + Recv func() (*ListenResponse, error) + type PiroService_ListenServer interface + Send func(*ListenResponse) error + type PiroService_StartLocalJobClient interface + CloseAndRecv func() (*StartJobResponse, error) + Send func(*StartLocalJobRequest) error + type PiroService_StartLocalJobServer interface + Recv func() (*StartLocalJobRequest, error) + SendAndClose func(*StartJobResponse) error + type PiroService_SubscribeClient interface + Recv func() (*SubscribeResponse, error) + type PiroService_SubscribeServer interface + Send func(*SubscribeResponse) error + type PiroUIClient interface + IsReadOnly func(ctx context.Context, in *IsReadOnlyRequest, opts ...grpc.CallOption) (*IsReadOnlyResponse, error) + ListJobSpecs func(ctx context.Context, in *ListJobSpecsRequest, opts ...grpc.CallOption) (PiroUI_ListJobSpecsClient, error) + func NewPiroUIClient(cc grpc.ClientConnInterface) PiroUIClient + type PiroUIServer interface + IsReadOnly func(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error) + ListJobSpecs func(*ListJobSpecsRequest, PiroUI_ListJobSpecsServer) error + type PiroUI_ListJobSpecsClient interface + Recv func() (*ListJobSpecsResponse, error) + type PiroUI_ListJobSpecsServer interface + Send func(*ListJobSpecsResponse) error + type Repository struct + DefaultBranch string + Host string + Owner string + Ref string + Repo string + Revision string + func (*Repository) Descriptor() ([]byte, []int) + func (*Repository) ProtoMessage() + func (x *Repository) GetDefaultBranch() string + func (x *Repository) GetHost() string + func (x *Repository) GetOwner() string + func (x *Repository) GetRef() string + func (x *Repository) GetRepo() string + func (x *Repository) GetRevision() string + func (x *Repository) ProtoReflect() protoreflect.Message + func (x *Repository) Reset() + func (x *Repository) String() string + type StartFromPreviousJobRequest struct + GithubToken string + PreviousJob string + WaitUntil *timestamppb.Timestamp + func (*StartFromPreviousJobRequest) Descriptor() ([]byte, []int) + func (*StartFromPreviousJobRequest) ProtoMessage() + func (x *StartFromPreviousJobRequest) GetGithubToken() string + func (x *StartFromPreviousJobRequest) GetPreviousJob() string + func (x *StartFromPreviousJobRequest) GetWaitUntil() *timestamppb.Timestamp + func (x *StartFromPreviousJobRequest) ProtoReflect() protoreflect.Message + func (x *StartFromPreviousJobRequest) Reset() + func (x *StartFromPreviousJobRequest) String() string + type StartGitHubJobRequest struct + GithubToken string + JobPath string + JobYaml []byte + Metadata *JobMetadata + NameSuffix string + Sideload []byte + WaitUntil *timestamppb.Timestamp + func (*StartGitHubJobRequest) Descriptor() ([]byte, []int) + func (*StartGitHubJobRequest) ProtoMessage() + func (x *StartGitHubJobRequest) GetGithubToken() string + func (x *StartGitHubJobRequest) GetJobPath() string + func (x *StartGitHubJobRequest) GetJobYaml() []byte + func (x *StartGitHubJobRequest) GetMetadata() *JobMetadata + func (x *StartGitHubJobRequest) GetNameSuffix() string + func (x *StartGitHubJobRequest) GetSideload() []byte + func (x *StartGitHubJobRequest) GetWaitUntil() *timestamppb.Timestamp + func (x *StartGitHubJobRequest) ProtoReflect() protoreflect.Message + func (x *StartGitHubJobRequest) Reset() + func (x *StartGitHubJobRequest) String() string + type StartJobRequest struct + JobPath string + JobYaml []byte + Metadata *JobMetadata + NameSuffix string + Sideload []byte + WaitUntil *timestamppb.Timestamp + func (*StartJobRequest) Descriptor() ([]byte, []int) + func (*StartJobRequest) ProtoMessage() + func (x *StartJobRequest) GetJobPath() string + func (x *StartJobRequest) GetJobYaml() []byte + func (x *StartJobRequest) GetMetadata() *JobMetadata + func (x *StartJobRequest) GetNameSuffix() string + func (x *StartJobRequest) GetSideload() []byte + func (x *StartJobRequest) GetWaitUntil() *timestamppb.Timestamp + func (x *StartJobRequest) ProtoReflect() protoreflect.Message + func (x *StartJobRequest) Reset() + func (x *StartJobRequest) String() string + type StartJobRequest2 struct + Metadata *JobMetadata + Spec *JobSpec + func (*StartJobRequest2) Descriptor() ([]byte, []int) + func (*StartJobRequest2) ProtoMessage() + func (x *StartJobRequest2) GetMetadata() *JobMetadata + func (x *StartJobRequest2) GetSpec() *JobSpec + func (x *StartJobRequest2) ProtoReflect() protoreflect.Message + func (x *StartJobRequest2) Reset() + func (x *StartJobRequest2) String() string + type StartJobResponse struct + Status *JobStatus + func (*StartJobResponse) Descriptor() ([]byte, []int) + func (*StartJobResponse) ProtoMessage() + func (x *StartJobResponse) GetStatus() *JobStatus + func (x *StartJobResponse) ProtoReflect() protoreflect.Message + func (x *StartJobResponse) Reset() + func (x *StartJobResponse) String() string + type StartLocalJobRequest struct + Content isStartLocalJobRequest_Content + func (*StartLocalJobRequest) Descriptor() ([]byte, []int) + func (*StartLocalJobRequest) ProtoMessage() + func (m *StartLocalJobRequest) GetContent() isStartLocalJobRequest_Content + func (x *StartLocalJobRequest) GetConfigYaml() []byte + func (x *StartLocalJobRequest) GetJobYaml() []byte + func (x *StartLocalJobRequest) GetMetadata() *JobMetadata + func (x *StartLocalJobRequest) GetWorkspaceTar() []byte + func (x *StartLocalJobRequest) GetWorkspaceTarDone() bool + func (x *StartLocalJobRequest) ProtoReflect() protoreflect.Message + func (x *StartLocalJobRequest) Reset() + func (x *StartLocalJobRequest) String() string + type StartLocalJobRequest_ConfigYaml struct + ConfigYaml []byte + type StartLocalJobRequest_JobYaml struct + JobYaml []byte + type StartLocalJobRequest_Metadata struct + Metadata *JobMetadata + type StartLocalJobRequest_WorkspaceTar struct + WorkspaceTar []byte + type StartLocalJobRequest_WorkspaceTarDone struct + WorkspaceTarDone bool + type StopJobRequest struct + Name string + func (*StopJobRequest) Descriptor() ([]byte, []int) + func (*StopJobRequest) ProtoMessage() + func (x *StopJobRequest) GetName() string + func (x *StopJobRequest) ProtoReflect() protoreflect.Message + func (x *StopJobRequest) Reset() + func (x *StopJobRequest) String() string + type StopJobResponse struct + func (*StopJobResponse) Descriptor() ([]byte, []int) + func (*StopJobResponse) ProtoMessage() + func (x *StopJobResponse) ProtoReflect() protoreflect.Message + func (x *StopJobResponse) Reset() + func (x *StopJobResponse) String() string + type SubscribeRequest struct + Filter []*FilterExpression + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetFilter() []*FilterExpression + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type SubscribeResponse struct + Result *JobStatus + func (*SubscribeResponse) Descriptor() ([]byte, []int) + func (*SubscribeResponse) ProtoMessage() + func (x *SubscribeResponse) GetResult() *JobStatus + func (x *SubscribeResponse) ProtoReflect() protoreflect.Message + func (x *SubscribeResponse) Reset() + func (x *SubscribeResponse) String() string + type UnimplementedPiroServiceServer struct + func (UnimplementedPiroServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) + func (UnimplementedPiroServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) + func (UnimplementedPiroServiceServer) Listen(*ListenRequest, PiroService_ListenServer) error + func (UnimplementedPiroServiceServer) StartFromPreviousJob(context.Context, *StartFromPreviousJobRequest) (*StartJobResponse, error) + func (UnimplementedPiroServiceServer) StartGitHubJob(context.Context, *StartGitHubJobRequest) (*StartJobResponse, error) + func (UnimplementedPiroServiceServer) StartJob(context.Context, *StartJobRequest) (*StartJobResponse, error) + func (UnimplementedPiroServiceServer) StartJob2(context.Context, *StartJobRequest2) (*StartJobResponse, error) + func (UnimplementedPiroServiceServer) StartLocalJob(PiroService_StartLocalJobServer) error + func (UnimplementedPiroServiceServer) StopJob(context.Context, *StopJobRequest) (*StopJobResponse, error) + func (UnimplementedPiroServiceServer) Subscribe(*SubscribeRequest, PiroService_SubscribeServer) error + type UnimplementedPiroUIServer struct + func (UnimplementedPiroUIServer) IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error) + func (UnimplementedPiroUIServer) ListJobSpecs(*ListJobSpecsRequest, PiroUI_ListJobSpecsServer) error + type UnsafePiroServiceServer interface + type UnsafePiroUIServer interface