definition

package
v0.0.0-...-4322bf5 Latest Latest
Warning

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

 Go to latest Published: May 1, 2024 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 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,
		},
	},
	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 {

	// Keeps BatchJob settings
	Spec *BatchJobSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// Keeps current BatchJob Status
	Status *BatchJobStatus `protobuf:"bytes,2,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) 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"`
	// List of the assigned profiles
	Profiles []string `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,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) GetProfiles 

func (x *CreateBatchJobResponse) GetProfiles() []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"`
	// List of the assigned profiles
	Profiles []string `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,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) GetProfiles 

func (x *CreateCronJobResponse) GetProfiles() []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 CronJob 

type CronJob struct {

	// Keeps the CronJob Settings
	Spec *CronJobSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,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) GetSpec 

func (x *CronJob) GetSpec() *CronJobSpec

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 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 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"`
	// Keeps list of created BatchJobs
	BatchJobs []string `protobuf:"bytes,3,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,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) GetBatchJobs 

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

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 JobBase 

type JobBase 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 Jobs

func (*JobBase) Descriptor deprecated 

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

Deprecated: Use JobBase.ProtoReflect.Descriptor instead.

func (*JobBase) GetLabels 

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

func (*JobBase) GetProfiles 

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

func (*JobBase) ProtoMessage 

func (*JobBase) ProtoMessage()

func (*JobBase) ProtoReflect 

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

func (*JobBase) Reset 

func (x *JobBase) Reset()

func (*JobBase) String 

func (x *JobBase) 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 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 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)
}

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.

func NewSchedulerV1Client 

func NewSchedulerV1Client(cc grpc.ClientConnInterface) SchedulerV1Client

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)
	// 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
	Job *JobBase `protobuf:"bytes,2,opt,name=job,proto3" json:"job,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) GetContainers 

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

func (*Spec) GetJob 

func (x *Spec) GetJob() *JobBase

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 UnimplementedSchedulerV1Server 

type UnimplementedSchedulerV1Server struct {
}

UnimplementedSchedulerV1Server must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerV1Server) CreateBatchJob 

func (UnimplementedSchedulerV1Server) CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)

func (UnimplementedSchedulerV1Server) CreateCronJob 

func (UnimplementedSchedulerV1Server) CreateCronJob(context.Context, *CreateCronJobRequest) (*CreateCronJobResponse, error)

func (UnimplementedSchedulerV1Server) DeleteBatchJob 

func (UnimplementedSchedulerV1Server) DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*DeleteBatchJobResponse, error)

func (UnimplementedSchedulerV1Server) DeleteCronJob 

func (UnimplementedSchedulerV1Server) DeleteCronJob(context.Context, *DeleteCronJobRequest) (*DeleteCronJobResponse, error)

func (UnimplementedSchedulerV1Server) GetBatchJob 

func (UnimplementedSchedulerV1Server) GetBatchJob(context.Context, *GetBatchJobRequest) (*GetBatchJobResponse, error)

func (UnimplementedSchedulerV1Server) GetCronJob 

func (UnimplementedSchedulerV1Server) GetCronJob(context.Context, *GetCronJobRequest) (*GetCronJobResponse, error)

func (UnimplementedSchedulerV1Server) ListBatchJob 

func (UnimplementedSchedulerV1Server) ListBatchJob(context.Context, *ListBatchJobRequest) (*ListBatchJobResponse, error)

func (UnimplementedSchedulerV1Server) ListCronJob 

func (UnimplementedSchedulerV1Server) ListCronJob(context.Context, *ListCronJobRequest) (*ListCronJobResponse, error)

func (UnimplementedSchedulerV1Server) UpdateCronJob 

func (UnimplementedSchedulerV1Server) UpdateCronJob(context.Context, *UpdateCronJobRequest) (*UpdateCronJobResponse, error)

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

Source Files

View all Source files

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.