dataflow

Documentation

Index

• func CreateDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig, ...) (*v1.NifiDataflowStatus, error)
• func DataflowExist(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)
• func GetDataflowInformation(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (*nigoapi.ProcessGroupFlowEntity, error)
• func IsDataflowEmpty(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)
• func IsDataflowUnscheduled(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)
• func IsOutOfSyncDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig, ...) (bool, error)
• func RemoveDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (*v1.NifiDataflowStatus, error)
• func RootProcessGroup(config *clientconfig.NifiConfig) (string, error)
• func ScheduleDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) error
• func SyncDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig, ...) (*v1.NifiDataflowStatus, error)
• func UnscheduleDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) error

Functions

func CreateDataflow

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

CreateDataflow will deploy the NifiDataflow on NiFi Cluster.

func DataflowExist

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

DataflowExist check if the NifiDataflow exist on NiFi Cluster.

func GetDataflowInformation

func GetDataflowInformation(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (*nigoapi.ProcessGroupFlowEntity, error)

func IsDataflowEmpty

func IsDataflowEmpty(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)

Check if a dataflow contains flowfile.

func IsDataflowUnscheduled

func IsDataflowUnscheduled(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (bool, error)

IsDataflowUnscheduled control if the deployed dataflow has unscheduled controller services and components.

func IsOutOfSyncDataflow

func IsOutOfSyncDataflow(
	flow *v1.NifiDataflow,
	config *clientconfig.NifiConfig,
	registry *v1.NifiRegistryClient,
	parameterContext *v1.NifiParameterContext) (bool, error)

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

func RemoveDataflow

func RemoveDataflow(flow *v1.NifiDataflow, config *clientconfig.NifiConfig) (*v1.NifiDataflowStatus, error)

func RootProcessGroup

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

func ScheduleDataflow

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

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

func SyncDataflow

func SyncDataflow(
	flow *v1.NifiDataflow,
	config *clientconfig.NifiConfig,
	registry *v1.NifiRegistryClient,
	parameterContext *v1.NifiParameterContext) (*v1.NifiDataflowStatus, error)

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

func UnscheduleDataflow

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