jaeger

Documentation

Index

• Variables
• type ReconcileJaeger
  • func New(client client.Client, clientReader client.Reader, scheme *runtime.Scheme) *ReconcileJaeger
  • func (r *ReconcileJaeger) Reconcile(request reconcile.Request) (reconcile.Result, error)

Variables

var (
	// ErrDependencyRemoved is returned when a dependency existed but has been removed
	ErrDependencyRemoved = errors.New("dependency has been removed")
)

var (
	// ErrDeploymentRemoved is returned when a deployment existed but has been removed
	ErrDeploymentRemoved = errors.New("deployment has been removed")
)

var (
	// ErrElasticsearchRemoved is returned when an ES cluster existed but has been removed
	ErrElasticsearchRemoved = errors.New("Elasticsearch cluster has been removed")
)

var (
	// ErrKafkaRemoved is returned when a kafka existed but has been removed
	ErrKafkaRemoved = errors.New("kafka has been removed")
)

var (
	// ErrKafkaUserRemoved is returned when a kafka user existed but has been removed
	ErrKafkaUserRemoved = errors.New("kafka user has been removed")
)

Types

type ReconcileJaeger

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

ReconcileJaeger reconciles a Jaeger object

func New

func New(client client.Client, clientReader client.Reader, scheme *runtime.Scheme) *ReconcileJaeger

New creates new jaeger controller

func (*ReconcileJaeger) Reconcile

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

Reconcile reads that state of the cluster for a Jaeger object and makes changes based on the state read and what is in the Jaeger.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.