dataflow

Documentation

Index

• func CreateDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) (*v1alpha1.NifiDataflowStatus, error)
• func DataflowExist(client client.Client, flow *v1alpha1.NifiDataflow, ...) (bool, error)
• func IsOutOfSyncDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) (bool, error)
• func RemoveDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) (*v1alpha1.NifiDataflowStatus, error)
• func RootProcessGroup(client client.Client, cluster *v1alpha1.NifiCluster) (string, error)
• func ScheduleDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) error
• func SyncDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) (*v1alpha1.NifiDataflowStatus, error)
• func UnscheduleDataflow(client client.Client, flow *v1alpha1.NifiDataflow, ...) error

Functions

func CreateDataflow

func CreateDataflow(
	client client.Client,
	flow *v1alpha1.NifiDataflow,
	cluster *v1alpha1.NifiCluster,
	registry *v1alpha1.NifiRegistryClient) (*v1alpha1.NifiDataflowStatus, error)

CreateDataflow will deploy the NifiDataflow on NiFi Cluster

func DataflowExist

func DataflowExist(client client.Client, flow *v1alpha1.NifiDataflow, cluster *v1alpha1.NifiCluster) (bool, error)

DataflowExist check if the NifiDataflow exist on NiFi Cluster

func IsOutOfSyncDataflow

func IsOutOfSyncDataflow(
	client client.Client,
	flow *v1alpha1.NifiDataflow,
	cluster *v1alpha1.NifiCluster,
	registry *v1alpha1.NifiRegistryClient,
	parameterContext *v1alpha1.NifiParameterContext) (bool, error)

IsOutOfSyncDataflow control if the deployed dataflow is out of sync with the NifiDataflow resource

func RemoveDataflow

func RemoveDataflow(
	client client.Client,
	flow *v1alpha1.NifiDataflow,
	cluster *v1alpha1.NifiCluster) (*v1alpha1.NifiDataflowStatus, error)

func RootProcessGroup

func RootProcessGroup(client client.Client, cluster *v1alpha1.NifiCluster) (string, error)

func ScheduleDataflow

func ScheduleDataflow(client client.Client, flow *v1alpha1.NifiDataflow, cluster *v1alpha1.NifiCluster) error

ScheduleDataflow will schedule the controller services and components of the NifiDataflow.

func SyncDataflow

func SyncDataflow(
	client client.Client,
	flow *v1alpha1.NifiDataflow,
	cluster *v1alpha1.NifiCluster,
	registry *v1alpha1.NifiRegistryClient,
	parameterContext *v1alpha1.NifiParameterContext) (*v1alpha1.NifiDataflowStatus, error)

SyncDataflow implements the logic to sync a NifiDataflow with the deployed flow.

func UnscheduleDataflow

func UnscheduleDataflow(client client.Client, flow *v1alpha1.NifiDataflow, cluster *v1alpha1.NifiCluster) error