jobs

package

v0.0.0-...-db62745 Latest Latest Go to latest Published: Aug 31, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Details

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

Repository

github.com/cloudfoundry/eirini

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Converter
- func NewTaskToJobConverter(serviceAccountName string, registrySecretName string, ...) *Converter
- func (m *Converter) Convert(task *api.Task, privateRegistrySecret *corev1.Secret) *batch.Job
type Deleter
- func NewDeleter(logger lager.Logger, jobGetter JobGetter, jobDeleter JobDeleter) Deleter
- func (d *Deleter) Delete(ctx context.Context, guid string) (string, error)
type Desirer
- func NewDesirer(logger lager.Logger, taskToJobConverter TaskToJobConverter, ...) Desirer
- func (d *Desirer) Desire(ctx context.Context, namespace string, task *api.Task, opts ...shared.Option) error
type Getter
- func NewGetter(jobGetter JobGetter) Getter
- func (g *Getter) Get(ctx context.Context, taskGUID string) (*api.Task, error)
type JobCreator
type JobDeleter
type JobGetter
type JobLister
type Lister
- func NewLister(jobLister JobLister) Lister
- func (l *Lister) List(ctx context.Context) ([]*api.Task, error)
type SecretsClient
type TaskToJobConverter

Constants ¶

View Source

const (
	TaskSourceType = "TASK"

	AnnotationGUID                        = "cloudfoundry.org/guid"
	AnnotationAppName                     = stset.AnnotationAppName
	AnnotationAppID                       = stset.AnnotationAppID
	AnnotationOrgName                     = stset.AnnotationOrgName
	AnnotationOrgGUID                     = stset.AnnotationOrgGUID
	AnnotationSpaceName                   = stset.AnnotationSpaceName
	AnnotationSpaceGUID                   = stset.AnnotationSpaceGUID
	AnnotationCompletionCallback          = "cloudfoundry.org/completion_callback"
	AnnotationTaskContainerName           = "cloudfoundry.org/opi-task-container-name"
	AnnotationTaskCompletionReportCounter = "cloudfoundry.org/task_completion_report_counter"
	AnnotationCCAckedTaskCompletion       = "cloudfoundry.org/cc_acked_task_completion"

	LabelGUID          = stset.LabelGUID
	LabelName          = "cloudfoundry.org/name"
	LabelAppGUID       = stset.LabelAppGUID
	LabelSourceType    = stset.LabelSourceType
	LabelTaskCompleted = "cloudfoundry.org/task_completed"

	TaskCompletedTrue                 = "true"
	PrivateRegistrySecretGenerateName = stset.PrivateRegistrySecretGenerateName
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Converter ¶

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

func NewTaskToJobConverter ¶

func NewTaskToJobConverter(
	serviceAccountName string,
	registrySecretName string,
	allowAutomountServiceAccountToken bool,
	latestMigration int,
) *Converter

func (*Converter) Convert ¶

func (m *Converter) Convert(task *api.Task, privateRegistrySecret *corev1.Secret) *batch.Job

type Deleter ¶

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

func NewDeleter ¶

func NewDeleter(
	logger lager.Logger,
	jobGetter JobGetter,
	jobDeleter JobDeleter,
) Deleter

func (*Deleter) Delete ¶

func (d *Deleter) Delete(ctx context.Context, guid string) (string, error)

type Desirer ¶

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

func NewDesirer ¶

func NewDesirer(
	logger lager.Logger,
	taskToJobConverter TaskToJobConverter,
	jobCreator JobCreator,
	secretCreator SecretsClient,
) Desirer

func (*Desirer) Desire ¶

func (d *Desirer) Desire(ctx context.Context, namespace string, task *api.Task, opts ...shared.Option) error

type Getter ¶

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

func NewGetter ¶

func NewGetter(
	jobGetter JobGetter,
) Getter

func (*Getter) Get ¶

func (g *Getter) Get(ctx context.Context, taskGUID string) (*api.Task, error)

type JobCreator ¶

type JobCreator interface {
	Create(ctx context.Context, namespace string, job *batch.Job) (*batch.Job, error)
}

type JobDeleter ¶

type JobDeleter interface {
	Delete(ctx context.Context, namespace string, name string) error
}

type JobGetter ¶

type JobGetter interface {
	GetByGUID(ctx context.Context, guid string, includeCompleted bool) ([]batchv1.Job, error)
}

type JobLister ¶

type JobLister interface {
	List(ctx context.Context, includeCompleted bool) ([]batch.Job, error)
}

type Lister ¶

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

func NewLister ¶

func NewLister(
	jobLister JobLister,
) Lister

func (*Lister) List ¶

func (l *Lister) List(ctx context.Context) ([]*api.Task, error)

type SecretsClient ¶

type SecretsClient interface {
	Create(ctx context.Context, namespace string, secret *corev1.Secret) (*corev1.Secret, error)
	SetOwner(ctx context.Context, secret *corev1.Secret, owner metav1.Object) (*corev1.Secret, error)
	Delete(ctx context.Context, namespace string, name string) error
}

type TaskToJobConverter ¶

type TaskToJobConverter interface {
	Convert(*api.Task, *corev1.Secret) *batch.Job
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
jobsfakes Code generated by counterfeiter.	Code generated by counterfeiter.

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