definition

package
v0.0.0-...-3c34c2e Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Name = "scheduler.v1"
)

Variables

View Source
var File_integrations_scheduler_v1_definition_batchjob_proto protoreflect.FileDescriptor
View Source
var File_integrations_scheduler_v1_definition_common_proto protoreflect.FileDescriptor
View Source
var File_integrations_scheduler_v1_definition_cronjob_proto protoreflect.FileDescriptor
View Source
var File_integrations_scheduler_v1_definition_definition_proto protoreflect.FileDescriptor
View Source
var File_integrations_scheduler_v1_definition_deployment_proto protoreflect.FileDescriptor
View Source
var SchedulerV1_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "scheduler.SchedulerV1",
	HandlerType: (*SchedulerV1Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBatchJob",
			Handler:    _SchedulerV1_CreateBatchJob_Handler,
		},
		{
			MethodName: "GetBatchJob",
			Handler:    _SchedulerV1_GetBatchJob_Handler,
		},
		{
			MethodName: "ListBatchJob",
			Handler:    _SchedulerV1_ListBatchJob_Handler,
		},
		{
			MethodName: "DeleteBatchJob",
			Handler:    _SchedulerV1_DeleteBatchJob_Handler,
		},
		{
			MethodName: "CreateCronJob",
			Handler:    _SchedulerV1_CreateCronJob_Handler,
		},
		{
			MethodName: "GetCronJob",
			Handler:    _SchedulerV1_GetCronJob_Handler,
		},
		{
			MethodName: "UpdateCronJob",
			Handler:    _SchedulerV1_UpdateCronJob_Handler,
		},
		{
			MethodName: "ListCronJob",
			Handler:    _SchedulerV1_ListCronJob_Handler,
		},
		{
			MethodName: "DeleteCronJob",
			Handler:    _SchedulerV1_DeleteCronJob_Handler,
		},
		{
			MethodName: "CreateDeployment",
			Handler:    _SchedulerV1_CreateDeployment_Handler,
		},
		{
			MethodName: "GetDeployment",
			Handler:    _SchedulerV1_GetDeployment_Handler,
		},
		{
			MethodName: "UpdateDeployment",
			Handler:    _SchedulerV1_UpdateDeployment_Handler,
		},
		{
			MethodName: "ListDeployment",
			Handler:    _SchedulerV1_ListDeployment_Handler,
		},
		{
			MethodName: "DeleteDeployment",
			Handler:    _SchedulerV1_DeleteDeployment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "integrations/scheduler/v1/definition/definition.proto",
}

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

Functions

func RegisterSchedulerV1Server

func RegisterSchedulerV1Server(s grpc.ServiceRegistrar, srv SchedulerV1Server)

Types

type BatchJob

type BatchJob struct {

	// defines object status metadate
	Metadata *StatusMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Keeps BatchJob settings
	Spec *BatchJobSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Keeps current BatchJob Status
	Status *BatchJobStatus `protobuf:"bytes,3,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Keeps information about Kubernetes Batch/V1 Job

func (*BatchJob) Descriptor deprecated

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetMetadata

func (x *BatchJob) GetMetadata() *StatusMetadata

func (*BatchJob) GetSpec

func (x *BatchJob) GetSpec() *BatchJobSpec

func (*BatchJob) GetStatus

func (x *BatchJob) GetStatus() *BatchJobStatus

func (*BatchJob) ProtoMessage

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect

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

func (*BatchJob) Reset

func (x *BatchJob) Reset()

func (*BatchJob) String

func (x *BatchJob) String() string

type BatchJobSpec

type BatchJobSpec struct {

	// Number of concurrent Pods which are started within a job. Defaults to 1
	Parallelism *int32 `protobuf:"varint,1,opt,name=parallelism,proto3,oneof" json:"parallelism,omitempty"`
	// Number of expected completed runs. Defaults to 1
	Completions *int32 `protobuf:"varint,2,opt,name=completions,proto3,oneof" json:"completions,omitempty"`
	// Number of allowed Pod failures. Defaults to 0
	BackoffLimit *int32 `protobuf:"varint,3,opt,name=backoff_limit,json=backoffLimit,proto3,oneof" json:"backoff_limit,omitempty"`
	// contains filtered or unexported fields
}

Information about BatchJob run settings, like completions and parallelism

func (*BatchJobSpec) Descriptor deprecated

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

Deprecated: Use BatchJobSpec.ProtoReflect.Descriptor instead.

func (*BatchJobSpec) GetBackoffLimit

func (x *BatchJobSpec) GetBackoffLimit() int32

func (*BatchJobSpec) GetCompletions

func (x *BatchJobSpec) GetCompletions() int32

func (*BatchJobSpec) GetParallelism

func (x *BatchJobSpec) GetParallelism() int32

func (*BatchJobSpec) ProtoMessage

func (*BatchJobSpec) ProtoMessage()

func (*BatchJobSpec) ProtoReflect

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

func (*BatchJobSpec) Reset

func (x *BatchJobSpec) Reset()

func (*BatchJobSpec) String

func (x *BatchJobSpec) String() string

type BatchJobStatus

type BatchJobStatus struct {

	// Number of active and running Pods within BatchJob
	Active int32 `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	// Number of completed Pods withing BatchJob
	Succeeded int32 `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// Number of failed Pods within BatchJob
	Failed int32 `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

Information about BatchJob Status

func (*BatchJobStatus) Descriptor deprecated

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

Deprecated: Use BatchJobStatus.ProtoReflect.Descriptor instead.

func (*BatchJobStatus) GetActive

func (x *BatchJobStatus) GetActive() int32

func (*BatchJobStatus) GetFailed

func (x *BatchJobStatus) GetFailed() int32

func (*BatchJobStatus) GetSucceeded

func (x *BatchJobStatus) GetSucceeded() int32

func (*BatchJobStatus) ProtoMessage

func (*BatchJobStatus) ProtoMessage()

func (*BatchJobStatus) ProtoReflect

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

func (*BatchJobStatus) Reset

func (x *BatchJobStatus) Reset()

func (*BatchJobStatus) String

func (x *BatchJobStatus) String() string

type ContainerBase

type ContainerBase struct {

	// Container Image used to run container
	Image *string `protobuf:"bytes,1,opt,name=image,proto3,oneof" json:"image,omitempty"`
	// Arguments passed to the container
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// EnvironmentVariables passed to the container
	EnvironmentVariables map[string]string `` /* 209-byte string literal not displayed */
	// contains filtered or unexported fields
}

Basic information about container

func (*ContainerBase) Descriptor deprecated

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

Deprecated: Use ContainerBase.ProtoReflect.Descriptor instead.

func (*ContainerBase) GetArgs

func (x *ContainerBase) GetArgs() []string

func (*ContainerBase) GetEnvironmentVariables

func (x *ContainerBase) GetEnvironmentVariables() map[string]string

func (*ContainerBase) GetImage

func (x *ContainerBase) GetImage() string

func (*ContainerBase) ProtoMessage

func (*ContainerBase) ProtoMessage()

func (*ContainerBase) ProtoReflect

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

func (*ContainerBase) Reset

func (x *ContainerBase) Reset()

func (*ContainerBase) String

func (x *ContainerBase) String() string

type CreateBatchJobRequest

type CreateBatchJobRequest struct {

	// Spec of the Schedule request
	Spec *Spec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// BatchJob run settings
	BatchJob *BatchJobSpec `protobuf:"bytes,2,opt,name=batch_job,json=batchJob,proto3" json:"batch_job,omitempty"`
	// contains filtered or unexported fields
}

Create Request

func (*CreateBatchJobRequest) Descriptor deprecated

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

Deprecated: Use CreateBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchJobRequest) GetBatchJob

