reconciler

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	IndexEventInvolvedObjectName = ".index.eventOwner.name"
	IndexEventInvolvedObjectKind = ".index.eventOwner.kind"
	IndexEventReason             = ".index.reason"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CrashEvent

type CrashEvent struct {
	ProcessGUID    string
	Reason         string
	Instance       string
	Index          int
	ExitCode       int
	CrashCount     int
	CrashTimestamp int64
}

type CrashEventGenerator

type CrashEventGenerator interface {
	Generate(context.Context, *corev1.Pod, lager.Logger) *CrashEvent
}

type LRP

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

func NewLRP

func NewLRP(logger lager.Logger, client client.Client, desirer LRPDesirer, updater LRPUpdater) *LRP

func (*LRP) Reconcile

func (r *LRP) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type LRPDesirer

type LRPDesirer interface {
	Desire(ctx context.Context, lrp *eiriniv1.LRP) error
}

type LRPUpdater

type LRPUpdater interface {
	Update(ctx context.Context, lrp *eiriniv1.LRP, stSet *appsv1.StatefulSet) error
}

type PodCrash

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

func NewPodCrash

func NewPodCrash(logger lager.Logger, client client.Client, crashEventGenerator CrashEventGenerator) *PodCrash

func (PodCrash) Reconcile

func (r PodCrash) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type SourceTypeUpdatePredicate

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

func NewSourceTypeUpdatePredicate

func NewSourceTypeUpdatePredicate(sourceType string) SourceTypeUpdatePredicate

func (SourceTypeUpdatePredicate) Create

func (SourceTypeUpdatePredicate) Delete

func (SourceTypeUpdatePredicate) Generic

func (SourceTypeUpdatePredicate) Update

type Task

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

func NewTask

func NewTask(logger lager.Logger,
	client client.Client,
	desirer TaskDesirer,
	statusGetter TaskStatusGetter,
	ttlSeconds int,
) *Task

func (*Task) Reconcile

func (t *Task) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type TaskDesirer

type TaskDesirer interface {
	Desire(ctx context.Context, task *eiriniv1.Task) (*batchv1.Job, error)
}

type TaskStatusGetter

type TaskStatusGetter interface {
	GetStatusConditions(ctx context.Context, job *batchv1.Job) ([]metav1.Condition, error)
}

Directories

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

Jump to

Keyboard shortcuts

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