integration

Documentation

Index

• Constants
• Variables
• func Add(ctx context.Context, mgr manager.Manager, c client.Client) error
• func NewHealthCheck(body []byte) (*v1.HealthCheck, error)
• type Action
  • func NewInitializeAction() Action
  • func NewMonitorAction() Action
  • func NewMonitorSyntheticAction() Action
  • func NewMonitorUnknownAction() Action
  • func NewPlatformSetupAction() Action
• type StatusChangedPredicate
  • func (StatusChangedPredicate) Update(e event.UpdateEvent) bool

Constants

const (
	// The key used for propagating error details from Camel health to MicroProfile Health
	// (See CAMEL-17138).
	HealthCheckErrorMessage = "error.message"
)

Variables

var Log = log.Log.WithName("controller").WithName("integration")

Log --.

Functions

func Add

func Add(ctx context.Context, mgr manager.Manager, c client.Client) error

func NewHealthCheck

func NewHealthCheck(body []byte) (*v1.HealthCheck, error)

Types

type Action

type Action interface {
	client.Injectable
	log.Injectable

	// a user friendly name for the action
	Name() string

	// returns true if the action can handle the integration
	CanHandle(integration *v1.Integration) bool

	// executes the handling function
	Handle(ctx context.Context, integration *v1.Integration) (*v1.Integration, error)
}

Action --.

func NewInitializeAction

func NewInitializeAction() Action

NewInitializeAction creates a new initialize action.

func NewMonitorAction

func NewMonitorAction() Action

NewMonitorAction is an action used to monitor manager Integrations.

func NewMonitorSyntheticAction

func NewMonitorSyntheticAction() Action

NewMonitorSyntheticAction is an action used to monitor synthetic Integrations.

func NewMonitorUnknownAction

func NewMonitorUnknownAction() Action

NewMonitorUnknownAction is an action used to verify when an Integration can be monitored back again.

func NewPlatformSetupAction

func NewPlatformSetupAction() Action

NewPlatformSetupAction creates a new platform-setup action.

type StatusChangedPredicate

type StatusChangedPredicate struct {
	predicate.Funcs
}

StatusChangedPredicate implements a generic update predicate function on status change.

func (StatusChangedPredicate) Update

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

Update implements default UpdateEvent filter for validating status change.