func (x *CreateBatchJobRequest) GetBatchJob() *BatchJobSpec

func (*CreateBatchJobRequest) GetSpec

func (x *CreateBatchJobRequest) GetSpec() *Spec

func (*CreateBatchJobRequest) ProtoMessage

func (*CreateBatchJobRequest) ProtoMessage()

func (*CreateBatchJobRequest) ProtoReflect

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

func (*CreateBatchJobRequest) Reset

func (x *CreateBatchJobRequest) Reset()

func (*CreateBatchJobRequest) String

func (x *CreateBatchJobRequest) String() string

type CreateBatchJobResponse

type CreateBatchJobResponse struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Create Response

func (*CreateBatchJobResponse) Descriptor deprecated

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

Deprecated: Use CreateBatchJobResponse.ProtoReflect.Descriptor instead.

func (*CreateBatchJobResponse) GetName

func (x *CreateBatchJobResponse) GetName() string

func (*CreateBatchJobResponse) ProtoMessage

func (*CreateBatchJobResponse) ProtoMessage()

func (*CreateBatchJobResponse) ProtoReflect

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

func (*CreateBatchJobResponse) Reset

func (x *CreateBatchJobResponse) Reset()

func (*CreateBatchJobResponse) String

func (x *CreateBatchJobResponse) String() string

type CreateCronJobRequest

type CreateCronJobRequest struct {

	// Spec of the Schedule request
	Spec *Spec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// CronJob run settings
	CronJob *CronJobSpec `protobuf:"bytes,2,opt,name=cron_job,json=cronJob,proto3" json:"cron_job,omitempty"`
	// contains filtered or unexported fields
}

Create Request

func (*CreateCronJobRequest) Descriptor deprecated

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

Deprecated: Use CreateCronJobRequest.ProtoReflect.Descriptor instead.

func (*CreateCronJobRequest) GetCronJob

func (x *CreateCronJobRequest) GetCronJob() *CronJobSpec

func (*CreateCronJobRequest) GetSpec

func (x *CreateCronJobRequest) GetSpec() *Spec

func (*CreateCronJobRequest) ProtoMessage

func (*CreateCronJobRequest) ProtoMessage()

func (*CreateCronJobRequest) ProtoReflect

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

func (*CreateCronJobRequest) Reset

func (x *CreateCronJobRequest) Reset()

func (*CreateCronJobRequest) String

func (x *CreateCronJobRequest) String() string

type CreateCronJobResponse

type CreateCronJobResponse struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Create Response

func (*CreateCronJobResponse) Descriptor deprecated

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

Deprecated: Use CreateCronJobResponse.ProtoReflect.Descriptor instead.

func (*CreateCronJobResponse) GetName

func (x *CreateCronJobResponse) GetName() string

func (*CreateCronJobResponse) ProtoMessage

func (*CreateCronJobResponse) ProtoMessage()

func (*CreateCronJobResponse) ProtoReflect

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

func (*CreateCronJobResponse) Reset

func (x *CreateCronJobResponse) Reset()

func (*CreateCronJobResponse) String

func (x *CreateCronJobResponse) String() string

type CreateDeploymentRequest

