dataflow

package
v0.7.0-release Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateDataflow

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 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

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

func UnscheduleDataflow

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL