Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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 CustomLogger ¶
func NewClusterConnection ¶
func NewClusterConnection(log *zap.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
NodeGroupAutoscalerRequeueInterval int
ParameterContextRequeueInterval int
UserGroupRequeueInterval int
DataFlowRequeueInterval int
ConnectionRequeueInterval int
ClusterTaskRequeueIntervals map[string]int
RequeueOffset int
}
func NewRequeueConfig ¶
func NewRequeueConfig() *RequeueConfig
Source Files
Click to show internal directories.
Click to hide internal directories.