type CreateDeploymentRequest struct {

	// Spec of the Schedule request
	Spec *Spec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// Deployment run settings
	Deployment *DeploymentSpec `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

Create Request

func (*CreateDeploymentRequest) Descriptor deprecated

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

Deprecated: Use CreateDeploymentRequest.ProtoReflect.Descriptor instead.

func (*CreateDeploymentRequest) GetDeployment

func (x *CreateDeploymentRequest) GetDeployment() *DeploymentSpec

func (*CreateDeploymentRequest) GetSpec

func (x *CreateDeploymentRequest) GetSpec() *Spec

func (*CreateDeploymentRequest) ProtoMessage

func (*CreateDeploymentRequest) ProtoMessage()

func (*CreateDeploymentRequest) ProtoReflect

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

func (*CreateDeploymentRequest) Reset

func (x *CreateDeploymentRequest) Reset()

func (*CreateDeploymentRequest) String

func (x *CreateDeploymentRequest) String() string

type CreateDeploymentResponse

type CreateDeploymentResponse struct {

	// Name of the scheduled deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Create Response

func (*CreateDeploymentResponse) Descriptor deprecated

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

Deprecated: Use CreateDeploymentResponse.ProtoReflect.Descriptor instead.

func (*CreateDeploymentResponse) GetName

func (x *CreateDeploymentResponse) GetName() string

func (*CreateDeploymentResponse) ProtoMessage

func (*CreateDeploymentResponse) ProtoMessage()

func (*CreateDeploymentResponse) ProtoReflect

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

func (*CreateDeploymentResponse) Reset

func (x *CreateDeploymentResponse) Reset()

func (*CreateDeploymentResponse) String

func (x *CreateDeploymentResponse) String() string

type CronJob

type CronJob struct {

	// defines object status metadate
	Metadata *StatusMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Keeps the CronJob Settings
	Spec *CronJobSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Keeps the CronJob Status
	Status *CronJobStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Keeps information about Kubernetes Batch/V1 CronJob

func (*CronJob) Descriptor deprecated

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

Deprecated: Use CronJob.ProtoReflect.Descriptor instead.

func (*CronJob) GetMetadata

func (x *CronJob) GetMetadata() *StatusMetadata

func (*CronJob) GetSpec

func (x *CronJob) GetSpec() *CronJobSpec

func (*CronJob) GetStatus

func (x *CronJob) GetStatus() *CronJobStatus

func (*CronJob) ProtoMessage

func (*CronJob) ProtoMessage()

func (*CronJob) ProtoReflect

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

func (*CronJob) Reset

func (x *CronJob) Reset()

func (*CronJob) String

func (x *CronJob) String() string

type CronJobSpec

type CronJobSpec struct {

	// Schedule definition
	Schedule string `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// Keeps BatchJob settings
	Job *BatchJobSpec `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

Information about CronJob run settings

func (*CronJobSpec) Descriptor deprecated

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

Deprecated: Use CronJobSpec.ProtoReflect.Descriptor instead.

func (*CronJobSpec) GetJob

func (x *CronJobSpec) GetJob() *BatchJobSpec

func (*CronJobSpec) GetSchedule

func (x *CronJobSpec) GetSchedule() string

func (*CronJobSpec) ProtoMessage

func (*CronJobSpec) ProtoMessage()

func (*CronJobSpec) ProtoReflect

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

func (*CronJobSpec) Reset

func (x *CronJobSpec) Reset()

func (*CronJobSpec) String

func (x *CronJobSpec) String() string

type CronJobStatus

type CronJobStatus struct {

	// Keeps list of created BatchJobs
	BatchJobs []string `protobuf:"bytes,1,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,omitempty"`
	// contains filtered or unexported fields
}

Information about CronJob Status

func (*CronJobStatus) Descriptor deprecated

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

Deprecated: Use CronJobStatus.ProtoReflect.Descriptor instead.

func (*CronJobStatus) GetBatchJobs

func (x *CronJobStatus) GetBatchJobs() []string

func (*CronJobStatus) ProtoMessage

func (*CronJobStatus) ProtoMessage()

func (*CronJobStatus) ProtoReflect

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

func (*CronJobStatus) Reset

func (x *CronJobStatus) Reset()

func (*CronJobStatus) String

func (x *CronJobStatus) String() string

type DeleteBatchJobRequest

type DeleteBatchJobRequest struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Defines if all child containers/pods should be removed together with job
	DeleteChildPods *bool `protobuf:"varint,2,opt,name=delete_child_pods,json=deleteChildPods,proto3,oneof" json:"delete_child_pods,omitempty"`
	// contains filtered or unexported fields
}

Delete Request

func (*DeleteBatchJobRequest) Descriptor deprecated

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

Deprecated: Use DeleteBatchJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobRequest) GetDeleteChildPods

func (x *DeleteBatchJobRequest) GetDeleteChildPods() bool

func (*DeleteBatchJobRequest) GetName

func (x *DeleteBatchJobRequest) GetName() string

func (*DeleteBatchJobRequest) ProtoMessage

func (*DeleteBatchJobRequest) ProtoMessage()

func (*DeleteBatchJobRequest) ProtoReflect

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

func (*DeleteBatchJobRequest) Reset

func (x *DeleteBatchJobRequest) Reset()

func (*DeleteBatchJobRequest) String

func (x *DeleteBatchJobRequest) String() string

type DeleteBatchJobResponse

type DeleteBatchJobResponse struct {

	// Defines if job was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

Delete Response

func (*DeleteBatchJobResponse) Descriptor deprecated

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

Deprecated: Use DeleteBatchJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobResponse) GetExists

func (x *DeleteBatchJobResponse) GetExists() bool

func (*DeleteBatchJobResponse) ProtoMessage

func (*DeleteBatchJobResponse) ProtoMessage()

func (*DeleteBatchJobResponse) ProtoReflect

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

func (*DeleteBatchJobResponse) Reset

func (x *DeleteBatchJobResponse) Reset()

func (*DeleteBatchJobResponse) String

func (x *DeleteBatchJobResponse) String() string

type DeleteCronJobRequest

type DeleteCronJobRequest struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Defines if all child containers/pods should be removed together with job
	DeleteChildPods *bool `protobuf:"varint,2,opt,name=delete_child_pods,json=deleteChildPods,proto3,oneof" json:"delete_child_pods,omitempty"`
	// contains filtered or unexported fields
}

Delete Request

func (*DeleteCronJobRequest) Descriptor deprecated

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

Deprecated: Use DeleteCronJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteCronJobRequest) GetDeleteChildPods

func (x *DeleteCronJobRequest) GetDeleteChildPods() bool

func (*DeleteCronJobRequest) GetName

func (x *DeleteCronJobRequest) GetName() string

func (*DeleteCronJobRequest) ProtoMessage

func (*DeleteCronJobRequest) ProtoMessage()

func (*DeleteCronJobRequest) ProtoReflect

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

func (*DeleteCronJobRequest) Reset

func (x *DeleteCronJobRequest) Reset()

func (*DeleteCronJobRequest) String

func (x *DeleteCronJobRequest) String() string

type DeleteCronJobResponse

type DeleteCronJobResponse struct {

	// Defines if job was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

Delete Response

func (*DeleteCronJobResponse) Descriptor deprecated

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

Deprecated: Use DeleteCronJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteCronJobResponse) GetExists

func (x *DeleteCronJobResponse) GetExists() bool

func (*DeleteCronJobResponse) ProtoMessage

func (*DeleteCronJobResponse) ProtoMessage()

func (*DeleteCronJobResponse) ProtoReflect

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

func (*DeleteCronJobResponse) Reset

func (x *DeleteCronJobResponse) Reset()

func (*DeleteCronJobResponse) String

func (x *DeleteCronJobResponse) String() string

type DeleteDeploymentRequest

type DeleteDeploymentRequest struct {

	// Name of the scheduled deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Defines if all child containers/pods should be removed together with deployment
	DeleteChildPods *bool `protobuf:"varint,2,opt,name=delete_child_pods,json=deleteChildPods,proto3,oneof" json:"delete_child_pods,omitempty"`
	// contains filtered or unexported fields
}

Delete Request

func (*DeleteDeploymentRequest) Descriptor deprecated

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

Deprecated: Use DeleteDeploymentRequest.ProtoReflect.Descriptor instead.

func (*DeleteDeploymentRequest) GetDeleteChildPods

func (x *DeleteDeploymentRequest) GetDeleteChildPods() bool

func (*DeleteDeploymentRequest) GetName

func (x *DeleteDeploymentRequest) GetName() string

func (*DeleteDeploymentRequest) ProtoMessage

func (*DeleteDeploymentRequest) ProtoMessage()

func (*DeleteDeploymentRequest) ProtoReflect

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

func (*DeleteDeploymentRequest) Reset

func (x *DeleteDeploymentRequest) Reset()

func (*DeleteDeploymentRequest) String

func (x *DeleteDeploymentRequest) String() string

type DeleteDeploymentResponse

type DeleteDeploymentResponse struct {

	// Defines if deployment was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

Delete Response

func (*DeleteDeploymentResponse) Descriptor deprecated

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

Deprecated: Use DeleteDeploymentResponse.ProtoReflect.Descriptor instead.

func (*DeleteDeploymentResponse) GetExists

func (x *DeleteDeploymentResponse) GetExists() bool

func (*DeleteDeploymentResponse) ProtoMessage

func (*DeleteDeploymentResponse) ProtoMessage()

func (*DeleteDeploymentResponse) ProtoReflect

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

func (*DeleteDeploymentResponse) Reset

func (x *DeleteDeploymentResponse) Reset()

func (*DeleteDeploymentResponse) String

func (x *DeleteDeploymentResponse) String() string

type Deployment

type Deployment struct {

	// defines object status metadate
	Metadata *StatusMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Keeps Deployment settings
	Spec *DeploymentSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Keeps current Deployment Status
	Status *DeploymentStatus `protobuf:"bytes,3,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Keeps information about Kubernetes Batch/V1 Job

func (*Deployment) Descriptor deprecated

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetMetadata

func (x *Deployment) GetMetadata() *StatusMetadata

func (*Deployment) GetSpec

func (x *Deployment) GetSpec() *DeploymentSpec

func (*Deployment) GetStatus

func (x *Deployment) GetStatus() *DeploymentStatus

func (*Deployment) ProtoMessage

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect

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

func (*Deployment) Reset

func (x *Deployment) Reset()

func (*Deployment) String

func (x *Deployment) String() string

type DeploymentSpec

type DeploymentSpec struct {

	// Number of Pods which are started within a deployment. Defaults to 1
	Replicas *int32 `protobuf:"varint,1,opt,name=replicas,proto3,oneof" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

Information about Deployment run settings

func (*DeploymentSpec) Descriptor deprecated

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

Deprecated: Use DeploymentSpec.ProtoReflect.Descriptor instead.

func (*DeploymentSpec) GetReplicas

func (x *DeploymentSpec) GetReplicas() int32

func (*DeploymentSpec) ProtoMessage

func (*DeploymentSpec) ProtoMessage()

func (*DeploymentSpec) ProtoReflect

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

func (*DeploymentSpec) Reset

func (x *DeploymentSpec) Reset()

func (*DeploymentSpec) String

func (x *DeploymentSpec) String() string

type DeploymentStatus

type DeploymentStatus struct {

	// Total number of non-terminated pods targeted by this deployment (their labels match the selector).
	Replicas int32 `protobuf:"varint,1,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// Total number of non-terminated pods targeted by this deployment that have the desired template spec.
	UpdatedReplicas int32 `protobuf:"varint,2,opt,name=updated_replicas,json=updatedReplicas,proto3" json:"updated_replicas,omitempty"`
	// readyReplicas is the number of pods targeted by this Deployment with a Ready Condition.
	ReadyReplicas int32 `protobuf:"varint,3,opt,name=ready_replicas,json=readyReplicas,proto3" json:"ready_replicas,omitempty"`
	// Total number of available pods (ready for at least minReadySeconds) targeted by this deployment.
	AvailableReplicas int32 `protobuf:"varint,4,opt,name=available_replicas,json=availableReplicas,proto3" json:"available_replicas,omitempty"`
	// Total number of unavailable pods targeted by this deployment. This is the total number of
	// pods that are still required for the deployment to have 100% available capacity. They may
	// either be pods that are running but not yet available or pods that still have not been created.
	UnavailableReplicas int32 `protobuf:"varint,5,opt,name=unavailable_replicas,json=unavailableReplicas,proto3" json:"unavailable_replicas,omitempty"`
	// contains filtered or unexported fields
}

Information about Deployment Status

func (*DeploymentStatus) Descriptor deprecated

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

Deprecated: Use DeploymentStatus.ProtoReflect.Descriptor instead.

func (*DeploymentStatus) GetAvailableReplicas

func (x *DeploymentStatus) GetAvailableReplicas() int32

func (*DeploymentStatus) GetReadyReplicas

func (x *DeploymentStatus) GetReadyReplicas() int32

func (*DeploymentStatus) GetReplicas

func (x *DeploymentStatus) GetReplicas() int32

func (*DeploymentStatus) GetUnavailableReplicas

func (x *DeploymentStatus) GetUnavailableReplicas() int32

func (*DeploymentStatus) GetUpdatedReplicas

func (x *DeploymentStatus) GetUpdatedReplicas() int32

func (*DeploymentStatus) ProtoMessage

func (*DeploymentStatus) ProtoMessage()

func (*DeploymentStatus) ProtoReflect

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

func (*DeploymentStatus) Reset

func (x *DeploymentStatus) Reset()

func (*DeploymentStatus) String

func (x *DeploymentStatus) String() string

type GetBatchJobRequest

type GetBatchJobRequest struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get Request

func (*GetBatchJobRequest) Descriptor deprecated

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

Deprecated: Use GetBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetBatchJobRequest) GetName

