camel

Documentation

Index

• Constants
• Variables
• func AnnotationForIntegration(rc *ReconciliationRequest) map[string]string
• func LabelsForIntegration(rc *ReconciliationRequest) map[string]string
• func LabelsForIntegrationSelector(rc *ReconciliationRequest) map[string]string
• func WithCurrentGenerationSelector(rc *ReconciliationRequest) (labels.Selector, error)
• func WithIntegrationLabelsSelector() (labels.Selector, error)
• type Action
  • func NewConditionsAction() Action
  • func NewDeployAction() Action
• type ConditionsAction
  • func (a *ConditionsAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error
  • func (a *ConditionsAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)
  • func (a *ConditionsAction) Run(ctx context.Context, rc *ReconciliationRequest) error
• type DeployAction
  • func (a *DeployAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error
  • func (a *DeployAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)
  • func (a *DeployAction) Run(ctx context.Context, rc *ReconciliationRequest) error
• type Options
• type Reconciler
  • func NewReconciler(ctx context.Context, manager ctrlRt.Manager, _ Options) (*Reconciler, error)
  • func (r *Reconciler) EnqueueRequestForOwner(owner ctrlCli.Object, opts ...handler.OwnerOption) handler.EventHandler
  • func (r *Reconciler) EnqueueRequestsFromMapFunc(fn func(context.Context, ctrlCli.Object) []reconcile.Request) handler.EventHandler
  • func (r *Reconciler) Event(object runtime.Object, eventType string, reason string, message string)
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) Watch(obj ctrlCli.Object, eh handler.EventHandler, predicates ...predicate.Predicate) error
• type ReconciliationRequest

Constants

const (
	RuntimeContainerName  = "integration"
	RuntimeContainerImage = "quay.io/lburgazzoli/camel-go:latest"
	RuntimeRoutesPath     = "/etc/camel/sources.d/routes.yaml"
	RuntimeRoutesSubPath  = "routes.yaml"
)

const (
	IntegrationGeneration = "camel.apache.org/integration.generation"
	IntegrationName       = "camel.apache.org/integration.name"
	IntegrationNamespace  = "camel.apache.org/integration.namespace"
	IntegrationChecksum   = "camel.apache.org/integration.checksum"

	FinalizerName = "camel.apache.org/finalizer"
	FieldManager  = "camel-control-plane"

	ConditionReconciled = "Reconcile"
	ConditionReady      = "Ready"
	PhaseError          = "Error"
	PhaseReady          = "Ready"

	HTTPPort     int32  = 8080
	HTTPPortName string = "http"

	LivenessProbePath  string = "/health/live"
	ReadinessProbePath string = "/health/ready"
)

Variables

var (
	DefaultMemory = resource.MustParse("50Mi")
	DefaultCPU    = resource.MustParse("500m")
)

Functions

func AnnotationForIntegration

func AnnotationForIntegration(rc *ReconciliationRequest) map[string]string

func LabelsForIntegration

func LabelsForIntegration(rc *ReconciliationRequest) map[string]string

func LabelsForIntegrationSelector

func LabelsForIntegrationSelector(rc *ReconciliationRequest) map[string]string

func WithCurrentGenerationSelector

func WithCurrentGenerationSelector(rc *ReconciliationRequest) (labels.Selector, error)

func WithIntegrationLabelsSelector

func WithIntegrationLabelsSelector() (labels.Selector, error)

Types

type Action

type Action interface {
	Configure(context.Context, *client.Client, *builder.Builder) (*builder.Builder, error)
	Run(context.Context, *ReconciliationRequest) error
	Cleanup(context.Context, *ReconciliationRequest) error
}

func NewConditionsAction

func NewConditionsAction() Action

func NewDeployAction

func NewDeployAction() Action

type ConditionsAction

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

func (*ConditionsAction) Cleanup

func (a *ConditionsAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error

func (*ConditionsAction) Configure

func (a *ConditionsAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)

func (*ConditionsAction) Run

func (a *ConditionsAction) Run(ctx context.Context, rc *ReconciliationRequest) error

type DeployAction

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

func (*DeployAction) Cleanup

func (a *DeployAction) Cleanup(_ context.Context, _ *ReconciliationRequest) error

func (*DeployAction) Configure

func (a *DeployAction) Configure(_ context.Context, _ *client.Client, b *builder.Builder) (*builder.Builder, error)

func (*DeployAction) Run

func (a *DeployAction) Run(ctx context.Context, rc *ReconciliationRequest) error

type Options

type Options struct {
}

type Reconciler

type Reconciler struct {
	*client.Client

	Scheme      *runtime.Scheme
	ClusterType controller.ClusterType
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctx context.Context, manager ctrlRt.Manager, _ Options) (*Reconciler, error)

func (*Reconciler) EnqueueRequestForOwner

func (r *Reconciler) EnqueueRequestForOwner(owner ctrlCli.Object, opts ...handler.OwnerOption) handler.EventHandler

func (*Reconciler) EnqueueRequestsFromMapFunc

func (r *Reconciler) EnqueueRequestsFromMapFunc(fn func(context.Context, ctrlCli.Object) []reconcile.Request) handler.EventHandler

func (*Reconciler) Event

func (r *Reconciler) Event(object runtime.Object, eventType string, reason string, message string)

func (*Reconciler) Reconcile

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

func (*Reconciler) Watch

func (r *Reconciler) Watch(obj ctrlCli.Object, eh handler.EventHandler, predicates ...predicate.Predicate) error

type ReconciliationRequest

type ReconciliationRequest struct {
	*client.Client
	types.NamespacedName

	Reconciler  *Reconciler
	ClusterType controller.ClusterType
	Resource    *camelApi.Integration
	Checksum    string
}