job

Documentation

Index

• Constants
• Variables
• func DeleteAllMigrationJobs(ctx context.Context, c client.Client, store *v1.Store) error
• func DeleteSetupJob(ctx context.Context, c client.Client, store *v1.Store) error
• func GetMigrateHash(store *v1.Store) string
• func GetMigrationJob(ctx context.Context, client client.Client, store *v1.Store) (*batchv1.Job, error)
• func GetSetupJob(ctx context.Context, client client.Client, store *v1.Store) (*batchv1.Job, error)
• func GetSetupJobName(store *v1.Store) string
• func IsMigrationJobCompleted(ctx context.Context, c client.Client, store *v1.Store) (bool, error)
• func IsSetupJobCompleted(ctx context.Context, c client.Client, store *v1.Store) (bool, error)
• func MigrateJobName(store *v1.Store) string
• func MigrationJob(store *v1.Store) *batchv1.Job
• func SetupJob(store *v1.Store) *batchv1.Job
• type JobState
  • func IsJobContainerDone(ctx context.Context, c client.Client, job *batchv1.Job, containerName string) (JobState, error)
  • func (s JobState) HasErrors() bool
  • func (s JobState) IsDone() bool

Constants

const CONTAINER_NAME_MIGRATION_JOB = "shopware-migration"

const CONTAINER_NAME_SETUP_JOB = "shopware-setup"

Variables

var MigrationJobIdentifyer = map[string]string{"type": "migration"}

Functions

func DeleteAllMigrationJobs

func DeleteAllMigrationJobs(ctx context.Context, c client.Client, store *v1.Store) error

func DeleteSetupJob

func DeleteSetupJob(ctx context.Context, c client.Client, store *v1.Store) error

func GetMigrateHash

func GetMigrateHash(store *v1.Store) string

func GetMigrationJob

func GetMigrationJob(
	ctx context.Context,
	client client.Client,
	store *v1.Store,
) (*batchv1.Job, error)

func GetSetupJob

func GetSetupJob(ctx context.Context, client client.Client, store *v1.Store) (*batchv1.Job, error)

func GetSetupJobName

func GetSetupJobName(store *v1.Store) string

func IsMigrationJobCompleted

func IsMigrationJobCompleted(
	ctx context.Context,
	c client.Client,
	store *v1.Store,
) (bool, error)

This is just a soft check, use container check for a clean check Will return true if container is stopped (Completed, Error)

func IsSetupJobCompleted

func IsSetupJobCompleted(
	ctx context.Context,
	c client.Client,
	store *v1.Store,
) (bool, error)

This is just a soft check, use container check for a clean check Will return true if container is stopped (Completed, Error)

func MigrateJobName

func MigrateJobName(store *v1.Store) string

func MigrationJob

func MigrationJob(store *v1.Store) *batchv1.Job

func SetupJob

func SetupJob(store *v1.Store) *batchv1.Job

Types

type JobState

type JobState struct {
	ExitCode int
	Running  bool
}

func IsJobContainerDone

func IsJobContainerDone(
	ctx context.Context,
	c client.Client,
	job *batchv1.Job,
	containerName string,
) (JobState, error)

This is used when sidecars are able to run. We should always use this method for checking

func (JobState) HasErrors

func (s JobState) HasErrors() bool

func (JobState) IsDone

func (s JobState) IsDone() bool