func (x *GetBatchJobRequest) GetName() string

func (*GetBatchJobRequest) ProtoMessage

func (*GetBatchJobRequest) ProtoMessage()

func (*GetBatchJobRequest) ProtoReflect

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

func (*GetBatchJobRequest) Reset

func (x *GetBatchJobRequest) Reset()

func (*GetBatchJobRequest) String

func (x *GetBatchJobRequest) String() string

type GetBatchJobResponse

type GetBatchJobResponse struct {

	// Defines if job was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// BatchJob run settings and current status
	BatchJob *BatchJob `protobuf:"bytes,2,opt,name=batch_job,json=batchJob,proto3,oneof" json:"batch_job,omitempty"`
	// contains filtered or unexported fields
}

Get Response

func (*GetBatchJobResponse) Descriptor deprecated

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

Deprecated: Use GetBatchJobResponse.ProtoReflect.Descriptor instead.

func (*GetBatchJobResponse) GetBatchJob

func (x *GetBatchJobResponse) GetBatchJob() *BatchJob

func (*GetBatchJobResponse) GetExists

func (x *GetBatchJobResponse) GetExists() bool

func (*GetBatchJobResponse) ProtoMessage

func (*GetBatchJobResponse) ProtoMessage()

func (*GetBatchJobResponse) ProtoReflect

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

