common

Documentation

Index

• Variables
• func CustomLogger() *zap.Logger
• func NewClusterConnection(log *zap.Logger, config *clientconfig.NifiConfig) (node nificlient.NifiClient, err error)
• func NewLogLevel(lvl string) (zapcore.Level, bool)
• 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 CustomLogger

func CustomLogger() *zap.Logger

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.

func NewLogLevel

func NewLogLevel(lvl string) (zapcore.Level, bool)

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