controllers

Documentation

Index

• Constants
• func SetupIndexes(indexer client.FieldIndexer) error
• type LeaderWorkerSetReconciler
  • func NewLeaderWorkerSetReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *LeaderWorkerSetReconciler
  • func (r *LeaderWorkerSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *LeaderWorkerSetReconciler) SSAWithStatefulset(ctx context.Context, lws *leaderworkerset.LeaderWorkerSet, partition int32) error
  • func (r *LeaderWorkerSetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PodReconciler
  • func NewPodReconciler(client client.Client, schema *runtime.Scheme) *PodReconciler
  • func (r *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// FailedCreate Event reason used when a resource creation fails.
	// The event uses the error(s) as the reason.
	FailedCreate = "FailedCreate"
)

Functions

func SetupIndexes

func SetupIndexes(indexer client.FieldIndexer) error

Types

type LeaderWorkerSetReconciler

type LeaderWorkerSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Record record.EventRecorder
}

LeaderWorkerSetReconciler reconciles a LeaderWorkerSet object

func NewLeaderWorkerSetReconciler

func NewLeaderWorkerSetReconciler(client client.Client, scheme *runtime.Scheme, record record.EventRecorder) *LeaderWorkerSetReconciler

func (*LeaderWorkerSetReconciler) Reconcile

func (r *LeaderWorkerSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LeaderWorkerSetReconciler) SSAWithStatefulset

func (r *LeaderWorkerSetReconciler) SSAWithStatefulset(ctx context.Context, lws *leaderworkerset.LeaderWorkerSet, partition int32) error

func (*LeaderWorkerSetReconciler) SetupWithManager

func (r *LeaderWorkerSetReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PodReconciler

type PodReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

PodReconciler reconciles a LeaderWorkerSet object

func NewPodReconciler

func NewPodReconciler(client client.Client, schema *runtime.Scheme) *PodReconciler

func (*PodReconciler) Reconcile

func (r *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PodReconciler) SetupWithManager

func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error