nifi

Documentation

Index

• Constants
• func GetServerPort(l *v1alpha1.ListenersConfig) int32
• type Reconciler
  • func New(client client.Client, directClient client.Reader, scheme *runtime.Scheme, ...) *Reconciler
  • func (r *Reconciler) GetNifiPropertiesBase(id int32) *v1alpha1.NifiProperties
  • func (r *Reconciler) Reconcile(log zap.Logger) error

Constants

const (
	ContainerName string = "nifi"
)

Functions

func GetServerPort

func GetServerPort(l *v1alpha1.ListenersConfig) int32

TODO : manage default port

Types

type Reconciler

type Reconciler struct {
	resources.Reconciler
	Scheme *runtime.Scheme
}

Reconciler implements the Component Reconciler

func New

func New(client client.Client, directClient client.Reader, scheme *runtime.Scheme, cluster *v1alpha1.NifiCluster) *Reconciler

New creates a new reconciler for Nifi

func (*Reconciler) GetNifiPropertiesBase

func (r *Reconciler) GetNifiPropertiesBase(id int32) *v1alpha1.NifiProperties

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(log zap.Logger) error

Reconcile implements the reconcile logic for nifi