api

package
v0.0.0-...-9d58fce Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0:  "STATUS_UNKNOWN",
		1:  "STATUS_CREATED",
		2:  "STATUS_QUEUED",
		24: "STATUS_PREPARING",
		25: "STATUS_RUNNING",
		26: "STATUS_CANCELING",
		50: "STATUS_FAILED",
		51: "STATUS_SKIPPED",
		52: "STATUS_SUCCEEDED",
	}
	Status_value = map[string]int32{
		"STATUS_UNKNOWN":   0,
		"STATUS_CREATED":   1,
		"STATUS_QUEUED":    2,
		"STATUS_PREPARING": 24,
		"STATUS_RUNNING":   25,
		"STATUS_CANCELING": 26,
		"STATUS_FAILED":    50,
		"STATUS_SKIPPED":   51,
		"STATUS_SUCCEEDED": 52,
	}
)

Enum value maps for Status.

View Source 
var (
	FailedReason_name = map[int32]string{
		0: "FAILED_REASON_INTERNAL_ERROR",
		1: "FAILED_REASON_TIMEOUT",
		2: "FAILED_REASON_CANCELLED",
		3: "FAILED_REASON_STEP_FAILED",
		4: "FAILED_REASON_HEARTBEAT_TIMEOUT",
	}
	FailedReason_value = map[string]int32{
		"FAILED_REASON_INTERNAL_ERROR":    0,
		"FAILED_REASON_TIMEOUT":           1,
		"FAILED_REASON_CANCELLED":         2,
		"FAILED_REASON_STEP_FAILED":       3,
		"FAILED_REASON_HEARTBEAT_TIMEOUT": 4,
	}
)

Enum value maps for ReasonType.

View Source 
var File_entity_proto protoreflect.FileDescriptor
View Source 
var File_internal_proto protoreflect.FileDescriptor
View Source 
var File_server_proto protoreflect.FileDescriptor
View Source 
var Server_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Server",
	HandlerType: (*ServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Server_Ping_Handler,
		},
		{
			MethodName: "CreatePipeline",
			Handler:    _Server_CreatePipeline_Handler,
		},
		{
			MethodName: "RequestJob",
			Handler:    _Server_RequestJob_Handler,
		},
		{
			MethodName: "GetJobExecution",
			Handler:    _Server_GetJobExecution_Handler,
		},
		{
			MethodName: "CancelJobExecution",
			Handler:    _Server_CancelJobExecution_Handler,
		},
		{
			MethodName: "ListJobExecutions",
			Handler:    _Server_ListJobExecutions_Handler,
		},
		{
			MethodName: "UpdateJobExecution",
			Handler:    _Server_UpdateJobExecution_Handler,
		},
		{
			MethodName: "GetStepExecution",
			Handler:    _Server_GetStepExecution_Handler,
		},
		{
			MethodName: "UpdateStepExecution",
			Handler:    _Server_UpdateStepExecution_Handler,
		},
		{
			MethodName: "UploadLogLines",
			Handler:    _Server_UploadLogLines_Handler,
		},
		{
			MethodName: "GetLogLines",
			Handler:    _Server_GetLogLines_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Server_Heartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "server.proto",
}

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

Functions

func ConvertTime 

func ConvertTime[T Time](t T) *timestamppb.Timestamp

func RegisterServerServer 

func RegisterServerServer(s grpc.ServiceRegistrar, srv ServerServer)

func ValidateDSL 

func ValidateDSL(dsl *PipelineDSL) error

Types

type ArchiveLogs 

type ArchiveLogs struct {
	Logs []*LogLine `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveLogs) Descriptor deprecated 

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

Deprecated: Use ArchiveLogs.ProtoReflect.Descriptor instead.

func (*ArchiveLogs) GetLogs 

func (x *ArchiveLogs) GetLogs() []*LogLine

func (*ArchiveLogs) ProtoMessage 

func (*ArchiveLogs) ProtoMessage()

func (*ArchiveLogs) ProtoReflect 

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

func (*ArchiveLogs) Reset 

func (x *ArchiveLogs) Reset()

func (*ArchiveLogs) String 

func (x *ArchiveLogs) String() string

type CancelJobExecutionRequest 

type CancelJobExecutionRequest struct {
	JobExecutionID int64 `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty" path:"job_execution_id"`
	// contains filtered or unexported fields
}

