presto

Documentation

Index

• Constants
• func Add(mgr manager.Manager, metricsClient *metrics.MetricsV1beta1Client, ...) error
• type ClusterUpdateAction
• type CommandLineParams
• type GenerationChangedPredicate
  • func (GenerationChangedPredicate) Update(e event.UpdateEvent) bool
• type OperatorError
  • func (e *OperatorError) Error() string
• type ReconcilePresto
  • func (r *ReconcilePresto) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

const (
	ControllerName string = "presto-controller"
)

const (
	DefaultTerminationGracePeriodSeconds = 7200
)

Functions

func Add

func Add(mgr manager.Manager, metricsClient *metrics.MetricsV1beta1Client,
	cmdLineParams CommandLineParams, log logr.Logger) error

Add creates a new Presto Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type ClusterUpdateAction

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

type CommandLineParams

type CommandLineParams struct {
	StatusUpdateInterval int
}

type GenerationChangedPredicate

type GenerationChangedPredicate struct {
	predicate.Funcs
}

func (GenerationChangedPredicate) Update

func (GenerationChangedPredicate) Update(e event.UpdateEvent) bool

Predicate to ignore the Update events where the resource version has not been changed This is needed to avoid the events generated by the status updates. The idea has been picked up from here: https://www.openshift.com/blog/kubernetes-operators-best-practices

type OperatorError

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

func (*OperatorError) Error

func (e *OperatorError) Error() string

type ReconcilePresto

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

ReconcilePresto reconciles a Presto object

func (*ReconcilePresto) Reconcile

func (r *ReconcilePresto) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Presto object and makes changes based on the state read and what is in the Presto.Spec