common

Documentation

Index

• Variables
• func NewClusterConnection(log logr.Logger, config *clientconfig.NifiConfig) (node nificlient.NifiClient, err error)
• type RequeueConfig
  • func NewRequeueConfig() *RequeueConfig

Variables

var NewNifiFromConfig = nificlient.NewFromConfig

NewNifiFromCluster points to the function for retrieving nifi clients, use as var so it can be overwritten from unit tests

Functions

func NewClusterConnection

func NewClusterConnection(log logr.Logger, config *clientconfig.NifiConfig) (node nificlient.NifiClient, err error)

newNodeConnection is a convenience wrapper for creating a node connection and creating a safer close function

Types

type RequeueConfig

type RequeueConfig struct {
	UserRequeueInterval             int
	RegistryClientRequeueInterval   int
	ParameterContextRequeueInterval int
	UserGroupRequeueInterval        int
	DataFlowRequeueInterval         int
	ClusterTaskRequeueIntervals     map[string]int
	RequeueOffset                   int
}

func NewRequeueConfig

func NewRequeueConfig() *RequeueConfig