Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterSchedulerV1Server(s grpc.ServiceRegistrar, srv SchedulerV1Server)
- type BatchJob
- func (*BatchJob) Descriptor() ([]byte, []int)deprecated
- func (x *BatchJob) GetMetadata() *StatusMetadata
- func (x *BatchJob) GetSpec() *BatchJobSpec
- func (x *BatchJob) GetStatus() *BatchJobStatus
- func (*BatchJob) ProtoMessage()
- func (x *BatchJob) ProtoReflect() protoreflect.Message
- func (x *BatchJob) Reset()
- func (x *BatchJob) String() string
- type BatchJobSpec
- func (*BatchJobSpec) Descriptor() ([]byte, []int)deprecated
- func (x *BatchJobSpec) GetBackoffLimit() int32
- func (x *BatchJobSpec) GetCompletions() int32
- func (x *BatchJobSpec) GetParallelism() int32
- func (*BatchJobSpec) ProtoMessage()
- func (x *BatchJobSpec) ProtoReflect() protoreflect.Message
- func (x *BatchJobSpec) Reset()
- func (x *BatchJobSpec) String() string
- type BatchJobStatus
- func (*BatchJobStatus) Descriptor() ([]byte, []int)deprecated
- func (x *BatchJobStatus) GetActive() int32
- func (x *BatchJobStatus) GetFailed() int32
- func (x *BatchJobStatus) GetSucceeded() int32
- func (*BatchJobStatus) ProtoMessage()
- func (x *BatchJobStatus) ProtoReflect() protoreflect.Message
- func (x *BatchJobStatus) Reset()
- func (x *BatchJobStatus) String() string
- type ContainerBase
- func (*ContainerBase) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerBase) GetArgs() []string
- func (x *ContainerBase) GetEnvironmentVariables() map[string]string
- func (x *ContainerBase) GetImage() string
- func (*ContainerBase) ProtoMessage()
- func (x *ContainerBase) ProtoReflect() protoreflect.Message
- func (x *ContainerBase) Reset()
- func (x *ContainerBase) String() string
- type CreateBatchJobRequest
- func (*CreateBatchJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBatchJobRequest) GetBatchJob() *BatchJobSpec
- func (x *CreateBatchJobRequest) GetSpec() *Spec
- func (*CreateBatchJobRequest) ProtoMessage()
- func (x *CreateBatchJobRequest) ProtoReflect() protoreflect.Message
- func (x *CreateBatchJobRequest) Reset()
- func (x *CreateBatchJobRequest) String() string
- type CreateBatchJobResponse
- func (*CreateBatchJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBatchJobResponse) GetName() string
- func (*CreateBatchJobResponse) ProtoMessage()
- func (x *CreateBatchJobResponse) ProtoReflect() protoreflect.Message
- func (x *CreateBatchJobResponse) Reset()
- func (x *CreateBatchJobResponse) String() string
- type CreateCronJobRequest
- func (*CreateCronJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCronJobRequest) GetCronJob() *CronJobSpec
- func (x *CreateCronJobRequest) GetSpec() *Spec
- func (*CreateCronJobRequest) ProtoMessage()
- func (x *CreateCronJobRequest) ProtoReflect() protoreflect.Message
- func (x *CreateCronJobRequest) Reset()
- func (x *CreateCronJobRequest) String() string
- type CreateCronJobResponse
- func (*CreateCronJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateCronJobResponse) GetName() string
- func (*CreateCronJobResponse) ProtoMessage()
- func (x *CreateCronJobResponse) ProtoReflect() protoreflect.Message
- func (x *CreateCronJobResponse) Reset()
- func (x *CreateCronJobResponse) String() string
- type CreateDeploymentRequest
- func (*CreateDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDeploymentRequest) GetDeployment() *DeploymentSpec
- func (x *CreateDeploymentRequest) GetSpec() *Spec
- func (*CreateDeploymentRequest) ProtoMessage()
- func (x *CreateDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDeploymentRequest) Reset()
- func (x *CreateDeploymentRequest) String() string
- type CreateDeploymentResponse
- func (*CreateDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDeploymentResponse) GetName() string
- func (*CreateDeploymentResponse) ProtoMessage()
- func (x *CreateDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDeploymentResponse) Reset()
- func (x *CreateDeploymentResponse) String() string
- type CronJob
- func (*CronJob) Descriptor() ([]byte, []int)deprecated
- func (x *CronJob) GetMetadata() *StatusMetadata
- func (x *CronJob) GetSpec() *CronJobSpec
- func (x *CronJob) GetStatus() *CronJobStatus
- func (*CronJob) ProtoMessage()
- func (x *CronJob) ProtoReflect() protoreflect.Message
- func (x *CronJob) Reset()
- func (x *CronJob) String() string
- type CronJobSpec
- func (*CronJobSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CronJobSpec) GetJob() *BatchJobSpec
- func (x *CronJobSpec) GetSchedule() string
- func (*CronJobSpec) ProtoMessage()
- func (x *CronJobSpec) ProtoReflect() protoreflect.Message
- func (x *CronJobSpec) Reset()
- func (x *CronJobSpec) String() string
- type CronJobStatus
- type DeleteBatchJobRequest
- func (*DeleteBatchJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteBatchJobRequest) GetDeleteChildPods() bool
- func (x *DeleteBatchJobRequest) GetName() string
- func (*DeleteBatchJobRequest) ProtoMessage()
- func (x *DeleteBatchJobRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteBatchJobRequest) Reset()
- func (x *DeleteBatchJobRequest) String() string
- type DeleteBatchJobResponse
- func (*DeleteBatchJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteBatchJobResponse) GetExists() bool
- func (*DeleteBatchJobResponse) ProtoMessage()
- func (x *DeleteBatchJobResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteBatchJobResponse) Reset()
- func (x *DeleteBatchJobResponse) String() string
- type DeleteCronJobRequest
- func (*DeleteCronJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCronJobRequest) GetDeleteChildPods() bool
- func (x *DeleteCronJobRequest) GetName() string
- func (*DeleteCronJobRequest) ProtoMessage()
- func (x *DeleteCronJobRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteCronJobRequest) Reset()
- func (x *DeleteCronJobRequest) String() string
- type DeleteCronJobResponse
- func (*DeleteCronJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteCronJobResponse) GetExists() bool
- func (*DeleteCronJobResponse) ProtoMessage()
- func (x *DeleteCronJobResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteCronJobResponse) Reset()
- func (x *DeleteCronJobResponse) String() string
- type DeleteDeploymentRequest
- func (*DeleteDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDeploymentRequest) GetDeleteChildPods() bool
- func (x *DeleteDeploymentRequest) GetName() string
- func (*DeleteDeploymentRequest) ProtoMessage()
- func (x *DeleteDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDeploymentRequest) Reset()
- func (x *DeleteDeploymentRequest) String() string
- type DeleteDeploymentResponse
- func (*DeleteDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDeploymentResponse) GetExists() bool
- func (*DeleteDeploymentResponse) ProtoMessage()
- func (x *DeleteDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteDeploymentResponse) Reset()
- func (x *DeleteDeploymentResponse) String() string
- type Deployment
- func (*Deployment) Descriptor() ([]byte, []int)deprecated
- func (x *Deployment) GetMetadata() *StatusMetadata
- func (x *Deployment) GetSpec() *DeploymentSpec
- func (x *Deployment) GetStatus() *DeploymentStatus
- func (*Deployment) ProtoMessage()
- func (x *Deployment) ProtoReflect() protoreflect.Message
- func (x *Deployment) Reset()
- func (x *Deployment) String() string
- type DeploymentSpec
- type DeploymentStatus
- func (*DeploymentStatus) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentStatus) GetAvailableReplicas() int32
- func (x *DeploymentStatus) GetReadyReplicas() int32
- func (x *DeploymentStatus) GetReplicas() int32
- func (x *DeploymentStatus) GetUnavailableReplicas() int32
- func (x *DeploymentStatus) GetUpdatedReplicas() int32
- func (*DeploymentStatus) ProtoMessage()
- func (x *DeploymentStatus) ProtoReflect() protoreflect.Message
- func (x *DeploymentStatus) Reset()
- func (x *DeploymentStatus) String() string
- type GetBatchJobRequest
- func (*GetBatchJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetBatchJobRequest) GetName() string
- func (*GetBatchJobRequest) ProtoMessage()
- func (x *GetBatchJobRequest) ProtoReflect() protoreflect.Message
- func (x *GetBatchJobRequest) Reset()
- func (x *GetBatchJobRequest) String() string
- type GetBatchJobResponse
- func (*GetBatchJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetBatchJobResponse) GetBatchJob() *BatchJob
- func (x *GetBatchJobResponse) GetExists() bool
- func (*GetBatchJobResponse) ProtoMessage()
- func (x *GetBatchJobResponse) ProtoReflect() protoreflect.Message
- func (x *GetBatchJobResponse) Reset()
- func (x *GetBatchJobResponse) String() string
- type GetCronJobRequest
- type GetCronJobResponse
- func (*GetCronJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCronJobResponse) GetCronJob() *CronJob
- func (x *GetCronJobResponse) GetExists() bool
- func (*GetCronJobResponse) ProtoMessage()
- func (x *GetCronJobResponse) ProtoReflect() protoreflect.Message
- func (x *GetCronJobResponse) Reset()
- func (x *GetCronJobResponse) String() string
- type GetDeploymentRequest
- func (*GetDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeploymentRequest) GetName() string
- func (*GetDeploymentRequest) ProtoMessage()
- func (x *GetDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *GetDeploymentRequest) Reset()
- func (x *GetDeploymentRequest) String() string
- type GetDeploymentResponse
- func (*GetDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeploymentResponse) GetDeployment() *Deployment
- func (x *GetDeploymentResponse) GetExists() bool
- func (*GetDeploymentResponse) ProtoMessage()
- func (x *GetDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *GetDeploymentResponse) Reset()
- func (x *GetDeploymentResponse) String() string
- type ListBatchJobRequest
- type ListBatchJobResponse
- func (*ListBatchJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListBatchJobResponse) GetBatchJobs() []string
- func (*ListBatchJobResponse) ProtoMessage()
- func (x *ListBatchJobResponse) ProtoReflect() protoreflect.Message
- func (x *ListBatchJobResponse) Reset()
- func (x *ListBatchJobResponse) String() string
- type ListCronJobRequest
- type ListCronJobResponse
- func (*ListCronJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListCronJobResponse) GetCronJobs() []string
- func (*ListCronJobResponse) ProtoMessage()
- func (x *ListCronJobResponse) ProtoReflect() protoreflect.Message
- func (x *ListCronJobResponse) Reset()
- func (x *ListCronJobResponse) String() string
- type ListDeploymentRequest
- type ListDeploymentResponse
- func (*ListDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDeploymentResponse) GetDeployments() []string
- func (*ListDeploymentResponse) ProtoMessage()
- func (x *ListDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *ListDeploymentResponse) Reset()
- func (x *ListDeploymentResponse) String() string
- type Metadata
- type ObjectBase
- func (*ObjectBase) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectBase) GetLabels() map[string]string
- func (x *ObjectBase) GetProfiles() []string
- func (*ObjectBase) ProtoMessage()
- func (x *ObjectBase) ProtoReflect() protoreflect.Message
- func (x *ObjectBase) Reset()
- func (x *ObjectBase) String() string
- type SchedulerV1Client
- type SchedulerV1Server
- type Spec
- func (*Spec) Descriptor() ([]byte, []int)deprecated
- func (x *Spec) GetBase() *ObjectBase
- func (x *Spec) GetContainers() map[string]*ContainerBase
- func (x *Spec) GetMetadata() *Metadata
- func (*Spec) ProtoMessage()
- func (x *Spec) ProtoReflect() protoreflect.Message
- func (x *Spec) Reset()
- func (x *Spec) String() string
- type StatusMetadata
- func (*StatusMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *StatusMetadata) GetChecksum() string
- func (x *StatusMetadata) GetCreated() bool
- func (x *StatusMetadata) GetProfiles() []string
- func (x *StatusMetadata) GetUid() string
- func (*StatusMetadata) ProtoMessage()
- func (x *StatusMetadata) ProtoReflect() protoreflect.Message
- func (x *StatusMetadata) Reset()
- func (x *StatusMetadata) String() string
- type UnimplementedSchedulerV1Server
- func (UnimplementedSchedulerV1Server) CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)
- func (UnimplementedSchedulerV1Server) CreateCronJob(context.Context, *CreateCronJobRequest) (*CreateCronJobResponse, error)
- func (UnimplementedSchedulerV1Server) CreateDeployment(context.Context, *CreateDeploymentRequest) (*CreateDeploymentResponse, error)
- func (UnimplementedSchedulerV1Server) DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*DeleteBatchJobResponse, error)
- func (UnimplementedSchedulerV1Server) DeleteCronJob(context.Context, *DeleteCronJobRequest) (*DeleteCronJobResponse, error)
- func (UnimplementedSchedulerV1Server) DeleteDeployment(context.Context, *DeleteDeploymentRequest) (*DeleteDeploymentResponse, error)
- func (UnimplementedSchedulerV1Server) GetBatchJob(context.Context, *GetBatchJobRequest) (*GetBatchJobResponse, error)
- func (UnimplementedSchedulerV1Server) GetCronJob(context.Context, *GetCronJobRequest) (*GetCronJobResponse, error)
- func (UnimplementedSchedulerV1Server) GetDeployment(context.Context, *GetDeploymentRequest) (*GetDeploymentResponse, error)
- func (UnimplementedSchedulerV1Server) ListBatchJob(context.Context, *ListBatchJobRequest) (*ListBatchJobResponse, error)
- func (UnimplementedSchedulerV1Server) ListCronJob(context.Context, *ListCronJobRequest) (*ListCronJobResponse, error)
- func (UnimplementedSchedulerV1Server) ListDeployment(context.Context, *ListDeploymentRequest) (*ListDeploymentResponse, error)
- func (UnimplementedSchedulerV1Server) UpdateCronJob(context.Context, *UpdateCronJobRequest) (*UpdateCronJobResponse, error)
- func (UnimplementedSchedulerV1Server) UpdateDeployment(context.Context, *UpdateDeploymentRequest) (*UpdateDeploymentResponse, error)
- type UnsafeSchedulerV1Server
- type UpdateCronJobRequest
- func (*UpdateCronJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCronJobRequest) GetName() string
- func (x *UpdateCronJobRequest) GetSpec() *CronJobSpec
- func (*UpdateCronJobRequest) ProtoMessage()
- func (x *UpdateCronJobRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateCronJobRequest) Reset()
- func (x *UpdateCronJobRequest) String() string
- type UpdateCronJobResponse
- func (*UpdateCronJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateCronJobResponse) GetCronJob() *CronJob
- func (x *UpdateCronJobResponse) GetExists() bool
- func (*UpdateCronJobResponse) ProtoMessage()
- func (x *UpdateCronJobResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateCronJobResponse) Reset()
- func (x *UpdateCronJobResponse) String() string
- type UpdateDeploymentRequest
- func (*UpdateDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeploymentRequest) GetName() string
- func (x *UpdateDeploymentRequest) GetSpec() *DeploymentSpec
- func (*UpdateDeploymentRequest) ProtoMessage()
- func (x *UpdateDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateDeploymentRequest) Reset()
- func (x *UpdateDeploymentRequest) String() string
- type UpdateDeploymentResponse
- func (*UpdateDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateDeploymentResponse) GetDeployment() *Deployment
- func (x *UpdateDeploymentResponse) GetExists() bool
- func (*UpdateDeploymentResponse) ProtoMessage()
- func (x *UpdateDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateDeploymentResponse) Reset()
- func (x *UpdateDeploymentResponse) String() string
Constants ¶
const (
Name = "scheduler.v1"
)
Variables ¶
var File_integrations_scheduler_v1_definition_batchjob_proto protoreflect.FileDescriptor
var File_integrations_scheduler_v1_definition_common_proto protoreflect.FileDescriptor
var File_integrations_scheduler_v1_definition_cronjob_proto protoreflect.FileDescriptor
var File_integrations_scheduler_v1_definition_definition_proto protoreflect.FileDescriptor
var File_integrations_scheduler_v1_definition_deployment_proto protoreflect.FileDescriptor
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) 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
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) 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
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"`
// 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) GetGenerateName ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) ProtoReflect ¶
func (x *Metadata) ProtoReflect() protoreflect.Message
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.
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)
// 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) GetBase ¶
func (x *Spec) GetBase() *ObjectBase
func (*Spec) GetContainers ¶
func (x *Spec) GetContainers() map[string]*ContainerBase
func (*Spec) GetMetadata ¶
func (*Spec) ProtoMessage ¶
func (*Spec) ProtoMessage()
func (*Spec) ProtoReflect ¶
func (x *Spec) ProtoReflect() protoreflect.Message
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) CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)
func (UnimplementedSchedulerV1Server) CreateCronJob ¶
func (UnimplementedSchedulerV1Server) CreateCronJob(context.Context, *CreateCronJobRequest) (*CreateCronJobResponse, error)
func (UnimplementedSchedulerV1Server) CreateDeployment ¶
func (UnimplementedSchedulerV1Server) CreateDeployment(context.Context, *CreateDeploymentRequest) (*CreateDeploymentResponse, 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) DeleteDeployment ¶
func (UnimplementedSchedulerV1Server) DeleteDeployment(context.Context, *DeleteDeploymentRequest) (*DeleteDeploymentResponse, 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) GetDeployment ¶
func (UnimplementedSchedulerV1Server) GetDeployment(context.Context, *GetDeploymentRequest) (*GetDeploymentResponse, 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) ListDeployment ¶
func (UnimplementedSchedulerV1Server) ListDeployment(context.Context, *ListDeploymentRequest) (*ListDeploymentResponse, error)
func (UnimplementedSchedulerV1Server) UpdateCronJob ¶
func (UnimplementedSchedulerV1Server) UpdateCronJob(context.Context, *UpdateCronJobRequest) (*UpdateCronJobResponse, error)
func (UnimplementedSchedulerV1Server) UpdateDeployment ¶
func (UnimplementedSchedulerV1Server) UpdateDeployment(context.Context, *UpdateDeploymentRequest) (*UpdateDeploymentResponse, 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
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 (x *UpdateDeploymentRequest) GetSpec() *DeploymentSpec
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