reconciler

Documentation

Index

• Constants
• type CrashEvent
• type CrashEventGenerator
• type LRP
  • func NewLRP(logger lager.Logger, client client.Client, desirer LRPDesirer, ...) *LRP
  • func (r *LRP) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type LRPDesirer
• type LRPUpdater
• type PodCrash
  • func NewPodCrash(logger lager.Logger, client client.Client, ...) *PodCrash
  • func (r PodCrash) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type SourceTypeUpdatePredicate
  • func NewSourceTypeUpdatePredicate(sourceType string) SourceTypeUpdatePredicate
  • func (SourceTypeUpdatePredicate) Create(event.CreateEvent) bool
  • func (SourceTypeUpdatePredicate) Delete(event.DeleteEvent) bool
  • func (SourceTypeUpdatePredicate) Generic(event.GenericEvent) bool
  • func (p SourceTypeUpdatePredicate) Update(e event.UpdateEvent) bool
• type Task
  • func NewTask(logger lager.Logger, client client.Client, desirer TaskDesirer, ...) *Task
  • func (t *Task) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type TaskDesirer
• type TaskStatusGetter

Constants

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

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) Create(event.CreateEvent) bool

func (SourceTypeUpdatePredicate) Delete

func (SourceTypeUpdatePredicate) Delete(event.DeleteEvent) bool

func (SourceTypeUpdatePredicate) Generic

func (SourceTypeUpdatePredicate) Generic(event.GenericEvent) bool

func (SourceTypeUpdatePredicate) Update

func (p SourceTypeUpdatePredicate) Update(e event.UpdateEvent) bool

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)
}