func (*GetBatchJobResponse) Reset

func (x *GetBatchJobResponse) Reset()

func (*GetBatchJobResponse) String

func (x *GetBatchJobResponse) String() string

type GetCronJobRequest

type GetCronJobRequest struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get Request

func (*GetCronJobRequest) Descriptor deprecated

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

Deprecated: Use GetCronJobRequest.ProtoReflect.Descriptor instead.

func (*GetCronJobRequest) GetName

func (x *GetCronJobRequest) GetName() string

func (*GetCronJobRequest) ProtoMessage

func (*GetCronJobRequest) ProtoMessage()

func (*GetCronJobRequest) ProtoReflect

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

func (*GetCronJobRequest) Reset

func (x *GetCronJobRequest) Reset()

func (*GetCronJobRequest) String

func (x *GetCronJobRequest) String() string

type GetCronJobResponse

type GetCronJobResponse struct {

	// Defines if job was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// CronJob run settings and current status
	CronJob *CronJob `protobuf:"bytes,2,opt,name=cron_job,json=cronJob,proto3,oneof" json:"cron_job,omitempty"`
	// contains filtered or unexported fields
}

Get Response

func (*GetCronJobResponse) Descriptor deprecated

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

Deprecated: Use GetCronJobResponse.ProtoReflect.Descriptor instead.

func (*GetCronJobResponse) GetCronJob

func (x *GetCronJobResponse) GetCronJob() *CronJob

func (*GetCronJobResponse) GetExists

func (x *GetCronJobResponse) GetExists() bool

func (*GetCronJobResponse) ProtoMessage

func (*GetCronJobResponse) ProtoMessage()

func (*GetCronJobResponse) ProtoReflect

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

func (*GetCronJobResponse) Reset

func (x *GetCronJobResponse) Reset()

func (*GetCronJobResponse) String

func (x *GetCronJobResponse) String() string

type GetDeploymentRequest

