batch

package

v1.17.0 Latest Latest Go to latest Published: Jul 18, 2025 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/equinor/radix-job-scheduler

Links

Open Source Insights

Documentation ¶

Overview ¶

Package batch is a generated GoMock package.

Index ¶

func CopyRadixBatchOrJob(ctx context.Context, radixClient versioned.Interface, ...) (*modelsv1.BatchStatus, error)
func DeleteRadixBatch(ctx context.Context, radixClient versioned.Interface, ...) error
func DeleteRadixBatchByName(ctx context.Context, radixClient versioned.Interface, ...) error
func GetRadixBatchStatus(radixBatch *radixv1.RadixBatch, ...) *modelsv1.BatchStatus
func GetRadixBatchStatuses(radixBatches []*radixv1.RadixBatch, ...) []modelsv1.BatchStatus
func RestartRadixBatch(ctx context.Context, radixClient versioned.Interface, ...) error
func RestartRadixBatchJob(ctx context.Context, radixClient versioned.Interface, ...) error
func StopAllRadixBatches(ctx context.Context, radixClient versioned.Interface, ...) error
func StopRadixBatch(ctx context.Context, radixClient versioned.Interface, ...) error
func StopRadixBatchJob(ctx context.Context, radixClient versioned.Interface, ...) error
type CompletedRadixBatchNames
type History
- func NewHistory(kubeUtil *kube.Kube, env *models.Env, ...) History
type MockHistory
- func NewMockHistory(ctrl *gomock.Controller) *MockHistory
- func (m *MockHistory) Cleanup(ctx context.Context, existingRadixBatchNamesMap map[string]struct{}) error
- func (m *MockHistory) EXPECT() *MockHistoryMockRecorder
type MockHistoryMockRecorder
- func (mr *MockHistoryMockRecorder) Cleanup(ctx, existingRadixBatchNamesMap interface{}) *gomock.Call

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CopyRadixBatchOrJob ¶

func CopyRadixBatchOrJob(ctx context.Context, radixClient versioned.Interface, sourceRadixBatch *radixv1.RadixBatch, sourceJobName string,
	radixDeployJobComponent *radixv1.RadixDeployJobComponent, radixDeploymentName string) (*modelsv1.BatchStatus, error)

CopyRadixBatchOrJob Copy the Radix batch or job

func DeleteRadixBatch ¶

func DeleteRadixBatch(ctx context.Context, radixClient versioned.Interface, radixBatch *radixv1.RadixBatch) error

DeleteRadixBatch Delete a batch

func DeleteRadixBatchByName ¶ added in v1.11.0

func DeleteRadixBatchByName(ctx context.Context, radixClient versioned.Interface, namespace, batchName string) error

DeleteRadixBatchByName Delete a batch by name

func GetRadixBatchStatus ¶

func GetRadixBatchStatus(radixBatch *radixv1.RadixBatch, radixDeployJobComponent *radixv1.RadixDeployJobComponent) *modelsv1.BatchStatus

GetRadixBatchStatus Get radix batch

func GetRadixBatchStatuses ¶

func GetRadixBatchStatuses(radixBatches []*radixv1.RadixBatch, radixDeployJobComponent *radixv1.RadixDeployJobComponent) []modelsv1.BatchStatus

GetRadixBatchStatuses Convert to radix batch statuses

func RestartRadixBatch ¶

func RestartRadixBatch(ctx context.Context, radixClient versioned.Interface, radixBatch *radixv1.RadixBatch) error

RestartRadixBatch Restart a batch

func RestartRadixBatchJob ¶

func RestartRadixBatchJob(ctx context.Context, radixClient versioned.Interface, radixBatch *radixv1.RadixBatch, jobName string) error

RestartRadixBatchJob Restart a job

func StopAllRadixBatches ¶ added in v1.14.0

func StopAllRadixBatches(ctx context.Context, radixClient versioned.Interface, appName, envName, jobComponentName string, batchType kube.RadixBatchType) error

StopAllRadixBatches Stop all batches

func StopRadixBatch ¶

func StopRadixBatch(ctx context.Context, radixClient versioned.Interface, appName, envName, jobComponentName, batchName string) error

StopRadixBatch Stop a batch

func StopRadixBatchJob ¶

func StopRadixBatchJob(ctx context.Context, radixClient versioned.Interface, appName, envName, jobComponentName, batchName, jobName string) error

StopRadixBatchJob Stop a job

Types ¶

type CompletedRadixBatchNames ¶ added in v1.14.0

type CompletedRadixBatchNames struct {
	SucceededRadixBatches    []string
	NotSucceededRadixBatches []string
	SucceededSingleJobs      []string
	NotSucceededSingleJobs   []string
}

CompletedRadixBatchNames Completed BatchStatus lists

type History ¶ added in v1.11.0

type History interface {
	// Cleanup the pipeline job history for the Radix application
	Cleanup(ctx context.Context, existingRadixBatchNamesMap map[string]struct{}) error
}

History Interface for job History

func NewHistory ¶ added in v1.11.0

func NewHistory(kubeUtil *kube.Kube, env *models.Env, radixDeployJobComponent *radixv1.RadixDeployJobComponent) History

NewHistory Constructor for job History

type MockHistory ¶ added in v1.11.0

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

MockHistory is a mock of History interface.

func NewMockHistory ¶ added in v1.11.0

func NewMockHistory(ctrl *gomock.Controller) *MockHistory

NewMockHistory creates a new mock instance.

func (*MockHistory) Cleanup ¶ added in v1.11.0

func (m *MockHistory) Cleanup(ctx context.Context, existingRadixBatchNamesMap map[string]struct{}) error

Cleanup mocks base method.

func (*MockHistory) EXPECT ¶ added in v1.11.0

func (m *MockHistory) EXPECT() *MockHistoryMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockHistoryMockRecorder ¶ added in v1.11.0

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

MockHistoryMockRecorder is the mock recorder for MockHistory.

func (*MockHistoryMockRecorder) Cleanup ¶ added in v1.11.0

func (mr *MockHistoryMockRecorder) Cleanup(ctx, existingRadixBatchNamesMap interface{}) *gomock.Call

Cleanup indicates an expected call of Cleanup.

Source Files ¶

View all Source files

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