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

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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