connection

Documentation

Index

• func ConnectionExist(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) (bool, error)
• func CreateConnection(connection *v1alpha1.NifiConnection, source *v1alpha1.ComponentInformation, ...) (*v1alpha1.NifiConnectionStatus, error)
• func DeleteConnection(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) error
• func DropConnectionFlowFiles(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) error
• func GetConnectionInformation(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) (*nigoapi.ConnectionEntity, error)
• func IsOutOfSyncConnection(connection *v1alpha1.NifiConnection, source *v1alpha1.ComponentInformation, ...) (bool, error)
• func SyncConnectionConfig(connection *v1alpha1.NifiConnection, source *v1alpha1.ComponentInformation, ...) (*v1alpha1.NifiConnectionStatus, error)
• func SyncConnectionDestination(connection *v1alpha1.NifiConnection, ...) (*v1alpha1.NifiConnectionStatus, error)

Functions

func ConnectionExist

func ConnectionExist(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) (bool, error)

ConnectionExist check if the NifiConnection exist on NiFi Cluster.

func CreateConnection

func CreateConnection(connection *v1alpha1.NifiConnection, source *v1alpha1.ComponentInformation, destination *v1alpha1.ComponentInformation,
	config *clientconfig.NifiConfig) (*v1alpha1.NifiConnectionStatus, error)

CreateConnection will deploy the NifiDataflow on NiFi Cluster.

func DeleteConnection

func DeleteConnection(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) error

DeleteConnection implements the logic to delete a connection.

func DropConnectionFlowFiles

func DropConnectionFlowFiles(connection *v1alpha1.NifiConnection,
	config *clientconfig.NifiConfig) error

DropConnectionFlowFiles implements the logic to drop the flowfiles from a connection.

func GetConnectionInformation

func GetConnectionInformation(connection *v1alpha1.NifiConnection, config *clientconfig.NifiConfig) (*nigoapi.ConnectionEntity, error)

GetConnectionInformation retrieve the connection information.

func IsOutOfSyncConnection

func IsOutOfSyncConnection(connection *v1alpha1.NifiConnection,
	source *v1alpha1.ComponentInformation, destination *v1alpha1.ComponentInformation,
	config *clientconfig.NifiConfig) (bool, error)

IsOutOfSyncConnection control if the deployed connection is out of sync with the NifiConnection resource.

func SyncConnectionConfig

func SyncConnectionConfig(connection *v1alpha1.NifiConnection,
	source *v1alpha1.ComponentInformation, destination *v1alpha1.ComponentInformation,
	config *clientconfig.NifiConfig) (*v1alpha1.NifiConnectionStatus, error)

SyncConnectionConfig implements the logic to sync a NifiConnection config with the deployed connection config.

func SyncConnectionDestination

func SyncConnectionDestination(connection *v1alpha1.NifiConnection, destination *v1alpha1.ComponentInformation,
	config *clientconfig.NifiConfig) (*v1alpha1.NifiConnectionStatus, error)

SyncConnectionDestination implements the logic to sync a NifiConnection with the deployed connection destination.