apiv2

Documentation

Index

• func GetRadixBatchJobStatusFromPhase(job radixv1.RadixBatchJob, phase radixv1.RadixBatchJobPhase) (status common.ProgressStatus)
• func GetRadixBatchStatus(radixBatch *radixv1.RadixBatch) (status common.ProgressStatus)
• type CompletedRadixBatches
• type Handler
  • func New(kube *kube.Kube, env *models.Env) Handler

Functions

func GetRadixBatchJobStatusFromPhase

func GetRadixBatchJobStatusFromPhase(job radixv1.RadixBatchJob, phase radixv1.RadixBatchJobPhase) (status common.ProgressStatus)

GetRadixBatchJobStatusFromPhase Get batch job status by job phase

func GetRadixBatchStatus

func GetRadixBatchStatus(radixBatch *radixv1.RadixBatch) (status common.ProgressStatus)

GetRadixBatchStatus Gets the batch status

Types

type CompletedRadixBatches

type CompletedRadixBatches struct {
	SucceededRadixBatches    []*modelsv2.RadixBatch
	NotSucceededRadixBatches []*modelsv2.RadixBatch
	SucceededSingleJobs      []*modelsv2.RadixBatch
	NotSucceededSingleJobs   []*modelsv2.RadixBatch
}

CompletedRadixBatches Completed RadixBatch lists

type Handler

type Handler interface {
	//GetRadixBatches Get status of all batches
	GetRadixBatches() ([]modelsv2.RadixBatch, error)
	//GetRadixBatchSingleJobs Get status of all single jobs
	GetRadixBatchSingleJobs() ([]modelsv2.RadixBatch, error)
	//GetRadixBatch Get a batch
	GetRadixBatch(string) (*modelsv2.RadixBatch, error)
	//CreateRadixBatch Create a batch with parameters
	CreateRadixBatch(*common.BatchScheduleDescription) (*modelsv2.RadixBatch, error)
	//CreateRadixBatchSingleJob Create a batch with single job parameters
	CreateRadixBatchSingleJob(*common.JobScheduleDescription) (*modelsv2.RadixBatch, error)
	//MaintainHistoryLimit Delete outdated batches
	MaintainHistoryLimit() error
	// GarbageCollectPayloadSecrets Delete orphaned payload secrets
	GarbageCollectPayloadSecrets() error
	//DeleteRadixBatch Delete a batch
	DeleteRadixBatch(string) error
	// GetCompletedRadixBatchesSortedByCompletionTimeAsc Gets completed RadixBatch lists for env.RadixComponentName
	GetCompletedRadixBatchesSortedByCompletionTimeAsc() (*CompletedRadixBatches, error)
	//StopRadixBatch Stop a batch
	StopRadixBatch(string) error
	//StopRadixBatchJob Stop a batch job
	StopRadixBatchJob(string, string) error
}

func New

func New(kube *kube.Kube, env *models.Env) Handler

New Constructor of the batch handler