 Documentation
      ¶
      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 ( SchedulerV1_CreateBatchJob_FullMethodName = "/scheduler.SchedulerV1/CreateBatchJob" SchedulerV1_GetBatchJob_FullMethodName = "/scheduler.SchedulerV1/GetBatchJob" SchedulerV1_ListBatchJob_FullMethodName = "/scheduler.SchedulerV1/ListBatchJob" SchedulerV1_DeleteBatchJob_FullMethodName = "/scheduler.SchedulerV1/DeleteBatchJob" SchedulerV1_CreateCronJob_FullMethodName = "/scheduler.SchedulerV1/CreateCronJob" SchedulerV1_GetCronJob_FullMethodName = "/scheduler.SchedulerV1/GetCronJob" SchedulerV1_UpdateCronJob_FullMethodName = "/scheduler.SchedulerV1/UpdateCronJob" SchedulerV1_ListCronJob_FullMethodName = "/scheduler.SchedulerV1/ListCronJob" SchedulerV1_DeleteCronJob_FullMethodName = "/scheduler.SchedulerV1/DeleteCronJob" SchedulerV1_CreateDeployment_FullMethodName = "/scheduler.SchedulerV1/CreateDeployment" SchedulerV1_GetDeployment_FullMethodName = "/scheduler.SchedulerV1/GetDeployment" SchedulerV1_UpdateDeployment_FullMethodName = "/scheduler.SchedulerV1/UpdateDeployment" SchedulerV1_ListDeployment_FullMethodName = "/scheduler.SchedulerV1/ListDeployment" SchedulerV1_DeleteDeployment_FullMethodName = "/scheduler.SchedulerV1/DeleteDeployment" )
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.
Definition of the ServiceInterface for Scheduler V1
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.
Definition of the ServiceInterface for Scheduler V1
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.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
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