func (*CancelJobExecutionRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobExecutionRequest.ProtoReflect.Descriptor instead.

func (*CancelJobExecutionRequest) GetJobExecutionID 

func (x *CancelJobExecutionRequest) GetJobExecutionID() int64

func (*CancelJobExecutionRequest) ProtoMessage 

func (*CancelJobExecutionRequest) ProtoMessage()

func (*CancelJobExecutionRequest) ProtoReflect 

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

func (*CancelJobExecutionRequest) Reset 

func (x *CancelJobExecutionRequest) Reset()

func (*CancelJobExecutionRequest) String 

func (x *CancelJobExecutionRequest) String() string

type CancelJobExecutionResponse 

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

func (*CancelJobExecutionResponse) Descriptor deprecated 

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

Deprecated: Use CancelJobExecutionResponse.ProtoReflect.Descriptor instead.

func (*CancelJobExecutionResponse) GetJobExecution 

func (x *CancelJobExecutionResponse) GetJobExecution() *JobExecution

func (*CancelJobExecutionResponse) ProtoMessage 

func (*CancelJobExecutionResponse) ProtoMessage()

func (*CancelJobExecutionResponse) ProtoReflect 

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

func (*CancelJobExecutionResponse) Reset 

func (x *CancelJobExecutionResponse) Reset()

func (*CancelJobExecutionResponse) String 

func (x *CancelJobExecutionResponse) String() string

type Container 

type Container struct {
	Name         string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image        string         `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	VolumeMounts []*VolumeMount `protobuf:"bytes,3,rep,name=volume_mounts,json=volumeMounts,proto3" json:"volume_mounts,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetImage 

func (x *Container) GetImage() string

func (*Container) GetName 

func (x *Container) GetName() string

func (*Container) GetVolumeMounts 

func (x *Container) GetVolumeMounts() []*VolumeMount

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

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

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type CreatePipelineRequest 

type CreatePipelineRequest struct {
	Pipeline *PipelineDSL `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRequest) GetPipeline 

func (x *CreatePipelineRequest) GetPipeline() *PipelineDSL

func (*CreatePipelineRequest) ProtoMessage 

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) ProtoReflect 

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

func (*CreatePipelineRequest) Reset 

func (x *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String 

func (x *CreatePipelineRequest) String() string

type CreatePipelineResponse 

type CreatePipelineResponse struct {
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineResponse) Descriptor deprecated 

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

Deprecated: Use CreatePipelineResponse.ProtoReflect.Descriptor instead.

func (*CreatePipelineResponse) GetPipeline 

func (x *CreatePipelineResponse) GetPipeline() *Pipeline

func (*CreatePipelineResponse) ProtoMessage 

func (*CreatePipelineResponse) ProtoMessage()

func (*CreatePipelineResponse) ProtoReflect 

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

func (*CreatePipelineResponse) Reset 

func (x *CreatePipelineResponse) Reset()

func (*CreatePipelineResponse) String 

func (x *CreatePipelineResponse) String() string

type Docker 

type Docker struct {
	Containers       []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	Volumes          []*Volume    `protobuf:"bytes,2,rep,name=volumes,proto3" json:"volumes,omitempty"`
	DefaultContainer string       `protobuf:"bytes,3,opt,name=default_container,json=defaultContainer,proto3" json:"default_container,omitempty"`
	// contains filtered or unexported fields
}

func (*Docker) Descriptor deprecated 

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

Deprecated: Use Docker.ProtoReflect.Descriptor instead.

func (*Docker) GetContainers 

func (x *Docker) GetContainers() []*Container

func (*Docker) GetDefaultContainer 

func (x *Docker) GetDefaultContainer() string

func (*Docker) GetVolumes 

func (x *Docker) GetVolumes() []*Volume

func (*Docker) ProtoMessage 

func (*Docker) ProtoMessage()

func (*Docker) ProtoReflect 

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

func (*Docker) Reset 

func (x *Docker) Reset()

func (*Docker) String 

func (x *Docker) String() string

type EmptyDirVolumeSource 

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

func (*EmptyDirVolumeSource) Descriptor deprecated 

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

Deprecated: Use EmptyDirVolumeSource.ProtoReflect.Descriptor instead.

func (*EmptyDirVolumeSource) ProtoMessage 

func (*EmptyDirVolumeSource) ProtoMessage()

func (*EmptyDirVolumeSource) ProtoReflect 

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

func (*EmptyDirVolumeSource) Reset 

func (x *EmptyDirVolumeSource) Reset()

func (*EmptyDirVolumeSource) String 

func (x *EmptyDirVolumeSource) String() string

type Event 

type Event struct {
	ObjectKind        string             `protobuf:"bytes,1,opt,name=object_kind,json=objectKind,proto3" json:"object_kind,omitempty"`
	StepExecution     *StepExecution     `protobuf:"bytes,2,opt,name=step_execution,json=stepExecution,proto3,oneof" json:"step_execution,omitempty"`
	JobExecution      *JobExecution      `protobuf:"bytes,3,opt,name=job_execution,json=jobExecution,proto3,oneof" json:"job_execution,omitempty"`
	PipelineExecution *PipelineExecution `protobuf:"bytes,4,opt,name=pipeline_execution,json=pipelineExecution,proto3,oneof" json:"pipeline_execution,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetJobExecution 

func (x *Event) GetJobExecution() *JobExecution

func (*Event) GetObjectKind 

func (x *Event) GetObjectKind() string

func (*Event) GetPipelineExecution 

func (x *Event) GetPipelineExecution() *PipelineExecution

func (*Event) GetStepExecution 

func (x *Event) GetStepExecution() *StepExecution

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type FailedReason 

type FailedReason int32
const (
	FailedReasonInternalError    FailedReason = 0
	FailedReasonTimeout          FailedReason = 1
	FailedReasonCancelled        FailedReason = 2
	FailedReasonStepFailed       FailedReason = 3
	FailedReasonHeartbeatTimeout FailedReason = 4
)

func (FailedReason) Descriptor 

func (FailedReason) Descriptor() protoreflect.EnumDescriptor

func (FailedReason) Enum 

func (x FailedReason) Enum() *FailedReason

func (FailedReason) EnumDescriptor deprecated 

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

Deprecated: Use ReasonType.Descriptor instead.

func (FailedReason) Number 

func (x FailedReason) Number() protoreflect.EnumNumber

func (FailedReason) String 

func (x FailedReason) String() string

func (FailedReason) Type 

func (FailedReason) Type() protoreflect.EnumType

type GetJobExecutionRequest 

type GetJobExecutionRequest struct {
	JobExecutionID int64 `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty" path:"job_execution_id"`

	WithStepExecution *bool `protobuf:"varint,100,opt,name=WithStepExecution,proto3,oneof" json:"WithStepExecution,omitempty" query:"with_step_execution"`
	// contains filtered or unexported fields
}

func (*GetJobExecutionRequest) Descriptor deprecated 

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

Deprecated: Use GetJobExecutionRequest.ProtoReflect.Descriptor instead.

func (*GetJobExecutionRequest) GetJobExecutionID 

func (x *GetJobExecutionRequest) GetJobExecutionID() int64

func (*GetJobExecutionRequest) GetWithStepExecution 

func (x *GetJobExecutionRequest) GetWithStepExecution() bool

func (*GetJobExecutionRequest) ProtoMessage 

func (*GetJobExecutionRequest) ProtoMessage()

func (*GetJobExecutionRequest) ProtoReflect 

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

func (*GetJobExecutionRequest) Reset 

func (x *GetJobExecutionRequest) Reset()

func (*GetJobExecutionRequest) String 

func (x *GetJobExecutionRequest) String() string

type GetJobExecutionResponse 

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

func (*GetJobExecutionResponse) Descriptor deprecated 

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

Deprecated: Use GetJobExecutionResponse.ProtoReflect.Descriptor instead.

func (*GetJobExecutionResponse) GetJobExecution 

func (x *GetJobExecutionResponse) GetJobExecution() *JobExecution

func (*GetJobExecutionResponse) ProtoMessage 

func (*GetJobExecutionResponse) ProtoMessage()

func (*GetJobExecutionResponse) ProtoReflect 

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

func (*GetJobExecutionResponse) Reset 

func (x *GetJobExecutionResponse) Reset()

func (*GetJobExecutionResponse) String 

func (x *GetJobExecutionResponse) String() string

type GetLogLinesRequest 

type GetLogLinesRequest struct {
	JobExecutionID int64 `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty" path:"job_execution_id"`

	Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty" path:"name"`

	Offset int64 `protobuf:"varint,3,opt,name=Offset,proto3" json:"Offset,omitempty" query:"offset"`

	Limit *int64 `protobuf:"varint,4,opt,name=Limit,proto3,oneof" json:"Limit,omitempty" query:"limit"`
	// contains filtered or unexported fields
}

func (*GetLogLinesRequest) Descriptor deprecated 

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

Deprecated: Use GetLogLinesRequest.ProtoReflect.Descriptor instead.

func (*GetLogLinesRequest) GetJobExecutionID 

func (x *GetLogLinesRequest) GetJobExecutionID() int64

func (*GetLogLinesRequest) GetLimit 

func (x *GetLogLinesRequest) GetLimit() int64

func (*GetLogLinesRequest) GetName 

func (x *GetLogLinesRequest) GetName() string

func (*GetLogLinesRequest) GetOffset 

func (x *GetLogLinesRequest) GetOffset() int64

func (*GetLogLinesRequest) ProtoMessage 

func (*GetLogLinesRequest) ProtoMessage()

func (*GetLogLinesRequest) ProtoReflect 

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

func (*GetLogLinesRequest) Reset 

func (x *GetLogLinesRequest) Reset()

func (*GetLogLinesRequest) String 

func (x *GetLogLinesRequest) String() string

type GetLogLinesResponse 

type GetLogLinesResponse struct {
	Lines []*LogLine `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogLinesResponse) Descriptor deprecated 

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

Deprecated: Use GetLogLinesResponse.ProtoReflect.Descriptor instead.

func (*GetLogLinesResponse) GetLines 

func (x *GetLogLinesResponse) GetLines() []*LogLine

func (*GetLogLinesResponse) ProtoMessage 

func (*GetLogLinesResponse) ProtoMessage()

func (*GetLogLinesResponse) ProtoReflect 

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

func (*GetLogLinesResponse) Reset 

func (x *GetLogLinesResponse) Reset()

func (*GetLogLinesResponse) String 

func (x *GetLogLinesResponse) String() string

type GetStepExecutionRequest 

type GetStepExecutionRequest struct {
	StepExecutionID int64 `protobuf:"varint,1,opt,name=StepExecutionID,proto3" json:"StepExecutionID,omitempty" path:"step_execution_id"`
	// contains filtered or unexported fields
}

func (*GetStepExecutionRequest) Descriptor deprecated 

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

Deprecated: Use GetStepExecutionRequest.ProtoReflect.Descriptor instead.

func (*GetStepExecutionRequest) GetStepExecutionID 

func (x *GetStepExecutionRequest) GetStepExecutionID() int64

func (*GetStepExecutionRequest) ProtoMessage 

func (*GetStepExecutionRequest) ProtoMessage()

func (*GetStepExecutionRequest) ProtoReflect 

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

func (*GetStepExecutionRequest) Reset 

func (x *GetStepExecutionRequest) Reset()

func (*GetStepExecutionRequest) String 

func (x *GetStepExecutionRequest) String() string

type GetStepExecutionResponse 

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

func (*GetStepExecutionResponse) Descriptor deprecated 

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

Deprecated: Use GetStepExecutionResponse.ProtoReflect.Descriptor instead.

func (*GetStepExecutionResponse) GetStepExecution 

func (x *GetStepExecutionResponse) GetStepExecution() *StepExecution

func (*GetStepExecutionResponse) ProtoMessage 

func (*GetStepExecutionResponse) ProtoMessage()

func (*GetStepExecutionResponse) ProtoReflect 

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

func (*GetStepExecutionResponse) Reset 

func (x *GetStepExecutionResponse) Reset()

func (*GetStepExecutionResponse) String 

func (x *GetStepExecutionResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	JobExecutionID int64 `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetJobExecutionID 

func (x *HeartbeatRequest) GetJobExecutionID() int64

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetStatus 

func (x *HeartbeatResponse) GetStatus() Status

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type HostPathVolumeSource 

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

func (*HostPathVolumeSource) Descriptor deprecated 

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

Deprecated: Use HostPathVolumeSource.ProtoReflect.Descriptor instead.

func (*HostPathVolumeSource) GetPath 

func (x *HostPathVolumeSource) GetPath() string

func (*HostPathVolumeSource) ProtoMessage 

func (*HostPathVolumeSource) ProtoMessage()

func (*HostPathVolumeSource) ProtoReflect 

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

func (*HostPathVolumeSource) Reset 

func (x *HostPathVolumeSource) Reset()

func (*HostPathVolumeSource) String 

func (x *HostPathVolumeSource) String() string

type Job 

type Job struct {
	ID               int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PipelineID       int64                  `protobuf:"varint,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Name             string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	RunsOn           *RunsOn                `protobuf:"bytes,4,opt,name=runs_on,json=runsOn,proto3" json:"runs_on,omitempty"`
	WorkingDirectory string                 `protobuf:"bytes,5,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
	EnvVar           map[string]string      `` /* 167-byte string literal not displayed */
	DependsOn        []string               `protobuf:"bytes,7,rep,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	Steps            []*Step                `protobuf:"bytes,8,rep,name=steps,proto3" json:"steps,omitempty"`
	Executions       []*JobExecution        `protobuf:"bytes,9,rep,name=executions,proto3" json:"executions,omitempty"`
	Execution        *JobExecution          `protobuf:"bytes,10,opt,name=execution,proto3" json:"execution,omitempty"`
	Timeout          int32                  `protobuf:"varint,11,opt,name=timeout,proto3" json:"timeout,omitempty"`
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt        *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetCreatedAt 

func (x *Job) GetCreatedAt() *timestamppb.Timestamp

func (*Job) GetDependsOn 

func (x *Job) GetDependsOn() []string

func (*Job) GetEnvVar 

func (x *Job) GetEnvVar() map[string]string

func (*Job) GetExecution 

func (x *Job) GetExecution() *JobExecution

func (*Job) GetExecutions 

func (x *Job) GetExecutions() []*JobExecution

func (*Job) GetID 

func (x *Job) GetID() int64

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetPipelineID 

func (x *Job) GetPipelineID() int64

func (*Job) GetRunsOn 

func (x *Job) GetRunsOn() *RunsOn

func (*Job) GetSteps 

func (x *Job) GetSteps() []*Step

func (*Job) GetTimeout 

func (x *Job) GetTimeout() int32

func (*Job) GetUpdatedAt 

func (x *Job) GetUpdatedAt() *timestamppb.Timestamp

func (*Job) GetWorkingDirectory 

func (x *Job) GetWorkingDirectory() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobDSL 

type JobDSL struct {
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty" validate:"required"`

	RunsOn           *RunsOn           `protobuf:"bytes,4,opt,name=runs_on,json=runsOn,proto3" json:"runs_on,omitempty" validate:"required"`
	WorkingDirectory string            `protobuf:"bytes,5,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
	EnvVar           map[string]string `` /* 167-byte string literal not displayed */
	DependsOn        []string          `protobuf:"bytes,7,rep,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`

	Steps []*StepDSL `protobuf:"bytes,8,rep,name=steps,proto3" json:"steps,omitempty" validate:"required,min=1,max=32,dive"`
	// Timeout in seconds
	Timeout int32 `protobuf:"varint,9,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// contains filtered or unexported fields
}

JobDSL represents a job definition. It only used to create a job.

func (*JobDSL) Descriptor deprecated 

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

Deprecated: Use JobDSL.ProtoReflect.Descriptor instead.

func (*JobDSL) GetDependsOn 

func (x *JobDSL) GetDependsOn() []string

func (*JobDSL) GetEnvVar 

func (x *JobDSL) GetEnvVar() map[string]string

func (*JobDSL) GetName 

func (x *JobDSL) GetName() string

func (*JobDSL) GetRunsOn 

func (x *JobDSL) GetRunsOn() *RunsOn

func (*JobDSL) GetSteps 

func (x *JobDSL) GetSteps() []*StepDSL

func (*JobDSL) GetTimeout 

func (x *JobDSL) GetTimeout() int32

func (*JobDSL) GetWorkingDirectory 

func (x *JobDSL) GetWorkingDirectory() string

func (*JobDSL) ProtoMessage 

func (*JobDSL) ProtoMessage()

func (*JobDSL) ProtoReflect 

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

func (*JobDSL) Reset 

func (x *JobDSL) Reset()

func (*JobDSL) String 

func (x *JobDSL) String() string

type JobExecution 

type JobExecution struct {
	ID          int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	JobID       int64                  `protobuf:"varint,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status      Status                 `protobuf:"varint,3,opt,name=status,proto3,enum=Status" json:"status,omitempty"`
	Steps       []*StepExecution       `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps,omitempty"`
	StartedAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	Reason      *Reason                `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*JobExecution) Descriptor deprecated 

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

Deprecated: Use JobExecution.ProtoReflect.Descriptor instead.

func (*JobExecution) GetCompletedAt 

func (x *JobExecution) GetCompletedAt() *timestamppb.Timestamp

func (*JobExecution) GetCreatedAt 

func (x *JobExecution) GetCreatedAt() *timestamppb.Timestamp

func (*JobExecution) GetID 

func (x *JobExecution) GetID() int64

func (*JobExecution) GetJobID 

func (x *JobExecution) GetJobID() int64

func (*JobExecution) GetReason 

func (x *JobExecution) GetReason() *Reason

func (*JobExecution) GetStartedAt 

func (x *JobExecution) GetStartedAt() *timestamppb.Timestamp

func (*JobExecution) GetStatus 

func (x *JobExecution) GetStatus() Status

func (*JobExecution) GetSteps 

func (x *JobExecution) GetSteps() []*StepExecution

func (*JobExecution) GetUpdatedAt 

func (x *JobExecution) GetUpdatedAt() *timestamppb.Timestamp

func (*JobExecution) ProtoMessage 

func (*JobExecution) ProtoMessage()

func (*JobExecution) ProtoReflect 

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

func (*JobExecution) Reset 

func (x *JobExecution) Reset()

func (*JobExecution) String 

func (x *JobExecution) String() string

type ListJobExecutionsRequest 

type ListJobExecutionsRequest struct {
	JobID int64 `protobuf:"varint,1,opt,name=JobID,proto3" json:"JobID,omitempty" path:"job_id"`
	// contains filtered or unexported fields
}

func (*ListJobExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListJobExecutionsRequest) GetJobID 

func (x *ListJobExecutionsRequest) GetJobID() int64

func (*ListJobExecutionsRequest) ProtoMessage 

func (*ListJobExecutionsRequest) ProtoMessage()

func (*ListJobExecutionsRequest) ProtoReflect 

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

func (*ListJobExecutionsRequest) Reset 

func (x *ListJobExecutionsRequest) Reset()

func (*ListJobExecutionsRequest) String 

func (x *ListJobExecutionsRequest) String() string

type ListJobExecutionsResponse 

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

func (*ListJobExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListJobExecutionsResponse) GetJobs 

func (x *ListJobExecutionsResponse) GetJobs() []*JobExecution

func (*ListJobExecutionsResponse) ProtoMessage 

func (*ListJobExecutionsResponse) ProtoMessage()

func (*ListJobExecutionsResponse) ProtoReflect 

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

func (*ListJobExecutionsResponse) Reset 

func (x *ListJobExecutionsResponse) Reset()

func (*ListJobExecutionsResponse) String 

func (x *ListJobExecutionsResponse) String() string

type LogLine 

type LogLine struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Number    int64  `protobuf:"varint,2,opt,name=Number,proto3" json:"Number,omitempty"`
	Output    string `protobuf:"bytes,3,opt,name=Output,proto3" json:"Output,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLine) Descriptor deprecated 

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

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) GetNumber 

func (x *LogLine) GetNumber() int64

func (*LogLine) GetOutput 

func (x *LogLine) GetOutput() string

func (*LogLine) GetTimestamp 

func (x *LogLine) GetTimestamp() int64

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect 

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

func (*LogLine) Reset 

func (x *LogLine) Reset()

func (*LogLine) String 

func (x *LogLine) String() string

type Pipeline 

type Pipeline struct {
	ID         int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Jobs       []*Job                 `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Executions []*PipelineExecution   `protobuf:"bytes,3,rep,name=executions,proto3" json:"executions,omitempty"`
	Execution  *PipelineExecution     `protobuf:"bytes,4,opt,name=execution,proto3" json:"execution,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor deprecated 

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCreatedAt 

func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp

func (*Pipeline) GetExecution 

func (x *Pipeline) GetExecution() *PipelineExecution

func (*Pipeline) GetExecutions 

func (x *Pipeline) GetExecutions() []*PipelineExecution

func (*Pipeline) GetID 

func (x *Pipeline) GetID() int64

func (*Pipeline) GetJobs 

func (x *Pipeline) GetJobs() []*Job

func (*Pipeline) GetUpdatedAt 

func (x *Pipeline) GetUpdatedAt() *timestamppb.Timestamp

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoReflect 

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

func (*Pipeline) Reset 

func (x *Pipeline) Reset()

func (*Pipeline) String 

func (x *Pipeline) String() string

type PipelineDSL 

type PipelineDSL struct {
	Jobs []*JobDSL `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty" validate:"required,min=1,max=16,dive"`
	// contains filtered or unexported fields
}

PipelineDSL represents a pipeline definition. It only used to create a pipeline.

func (*PipelineDSL) Descriptor deprecated 

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

Deprecated: Use PipelineDSL.ProtoReflect.Descriptor instead.

func (*PipelineDSL) GetJobs 

func (x *PipelineDSL) GetJobs() []*JobDSL

func (*PipelineDSL) ProtoMessage 

func (*PipelineDSL) ProtoMessage()

func (*PipelineDSL) ProtoReflect 

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

func (*PipelineDSL) Reset 

func (x *PipelineDSL) Reset()

func (*PipelineDSL) String 

func (x *PipelineDSL) String() string

type PipelineExecution 

type PipelineExecution struct {
	Id     int64           `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status Status          `protobuf:"varint,2,opt,name=status,proto3,enum=Status" json:"status,omitempty"`
	Jobs   []*JobExecution `protobuf:"bytes,3,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineExecution) Descriptor deprecated 

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

Deprecated: Use PipelineExecution.ProtoReflect.Descriptor instead.

func (*PipelineExecution) GetId 

func (x *PipelineExecution) GetId() int64

func (*PipelineExecution) GetJobs 

func (x *PipelineExecution) GetJobs() []*JobExecution

func (*PipelineExecution) GetStatus 

func (x *PipelineExecution) GetStatus() Status

func (*PipelineExecution) ProtoMessage 

func (*PipelineExecution) ProtoMessage()

func (*PipelineExecution) ProtoReflect 

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

func (*PipelineExecution) Reset 

func (x *PipelineExecution) Reset()

func (*PipelineExecution) String 

func (x *PipelineExecution) String() string

type Reason 

type Reason struct {
	Reason  FailedReason `protobuf:"varint,1,opt,name=reason,proto3,enum=ReasonType" json:"reason,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Reason) Descriptor deprecated 

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

Deprecated: Use Reason.ProtoReflect.Descriptor instead.

func (*Reason) GetMessage 

func (x *Reason) GetMessage() string

func (*Reason) GetReason 

func (x *Reason) GetReason() FailedReason

func (*Reason) ProtoMessage 

func (*Reason) ProtoMessage()

func (*Reason) ProtoReflect 

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

func (*Reason) Reset 

func (x *Reason) Reset()

func (*Reason) String 

func (x *Reason) String() string

type RequestJobRequest 

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

func (*RequestJobRequest) Descriptor deprecated 

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

Deprecated: Use RequestJobRequest.ProtoReflect.Descriptor instead.

func (*RequestJobRequest) GetLabel 

func (x *RequestJobRequest) GetLabel() string

func (*RequestJobRequest) ProtoMessage 

func (*RequestJobRequest) ProtoMessage()

func (*RequestJobRequest) ProtoReflect 

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

func (*RequestJobRequest) Reset 

func (x *RequestJobRequest) Reset()

func (*RequestJobRequest) String 

func (x *RequestJobRequest) String() string

type RequestJobResponse 

type RequestJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestJobResponse) Descriptor deprecated 

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

Deprecated: Use RequestJobResponse.ProtoReflect.Descriptor instead.

func (*RequestJobResponse) GetJob 

func (x *RequestJobResponse) GetJob() *Job

func (*RequestJobResponse) ProtoMessage 

func (*RequestJobResponse) ProtoMessage()

func (*RequestJobResponse) ProtoReflect 

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

func (*RequestJobResponse) Reset 

func (x *RequestJobResponse) Reset()

func (*RequestJobResponse) String 

func (x *RequestJobResponse) String() string

type RunsOn 

type RunsOn struct {
	Label  string  `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty" validate:"required"`
	Docker *Docker `protobuf:"bytes,2,opt,name=docker,proto3" json:"docker,omitempty"`
	VM     *VM     `protobuf:"bytes,3,opt,name=vm,proto3" json:"vm,omitempty"`
	// contains filtered or unexported fields
}

func (*RunsOn) Descriptor deprecated 

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

Deprecated: Use RunsOn.ProtoReflect.Descriptor instead.

func (*RunsOn) GetDocker 

func (x *RunsOn) GetDocker() *Docker

func (*RunsOn) GetLabel 

func (x *RunsOn) GetLabel() string

func (*RunsOn) GetVM 

func (x *RunsOn) GetVM() *VM

func (*RunsOn) ProtoMessage 

func (*RunsOn) ProtoMessage()

func (*RunsOn) ProtoReflect 

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

func (*RunsOn) Reset 

func (x *RunsOn) Reset()

func (*RunsOn) String 

func (x *RunsOn) String() string

type ServerClient 

type ServerClient interface {
	Ping(ctx context.Context, in *ServerPingRequest, opts ...grpc.CallOption) (*ServerPingResponse, error)
	CreatePipeline(ctx context.Context, in *CreatePipelineRequest, opts ...grpc.CallOption) (*CreatePipelineResponse, error)
	RequestJob(ctx context.Context, in *RequestJobRequest, opts ...grpc.CallOption) (*RequestJobResponse, error)
	GetJobExecution(ctx context.Context, in *GetJobExecutionRequest, opts ...grpc.CallOption) (*GetJobExecutionResponse, error)
	CancelJobExecution(ctx context.Context, in *CancelJobExecutionRequest, opts ...grpc.CallOption) (*CancelJobExecutionResponse, error)
	ListJobExecutions(ctx context.Context, in *ListJobExecutionsRequest, opts ...grpc.CallOption) (*ListJobExecutionsResponse, error)
	UpdateJobExecution(ctx context.Context, in *UpdateJobExecutionRequest, opts ...grpc.CallOption) (*UpdateJobExecutionResponse, error)
	GetStepExecution(ctx context.Context, in *GetStepExecutionRequest, opts ...grpc.CallOption) (*GetStepExecutionResponse, error)
	UpdateStepExecution(ctx context.Context, in *UpdateStepExecutionRequest, opts ...grpc.CallOption) (*UpdateStepExecutionResponse, error)
	UploadLogLines(ctx context.Context, in *UpdateLogLinesRequest, opts ...grpc.CallOption) (*UpdateLogLinesResponse, error)
	GetLogLines(ctx context.Context, in *GetLogLinesRequest, opts ...grpc.CallOption) (*GetLogLinesResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
}

ServerClient is the client API for Server 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 NewServerClient 

func NewServerClient(cc grpc.ClientConnInterface) ServerClient

type ServerPingRequest 

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

func (*ServerPingRequest) Descriptor deprecated 

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

Deprecated: Use ServerPingRequest.ProtoReflect.Descriptor instead.

func (*ServerPingRequest) ProtoMessage 

func (*ServerPingRequest) ProtoMessage()

func (*ServerPingRequest) ProtoReflect 

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

func (*ServerPingRequest) Reset 

func (x *ServerPingRequest) Reset()

func (*ServerPingRequest) String 

func (x *ServerPingRequest) String() string

type ServerPingResponse 

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

func (*ServerPingResponse) Descriptor deprecated 

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

Deprecated: Use ServerPingResponse.ProtoReflect.Descriptor instead.

func (*ServerPingResponse) ProtoMessage 

func (*ServerPingResponse) ProtoMessage()

func (*ServerPingResponse) ProtoReflect 

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

func (*ServerPingResponse) Reset 

func (x *ServerPingResponse) Reset()

func (*ServerPingResponse) String 

func (x *ServerPingResponse) String() string

type ServerServer 

type ServerServer interface {
	Ping(context.Context, *ServerPingRequest) (*ServerPingResponse, error)
	CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)
	RequestJob(context.Context, *RequestJobRequest) (*RequestJobResponse, error)
	GetJobExecution(context.Context, *GetJobExecutionRequest) (*GetJobExecutionResponse, error)
	CancelJobExecution(context.Context, *CancelJobExecutionRequest) (*CancelJobExecutionResponse, error)
	ListJobExecutions(context.Context, *ListJobExecutionsRequest) (*ListJobExecutionsResponse, error)
	UpdateJobExecution(context.Context, *UpdateJobExecutionRequest) (*UpdateJobExecutionResponse, error)
	GetStepExecution(context.Context, *GetStepExecutionRequest) (*GetStepExecutionResponse, error)
	UpdateStepExecution(context.Context, *UpdateStepExecutionRequest) (*UpdateStepExecutionResponse, error)
	UploadLogLines(context.Context, *UpdateLogLinesRequest) (*UpdateLogLinesResponse, error)
	GetLogLines(context.Context, *GetLogLinesRequest) (*GetLogLinesResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// contains filtered or unexported methods
}

ServerServer is the server API for Server service. All implementations must embed UnimplementedServerServer for forward compatibility

type Status 

type Status int32

Status represents the status of a step. 

const (
	UnknownStatus   Status = 0
	StatusCreated   Status = 1
	StatusQueued    Status = 2
	StatusPreparing Status = 24
	StatusRunning   Status = 25
	StatusCanceling Status = 26
	StatusFailed    Status = 50
	StatusSkipped   Status = 51
	StatusSucceeded Status = 52
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) IsCompleted 

func (s Status) IsCompleted() bool

IsCompleted returns true if the status is completed.

func (Status) IsPreDispatch 

func (s Status) IsPreDispatch() bool

IsPreDispatch returns true if the status is before dispatching.

func (Status) IsRunning 

func (s Status) IsRunning() bool

IsRunning returns true if the status is dispatched to agent.

func (Status) MarshalJSON 

func (s Status) MarshalJSON() ([]byte, error)

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) ToString 

func (s Status) ToString() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

func (*Status) UnmarshalJSON 

func (s *Status) UnmarshalJSON(bytes []byte) error

type Step 

type Step struct {
	ID               int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PipelineID       int64                  `protobuf:"varint,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	JobID            int64                  `protobuf:"varint,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Name             string                 `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	WorkingDirectory string                 `protobuf:"bytes,5,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
	User             string                 `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"`
	Container        string                 `protobuf:"bytes,7,opt,name=container,proto3" json:"container,omitempty"`
	DependsOn        []string               `protobuf:"bytes,8,rep,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
	Commands         []string               `protobuf:"bytes,9,rep,name=commands,proto3" json:"commands,omitempty"`
	EnvVar           map[string]string      `` /* 168-byte string literal not displayed */
	Executions       []*StepExecution       `protobuf:"bytes,11,rep,name=executions,proto3" json:"executions,omitempty"`
	Execution        *StepExecution         `protobuf:"bytes,12,opt,name=execution,proto3" json:"execution,omitempty"`
	If               string                 `protobuf:"bytes,13,opt,name=if,proto3" json:"if,omitempty"`
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt        *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Step) Descriptor deprecated 

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

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetCommands 

func (x *Step) GetCommands() []string

func (*Step) GetContainer 

func (x *Step) GetContainer() string

func (*Step) GetCreatedAt 

func (x *Step) GetCreatedAt() *timestamppb.Timestamp

func (*Step) GetDependsOn 

func (x *Step) GetDependsOn() []string

func (*Step) GetEnvVar 

func (x *Step) GetEnvVar() map[string]string

func (*Step) GetExecution 

func (x *Step) GetExecution() *StepExecution

func (*Step) GetExecutions 

func (x *Step) GetExecutions() []*StepExecution

func (*Step) GetID 

func (x *Step) GetID() int64

func (*Step) GetIf 

func (x *Step) GetIf() string

func (*Step) GetJobID 

func (x *Step) GetJobID() int64

func (*Step) GetName 

func (x *Step) GetName() string

func (*Step) GetPipelineID 

func (x *Step) GetPipelineID() int64

func (*Step) GetUpdatedAt 

func (x *Step) GetUpdatedAt() *timestamppb.Timestamp

func (*Step) GetUser 

func (x *Step) GetUser() string

func (*Step) GetWorkingDirectory 

func (x *Step) GetWorkingDirectory() string

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) ProtoReflect 

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

func (*Step) Reset 

func (x *Step) Reset()

func (*Step) String 

func (x *Step) String() string

type StepDSL 

type StepDSL struct {
	Name             string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" validate:"required"`
	WorkingDirectory string   `protobuf:"bytes,5,opt,name=working_directory,json=workingDirectory,proto3" json:"working_directory,omitempty"`
	User             string   `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"`
	Container        string   `protobuf:"bytes,7,opt,name=container,proto3" json:"container,omitempty"`
	DependsOn        []string `protobuf:"bytes,8,rep,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`

	Commands []string          `protobuf:"bytes,9,rep,name=commands,proto3" json:"commands,omitempty" validate:"required,min=1,max=32,dive"`
	EnvVar   map[string]string `` /* 168-byte string literal not displayed */
	If       string            `protobuf:"bytes,11,opt,name=if,proto3" json:"if,omitempty"`
	// contains filtered or unexported fields
}

StepDSL represents a step definition. It only used to create a step.

func (*StepDSL) Descriptor deprecated 

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

Deprecated: Use StepDSL.ProtoReflect.Descriptor instead.

func (*StepDSL) GetCommands 

func (x *StepDSL) GetCommands() []string

func (*StepDSL) GetContainer 

func (x *StepDSL) GetContainer() string

func (*StepDSL) GetDependsOn 

func (x *StepDSL) GetDependsOn() []string

func (*StepDSL) GetEnvVar 

func (x *StepDSL) GetEnvVar() map[string]string

func (*StepDSL) GetIf 

func (x *StepDSL) GetIf() string

func (*StepDSL) GetName 

func (x *StepDSL) GetName() string

func (*StepDSL) GetUser 

func (x *StepDSL) GetUser() string

func (*StepDSL) GetWorkingDirectory 

func (x *StepDSL) GetWorkingDirectory() string

func (*StepDSL) ProtoMessage 

func (*StepDSL) ProtoMessage()

func (*StepDSL) ProtoReflect 

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

func (*StepDSL) Reset 

func (x *StepDSL) Reset()

func (*StepDSL) String 

func (x *StepDSL) String() string

type StepExecution 

type StepExecution struct {
	ID             int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	JobExecutionID int64                  `protobuf:"varint,2,opt,name=job_execution_id,json=jobExecutionId,proto3" json:"job_execution_id,omitempty"`
	StepID         int64                  `protobuf:"varint,3,opt,name=step_id,json=stepId,proto3" json:"step_id,omitempty"`
	Status         Status                 `protobuf:"varint,4,opt,name=status,proto3,enum=Status" json:"status,omitempty"`
	ExitCode       uint32                 `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	StartedAt      *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	CreatedAt      *timestamppb.Timestamp `protobuf:"bytes,101,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt      *timestamppb.Timestamp `protobuf:"bytes,102,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StepExecution) Descriptor deprecated 

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

Deprecated: Use StepExecution.ProtoReflect.Descriptor instead.

func (*StepExecution) GetCompletedAt 

func (x *StepExecution) GetCompletedAt() *timestamppb.Timestamp

func (*StepExecution) GetCreatedAt 

func (x *StepExecution) GetCreatedAt() *timestamppb.Timestamp

func (*StepExecution) GetExitCode 

func (x *StepExecution) GetExitCode() uint32

func (*StepExecution) GetID 

func (x *StepExecution) GetID() int64

func (*StepExecution) GetJobExecutionID 

func (x *StepExecution) GetJobExecutionID() int64

func (*StepExecution) GetStartedAt 

func (x *StepExecution) GetStartedAt() *timestamppb.Timestamp

func (*StepExecution) GetStatus 

func (x *StepExecution) GetStatus() Status

func (*StepExecution) GetStepID 

func (x *StepExecution) GetStepID() int64

func (*StepExecution) GetUpdatedAt 

func (x *StepExecution) GetUpdatedAt() *timestamppb.Timestamp

func (*StepExecution) ProtoMessage 

func (*StepExecution) ProtoMessage()

func (*StepExecution) ProtoReflect 

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

func (*StepExecution) Reset 

func (x *StepExecution) Reset()

func (*StepExecution) String 

func (x *StepExecution) String() string

type Time 

type Time interface {
	time.Time | *time.Time
}

type UnimplementedServerServer 

type UnimplementedServerServer struct {
}

UnimplementedServerServer must be embedded to have forward compatible implementations.

func (UnimplementedServerServer) CancelJobExecution 

func (UnimplementedServerServer) CancelJobExecution(context.Context, *CancelJobExecutionRequest) (*CancelJobExecutionResponse, error)

func (UnimplementedServerServer) CreatePipeline 

func (UnimplementedServerServer) CreatePipeline(context.Context, *CreatePipelineRequest) (*CreatePipelineResponse, error)

func (UnimplementedServerServer) GetJobExecution 

func (UnimplementedServerServer) GetJobExecution(context.Context, *GetJobExecutionRequest) (*GetJobExecutionResponse, error)

func (UnimplementedServerServer) GetLogLines 

func (UnimplementedServerServer) GetLogLines(context.Context, *GetLogLinesRequest) (*GetLogLinesResponse, error)

func (UnimplementedServerServer) GetStepExecution 

func (UnimplementedServerServer) GetStepExecution(context.Context, *GetStepExecutionRequest) (*GetStepExecutionResponse, error)

func (UnimplementedServerServer) Heartbeat 

func (UnimplementedServerServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedServerServer) ListJobExecutions 

func (UnimplementedServerServer) ListJobExecutions(context.Context, *ListJobExecutionsRequest) (*ListJobExecutionsResponse, error)

func (UnimplementedServerServer) Ping 

func (UnimplementedServerServer) Ping(context.Context, *ServerPingRequest) (*ServerPingResponse, error)

func (UnimplementedServerServer) RequestJob 

func (UnimplementedServerServer) RequestJob(context.Context, *RequestJobRequest) (*RequestJobResponse, error)

func (UnimplementedServerServer) UpdateJobExecution 

func (UnimplementedServerServer) UpdateJobExecution(context.Context, *UpdateJobExecutionRequest) (*UpdateJobExecutionResponse, error)

func (UnimplementedServerServer) UpdateStepExecution 

func (UnimplementedServerServer) UpdateStepExecution(context.Context, *UpdateStepExecutionRequest) (*UpdateStepExecutionResponse, error)

func (UnimplementedServerServer) UploadLogLines 

func (UnimplementedServerServer) UploadLogLines(context.Context, *UpdateLogLinesRequest) (*UpdateLogLinesResponse, error)

type UnsafeServerServer 

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

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

type UpdateJobExecutionRequest 

type UpdateJobExecutionRequest struct {
	JobExecutionID int64   `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty" path:"job_execution_id"`
	Status         *Status `protobuf:"varint,3,opt,name=status,proto3,enum=Status,oneof" json:"status,omitempty"`
	Reason         *Reason `protobuf:"bytes,4,opt,name=reason,proto3,oneof" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateJobExecutionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateJobExecutionRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobExecutionRequest) GetJobExecutionID 

func (x *UpdateJobExecutionRequest) GetJobExecutionID() int64

func (*UpdateJobExecutionRequest) GetReason 

func (x *UpdateJobExecutionRequest) GetReason() *Reason

func (*UpdateJobExecutionRequest) GetStatus 

func (x *UpdateJobExecutionRequest) GetStatus() Status

func (*UpdateJobExecutionRequest) ProtoMessage 

func (*UpdateJobExecutionRequest) ProtoMessage()

func (*UpdateJobExecutionRequest) ProtoReflect 

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

func (*UpdateJobExecutionRequest) Reset 

func (x *UpdateJobExecutionRequest) Reset()

func (*UpdateJobExecutionRequest) String 

func (x *UpdateJobExecutionRequest) String() string

type UpdateJobExecutionResponse 

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

func (*UpdateJobExecutionResponse) Descriptor deprecated 

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

Deprecated: Use UpdateJobExecutionResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobExecutionResponse) GetJobExecution 

func (x *UpdateJobExecutionResponse) GetJobExecution() *JobExecution

func (*UpdateJobExecutionResponse) ProtoMessage 

func (*UpdateJobExecutionResponse) ProtoMessage()

func (*UpdateJobExecutionResponse) ProtoReflect 

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

func (*UpdateJobExecutionResponse) Reset 

func (x *UpdateJobExecutionResponse) Reset()

func (*UpdateJobExecutionResponse) String 

func (x *UpdateJobExecutionResponse) String() string

type UpdateLogLinesRequest 

type UpdateLogLinesRequest struct {
	JobExecutionID int64      `protobuf:"varint,1,opt,name=JobExecutionID,proto3" json:"JobExecutionID,omitempty" path:"job_execution_id"`
	Name           string     `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Lines          []*LogLine `protobuf:"bytes,3,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLogLinesRequest) Descriptor deprecated 

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

Deprecated: Use UpdateLogLinesRequest.ProtoReflect.Descriptor instead.

func (*UpdateLogLinesRequest) GetJobExecutionID 

func (x *UpdateLogLinesRequest) GetJobExecutionID() int64

func (*UpdateLogLinesRequest) GetLines 

func (x *UpdateLogLinesRequest) GetLines() []*LogLine

func (*UpdateLogLinesRequest) GetName 

func (x *UpdateLogLinesRequest) GetName() string

func (*UpdateLogLinesRequest) ProtoMessage 

func (*UpdateLogLinesRequest) ProtoMessage()

func (*UpdateLogLinesRequest) ProtoReflect 

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

func (*UpdateLogLinesRequest) Reset 

func (x *UpdateLogLinesRequest) Reset()

func (*UpdateLogLinesRequest) String 

func (x *UpdateLogLinesRequest) String() string

type UpdateLogLinesResponse 

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

func (*UpdateLogLinesResponse) Descriptor deprecated 

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

Deprecated: Use UpdateLogLinesResponse.ProtoReflect.Descriptor instead.

func (*UpdateLogLinesResponse) ProtoMessage 

func (*UpdateLogLinesResponse) ProtoMessage()

func (*UpdateLogLinesResponse) ProtoReflect 

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

func (*UpdateLogLinesResponse) Reset 

func (x *UpdateLogLinesResponse) Reset()

func (*UpdateLogLinesResponse) String 

func (x *UpdateLogLinesResponse) String() string

type UpdateStepExecutionRequest 

type UpdateStepExecutionRequest struct {
	StepExecutionID int64   `protobuf:"varint,1,opt,name=StepExecutionID,proto3" json:"StepExecutionID,omitempty" path:"step_execution_id"`
	Status          *Status `protobuf:"varint,2,opt,name=status,proto3,enum=Status,oneof" json:"status,omitempty"`
	ExitCode        *uint32 `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStepExecutionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateStepExecutionRequest.ProtoReflect.Descriptor instead.

func (*UpdateStepExecutionRequest) GetExitCode 

func (x *UpdateStepExecutionRequest) GetExitCode() uint32

func (*UpdateStepExecutionRequest) GetStatus 

func (x *UpdateStepExecutionRequest) GetStatus() Status

func (*UpdateStepExecutionRequest) GetStepExecutionID 

func (x *UpdateStepExecutionRequest) GetStepExecutionID() int64

func (*UpdateStepExecutionRequest) ProtoMessage 

func (*UpdateStepExecutionRequest) ProtoMessage()

func (*UpdateStepExecutionRequest) ProtoReflect 

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

func (*UpdateStepExecutionRequest) Reset 

func (x *UpdateStepExecutionRequest) Reset()

func (*UpdateStepExecutionRequest) String 

func (x *UpdateStepExecutionRequest) String() string

type UpdateStepExecutionResponse 

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

func (*UpdateStepExecutionResponse) Descriptor deprecated 

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

Deprecated: Use UpdateStepExecutionResponse.ProtoReflect.Descriptor instead.

func (*UpdateStepExecutionResponse) GetStepExecution 

func (x *UpdateStepExecutionResponse) GetStepExecution() *StepExecution

func (*UpdateStepExecutionResponse) ProtoMessage 

func (*UpdateStepExecutionResponse) ProtoMessage()

func (*UpdateStepExecutionResponse) ProtoReflect 

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

func (*UpdateStepExecutionResponse) Reset 

func (x *UpdateStepExecutionResponse) Reset()

func (*UpdateStepExecutionResponse) String 

func (x *UpdateStepExecutionResponse) String() string

type VM 

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

func (*VM) Descriptor deprecated 

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

Deprecated: Use VM.ProtoReflect.Descriptor instead.

func (*VM) GetImage 

func (x *VM) GetImage() string

func (*VM) ProtoMessage 

func (*VM) ProtoMessage()

func (*VM) ProtoReflect 

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

func (*VM) Reset 

func (x *VM) Reset()

func (*VM) String 

func (x *VM) String() string

type Volume 

type Volume struct {
	Name     string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	HostPath *HostPathVolumeSource `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3" json:"host_path,omitempty"`
	EmptyDir *EmptyDirVolumeSource `protobuf:"bytes,3,opt,name=empty_dir,json=emptyDir,proto3" json:"empty_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetEmptyDir 

func (x *Volume) GetEmptyDir() *EmptyDirVolumeSource

func (*Volume) GetHostPath 

func (x *Volume) GetHostPath() *HostPathVolumeSource

func (*Volume) GetName 

func (x *Volume) GetName() string

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

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

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type VolumeMount 

type VolumeMount struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ReadOnly  bool   `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	MountPath string `protobuf:"bytes,3,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMount) Descriptor deprecated 

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

Deprecated: Use VolumeMount.ProtoReflect.Descriptor instead.

func (*VolumeMount) GetMountPath 

func (x *VolumeMount) GetMountPath() string

func (*VolumeMount) GetName 

func (x *VolumeMount) GetName() string

func (*VolumeMount) GetReadOnly 

func (x *VolumeMount) GetReadOnly() bool

func (*VolumeMount) ProtoMessage 

func (*VolumeMount) ProtoMessage()

func (*VolumeMount) ProtoReflect 

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

func (*VolumeMount) Reset 

func (x *VolumeMount) Reset()

func (*VolumeMount) String 

func (x *VolumeMount) String() string

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.