dataflow

Documentation

Index

• func CreateDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig, ...) (*v1alpha1.NifiDataflowStatus, error)
• func DataflowExist(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)
• func IsOutOfSyncDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig, ...) (bool, error)
• func RemoveDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) (*v1alpha1.NifiDataflowStatus, error)
• func RootProcessGroup(config *clientconfig.NifiConfig) (string, error)
• func ScheduleDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) error
• func SyncDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig, ...) (*v1alpha1.NifiDataflowStatus, error)
• func UnscheduleDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) error

Functions

func CreateDataflow

func CreateDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig,
	registry *v1alpha1.NifiRegistryClient) (*v1alpha1.NifiDataflowStatus, error)

CreateDataflow will deploy the NifiDataflow on NiFi Cluster

func DataflowExist

func DataflowExist(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)

DataflowExist check if the NifiDataflow exist on NiFi Cluster

func IsOutOfSyncDataflow

func IsOutOfSyncDataflow(
	flow *v1alpha1.NifiDataflow,
	config *clientconfig.NifiConfig,
	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(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) (*v1alpha1.NifiDataflowStatus, error)

func RootProcessGroup

func RootProcessGroup(config *clientconfig.NifiConfig) (string, error)

func ScheduleDataflow

func ScheduleDataflow(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) error

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

func SyncDataflow

func SyncDataflow(
	flow *v1alpha1.NifiDataflow,
	config *clientconfig.NifiConfig,
	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(flow *v1alpha1.NifiDataflow, config *clientconfig.NifiConfig) error