Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ProcessorExist ¶
func ProcessorExist(client client.Client, processor *v1alpha1.ProcessorControl, cluster *v1alpha1.NifiCluster) (bool, error)
ProcessorExist check if the Processor exist on NiFi Cluster
func ScheduleProcessor ¶
func ScheduleProcessor(client client.Client, processor *v1alpha1.ProcessorControl, cluster *v1alpha1.NifiCluster) error
ScheduleProcessor will schedule the processor in the sequence listed in ProcessorControl.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.