preview

Documentation

Index

• func NewProfileReconciler(client client.Client, cfg *rest.Config, recorder record.EventRecorder) profiles.ProfileReconciler
• type CreationTimestamp
  • func (a CreationTimestamp) Len() int
  • func (a CreationTimestamp) Less(i, j int) bool
  • func (a CreationTimestamp) Swap(i, j int)
• type DeploymentReconciler
  • func NewDeploymentReconciler(stateSupport *common.StateSupport, ensurer *ObjectEnsurers) *DeploymentReconciler
  • func (d *DeploymentReconciler) Reconcile(ctx context.Context, workflow *operatorapi.SonataFlow) (reconcile.Result, []client.Object, error)
• type ObjectEnsurers
  • func NewObjectEnsurers(support *common.StateSupport) *ObjectEnsurers
  • func (o *ObjectEnsurers) DeploymentByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurerWithPlatform
  • func (o *ObjectEnsurers) ServiceByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurer
  • func (o *ObjectEnsurers) ServiceMonitorByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurer

Functions

func NewProfileReconciler

func NewProfileReconciler(client client.Client, cfg *rest.Config, recorder record.EventRecorder) profiles.ProfileReconciler

NewProfileReconciler the default profile builder which includes a build state to run an internal build process to have an immutable workflow image deployed

Types

type CreationTimestamp

type CreationTimestamp []servingv1.Revision

func (CreationTimestamp) Len

func (a CreationTimestamp) Len() int

func (CreationTimestamp) Less

func (a CreationTimestamp) Less(i, j int) bool

func (CreationTimestamp) Swap

func (a CreationTimestamp) Swap(i, j int)

type DeploymentReconciler

type DeploymentReconciler struct {
	*common.StateSupport
	// contains filtered or unexported fields
}

func NewDeploymentReconciler

func NewDeploymentReconciler(stateSupport *common.StateSupport, ensurer *ObjectEnsurers) *DeploymentReconciler

func (*DeploymentReconciler) Reconcile

func (d *DeploymentReconciler) Reconcile(ctx context.Context, workflow *operatorapi.SonataFlow) (reconcile.Result, []client.Object, error)

type ObjectEnsurers

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

ObjectEnsurers is a struct for the objects that ReconciliationState needs to create in the platform for the preview profile. ReconciliationState that needs access to it must include this struct as an attribute and initialize it in the profile builder. Use NewObjectEnsurers to facilitate building this struct

func NewObjectEnsurers

func NewObjectEnsurers(support *common.StateSupport) *ObjectEnsurers

NewObjectEnsurers common.ObjectEnsurer(s) for the preview profile.

func (*ObjectEnsurers) DeploymentByDeploymentModel

func (o *ObjectEnsurers) DeploymentByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurerWithPlatform

DeploymentByDeploymentModel gets the deployment ensurer based on the SonataFlow deployment model

func (*ObjectEnsurers) ServiceByDeploymentModel

func (o *ObjectEnsurers) ServiceByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurer

ServiceByDeploymentModel gets the service ensurer based on the SonataFlow deployment model

func (*ObjectEnsurers) ServiceMonitorByDeploymentModel

func (o *ObjectEnsurers) ServiceMonitorByDeploymentModel(workflow *v1alpha08.SonataFlow) common.ObjectEnsurer

ServiceMonitorByDeploymentModel gets the service monitor ensurer based on the SonataFlow deployment model