type GetDeploymentRequest struct {

	// Name of the scheduled deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get Request

func (*GetDeploymentRequest) Descriptor deprecated

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

Deprecated: Use GetDeploymentRequest.ProtoReflect.Descriptor instead.

func (*GetDeploymentRequest) GetName

func (x *GetDeploymentRequest) GetName() string

func (*GetDeploymentRequest) ProtoMessage

func (*GetDeploymentRequest) ProtoMessage()

func (*GetDeploymentRequest) ProtoReflect

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

func (*GetDeploymentRequest) Reset

func (x *GetDeploymentRequest) Reset()

func (*GetDeploymentRequest) String

func (x *GetDeploymentRequest) String() string

type GetDeploymentResponse

type GetDeploymentResponse struct {

	// Defines if deployment was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// Deployment run settings and current status
	Deployment *Deployment `protobuf:"bytes,2,opt,name=deployment,proto3,oneof" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

Get Response

func (*GetDeploymentResponse) Descriptor deprecated

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

Deprecated: Use GetDeploymentResponse.ProtoReflect.Descriptor instead.

func (*GetDeploymentResponse) GetDeployment

func (x *GetDeploymentResponse) GetDeployment() *Deployment

func (*GetDeploymentResponse) GetExists

func (x *GetDeploymentResponse) GetExists() bool

func (*GetDeploymentResponse) ProtoMessage

func (*GetDeploymentResponse) ProtoMessage()

func (*GetDeploymentResponse) ProtoReflect

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

func (*GetDeploymentResponse) Reset

func (x *GetDeploymentResponse) Reset()

func (*GetDeploymentResponse) String

func (x *GetDeploymentResponse) String() string

type ListBatchJobRequest

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

List Request

func (*ListBatchJobRequest) Descriptor deprecated

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

Deprecated: Use ListBatchJobRequest.ProtoReflect.Descriptor instead.

func (*ListBatchJobRequest) ProtoMessage

func (*ListBatchJobRequest) ProtoMessage()

func (*ListBatchJobRequest) ProtoReflect

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

func (*ListBatchJobRequest) Reset

func (x *ListBatchJobRequest) Reset()

func (*ListBatchJobRequest) String

func (x *ListBatchJobRequest) String() string

type ListBatchJobResponse

type ListBatchJobResponse struct {

	// List of the BatchJobs
	BatchJobs []string `protobuf:"bytes,1,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,omitempty"`
	// contains filtered or unexported fields
}

List Response

func (*ListBatchJobResponse) Descriptor deprecated

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

Deprecated: Use ListBatchJobResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobResponse) GetBatchJobs

func (x *ListBatchJobResponse) GetBatchJobs() []string

func (*ListBatchJobResponse) ProtoMessage

func (*ListBatchJobResponse) ProtoMessage()

func (*ListBatchJobResponse) ProtoReflect

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

func (*ListBatchJobResponse) Reset

func (x *ListBatchJobResponse) Reset()

func (*ListBatchJobResponse) String

func (x *ListBatchJobResponse) String() string

type ListCronJobRequest

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

List Request

func (*ListCronJobRequest) Descriptor deprecated

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

Deprecated: Use ListCronJobRequest.ProtoReflect.Descriptor instead.

func (*ListCronJobRequest) ProtoMessage

func (*ListCronJobRequest) ProtoMessage()

func (*ListCronJobRequest) ProtoReflect

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

func (*ListCronJobRequest) Reset

func (x *ListCronJobRequest) Reset()

func (*ListCronJobRequest) String

func (x *ListCronJobRequest) String() string

type ListCronJobResponse

type ListCronJobResponse struct {

	// List of the CronJobs
	CronJobs []string `protobuf:"bytes,1,rep,name=cron_jobs,json=cronJobs,proto3" json:"cron_jobs,omitempty"`
	// contains filtered or unexported fields
}

List Response

func (*ListCronJobResponse) Descriptor deprecated

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

Deprecated: Use ListCronJobResponse.ProtoReflect.Descriptor instead.

func (*ListCronJobResponse) GetCronJobs

func (x *ListCronJobResponse) GetCronJobs() []string

func (*ListCronJobResponse) ProtoMessage

func (*ListCronJobResponse) ProtoMessage()

func (*ListCronJobResponse) ProtoReflect

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

func (*ListCronJobResponse) Reset

func (x *ListCronJobResponse) Reset()

func (*ListCronJobResponse) String

func (x *ListCronJobResponse) String() string

type ListDeploymentRequest

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

List Request

func (*ListDeploymentRequest) Descriptor deprecated

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

Deprecated: Use ListDeploymentRequest.ProtoReflect.Descriptor instead.

func (*ListDeploymentRequest) ProtoMessage

func (*ListDeploymentRequest) ProtoMessage()

func (*ListDeploymentRequest) ProtoReflect

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

func (*ListDeploymentRequest) Reset

func (x *ListDeploymentRequest) Reset()

func (*ListDeploymentRequest) String

func (x *ListDeploymentRequest) String() string

type ListDeploymentResponse

type ListDeploymentResponse struct {

	// List of the Deployments
	Deployments []string `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// contains filtered or unexported fields
}

List Response

func (*ListDeploymentResponse) Descriptor deprecated

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

Deprecated: Use ListDeploymentResponse.ProtoReflect.Descriptor instead.

func (*ListDeploymentResponse) GetDeployments

func (x *ListDeploymentResponse) GetDeployments() []string

func (*ListDeploymentResponse) ProtoMessage

func (*ListDeploymentResponse) ProtoMessage()

func (*ListDeploymentResponse) ProtoReflect

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

func (*ListDeploymentResponse) Reset

func (x *ListDeploymentResponse) Reset()

func (*ListDeploymentResponse) String

func (x *ListDeploymentResponse) String() string

type Metadata

type Metadata struct {

	// Name of the job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optionally extends name of the job with random characters
	GenerateName *bool `protobuf:"varint,2,opt,name=generate_name,json=generateName,proto3,oneof" json:"generate_name,omitempty"`
	// contains filtered or unexported fields
}

Basic information about Job

func (*Metadata) Descriptor deprecated

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetGenerateName

func (x *Metadata) GetGenerateName() bool

func (*Metadata) GetName

func (x *Metadata) GetName() string

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect

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

func (*Metadata) Reset

func (x *Metadata) Reset()

func (*Metadata) String

func (x *Metadata) String() string

type ObjectBase

type ObjectBase struct {

	// Map of the Labels assigned to the job. Used for Profile selection
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// List of additional profiles assigned to Job
	Profiles []string `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

Common base of the objects

func (*ObjectBase) Descriptor deprecated

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

Deprecated: Use ObjectBase.ProtoReflect.Descriptor instead.

func (*ObjectBase) GetLabels

func (x *ObjectBase) GetLabels() map[string]string

func (*ObjectBase) GetProfiles

func (x *ObjectBase) GetProfiles() []string

func (*ObjectBase) ProtoMessage

func (*ObjectBase) ProtoMessage()

func (*ObjectBase) ProtoReflect

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

func (*ObjectBase) Reset

func (x *ObjectBase) Reset()

func (*ObjectBase) String

func (x *ObjectBase) String() string

type SchedulerV1Client

type SchedulerV1Client interface {
	// Creates BatchJob from specification
	CreateBatchJob(ctx context.Context, in *CreateBatchJobRequest, opts ...grpc.CallOption) (*CreateBatchJobResponse, error)
	// Returns BatchJob. If job does not exists, Exists flag is set to false
	GetBatchJob(ctx context.Context, in *GetBatchJobRequest, opts ...grpc.CallOption) (*GetBatchJobResponse, error)
	// Returns list of the BatchJobs
	ListBatchJob(ctx context.Context, in *ListBatchJobRequest, opts ...grpc.CallOption) (*ListBatchJobResponse, error)
	// Deletes BatchJob. If job does not exists, Exists flag is set to false
	DeleteBatchJob(ctx context.Context, in *DeleteBatchJobRequest, opts ...grpc.CallOption) (*DeleteBatchJobResponse, error)
	// Creates CronJob from specification
	CreateCronJob(ctx context.Context, in *CreateCronJobRequest, opts ...grpc.CallOption) (*CreateCronJobResponse, error)
	// Returns CronJob. If job does not exists, Exists flag is set to false
	GetCronJob(ctx context.Context, in *GetCronJobRequest, opts ...grpc.CallOption) (*GetCronJobResponse, error)
	// Updates CronJob from specification
	UpdateCronJob(ctx context.Context, in *UpdateCronJobRequest, opts ...grpc.CallOption) (*UpdateCronJobResponse, error)
	// Returns list of the CronJobs
	ListCronJob(ctx context.Context, in *ListCronJobRequest, opts ...grpc.CallOption) (*ListCronJobResponse, error)
	// Deletes CronJob. If job does not exists, Exists flag is set to false
	DeleteCronJob(ctx context.Context, in *DeleteCronJobRequest, opts ...grpc.CallOption) (*DeleteCronJobResponse, error)
	// Creates Deployment from specification
	CreateDeployment(ctx context.Context, in *CreateDeploymentRequest, opts ...grpc.CallOption) (*CreateDeploymentResponse, error)
	// Returns Deployment. If job does not exists, Exists flag is set to false
	GetDeployment(ctx context.Context, in *GetDeploymentRequest, opts ...grpc.CallOption) (*GetDeploymentResponse, error)
	// Updates Deployment from specification
	UpdateDeployment(ctx context.Context, in *UpdateDeploymentRequest, opts ...grpc.CallOption) (*UpdateDeploymentResponse, error)
	// Returns list of the Deployments
	ListDeployment(ctx context.Context, in *ListDeploymentRequest, opts ...grpc.CallOption) (*ListDeploymentResponse, error)
	// Deletes Deployment. If job does not exists, Exists flag is set to false
	DeleteDeployment(ctx context.Context, in *DeleteDeploymentRequest, opts ...grpc.CallOption) (*DeleteDeploymentResponse, error)
}

SchedulerV1Client is the client API for SchedulerV1 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.

type SchedulerV1Server

type SchedulerV1Server interface {
	// Creates BatchJob from specification
	CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)
	// Returns BatchJob. If job does not exists, Exists flag is set to false
	GetBatchJob(context.Context, *GetBatchJobRequest) (*GetBatchJobResponse, error)
	// Returns list of the BatchJobs
	ListBatchJob(context.Context, *ListBatchJobRequest) (*ListBatchJobResponse, error)
	// Deletes BatchJob. If job does not exists, Exists flag is set to false
	DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*DeleteBatchJobResponse, error)
	// Creates CronJob from specification
	CreateCronJob(context.Context, *CreateCronJobRequest) (*CreateCronJobResponse, error)
	// Returns CronJob. If job does not exists, Exists flag is set to false
	GetCronJob(context.Context, *GetCronJobRequest) (*GetCronJobResponse, error)
	// Updates CronJob from specification
	UpdateCronJob(context.Context, *UpdateCronJobRequest) (*UpdateCronJobResponse, error)
	// Returns list of the CronJobs
	ListCronJob(context.Context, *ListCronJobRequest) (*ListCronJobResponse, error)
	// Deletes CronJob. If job does not exists, Exists flag is set to false
	DeleteCronJob(context.Context, *DeleteCronJobRequest) (*DeleteCronJobResponse, error)
	// Creates Deployment from specification
	CreateDeployment(context.Context, *CreateDeploymentRequest) (*CreateDeploymentResponse, error)
	// Returns Deployment. If job does not exists, Exists flag is set to false
	GetDeployment(context.Context, *GetDeploymentRequest) (*GetDeploymentResponse, error)
	// Updates Deployment from specification
	UpdateDeployment(context.Context, *UpdateDeploymentRequest) (*UpdateDeploymentResponse, error)
	// Returns list of the Deployments
	ListDeployment(context.Context, *ListDeploymentRequest) (*ListDeploymentResponse, error)
	// Deletes Deployment. If job does not exists, Exists flag is set to false
	DeleteDeployment(context.Context, *DeleteDeploymentRequest) (*DeleteDeploymentResponse, error)
	// contains filtered or unexported methods
}

SchedulerV1Server is the server API for SchedulerV1 service. All implementations must embed UnimplementedSchedulerV1Server for forward compatibility

type Spec

type Spec struct {

	// Keeps requested Metadata
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Keeps requested Job base
	Base *ObjectBase `protobuf:"bytes,2,opt,name=base,proto3" json:"base,omitempty"`
	// Keeps map of the containers
	Containers map[string]*ContainerBase `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Common Spec of the Schedule request

func (*Spec) Descriptor deprecated

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetBase

func (x *Spec) GetBase() *ObjectBase

func (*Spec) GetContainers

func (x *Spec) GetContainers() map[string]*ContainerBase

func (*Spec) GetMetadata

func (x *Spec) GetMetadata() *Metadata

func (*Spec) ProtoMessage

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect

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

func (*Spec) Reset

func (x *Spec) Reset()

func (*Spec) String

func (x *Spec) String() string

type StatusMetadata

type StatusMetadata struct {

	// Defines if upstream object has been created
	Created bool `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	// Defines checksum
	Checksum *string `protobuf:"bytes,2,opt,name=checksum,proto3,oneof" json:"checksum,omitempty"`
	// Defines uid
	Uid *string `protobuf:"bytes,3,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
	// Defiles list of applied profiles
	Profiles []string `protobuf:"bytes,4,rep,name=profiles,proto3" json:"profiles,omitempty"`
	// contains filtered or unexported fields
}

Defines status of the scheduled object

func (*StatusMetadata) Descriptor deprecated

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

Deprecated: Use StatusMetadata.ProtoReflect.Descriptor instead.

func (*StatusMetadata) GetChecksum

func (x *StatusMetadata) GetChecksum() string

func (*StatusMetadata) GetCreated

func (x *StatusMetadata) GetCreated() bool

func (*StatusMetadata) GetProfiles

func (x *StatusMetadata) GetProfiles() []string

func (*StatusMetadata) GetUid

func (x *StatusMetadata) GetUid() string

func (*StatusMetadata) ProtoMessage

func (*StatusMetadata) ProtoMessage()

func (*StatusMetadata) ProtoReflect

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

func (*StatusMetadata) Reset

func (x *StatusMetadata) Reset()

func (*StatusMetadata) String

func (x *StatusMetadata) String() string

type UnimplementedSchedulerV1Server

type UnimplementedSchedulerV1Server struct {
}

UnimplementedSchedulerV1Server must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerV1Server) CreateBatchJob

func (UnimplementedSchedulerV1Server) CreateCronJob

func (UnimplementedSchedulerV1Server) CreateDeployment

func (UnimplementedSchedulerV1Server) DeleteBatchJob

func (UnimplementedSchedulerV1Server) DeleteCronJob

func (UnimplementedSchedulerV1Server) DeleteDeployment

func (UnimplementedSchedulerV1Server) GetBatchJob

func (UnimplementedSchedulerV1Server) GetCronJob

func (UnimplementedSchedulerV1Server) GetDeployment

func (UnimplementedSchedulerV1Server) ListBatchJob

func (UnimplementedSchedulerV1Server) ListCronJob

func (UnimplementedSchedulerV1Server) ListDeployment

func (UnimplementedSchedulerV1Server) UpdateCronJob

func (UnimplementedSchedulerV1Server) UpdateDeployment

type UnsafeSchedulerV1Server

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

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

type UpdateCronJobRequest

type UpdateCronJobRequest struct {

	// Name of the scheduled job
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// CronJob spec to be updated
	Spec *CronJobSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Update Request

func (*UpdateCronJobRequest) Descriptor deprecated

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

Deprecated: Use UpdateCronJobRequest.ProtoReflect.Descriptor instead.

func (*UpdateCronJobRequest) GetName

func (x *UpdateCronJobRequest) GetName() string

func (*UpdateCronJobRequest) GetSpec

func (x *UpdateCronJobRequest) GetSpec() *CronJobSpec

func (*UpdateCronJobRequest) ProtoMessage

func (*UpdateCronJobRequest) ProtoMessage()

func (*UpdateCronJobRequest) ProtoReflect

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

func (*UpdateCronJobRequest) Reset

func (x *UpdateCronJobRequest) Reset()

func (*UpdateCronJobRequest) String

func (x *UpdateCronJobRequest) String() string

type UpdateCronJobResponse

type UpdateCronJobResponse struct {

	// Defines if job was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// CronJob run settings and current status
	CronJob *CronJob `protobuf:"bytes,2,opt,name=cron_job,json=cronJob,proto3,oneof" json:"cron_job,omitempty"`
	// contains filtered or unexported fields
}

Update Response

func (*UpdateCronJobResponse) Descriptor deprecated

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

Deprecated: Use UpdateCronJobResponse.ProtoReflect.Descriptor instead.

func (*UpdateCronJobResponse) GetCronJob

func (x *UpdateCronJobResponse) GetCronJob() *CronJob

func (*UpdateCronJobResponse) GetExists

func (x *UpdateCronJobResponse) GetExists() bool

func (*UpdateCronJobResponse) ProtoMessage

func (*UpdateCronJobResponse) ProtoMessage()

func (*UpdateCronJobResponse) ProtoReflect

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

func (*UpdateCronJobResponse) Reset

func (x *UpdateCronJobResponse) Reset()

func (*UpdateCronJobResponse) String

func (x *UpdateCronJobResponse) String() string

type UpdateDeploymentRequest

type UpdateDeploymentRequest struct {

	// Name of the scheduled deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Deployment spec to be updated
	Spec *DeploymentSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Update Request

func (*UpdateDeploymentRequest) Descriptor deprecated

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

Deprecated: Use UpdateDeploymentRequest.ProtoReflect.Descriptor instead.

func (*UpdateDeploymentRequest) GetName

func (x *UpdateDeploymentRequest) GetName() string

func (*UpdateDeploymentRequest) GetSpec

func (*UpdateDeploymentRequest) ProtoMessage

func (*UpdateDeploymentRequest) ProtoMessage()

func (*UpdateDeploymentRequest) ProtoReflect

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

func (*UpdateDeploymentRequest) Reset

func (x *UpdateDeploymentRequest) Reset()

func (*UpdateDeploymentRequest) String

func (x *UpdateDeploymentRequest) String() string

type UpdateDeploymentResponse

type UpdateDeploymentResponse struct {

	// Defines if deployment was found
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// Deployment run settings and current status
	Deployment *Deployment `protobuf:"bytes,2,opt,name=deployment,proto3,oneof" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

Update Response

func (*UpdateDeploymentResponse) Descriptor deprecated

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

Deprecated: Use UpdateDeploymentResponse.ProtoReflect.Descriptor instead.

func (*UpdateDeploymentResponse) GetDeployment

func (x *UpdateDeploymentResponse) GetDeployment() *Deployment

func (*UpdateDeploymentResponse) GetExists

func (x *UpdateDeploymentResponse) GetExists() bool

func (*UpdateDeploymentResponse) ProtoMessage

func (*UpdateDeploymentResponse) ProtoMessage()

func (*UpdateDeploymentResponse) ProtoReflect

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

func (*UpdateDeploymentResponse) Reset

func (x *UpdateDeploymentResponse) Reset()

func (*UpdateDeploymentResponse) String

func (x *UpdateDeploymentResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL