v1alpha1

package
v1.8.0-release Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the nifi v1alpha1 API group +kubebuilder:object:generate=true +groupName=nifi.konpyutaika.com

Index

Constants

View Source 
const (
	// Global access policies govern the following system level authorizations.
	GlobalAccessPolicyType AccessPolicyType = "global"
	// Component level access policies govern the following component level authorizations.
	ComponentAccessPolicyType AccessPolicyType = "component"

	// Allows users to view.
	ReadAccessPolicyAction AccessPolicyAction = "read"
	// Allows users to modify.
	WriteAccessPolicyAction AccessPolicyAction = "write"

	// Global
	// About the UI.
	FlowAccessPolicyResource AccessPolicyResource = "/flow"
	// About the controller including Reporting Tasks, Controller Services, Parameter Contexts and Nodes in the Cluster.
	ControllerAccessPolicyResource AccessPolicyResource = "/controller"
	// About the Parameter Contexts. Access to Parameter Contexts are inherited from the "access the controller"
	// policies unless overridden.
	ParameterContextAccessPolicyResource AccessPolicyResource = "/parameter-context"
	// Allows users to submit a Provenance Search and request Event Lineage.
	ProvenanceAccessPolicyResource AccessPolicyResource = "/provenance"
	// About the restricted components assuming other permissions are sufficient. The restricted components may
	// indicate which specific permissions are required. Permissions can be granted for specific restrictions or
	// be granted regardless of restrictions. If permission is granted regardless of restrictions,
	// the user can create/modify all restricted components.
	RestrictedComponentsAccessPolicyResource AccessPolicyResource = "/restricted-components"
	// About the policies for all components.
	PoliciesAccessPolicyResource AccessPolicyResource = "/policies"
	// About the users and user groups.
	TenantsAccessPolicyResource AccessPolicyResource = "/tenants"
	// Allows other NiFi instances to retrieve Site-To-Site details.
	SiteToSiteAccessPolicyResource AccessPolicyResource = "/site-to-site"
	// Allows users to view System Diagnostics.
	SystemAccessPolicyResource AccessPolicyResource = "/system"
	// Allows proxy machines to send requests on the behalf of others.
	ProxyAccessPolicyResource AccessPolicyResource = "/proxy"
	// About counters.
	CountersAccessPolicyResource AccessPolicyResource = "/counters"

	// Component
	// About the component configuration details.
	ComponentsAccessPolicyResource AccessPolicyResource = "/"
	// to operate components by changing component run status (start/stop/enable/disable),
	// remote port transmission status, or terminating processor threads.
	OperationAccessPolicyResource AccessPolicyResource = "/operation"
	// to view provenance events generated by this component.
	ProvenanceDataAccessPolicyResource AccessPolicyResource = "/provenance-data"
	// About metadata and content for this component in flowfile queues in outbound connections
	// and through provenance events.
	DataAccessPolicyResource AccessPolicyResource = "/data"
	//
	PoliciesComponentAccessPolicyResource AccessPolicyResource = "/policies"
	// Allows a port to receive data from NiFi instances.
	DataTransferAccessPolicyResource AccessPolicyResource = "/data-transfer"

	// ComponentType.
	ProcessGroupType string = "process-groups"
)
View Source 
const (
	// DataflowStateCreated describes the status of a NifiDataflow as created.
	DataflowStateCreated DataflowState = "Created"
	// DataflowStateStarting describes the status of a NifiDataflow as starting.
	DataflowStateStarting DataflowState = "Starting"
	// DataflowStateRunning describes the status of a NifiDataflow as running.
	DataflowStateRan DataflowState = "Ran"
	// DataflowStateOutOfSync describes the status of a NifiDataflow as out of sync.
	DataflowStateOutOfSync DataflowState = "OutOfSync"
	// DataflowStateInSync describes the status of a NifiDataflow as in sync.
	DataflowStateInSync DataflowState = "InSync"

	// ConnectionStateOutOfSync describes the status of a NifiConnection as out of sync.
	ConnectionStateOutOfSync ConnectionState = "OutOfSync"
	// ConnectionStateInSync describes the status of a NifiConnection as in sync.
	ConnectionStateInSync ConnectionState = "InSync"
	// ConnectionStateCreated describes the status of a NifiConnection as created.
	ConnectionStateCreated ConnectionState = "Created"

	// RevertRequestType defines a revert changes request.
	RevertRequestType DataflowUpdateRequestType = "Revert"
	// UpdateRequestType defines an update version request.
	UpdateRequestType DataflowUpdateRequestType = "Update"

	// DrainStrategy leads to shutting down only input components (Input processors, remote input process group)
	// and waiting the dataflow to be drained.
	DrainStrategy ComponentUpdateStrategy = "drain"
	// DropStrategy leads to shutting down all components and dropping all flowfiles from the flow.
	DropStrategy ComponentUpdateStrategy = "drop"

	// UserStateCreated describes the status of a NifiUser as created.
	UserStateCreated UserState = "created"
	// TLSCert is where a cert is stored in a user secret when requested.
	TLSCert string = "tls.crt"
	// TLSCert is where a private key is stored in a user secret when requested.
	TLSKey string = "tls.key"
	// TLSJKSKeyStore is where a JKS keystore is stored in a user secret when requested.
	TLSJKSKeyStore string = "keystore.jks"
	// TLSJKSTrustStore is where a JKS truststore is stored in a user secret when requested.
	TLSJKSTrustStore string = "truststore.jks"
	// CoreCACertKey is where ca ceritificates are stored in user certificates.
	CoreCACertKey string = "ca.crt"
	// CACertKey is the key where the CA certificate is stored in the operator secrets.
	CACertKey string = "caCert"
	// CAPrivateKeyKey stores the private key for the CA.
	CAPrivateKeyKey string = "caKey"
	// ClientCertKey stores the client certificate (operator usage).
	ClientCertKey string = "clientCert"
	// ClientPrivateKeyKey stores the client private key.
	ClientPrivateKeyKey string = "clientKey"
	// PeerCertKey stores the peer certificate (node certificates).
	PeerCertKey string = "peerCert"
	// PeerPrivateKeyKey stores the peer private key.
	PeerPrivateKeyKey string = "peerKey"
	// PasswordKey stores the JKS password.
	PasswordKey string = "password"
)
View Source 
const (
	// Configured states the node is running.
	Configured RackAwarenessState = "Configured"

	// GracefulUpscaleRequired states that a node upscale is required.
	GracefulUpscaleRequired State = "GracefulUpscaleRequired"
	// GracefulUpscaleRunning states that the node upscale task is still running.
	GracefulUpscaleRunning State = "GracefulUpscaleRunning"
	// GracefulUpscaleSucceeded states the node is updated gracefully.
	GracefulUpscaleSucceeded State = "GracefulUpscaleSucceeded"

	// Downscale nifi cluster states
	// GracefulDownscaleRequired states that a node downscale is required.
	GracefulDownscaleRequired State = "GracefulDownscaleRequired"
	// GracefulDownscaleRunning states that the node downscale is still running in.
	GracefulDownscaleRunning State = "GracefulDownscaleRunning"
	// GracefulUpscaleSucceeded states the node is updated gracefully.
	GracefulDownscaleSucceeded State = "GracefulDownscaleSucceeded"

	// NifiClusterInitializing states that the cluster is still in initializing stage.
	NifiClusterInitializing ClusterState = "ClusterInitializing"
	// NifiClusterInitialized states that the cluster is initialized.
	NifiClusterInitialized ClusterState = "ClusterInitialized"
	// NifiClusterReconciling states that the cluster is still in reconciling stage.
	NifiClusterReconciling ClusterState = "ClusterReconciling"
	// NifiClusterRollingUpgrading states that the cluster is rolling upgrading.
	NifiClusterRollingUpgrading ClusterState = "ClusterRollingUpgrading"
	// NifiClusterRunning states that the cluster is in running state.
	NifiClusterRunning ClusterState = "ClusterRunning"

	// ConfigInSync states that the generated nodeConfig is in sync with the Node.
	ConfigInSync ConfigurationState = "ConfigInSync"
	// ConfigOutOfSync states that the generated nodeConfig is out of sync with the Node.
	ConfigOutOfSync ConfigurationState = "ConfigOutOfSync"

	// DisconnectNodeAction states that the NiFi node is disconnecting from NiFi Cluster.
	DisconnectNodeAction ActionStep = "DISCONNECTING"
	// DisconnectStatus states that the NiFi node is disconnected from NiFi Cluster.
	DisconnectStatus ActionStep = "DISCONNECTED"
	// OffloadNodeAction states that the NiFi node is offloading data to NiFi Cluster.
	OffloadNodeAction ActionStep = "OFFLOADING"
	// OffloadStatus states that the NiFi node offloaded data to NiFi Cluster.
	OffloadStatus ActionStep = "OFFLOADED"
	// RemovePodAction states that the NiFi node pod and object related are removing by operator.
	RemovePodAction ActionStep = "POD_REMOVING"
	// RemovePodAction states that the NiFi node pod and object related have been removed by operator.
	RemovePodStatus ActionStep = "POD_REMOVED"
	// RemoveNodeAction states that the NiFi node is removing from NiFi Cluster.
	RemoveNodeAction ActionStep = "REMOVING"
	// RemoveStatus states that the NiFi node is removed from NiFi Cluster.
	RemoveStatus ActionStep = "REMOVED"
	// ConnectNodeAction states that the NiFi node is connecting to the NiFi Cluster.
	ConnectNodeAction ActionStep = "CONNECTING"
	// ConnectStatus states that the NiFi node is connected to the NiFi Cluster.
	ConnectStatus ActionStep = "CONNECTED"

	// IsInitClusterNode states the node is part of initial cluster setup.
	IsInitClusterNode InitClusterNode = true
	// NotInitClusterNode states the node is not part of initial cluster setup.
	NotInitClusterNode InitClusterNode = false
)
View Source 
const (
	// AutoscalerStateOutOfSync describes the status of a NifiNodeGroupAutoscaler as out of sync.
	AutoscalerStateOutOfSync NodeGroupAutoscalerState = "OutOfSync"
	// AutoscalerStateInSync describes the status of a NifiNodeGroupAutoscaler as in sync.
	AutoscalerStateInSync NodeGroupAutoscalerState = "InSync"

	// upscale strategy representing 'Scale > Disconnect the nodes > Offload data > Reconnect the node' strategy.
	GracefulClusterUpscaleStrategy ClusterScalingStrategy = "graceful"
	// simply add a node to the cluster and nothing else.
	SimpleClusterUpscaleStrategy ClusterScalingStrategy = "simple"
	// downscale strategy to remove the last node added.
	LIFOClusterDownscaleStrategy ClusterScalingStrategy = "lifo"
	// downscale strategy avoiding primary/coordinator nodes.
	NonPrimaryClusterDownscaleStrategy ClusterScalingStrategy = "nonprimary"
	// downscale strategy targeting nodes which are least busy in terms of # flowfiles in queues.
	LeastBusyClusterDownscaleStrategy ClusterScalingStrategy = "leastbusy"
)
View Source 
const (
	ClusterListenerType     = "cluster"
	HttpListenerType        = "http"
	HttpsListenerType       = "https"
	S2sListenerType         = "s2s"
	PrometheusListenerType  = "prometheus"
	LoadBalanceListenerType = "load-balance"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects.
	GroupVersion = schema.GroupVersion{Group: "nifi.konpyutaika.com", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme.
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func ClusterRefsEquals 

func ClusterRefsEquals(clusterRefs []ClusterReference) bool

func ComponentRefsEquals 

func ComponentRefsEquals(componentRefs []ComponentReference) bool

func ConvertNifiClusterFrom 

func ConvertNifiClusterFrom(dst *NifiCluster, src *v1.NifiCluster) error

ConvertFrom use to convert v1alpha1.NifiCluster from v1.NifiCluster.

func ConvertNifiClusterTo 

func ConvertNifiClusterTo(src *NifiCluster, dst *v1.NifiCluster) error

ConvertNifiClusterTo use to convert v1alpha1.NifiCluster to v1.NifiCluster.

func ConvertNifiDataflowTo 

func ConvertNifiDataflowTo(src *NifiDataflow, dst *v1.NifiDataflow) error

ConvertNifiDataflowTo use to convert v1alpha1.NifiDataflow to v1.NifiDataflow.

func ConvertNifiDatflowFrom 

func ConvertNifiDatflowFrom(dst *NifiDataflow, src *v1.NifiDataflow) error

ConvertNifiDatflowFrom use to convert v1alpha1.NifiCluster from v1.NifiCluster.

func ConvertNifiParameterContextFrom 

func ConvertNifiParameterContextFrom(dst *NifiParameterContext, src *v1.NifiParameterContext) error

ConvertNifiParameterContextFrom use to convert v1alpha1.NifiParameterContext from v1.NifiParameterContext.

func ConvertNifiParameterContextTo 

func ConvertNifiParameterContextTo(src *NifiParameterContext, dst *v1.NifiParameterContext) error

ConvertNifiParameterContextTo use to convert v1alpha1.NifiParameterContext to v1.NifiParameterContext.

func ConvertNifiRegistryClientFrom 

func ConvertNifiRegistryClientFrom(dst *NifiRegistryClient, src *v1.NifiRegistryClient) error

ConvertNifiRegistryClientFrom use to convert v1alpha1.NifiRegistryClient from v1.NifiRegistryClient.

func ConvertNifiRegistryClientTo 

func ConvertNifiRegistryClientTo(src *NifiRegistryClient, dst *v1.NifiRegistryClient) error

ConvertNifiRegistryClientTo use to convert v1alpha1.NifiRegistryClient to v1.NifiRegistryClient.

func ConvertNifiUserFrom 

func ConvertNifiUserFrom(dst *NifiUser, src *v1.NifiUser) error

ConvertNifiUserFrom use to convert v1alpha1.NifiUser from v1.NifiUser.

func ConvertNifiUserGroupFrom 

func ConvertNifiUserGroupFrom(dst *NifiUserGroup, src *v1.NifiUserGroup) error

ConvertNifiUserGroupFrom use to convert v1alpha1.NifiUserGroup From v1.NifiUserGroup.

func ConvertNifiUserGroupTo 

func ConvertNifiUserGroupTo(src *NifiUserGroup, dst *v1.NifiUserGroup) error

ConvertNifiUserGroupTo use to convert v1alpha1.NifiUserGroup to v1.NifiUserGroup.

func ConvertNifiUserTo 

func ConvertNifiUserTo(src *NifiUser, dst *v1.NifiUser) error

ConvertNifiUserTo use to convert v1alpha1.NifiUser to v1.NifiUser.

func NodesToIdMap 

func NodesToIdMap(nodes []Node) (nodeMap map[int32]Node)

func SecretRefsEquals 

func SecretRefsEquals(secretRefs []SecretReference) bool

Types

type AccessPolicy 

type AccessPolicy struct {
	// +kubebuilder:validation:Enum={"global","component"}
	// type defines the kind of access policy, could be "global" or "component".
	Type AccessPolicyType `json:"type"`
	// +kubebuilder:validation:Enum={"read","write"}
	// action defines the kind of action that will be granted, could be "read" or "write"
	Action AccessPolicyAction `json:"action"`
	// +kubebuilder:validation:Enum={"/system","/flow","/controller","/parameter-context","/provenance","/restricted-components","/policies","/tenants","/site-to-site","/proxy","/counters","/","/operation","/provenance-data","/data","/policies","/data-transfer"}
	// resource defines the kind of resource targeted by this access policies, please refer to the following page:
	// https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#access-policies
	Resource AccessPolicyResource `json:"resource"`
	// componentType is used if the type is "component", it's allow to define the kind of component on which is the
	// access policy
	ComponentType string `json:"componentType,omitempty"`
	// componentId is used if the type is "component", it's allow to define the id of the component on which is the
	// access policy
	ComponentId string `json:"componentId,omitempty"`
}

func (*AccessPolicy) DeepCopy 

func (in *AccessPolicy) DeepCopy() *AccessPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AccessPolicy.

func (*AccessPolicy) DeepCopyInto 

func (in *AccessPolicy) DeepCopyInto(out *AccessPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AccessPolicy) GetResource 

func (a *AccessPolicy) GetResource(rootProcessGroupId string) string

type AccessPolicyAction 

type AccessPolicyAction string

AccessPolicyAction represents the access policy action.

type AccessPolicyResource 

type AccessPolicyResource string

AccessPolicyResource represents the access policy resource.

type AccessPolicyType 

type AccessPolicyType string

AccessPolicyType represents the type of access policy.

type ActionStep 

type ActionStep string

Action step holds info about the action step.

type AuthorizerConfig 

type AuthorizerConfig struct {
	// A replacement authorizers.xml template configuration that will replace the default template. NOTE: this is a template as seen in authorizers.go.
	ReplaceTemplateConfigMap *ConfigmapReference `json:"replaceTemplateConfigMap,omitempty"`
	// a replacement authorizers.xml template configuration that will replace the default template and replaceConfigMap. NOTE: this is a template as seen in authorizers.go.
	ReplaceTemplateSecretConfig *SecretConfigReference `json:"replaceTemplateSecretConfig,omitempty"`
}

Optional configuration for the default authorizers.xml template.

func (*AuthorizerConfig) DeepCopy 

func (in *AuthorizerConfig) DeepCopy() *AuthorizerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuthorizerConfig.

func (*AuthorizerConfig) DeepCopyInto 

func (in *AuthorizerConfig) DeepCopyInto(out *AuthorizerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BootstrapNotificationServicesConfig 

type BootstrapNotificationServicesConfig struct {
	// bootstrap_notifications_services.xml configuration that will replace the one produced based on template
	ReplaceConfigMap *ConfigmapReference `json:"replaceConfigMap,omitempty"`
	// bootstrap_notifications_services.xml configuration that will replace the one produced based on template and overrideConfigMap
	ReplaceSecretConfig *SecretConfigReference `json:"replaceSecretConfig,omitempty"`
}

func (*BootstrapNotificationServicesConfig) DeepCopy 

func (in *BootstrapNotificationServicesConfig) DeepCopy() *BootstrapNotificationServicesConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BootstrapNotificationServicesConfig.

func (*BootstrapNotificationServicesConfig) DeepCopyInto 

func (in *BootstrapNotificationServicesConfig) DeepCopyInto(out *BootstrapNotificationServicesConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BootstrapProperties 

type BootstrapProperties struct {
	// JVM memory settings
	NifiJvmMemory string `json:"nifiJvmMemory,omitempty"`
	// Additionnal bootstrap.properties configuration that will override the one produced based on template and
	// configuration
	OverrideConfigMap *ConfigmapReference `json:"overrideConfigMap,omitempty"`
	// Additionnal bootstrap.properties configuration that will override the one produced based
	// on template and configurations.
	OverrideConfigs string `json:"overrideConfigs,omitempty"`
	// Additionnal bootstrap.properties configuration that will override the one produced based
	// on template, configurations, overrideConfigMap and overrideConfigs.
	OverrideSecretConfig *SecretConfigReference `json:"overrideSecretConfig,omitempty"`
}

BootstrapProperties configuration that will be applied to the node.

func (*BootstrapProperties) DeepCopy 

func (in *BootstrapProperties) DeepCopy() *BootstrapProperties

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BootstrapProperties.

func (*BootstrapProperties) DeepCopyInto 

func (in *BootstrapProperties) DeepCopyInto(out *BootstrapProperties)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BootstrapProperties) GetNifiJvmMemory 

func (bProperties *BootstrapProperties) GetNifiJvmMemory() string

GetNifiJvmMemory returns the default "512m" NifiJvmMemory if not specified otherwise.

type ClientConfigType 

type ClientConfigType string

ClientConfigType represents an interface implementing the ClientConfigManager. +kubebuilder:validation:Enum={"tls","basic"} 

const (
	ClientConfigTLS   ClientConfigType = "tls"
	ClientConfigBasic ClientConfigType = "basic"
)

type ClusterReference 

type ClusterReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

ClusterReference states a reference to a cluster for dataflow/registryclient/user provisioning.

func (*ClusterReference) DeepCopy 

func (in *ClusterReference) DeepCopy() *ClusterReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterReference.

func (*ClusterReference) DeepCopyInto 

func (in *ClusterReference) DeepCopyInto(out *ClusterReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterReplicaSelector 

type ClusterReplicaSelector string

ClusterReplicaSelector holds info about the pod selector for cluster replicas.

type ClusterReplicas 

type ClusterReplicas int32

ClusterReplicas holds info about the current number of replicas in the cluster.

type ClusterScalingStrategy 

type ClusterScalingStrategy string

ClusterScalingStrategy holds info about how a cluster should be scaled.

type ClusterState 

type ClusterState string

ClusterState holds info about the cluster state.

func (ClusterState) IsReady 

func (r ClusterState) IsReady() bool

type ClusterType 

type ClusterType string

ClusterType represents an interface implementing the ClientConfigManager. +kubebuilder:validation:Enum={"external","internal"} 

const (
	ExternalCluster ClusterType = "external"
	InternalCluster ClusterType = "internal"
)

type ComponentInformation 

type ComponentInformation struct {
	Id            string              `json:"id"`
	GroupId       string              `json:"groupId"`
	Type          string              `json:"type"`
	ParentGroupId string              `json:"parentGroupId"`
	ClusterRef    v1.ClusterReference `json:"clusterRef"`
}

func (*ComponentInformation) DeepCopy 

func (in *ComponentInformation) DeepCopy() *ComponentInformation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentInformation.

func (*ComponentInformation) DeepCopyInto 

func (in *ComponentInformation) DeepCopyInto(out *ComponentInformation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ComponentReference 

type ComponentReference struct {
	// the name of the component.
	Name string `json:"name"`
	// the namespace of the component.
	Namespace string `json:"namespace,omitempty"`
	// the type of the component (e.g. nifidataflow).
	Type ComponentType `json:"type"`
	// the name of the sub component (e.g. queue or port name).
	SubName string `json:"subName,omitempty"`
}

func (*ComponentReference) DeepCopy 

func (in *ComponentReference) DeepCopy() *ComponentReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ComponentReference.

func (*ComponentReference) DeepCopyInto 

func (in *ComponentReference) DeepCopyInto(out *ComponentReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ComponentReference) IsValid 

func (ref *ComponentReference) IsValid() bool

type ComponentType 

type ComponentType string

Change the list to {"dataflow","input-port","output-port","processor","process-group"} when all the type are available +kubebuilder:validation:Enum={"dataflow"} 

const (
	ComponentDataflow     ComponentType = "dataflow"
	ComponentInputPort    ComponentType = "input-port"
	ComponentOutputPort   ComponentType = "output-port"
	ComponentProcessor    ComponentType = "processor"
	ComponentFunnel       ComponentType = "funnel"
	ComponentProcessGroup ComponentType = "process-group"
)

type ComponentUpdateStrategy 

type ComponentUpdateStrategy string

ComponentUpdateStrategy defines the type of strategy to update a component. +kubebuilder:validation:Enum={"drop","drain"}

type ConfigmapReference 

type ConfigmapReference struct {
	// Name of the configmap that we want to refer.
	Name string `json:"name"`
	// Namespace where is located the secret that we want to refer.
	Namespace string `json:"namespace,omitempty"`
	// The key of the value,in data content, that we want use.
	Data string `json:"data"`
}

ConfigmapReference states a reference to a data into a configmap.

func (*ConfigmapReference) DeepCopy 

func (in *ConfigmapReference) DeepCopy() *ConfigmapReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigmapReference.

func (*ConfigmapReference) DeepCopyInto 

func (in *ConfigmapReference) DeepCopyInto(out *ConfigmapReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConfigurationState 

type ConfigurationState string

ConfigurationState holds info about the configuration state.

type ConnectionBend 

type ConnectionBend struct {
	// The x coordinate.
	X *int64 `json:"posX,omitempty"`
	// The y coordinate.
	Y *int64 `json:"posY,omitempty"`
}

func (*ConnectionBend) DeepCopy 

func (in *ConnectionBend) DeepCopy() *ConnectionBend

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionBend.

func (*ConnectionBend) DeepCopyInto 

func (in *ConnectionBend) DeepCopyInto(out *ConnectionBend)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ConnectionConfiguration 

type ConnectionConfiguration struct {
	// the maximum amount of time an object may be in the flow before it will be automatically aged out of the flow.
	FlowFileExpiration string `json:"flowFileExpiration,omitempty"`
	// the maximum data size of objects that can be queued before back pressure is applied.
	// +kubebuilder:default="1 GB"
	BackPressureDataSizeThreshold string `json:"backPressureDataSizeThreshold,omitempty"`
	// the maximum number of objects that can be queued before back pressure is applied.
	// +kubebuilder:default=10000
	BackPressureObjectThreshold int64 `json:"backPressureObjectThreshold,omitempty"`
	// how to load balance the data in this Connection across the nodes in the cluster.
	// +kubebuilder:default="DO_NOT_LOAD_BALANCE"
	LoadBalanceStrategy ConnectionLoadBalanceStrategy `json:"loadBalanceStrategy,omitempty"`
	// the FlowFile Attribute to use for determining which node a FlowFile will go to.
	LoadBalancePartitionAttribute string `json:"loadBalancePartitionAttribute,omitempty"`
	// whether or not data should be compressed when being transferred between nodes in the cluster.
	// +kubebuilder:default="DO_NOT_COMPRESS"
	LoadBalanceCompression ConnectionLoadBalanceCompression `json:"loadBalanceCompression,omitempty"`
	// the comparators used to prioritize the queue.
	Prioritizers []ConnectionPrioritizer `json:"prioritizers,omitempty"`
	// the index of the bend point where to place the connection label.
	LabelIndex *int32 `json:"labelIndex,omitempty"`
	// the bend points on the connection.
	Bends []ConnectionBend `json:"bends,omitempty"`
}

func (*ConnectionConfiguration) DeepCopy 

func (in *ConnectionConfiguration) DeepCopy() *ConnectionConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionConfiguration.

func (*ConnectionConfiguration) DeepCopyInto 

func (in *ConnectionConfiguration) DeepCopyInto(out *ConnectionConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ConnectionConfiguration) GetBends 

func (conf *ConnectionConfiguration) GetBends() []ConnectionBend

func (*ConnectionConfiguration) GetFlowFileExpiration 

func (conf *ConnectionConfiguration) GetFlowFileExpiration() string

func (*ConnectionConfiguration) GetLabelIndex 

func (conf *ConnectionConfiguration) GetLabelIndex() int32

func (*ConnectionConfiguration) GetLoadBalancePartitionAttribute 

func (conf *ConnectionConfiguration) GetLoadBalancePartitionAttribute() string

func (*ConnectionConfiguration) GetPrioritizers 

func (conf *ConnectionConfiguration) GetPrioritizers() []ConnectionPrioritizer

func (*ConnectionConfiguration) GetStringPrioritizers 

func (conf *ConnectionConfiguration) GetStringPrioritizers() []string

func (*ConnectionConfiguration) IsValid 

func (conf *ConnectionConfiguration) IsValid() bool

type ConnectionLoadBalanceCompression 

type ConnectionLoadBalanceCompression string

+kubebuilder:validation:Enum={"DO_NOT_COMPRESS","COMPRESS_ATTRIBUTES_ONLY","COMPRESS_ATTRIBUTES_AND_CONTENT"} 

const (
	// FlowFiles will not be compressed.
	CompressionDoNotCompress ConnectionLoadBalanceCompression = "DO_NOT_COMPRESS"
	// FlowFiles' attributes will be compressed, but the FlowFiles' contents will not be.
	CompressionCompressAttributesOnly ConnectionLoadBalanceCompression = "COMPRESS_ATTRIBUTES_ONLY"
	// FlowFiles' attributes and content will be compressed.
	CompressionCompressAttributesAndContent ConnectionLoadBalanceCompression = "COMPRESS_ATTRIBUTES_AND_CONTENT"
)

type ConnectionLoadBalanceStrategy 

type ConnectionLoadBalanceStrategy string

+kubebuilder:validation:Enum={"DO_NOT_LOAD_BALANCE","PARTITION_BY_ATTRIBUTE","ROUND_ROBIN","SINGLE"} 

const (
	// Do not load balance FlowFiles between nodes in the cluster.
	StrategyDoNotLoadBalance ConnectionLoadBalanceStrategy = "DO_NOT_LOAD_BALANCE"
	// Determine which node to send a given FlowFile to based on the value of a user-specified FlowFile Attribute. All FlowFiles that have the same value for said Attribute will be sent to the same node in the cluster.
	StrategyPartitionByAttribute ConnectionLoadBalanceStrategy = "PARTITION_BY_ATTRIBUTE"
	// FlowFiles will be distributed to nodes in the cluster in a Round-Robin fashion. However, if a node in the cluster is not able to receive data as fast as other nodes, that node may be skipped in one or more iterations in order to maximize throughput of data distribution across the cluster.
	StrategyRoundRobin ConnectionLoadBalanceStrategy = "ROUND_ROBIN"
	// All FlowFiles will be sent to the same node. Which node they are sent to is not defined.
	StrategySingle ConnectionLoadBalanceStrategy = "SINGLE"
)

type ConnectionPrioritizer 

type ConnectionPrioritizer string

+kubebuilder:validation:Enum={"FirstInFirstOutPrioritizer","NewestFlowFileFirstPrioritizer","OldestFlowFileFirstPrioritizer","PriorityAttributePrioritizer"} 

const (
	// Given two FlowFiles, the one that reached the connection first will be processed first.
	PrioritizerFirstInFirstOutPrioritizer ConnectionPrioritizer = "FirstInFirstOutPrioritizer"
	// Given two FlowFiles, the one that is newest in the dataflow will be processed first.
	PrioritizerNewestFlowFileFirstPrioritizer ConnectionPrioritizer = "NewestFlowFileFirstPrioritizer"
	// Given two FlowFiles, the one that is oldest in the dataflow will be processed first. 'This is the default scheme that is used if no prioritizers are selected'.
	PrioritizerOldestFlowFileFirstPrioritizer ConnectionPrioritizer = "OldestFlowFileFirstPrioritizer"
	// Given two FlowFiles, an attribute called “priority” will be extracted. The one that has the lowest priority value will be processed first.
	PrioritizerPriorityAttributePrioritizer ConnectionPrioritizer = "PriorityAttributePrioritizer"
)

type ConnectionState 

type ConnectionState string

ConnectionState defines the state of a NifiConnection.

type DataflowState 

type DataflowState string

DataflowState defines the state of a NifiDataflow.

type DataflowSyncMode 

type DataflowSyncMode string

+kubebuilder:validation:Enum={"never","always","once"} 

const (
	SyncNever  DataflowSyncMode = "never"
	SyncOnce   DataflowSyncMode = "once"
	SyncAlways DataflowSyncMode = "always"
)

type DataflowUpdateRequestType 

type DataflowUpdateRequestType string

DataflowUpdateRequestType defines the type of versioned flow update request.

type DisruptionBudget 

type DisruptionBudget struct {
	// If set to true, will create a podDisruptionBudget
	// +optional
	Create bool `json:"create,omitempty"`
	// The budget to set for the PDB, can either be static number or a percentage
	// +kubebuilder:validation:Pattern:="^[0-9]+$|^[0-9]{1,2}%$|^100%$"
	Budget string `json:"budget,omitempty"`
}

DisruptionBudget defines the configuration for PodDisruptionBudget.

func (*DisruptionBudget) DeepCopy 

func (in *DisruptionBudget) DeepCopy() *DisruptionBudget

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DisruptionBudget.

func (*DisruptionBudget) DeepCopyInto 

func (in *DisruptionBudget) DeepCopyInto(out *DisruptionBudget)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DropRequest 

type DropRequest struct {
	// the connection id.
	ConnectionId string `json:"connectionId"`
	// the id for this drop request.
	Id string `json:"id"`
	// the uri for this request.
	Uri string `json:"uri"`
	// the last time this request was updated.
	LastUpdated string `json:"lastUpdated"`
	// whether the request has finished.
	Finished bool `json:"finished"`
	// an explication of why the request failed, or null if this request has not failed.
	FailureReason string `json:"failureReason"`
	// the percentage complete of the request, between 0 and 100.
	PercentCompleted int32 `json:"percentCompleted"`
	// the number of flow files currently queued.
	CurrentCount int32 `json:"currentCount"`
	// the size of flow files currently queued in bytes.
	CurrentSize int64 `json:"currentSize"`
	// the count and size of flow files currently queued.
	Current string `json:"current"`
	// the number of flow files to be dropped as a result of this request.
	OriginalCount int32 `json:"originalCount"`
	// the size of flow files to be dropped as a result of this request in bytes.
	OriginalSize int64 `json:"originalSize"`
	// the count and size of flow files to be dropped as a result of this request.
	Original string `json:"original"`
	// the number of flow files that have been dropped thus far.
	DroppedCount int32 `json:"droppedCount"`
	// the size of flow files currently queued in bytes.
	DroppedSize int64 `json:"droppedSize"`
	// the count and size of flow files that have been dropped thus far.
	Dropped string `json:"dropped"`
	// the state of the request
	State string `json:"state"`
}

func (*DropRequest) DeepCopy 

func (in *DropRequest) DeepCopy() *DropRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DropRequest.

func (*DropRequest) DeepCopyInto 

func (in *DropRequest) DeepCopyInto(out *DropRequest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExternalServiceConfig 

type ExternalServiceConfig struct {
	// Name must be unique within a namespace. Is required when creating resources, although
	// some resources may allow a client to request the generation of an appropriate name
	// automatically. Name is primarily intended for creation idempotence and configuration
	// definition.
	// Cannot be updated.
	// More info: http://kubernetes.io/docs/user-guide/identifiers#names
	// +optional
	Name string `json:"name"`
	// metadata allows to add additionnal metadata to the service
	Metadata Metadata `json:"metadata,omitempty"`
	// Spec defines the behavior of a service.
	Spec ExternalServiceSpec `json:"spec"`
}

func (*ExternalServiceConfig) DeepCopy 

func (in *ExternalServiceConfig) DeepCopy() *ExternalServiceConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExternalServiceConfig.

func (*ExternalServiceConfig) DeepCopyInto 

func (in *ExternalServiceConfig) DeepCopyInto(out *ExternalServiceConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ExternalServiceSpec 

type ExternalServiceSpec struct {
	// Contains the list port for the service and the associated listener
	PortConfigs []PortConfig `json:"portConfigs"`
	// clusterIP is the IP address of the service and is usually assigned
	// randomly by the master. If an address is specified manually and is not in
	// use by others, it will be allocated to the service; otherwise, creation
	// of the service will fail. This field can not be changed through updates.
	// Valid values are "None", empty string (""), or a valid IP address. "None"
	// can be specified for headless services when proxying is not required.
	// Only applies to types ClusterIP, NodePort, and LoadBalancer. Ignored if
	// type is ExternalName.
	// More info: https://kubernetes.io/docs/concepts/services-networking/service/#virtual-ips-and-service-proxies
	// +optional
	ClusterIP string `json:"clusterIP,omitempty" protobuf:"bytes,3,opt,name=clusterIP"`
	// type determines how the Service is exposed. Defaults to ClusterIP. Valid
	// options are ExternalName, ClusterIP, NodePort, and LoadBalancer.
	// "ExternalName" maps to the specified externalName.
	// "ClusterIP" allocates a cluster-internal IP address for load-balancing to
	// endpoints. Endpoints are determined by the selector or if that is not
	// specified, by manual construction of an Endpoints object. If clusterIP is
	// "None", no virtual IP is allocated and the endpoints are published as a
	// set of endpoints rather than a stable IP.
	// "NodePort" builds on ClusterIP and allocates a port on every node which
	// routes to the clusterIP.
	// "LoadBalancer" builds on NodePort and creates an
	// external load-balancer (if supported in the current cloud) which routes
	// to the clusterIP.
	// More info: https://kubernetes.io/docs/concepts/services-networking/service/#publishing-services-service-types
	// +optional
	Type corev1.ServiceType `json:"type,omitempty" protobuf:"bytes,4,opt,name=type,casttype=ServiceType"`
	// externalIPs is a list of IP addresses for which nodes in the cluster
	// will also accept traffic for this service.  These IPs are not managed by
	// Kubernetes.  The user is responsible for ensuring that traffic arrives
	// at a node with this IP.  A common example is external load-balancers
	// that are not part of the Kubernetes system.
	// +optional
	ExternalIPs []string `json:"externalIPs,omitempty" protobuf:"bytes,5,rep,name=externalIPs"`
	// Only applies to Service Type: LoadBalancer
	// LoadBalancer will get created with the IP specified in this field.
	// This feature depends on whether the underlying cloud-provider supports specifying
	// the loadBalancerIP when a load balancer is created.
	// This field will be ignored if the cloud-provider does not support the feature.
	// +optional
	LoadBalancerIP string `json:"loadBalancerIP,omitempty" protobuf:"bytes,8,opt,name=loadBalancerIP"`
	// If specified and supported by the platform, this will restrict traffic through the cloud-provider
	// load-balancer will be restricted to the specified client IPs. This field will be ignored if the
	// cloud-provider does not support the feature."
	// More info: https://kubernetes.io/docs/tasks/access-application-cluster/configure-cloud-provider-firewall/
	// +optional
	LoadBalancerSourceRanges []string `json:"loadBalancerSourceRanges,omitempty" protobuf:"bytes,9,opt,name=loadBalancerSourceRanges"`
	// externalName is the external reference that kubedns or equivalent will
	// return as a CNAME record for this service. No proxying will be involved.
	// Must be a valid RFC-1123 hostname (https://tools.ietf.org/html/rfc1123)
	// and requires Type to be ExternalName.
	// +optional
	ExternalName string `json:"externalName,omitempty" protobuf:"bytes,10,opt,name=externalName"`
}

func (*ExternalServiceSpec) DeepCopy 

func (in *ExternalServiceSpec) DeepCopy() *ExternalServiceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExternalServiceSpec.

func (*ExternalServiceSpec) DeepCopyInto 

func (in *ExternalServiceSpec) DeepCopyInto(out *ExternalServiceSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FlowPosition 

type FlowPosition struct {
	// The x coordinate.
	X *int64 `json:"posX,omitempty"`
	// The y coordinate.
	Y *int64 `json:"posY,omitempty"`
}

func (*FlowPosition) DeepCopy 

func (in *FlowPosition) DeepCopy() *FlowPosition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlowPosition.

func (*FlowPosition) DeepCopyInto 

func (in *FlowPosition) DeepCopyInto(out *FlowPosition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlowPosition) GetX 

func (p *FlowPosition) GetX() int64

func (*FlowPosition) GetY 

func (p *FlowPosition) GetY() int64

type GracefulActionState 

type GracefulActionState struct {
	// ErrorMessage holds the information what happened with Nifi Cluster
	ErrorMessage string `json:"errorMessage"`
	// ActionStep holds info about the action step ran
	ActionStep ActionStep `json:"actionStep,omitempty"`
	// TaskStarted hold the time when the execution started
	TaskStarted string `json:"TaskStarted,omitempty"`
	// ActionState holds the information about Action state
	State State `json:"actionState"`
}

GracefulActionState holds information about GracefulAction State.

func (*GracefulActionState) DeepCopy 

func (in *GracefulActionState) DeepCopy() *GracefulActionState

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GracefulActionState.

func (*GracefulActionState) DeepCopyInto 

func (in *GracefulActionState) DeepCopyInto(out *GracefulActionState)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type InitClusterNode 

type InitClusterNode bool

InitClusterNode holds info about if the node was part of the init cluster setup.

type InternalListenerConfig 

type InternalListenerConfig struct {
	// +kubebuilder:validation:Enum={"cluster", "http", "https", "s2s", "prometheus", "load-balance"}
	// (Optional field) Type allow to specify if we are in a specific nifi listener
	// it's allowing to define some required information such as Cluster Port,
	// Http Port, Https Port, Prometheus port, Load Balance port, or S2S port
	Type string `json:"type,omitempty"`
	// An identifier for the port which will be configured.
	Name string `json:"name"`
	// The container port.
	ContainerPort int32 `json:"containerPort"`
}

InternalListenerConfig defines the internal listener config for Nifi.

func (*InternalListenerConfig) DeepCopy 

func (in *InternalListenerConfig) DeepCopy() *InternalListenerConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new InternalListenerConfig.

func (*InternalListenerConfig) DeepCopyInto 

func (in *InternalListenerConfig) DeepCopyInto(out *InternalListenerConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LdapConfiguration 

type LdapConfiguration struct {
	// If set to true, we will enable ldap usage into nifi.properties configuration.
	Enabled bool `json:"enabled,omitempty"`
	// Space-separated list of URLs of the LDAP servers (i.e. ldap://<hostname>:<port>).
	Url string `json:"url,omitempty"`
	// Base DN for searching for users (i.e. CN=Users,DC=example,DC=com).
	SearchBase string `json:"searchBase,omitempty"`
	// Filter for searching for users against the 'User Search Base'.
	// (i.e. sAMAccountName={0}). The user specified name is inserted into '{0}'.
	SearchFilter string `json:"searchFilter,omitempty"`
}

LdapConfiguration specifies the configuration if you want to use LDAP.

func (*LdapConfiguration) DeepCopy 

func (in *LdapConfiguration) DeepCopy() *LdapConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LdapConfiguration.

func (*LdapConfiguration) DeepCopyInto 

func (in *LdapConfiguration) DeepCopyInto(out *LdapConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ListenersConfig 

type ListenersConfig struct {
	// internalListeners specifies settings required to access nifi internally
	InternalListeners []InternalListenerConfig `json:"internalListeners"`
	// sslSecrets contains information about ssl related kubernetes secrets if one of the
	// listener setting type set to ssl these fields must be populated to
	SSLSecrets *SSLSecrets `json:"sslSecrets,omitempty"`
	// clusterDomain allow to override the default cluster domain which is "cluster.local"
	ClusterDomain string `json:"clusterDomain,omitempty"`
	// useExternalDNS allow to manage externalDNS usage by limiting the DNS names associated
	// to each nodes and load balancer: <cluster-name>-node-<node Id>.<cluster-name>.<service name>.<cluster domain>
	UseExternalDNS bool `json:"useExternalDNS,omitempty"`
}

func (*ListenersConfig) DeepCopy 

func (in *ListenersConfig) DeepCopy() *ListenersConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ListenersConfig.

func (*ListenersConfig) DeepCopyInto 

func (in *ListenersConfig) DeepCopyInto(out *ListenersConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ListenersConfig) GetClusterDomain 

func (lConfig *ListenersConfig) GetClusterDomain() string

type LogbackConfig 

type LogbackConfig struct {
	// logback.xml configuration that will replace the one produced based on template
	ReplaceConfigMap *ConfigmapReference `json:"replaceConfigMap,omitempty"`
	// logback.xml configuration that will replace the one produced based on template and overrideConfigMap
	ReplaceSecretConfig *SecretConfigReference `json:"replaceSecretConfig,omitempty"`
}

Logback configuration that will be applied to the node.

func (*LogbackConfig) DeepCopy 

func (in *LogbackConfig) DeepCopy() *LogbackConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogbackConfig.

func (*LogbackConfig) DeepCopyInto 

func (in *LogbackConfig) DeepCopyInto(out *LogbackConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ManagedUser 

type ManagedUser struct {
	// identity field is use to define the user identity on NiFi cluster side,
	// it use full when the user's name doesn't suite with Kubernetes resource name.
	Identity string `json:"identity,omitempty"`
	// name field is use to name the NifiUser resource, if not identity is provided it will be used to name
	// the user on NiFi cluster side.
	Name string `json:"name"`
}

func (*ManagedUser) DeepCopy 

func (in *ManagedUser) DeepCopy() *ManagedUser

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedUser.

func (*ManagedUser) DeepCopyInto 

func (in *ManagedUser) DeepCopyInto(out *ManagedUser)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ManagedUser) GetIdentity 

func (u *ManagedUser) GetIdentity() string

type Metadata 

type Metadata struct {
	// Additionnal annotation to merge to the resource associated
	// https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/#syntax-and-character-set
	Annotations map[string]string `json:"annotations,omitempty"`
	// Additionnal labels to merge to the resource associated
	// https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#syntax-and-character-set
	Labels map[string]string `json:"labels,omitempty"`
}

func (*Metadata) DeepCopy 

func (in *Metadata) DeepCopy() *Metadata

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.

func (*Metadata) DeepCopyInto 

func (in *Metadata) DeepCopyInto(out *Metadata)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiAccessType 

type NifiAccessType string

NifiAccessType hold info about Nifi ACL.

type NifiCluster 

type NifiCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiClusterSpec   `json:"spec,omitempty"`
	Status NifiClusterStatus `json:"status,omitempty"`
}

NifiCluster is the Schema for the nificlusters API.

func (*NifiCluster) ConvertFrom 

func (dst *NifiCluster) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiCluster) ConvertTo 

func (src *NifiCluster) ConvertTo(dst conversion.Hub) error

ConvertNifiClusterTo converts a v1alpha1 to v1 (Hub).

func (*NifiCluster) DeepCopy 

func (in *NifiCluster) DeepCopy() *NifiCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiCluster.

func (*NifiCluster) DeepCopyInto 

func (in *NifiCluster) DeepCopyInto(out *NifiCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiCluster) DeepCopyObject 

func (in *NifiCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NifiCluster) GetClientType 

func (c *NifiCluster) GetClientType() ClientConfigType

func (*NifiCluster) GetCreationTimeOrderedNodes 

func (cluster *NifiCluster) GetCreationTimeOrderedNodes() []Node

Order the nodes in the cluster by the time they were created. The list will be in ascending order. Older nodes will be in the beginning of the list, newer nodes at the end. Nodes for Clusters that existed prior to this feature (v0.11.0+) will not have a creationTime. In this case, LIFO will not be able to reliably determine the oldest node. A rolling restart of nodes in the cluster will resolve this issue going forward.

func (*NifiCluster) GetNifiControllerUserIdentity 

func (cluster *NifiCluster) GetNifiControllerUserIdentity() string

func (*NifiCluster) GetNodeServiceName 

func (cluster *NifiCluster) GetNodeServiceName() string

func (*NifiCluster) GetType 

func (c *NifiCluster) GetType() ClusterType

func (*NifiCluster) Id 

func (cluster *NifiCluster) Id() string

func (NifiCluster) IsExternal 

func (c NifiCluster) IsExternal() bool

func (*NifiCluster) IsInternal 

func (c *NifiCluster) IsInternal() bool

func (NifiCluster) IsReady 

func (cluster NifiCluster) IsReady() bool

func (*NifiCluster) IsSet 

func (c *NifiCluster) IsSet() bool

func (*NifiCluster) RootProcessGroupId 

func (cluster *NifiCluster) RootProcessGroupId() string

func (*NifiCluster) SetupWebhookWithManager 

func (r *NifiCluster) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiClusterList 

type NifiClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiCluster `json:"items"`
}

NifiClusterList contains a list of NifiCluster.

func (*NifiClusterList) DeepCopy 

func (in *NifiClusterList) DeepCopy() *NifiClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiClusterList.

func (*NifiClusterList) DeepCopyInto 

func (in *NifiClusterList) DeepCopyInto(out *NifiClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiClusterList) DeepCopyObject 

func (in *NifiClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiClusterSpec 

type NifiClusterSpec struct {
	// clientType defines if the operator will use basic or tls authentication to query the NiFi cluster.
	ClientType ClientConfigType `json:"clientType,omitempty"`
	// type defines if the cluster is internal (i.e manager by the operator) or external.
	Type ClusterType `json:"type,omitempty"`
	// nodeURITemplate used to dynamically compute node uri (used if external type)
	NodeURITemplate string `json:"nodeURITemplate,omitempty"`
	// nifiURI used access through a LB uri (used if external type)
	NifiURI string `json:"nifiURI,omitempty"`
	// rootProcessGroupId contains the uuid of the root process group for this cluster (used if external type)
	RootProcessGroupId string `json:"rootProcessGroupId,omitempty"`
	// secretRef reference the secret containing the informations required to authentiticate to the cluster (used if external type)
	SecretRef SecretReference `json:"secretRef,omitempty"`
	// proxyUrl defines the proxy required to query the NiFi cluster (used if external type)
	ProxyUrl string `json:"proxyUrl,omitempty"`
	// Service defines the policy for services owned by NiFiKop operator.
	Service ServicePolicy `json:"service,omitempty"`
	// Pod defines the policy for pods owned by NiFiKop operator.
	Pod PodPolicy `json:"pod,omitempty"`
	// zKAddress specifies the ZooKeeper connection string
	// in the form hostname:port where host and port are those of a Zookeeper server.
	ZKAddress string `json:"zkAddress,omitempty"`
	// zKPath specifies the Zookeeper chroot path as part
	// of its Zookeeper connection string which puts its data under same path in the global ZooKeeper namespace.
	ZKPath string `json:"zkPath,omitempty"`
	// initContainerImage can override the default image used into the init container to check if
	// ZoooKeeper server is reachable.
	InitContainerImage string `json:"initContainerImage,omitempty"`
	// initContainers defines additional initContainers configurations
	InitContainers []corev1.Container `json:"initContainers,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=containers"`
	// clusterImage can specify the whole NiFi cluster image in one place
	ClusterImage string `json:"clusterImage,omitempty"`
	// oneNifiNodePerNode if set to true every nifi node is started on a new node, if there is not enough node to do that
	// it will stay in pending state. If set to false the operator also tries to schedule the nifi node to a unique node
	// but if the node number is insufficient the nifi node will be scheduled to a node where a nifi node is already running.
	OneNifiNodePerNode bool `json:"oneNifiNodePerNode,omitempty"`
	// propage
	PropagateLabels bool `json:"propagateLabels,omitempty"`
	// managedAdminUsers contains the list of users that will be added to the managed admin group (with all rights)
	ManagedAdminUsers []ManagedUser `json:"managedAdminUsers,omitempty"`
	// managedReaderUsers contains the list of users that will be added to the managed reader group (with all view rights)
	ManagedReaderUsers []ManagedUser `json:"managedReaderUsers,omitempty"`
	// readOnlyConfig specifies the read-only type Nifi config cluster wide, all theses
	// will be merged with node specified readOnly configurations, so it can be overwritten per node.
	ReadOnlyConfig ReadOnlyConfig `json:"readOnlyConfig,omitempty"`
	// nodeConfigGroups specifies multiple node configs with unique name
	NodeConfigGroups map[string]NodeConfig `json:"nodeConfigGroups,omitempty"`
	// NodeUserIdentityTemplate specifies the template to be used when naming the node user identity (e.g. node-%d-mysuffix)
	NodeUserIdentityTemplate *string `json:"nodeUserIdentityTemplate,omitempty"`
	// all node requires an image, unique id, and storageConfigs settings
	Nodes []Node `json:"nodes" patchStrategy:"merge" patchMergeKey:"id"`
	// Defines the configuration for PodDisruptionBudget
	DisruptionBudget DisruptionBudget `json:"disruptionBudget,omitempty"`
	// LdapConfiguration specifies the configuration if you want to use LDAP
	LdapConfiguration LdapConfiguration `json:"ldapConfiguration,omitempty"`
	// NifiClusterTaskSpec specifies the configuration of the nifi cluster Tasks
	NifiClusterTaskSpec NifiClusterTaskSpec `json:"nifiClusterTaskSpec,omitempty"`
	// TODO: add vault
	// VaultConfig         	VaultConfig         `json:"vaultConfig,omitempty"`
	// listenerConfig specifies nifi's listener specifig configs
	ListenersConfig *ListenersConfig `json:"listenersConfig,omitempty"`
	// SidecarsConfig defines additional sidecar configurations
	SidecarConfigs []corev1.Container `json:"sidecarConfigs,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,2,rep,name=containers"`
	// ExternalService specifies settings required to access nifi externally
	ExternalServices []ExternalServiceConfig `json:"externalServices,omitempty"`
	// TopologySpreadConstraints specifies any TopologySpreadConstraint objects to be applied to all nodes
	TopologySpreadConstraints []corev1.TopologySpreadConstraint `json:"topologySpreadConstraints,omitempty"`
	// NifiControllerTemplate specifies the template to be used when naming the node controller (e.g. %s-mysuffix)
	// Warning: once defined don't change this value either the operator will no longer be able to manage the cluster
	NifiControllerTemplate *string `json:"nifiControllerTemplate,omitempty"`
	// ControllerUserIdentity specifies what to call the static admin user's identity
	// Warning: once defined don't change this value either the operator will no longer be able to manage the cluster
	ControllerUserIdentity *string `json:"controllerUserIdentity,omitempty"`
}

NifiClusterSpec defines the desired state of NifiCluster.

func (*NifiClusterSpec) DeepCopy 

func (in *NifiClusterSpec) DeepCopy() *NifiClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiClusterSpec.

func (*NifiClusterSpec) DeepCopyInto 

func (in *NifiClusterSpec) DeepCopyInto(out *NifiClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiClusterSpec) GetInitContainerImage 

func (nSpec *NifiClusterSpec) GetInitContainerImage() string

func (*NifiClusterSpec) GetMetricPort 

func (nSpec *NifiClusterSpec) GetMetricPort() *int

func (*NifiClusterSpec) GetZkPath 

func (nSpec *NifiClusterSpec) GetZkPath() string

GetZkPath returns the default "/" ZkPath if not specified otherwise.

type NifiClusterStatus 

type NifiClusterStatus struct {
	// Store the state of each nifi node
	NodesState map[string]NodeState `json:"nodesState,omitempty"`
	// ClusterState holds info about the cluster state
	State ClusterState `json:"state"`
	// RollingUpgradeStatus defines status of rolling upgrade
	RollingUpgrade RollingUpgradeStatus `json:"rollingUpgradeStatus,omitempty"`
	// RootProcessGroupId contains the uuid of the root process group for this cluster
	RootProcessGroupId string `json:"rootProcessGroupId,omitempty"`
	// PrometheusReportingTask contains the status of the prometheus reporting task managed by the operator
	PrometheusReportingTask PrometheusReportingTaskStatus `json:"prometheusReportingTask,omitempty"`
}

NifiClusterStatus defines the observed state of NifiCluster.

func (*NifiClusterStatus) DeepCopy 

func (in *NifiClusterStatus) DeepCopy() *NifiClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiClusterStatus.

func (*NifiClusterStatus) DeepCopyInto 

func (in *NifiClusterStatus) DeepCopyInto(out *NifiClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiClusterTaskSpec 

type NifiClusterTaskSpec struct {
	// RetryDurationMinutes describes the time the operator waits before going back and retrying a cluster task,
	// which can be: scale up, scale down, rolling upgrade.
	RetryDurationMinutes int `json:"retryDurationMinutes"`
}

NifiClusterTaskSpec specifies the configuration of the nifi cluster Tasks.

func (*NifiClusterTaskSpec) DeepCopy 

func (in *NifiClusterTaskSpec) DeepCopy() *NifiClusterTaskSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiClusterTaskSpec.

func (*NifiClusterTaskSpec) DeepCopyInto 

func (in *NifiClusterTaskSpec) DeepCopyInto(out *NifiClusterTaskSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiClusterTaskSpec) GetDurationMinutes 

func (nTaskSpec *NifiClusterTaskSpec) GetDurationMinutes() float64

type NifiConnection 

type NifiConnection struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiConnectionSpec   `json:"spec,omitempty"`
	Status NifiConnectionStatus `json:"status,omitempty"`
}

NifiConnection is the Schema for the nificonnections API.

func (*NifiConnection) DeepCopy 

func (in *NifiConnection) DeepCopy() *NifiConnection

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiConnection.

func (*NifiConnection) DeepCopyInto 

func (in *NifiConnection) DeepCopyInto(out *NifiConnection)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiConnection) DeepCopyObject 

func (in *NifiConnection) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiConnectionList 

type NifiConnectionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiConnection `json:"items"`
}

NifiConnectionList contains a list of NifiConnection.

func (*NifiConnectionList) DeepCopy 

func (in *NifiConnectionList) DeepCopy() *NifiConnectionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiConnectionList.

func (*NifiConnectionList) DeepCopyInto 

func (in *NifiConnectionList) DeepCopyInto(out *NifiConnectionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiConnectionList) DeepCopyObject 

func (in *NifiConnectionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiConnectionSpec 

type NifiConnectionSpec struct {
	// the Source component of the connection.
	Source ComponentReference `json:"source"`
	// the Destination component of the connection.
	Destination ComponentReference `json:"destination"`
	// the Configuration of the connection.
	Configuration ConnectionConfiguration `json:"configuration,omitempty"`
	// describes the way the operator will deal with data when a connection will be updated: drop or drain.
	UpdateStrategy v1.ComponentUpdateStrategy `json:"updateStrategy"`
}

NifiConnectionSpec defines the desired state of NifiConnection.

func (*NifiConnectionSpec) DeepCopy 

func (in *NifiConnectionSpec) DeepCopy() *NifiConnectionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiConnectionSpec.

func (*NifiConnectionSpec) DeepCopyInto 

func (in *NifiConnectionSpec) DeepCopyInto(out *NifiConnectionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiConnectionSpec) IsValid 

func (nCon *NifiConnectionSpec) IsValid() bool

type NifiConnectionStatus 

type NifiConnectionStatus struct {
	// connection ID.
	ConnectionId string `json:"connectionID"`
	// connection current state.
	State ConnectionState `json:"state"`
}

NifiConnectionStatus defines the observed state of NifiConnection.

func (*NifiConnectionStatus) DeepCopy 

func (in *NifiConnectionStatus) DeepCopy() *NifiConnectionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiConnectionStatus.

func (*NifiConnectionStatus) DeepCopyInto 

func (in *NifiConnectionStatus) DeepCopyInto(out *NifiConnectionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiDataflow 

type NifiDataflow struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiDataflowSpec   `json:"spec,omitempty"`
	Status NifiDataflowStatus `json:"status,omitempty"`
}

NifiDataflow is the Schema for the nifidataflows API.

func (*NifiDataflow) ConvertFrom 

func (dst *NifiDataflow) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiDataflow) ConvertTo 

func (src *NifiDataflow) ConvertTo(dst conversion.Hub) error

ConvertNifiClusterTo converts a v1alpha1 to v1 (Hub).

func (*NifiDataflow) DeepCopy 

func (in *NifiDataflow) DeepCopy() *NifiDataflow

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiDataflow.

func (*NifiDataflow) DeepCopyInto 

func (in *NifiDataflow) DeepCopyInto(out *NifiDataflow)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiDataflow) DeepCopyObject 

func (in *NifiDataflow) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NifiDataflow) SetupWebhookWithManager 

func (r *NifiDataflow) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiDataflowList 

type NifiDataflowList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiDataflow `json:"items"`
}

NifiDataflowList contains a list of NifiDataflow.

func (*NifiDataflowList) DeepCopy 

func (in *NifiDataflowList) DeepCopy() *NifiDataflowList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiDataflowList.

func (*NifiDataflowList) DeepCopyInto 

func (in *NifiDataflowList) DeepCopyInto(out *NifiDataflowList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiDataflowList) DeepCopyObject 

func (in *NifiDataflowList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiDataflowSpec 

type NifiDataflowSpec struct {
	// the UUID of the parent process group where you want to deploy your dataflow, if not set deploy at root level.
	ParentProcessGroupID string `json:"parentProcessGroupID,omitempty"`
	// the UUID of the Bucket containing the flow.
	BucketId string `json:"bucketId"`
	// the UUID of the flow to run.
	FlowId string `json:"flowId"`
	// the version of the flow to run, then the latest version of flow will be used.
	FlowVersion *int32 `json:"flowVersion,omitempty"`
	// the position of your dataflow in the canvas.
	FlowPosition *FlowPosition `json:"flowPosition,omitempty"`
	// contains the reference to the ParameterContext with the one the dataflow is linked.
	ParameterContextRef *ParameterContextReference `json:"parameterContextRef,omitempty"`
	// if the flow will be synchronized once, continuously or never
	SyncMode *DataflowSyncMode `json:"syncMode,omitempty"`
	// whether the flow is considered as ran if some controller services are still invalid or not.
	SkipInvalidControllerService bool `json:"skipInvalidControllerService,omitempty"`
	// whether the flow is considered as ran if some components are still invalid or not.
	SkipInvalidComponent bool `json:"skipInvalidComponent,omitempty"`
	// contains the reference to the NifiCluster with the one the dataflow is linked.
	ClusterRef ClusterReference `json:"clusterRef,omitempty"`
	// contains the reference to the NifiRegistry with the one the dataflow is linked.
	RegistryClientRef *RegistryClientReference `json:"registryClientRef,omitempty"`
	// describes the way the operator will deal with data when a dataflow will be updated: drop or drain
	UpdateStrategy ComponentUpdateStrategy `json:"updateStrategy"`
}

NifiDataflowSpec defines the desired state of NifiDataflow.

func (*NifiDataflowSpec) DeepCopy 

func (in *NifiDataflowSpec) DeepCopy() *NifiDataflowSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiDataflowSpec.

func (*NifiDataflowSpec) DeepCopyInto 

func (in *NifiDataflowSpec) DeepCopyInto(out *NifiDataflowSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiDataflowSpec) GetParentProcessGroupID 

func (d *NifiDataflowSpec) GetParentProcessGroupID(rootProcessGroupId string) string

func (*NifiDataflowSpec) GetSyncMode 

func (d *NifiDataflowSpec) GetSyncMode() DataflowSyncMode

func (*NifiDataflowSpec) SyncAlways 

func (d *NifiDataflowSpec) SyncAlways() bool

func (*NifiDataflowSpec) SyncNever 

func (d *NifiDataflowSpec) SyncNever() bool

func (*NifiDataflowSpec) SyncOnce 

func (d *NifiDataflowSpec) SyncOnce() bool

type NifiDataflowStatus 

type NifiDataflowStatus struct {
	// process Group ID
	ProcessGroupID string `json:"processGroupID"`
	// the dataflow current state.
	State DataflowState `json:"state"`
	// the latest version update request sent.
	LatestUpdateRequest *UpdateRequest `json:"latestUpdateRequest,omitempty"`
	// the latest queue drop request sent.
	LatestDropRequest *DropRequest `json:"latestDropRequest,omitempty"`
}

NifiDataflowStatus defines the observed state of NifiDataflow.

func (*NifiDataflowStatus) DeepCopy 

func (in *NifiDataflowStatus) DeepCopy() *NifiDataflowStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiDataflowStatus.

func (*NifiDataflowStatus) DeepCopyInto 

func (in *NifiDataflowStatus) DeepCopyInto(out *NifiDataflowStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiNodeGroupAutoscaler 

type NifiNodeGroupAutoscaler struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiNodeGroupAutoscalerSpec   `json:"spec,omitempty"`
	Status NifiNodeGroupAutoscalerStatus `json:"status,omitempty"`
}

NifiNodeGroupAutoscaler is the Schema for the nifinodegroupautoscalers API.

func (*NifiNodeGroupAutoscaler) DeepCopy 

func (in *NifiNodeGroupAutoscaler) DeepCopy() *NifiNodeGroupAutoscaler

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiNodeGroupAutoscaler.

func (*NifiNodeGroupAutoscaler) DeepCopyInto 

func (in *NifiNodeGroupAutoscaler) DeepCopyInto(out *NifiNodeGroupAutoscaler)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiNodeGroupAutoscaler) DeepCopyObject 

func (in *NifiNodeGroupAutoscaler) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiNodeGroupAutoscalerList 

type NifiNodeGroupAutoscalerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiNodeGroupAutoscaler `json:"items"`
}

NifiNodeGroupAutoscalerList contains a list of NifiNodeGroupAutoscaler.

func (*NifiNodeGroupAutoscalerList) DeepCopy 

func (in *NifiNodeGroupAutoscalerList) DeepCopy() *NifiNodeGroupAutoscalerList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiNodeGroupAutoscalerList.

func (*NifiNodeGroupAutoscalerList) DeepCopyInto 

func (in *NifiNodeGroupAutoscalerList) DeepCopyInto(out *NifiNodeGroupAutoscalerList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiNodeGroupAutoscalerList) DeepCopyObject 

func (in *NifiNodeGroupAutoscalerList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiNodeGroupAutoscalerSpec 

type NifiNodeGroupAutoscalerSpec struct {
	// contains the reference to the NifiCluster with the one the dataflow is linked.
	ClusterRef v1.ClusterReference `json:"clusterRef"`
	// reference to the nodeConfigGroup that will be set for nodes that are managed and autoscaled
	// This Id is used to compute the names of some Kubernetes resources, so it must be a safe value.
	// +kubebuilder:validation:Pattern:="[a-z0-9]([-a-z0-9]*[a-z0-9])?"
	// +kubebuilder:validation:MaxLength:=63
	NodeConfigGroupId string `json:"nodeConfigGroupId"`
	// A label selector used to identify & manage Node objects in the referenced NifiCluster. Any node matching this
	// selector will be managed by this autoscaler. Even if that node was previously statically defined.
	NodeLabelsSelector *metav1.LabelSelector `json:"nodeLabelsSelector"`
	// the node readOnlyConfig for each node in the node group
	// +optional
	ReadOnlyConfig *v1.ReadOnlyConfig `json:"readOnlyConfig,omitempty"`
	// the nodeConfig to use for each node in the node group. This will be merged with and is preferred to the configured
	// nodeConfigGroupId
	// +optional
	NodeConfig *v1.NodeConfig `json:"nodeConfig,omitempty"`
	// current number of replicas expected for the node config group
	// +kubebuilder:default:=0
	// +optional
	Replicas int32 `json:"replicas"`
	// The strategy to use when scaling up the nifi cluster
	// +kubebuilder:validation:Enum={"graceful","simple"}
	UpscaleStrategy ClusterScalingStrategy `json:"upscaleStrategy,omitempty"`
	// The strategy to use when scaling down the nifi cluster
	// +kubebuilder:validation:Enum={"lifo","nonprimary","leastbusy"}
	DownscaleStrategy ClusterScalingStrategy `json:"downscaleStrategy,omitempty"`
}

NifiNodeGroupAutoscalerSpec defines the desired state of NifiNodeGroupAutoscaler.

func (*NifiNodeGroupAutoscalerSpec) DeepCopy 

func (in *NifiNodeGroupAutoscalerSpec) DeepCopy() *NifiNodeGroupAutoscalerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiNodeGroupAutoscalerSpec.

func (*NifiNodeGroupAutoscalerSpec) DeepCopyInto 

func (in *NifiNodeGroupAutoscalerSpec) DeepCopyInto(out *NifiNodeGroupAutoscalerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiNodeGroupAutoscalerSpec) NifiNodeGroupSelectorAsMap 

func (aSpec *NifiNodeGroupAutoscalerSpec) NifiNodeGroupSelectorAsMap() (map[string]string, error)

type NifiNodeGroupAutoscalerStatus 

type NifiNodeGroupAutoscalerStatus struct {
	// The state of this autoscaler
	State NodeGroupAutoscalerState `json:"state"`
	// the current number of replicas in this cluster
	Replicas ClusterReplicas `json:"replicas"`
	// label selectors for cluster child pods. HPA uses this to identify pod replicas
	Selector ClusterReplicaSelector `json:"selector"`
}

NifiNodeGroupAutoscalerStatus defines the observed state of NifiNodeGroupAutoscaler.

func (*NifiNodeGroupAutoscalerStatus) DeepCopy 

func (in *NifiNodeGroupAutoscalerStatus) DeepCopy() *NifiNodeGroupAutoscalerStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiNodeGroupAutoscalerStatus.

func (*NifiNodeGroupAutoscalerStatus) DeepCopyInto 

func (in *NifiNodeGroupAutoscalerStatus) DeepCopyInto(out *NifiNodeGroupAutoscalerStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiParameterContext 

type NifiParameterContext struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiParameterContextSpec   `json:"spec,omitempty"`
	Status NifiParameterContextStatus `json:"status,omitempty"`
}

NifiParameterContext is the Schema for the nifiparametercontexts API.

func (*NifiParameterContext) ConvertFrom 

func (dst *NifiParameterContext) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiParameterContext) ConvertTo 

func (src *NifiParameterContext) ConvertTo(dst conversion.Hub) error

ConvertTo converts a v1alpha1 to v1 (Hub).

func (*NifiParameterContext) DeepCopy 

func (in *NifiParameterContext) DeepCopy() *NifiParameterContext

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiParameterContext.

func (*NifiParameterContext) DeepCopyInto 

func (in *NifiParameterContext) DeepCopyInto(out *NifiParameterContext)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiParameterContext) DeepCopyObject 

func (in *NifiParameterContext) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NifiParameterContext) SetupWebhookWithManager 

func (r *NifiParameterContext) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiParameterContextList 

type NifiParameterContextList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiParameterContext `json:"items"`
}

NifiParameterContextList contains a list of NifiParameterContext.

func (*NifiParameterContextList) DeepCopy 

func (in *NifiParameterContextList) DeepCopy() *NifiParameterContextList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiParameterContextList.

func (*NifiParameterContextList) DeepCopyInto 

func (in *NifiParameterContextList) DeepCopyInto(out *NifiParameterContextList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiParameterContextList) DeepCopyObject 

func (in *NifiParameterContextList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiParameterContextSpec 

type NifiParameterContextSpec struct {
	// the Description of the Parameter Context.
	Description string `json:"description,omitempty"`
	// a list of non-sensitive Parameters.
	Parameters []Parameter `json:"parameters"`
	// contains the reference to the NifiCluster with the one the parameter context is linked.
	ClusterRef ClusterReference `json:"clusterRef,omitempty"`
	// a list of secret containing sensitive parameters (the key will name of the parameter).
	SecretRefs []SecretReference `json:"secretRefs,omitempty"`
	// a list of references of Parameter Contexts from which this one inherits parameters
	InheritedParameterContexts []ParameterContextReference `json:"inheritedParameterContexts,omitempty"`
	// whether or not the operator should take over an existing parameter context if its name is the same.
	DisableTakeOver *bool `json:"disableTakeOver,omitempty"`
}

NifiParameterContextSpec defines the desired state of NifiParameterContext.

func (*NifiParameterContextSpec) DeepCopy 

func (in *NifiParameterContextSpec) DeepCopy() *NifiParameterContextSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiParameterContextSpec.

func (*NifiParameterContextSpec) DeepCopyInto 

func (in *NifiParameterContextSpec) DeepCopyInto(out *NifiParameterContextSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiParameterContextSpec) IsTakeOverEnabled 

func (d *NifiParameterContextSpec) IsTakeOverEnabled() bool

type NifiParameterContextStatus 

type NifiParameterContextStatus struct {
	// the nifi parameter context id.
	Id string `json:"id"`
	// the last nifi parameter context revision version catched.
	Version int64 `json:"version"`
	// the latest update request.
	LatestUpdateRequest *ParameterContextUpdateRequest `json:"latestUpdateRequest,omitempty"`
}

NifiParameterContextStatus defines the observed state of NifiParameterContext.

func (*NifiParameterContextStatus) DeepCopy 

func (in *NifiParameterContextStatus) DeepCopy() *NifiParameterContextStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiParameterContextStatus.

func (*NifiParameterContextStatus) DeepCopyInto 

func (in *NifiParameterContextStatus) DeepCopyInto(out *NifiParameterContextStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiProperties 

type NifiProperties struct {
	// Additionnal nifi.properties configuration that will override the one produced based on template and
	// configuration
	OverrideConfigMap *ConfigmapReference `json:"overrideConfigMap,omitempty"`
	// Additionnal nifi.properties configuration that will override the one produced based
	// on template, configurations and overrideConfigMap.
	OverrideConfigs string `json:"overrideConfigs,omitempty"`
	// Additionnal nifi.properties configuration that will override the one produced based
	// on template, configurations, overrideConfigMap and overrideConfigs.
	OverrideSecretConfig *SecretConfigReference `json:"overrideSecretConfig,omitempty"`
	// A comma separated list of allowed HTTP Host header values to consider when NiFi
	// is running securely and will be receiving requests to a different host[:port] than it is bound to.
	// https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#web-properties
	WebProxyHosts []string `json:"webProxyHosts,omitempty"`
	// Nifi security client auth
	NeedClientAuth bool `json:"needClientAuth,omitempty"`
	// Indicates which of the configured authorizers in the authorizers.xml file to use
	// https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#authorizer-configuration
	Authorizer string `json:"authorizer,omitempty"`
}

NifiProperties configuration that will be applied to the node.

func (*NifiProperties) DeepCopy 

func (in *NifiProperties) DeepCopy() *NifiProperties

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiProperties.

func (*NifiProperties) DeepCopyInto 

func (in *NifiProperties) DeepCopyInto(out *NifiProperties)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (NifiProperties) GetAuthorizer 

func (nProperties NifiProperties) GetAuthorizer() string

type NifiRegistryClient 

type NifiRegistryClient struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiRegistryClientSpec   `json:"spec,omitempty"`
	Status NifiRegistryClientStatus `json:"status,omitempty"`
}

NifiRegistryClient is the Schema for the nifiregistryclients API.

func (*NifiRegistryClient) ConvertFrom 

func (dst *NifiRegistryClient) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiRegistryClient) ConvertTo 

func (src *NifiRegistryClient) ConvertTo(dst conversion.Hub) error

ConvertTo converts a v1alpha1 to v1 (Hub).

func (*NifiRegistryClient) DeepCopy 

func (in *NifiRegistryClient) DeepCopy() *NifiRegistryClient

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiRegistryClient.

func (*NifiRegistryClient) DeepCopyInto 

func (in *NifiRegistryClient) DeepCopyInto(out *NifiRegistryClient)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiRegistryClient) DeepCopyObject 

func (in *NifiRegistryClient) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NifiRegistryClient) SetupWebhookWithManager 

func (r *NifiRegistryClient) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiRegistryClientList 

type NifiRegistryClientList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiRegistryClient `json:"items"`
}

NifiRegistryClientList contains a list of NifiRegistryClient.

func (*NifiRegistryClientList) DeepCopy 

func (in *NifiRegistryClientList) DeepCopy() *NifiRegistryClientList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiRegistryClientList.

func (*NifiRegistryClientList) DeepCopyInto 

func (in *NifiRegistryClientList) DeepCopyInto(out *NifiRegistryClientList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiRegistryClientList) DeepCopyObject 

func (in *NifiRegistryClientList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiRegistryClientSpec 

type NifiRegistryClientSpec struct {
	// The URI of the NiFi registry that should be used for pulling the flow.
	Uri string `json:"uri"`
	// The Description of the Registry client.
	Description string `json:"description,omitempty"`
	// contains the reference to the NifiCluster with the one the registry client is linked.
	ClusterRef ClusterReference `json:"clusterRef,omitempty"`
}

NifiRegistryClientSpec defines the desired state of NifiRegistryClient.

func (*NifiRegistryClientSpec) DeepCopy 

func (in *NifiRegistryClientSpec) DeepCopy() *NifiRegistryClientSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiRegistryClientSpec.

func (*NifiRegistryClientSpec) DeepCopyInto 

func (in *NifiRegistryClientSpec) DeepCopyInto(out *NifiRegistryClientSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiRegistryClientStatus 

type NifiRegistryClientStatus struct {
	// The nifi registry client's id
	Id string `json:"id"`
	// The last nifi registry client revision version catched
	Version int64 `json:"version"`
}

NifiRegistryClientStatus defines the observed state of NifiRegistryClient.

func (*NifiRegistryClientStatus) DeepCopy 

func (in *NifiRegistryClientStatus) DeepCopy() *NifiRegistryClientStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiRegistryClientStatus.

func (*NifiRegistryClientStatus) DeepCopyInto 

func (in *NifiRegistryClientStatus) DeepCopyInto(out *NifiRegistryClientStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiUser 

type NifiUser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiUserSpec   `json:"spec,omitempty"`
	Status NifiUserStatus `json:"status,omitempty"`
}

NifiUser is the Schema for the nifiusers API.

func (*NifiUser) ConvertFrom 

func (dst *NifiUser) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiUser) ConvertTo 

func (src *NifiUser) ConvertTo(dst conversion.Hub) error

ConvertTo converts a v1alpha1 to v1 (Hub).

func (*NifiUser) DeepCopy 

func (in *NifiUser) DeepCopy() *NifiUser

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUser.

func (*NifiUser) DeepCopyInto 

func (in *NifiUser) DeepCopyInto(out *NifiUser)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiUser) DeepCopyObject 

func (in *NifiUser) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*NifiUser) GetIdentity 

func (u *NifiUser) GetIdentity() string

func (*NifiUser) SetupWebhookWithManager 

func (r *NifiUser) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiUserGroup 

type NifiUserGroup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   NifiUserGroupSpec   `json:"spec,omitempty"`
	Status NifiUserGroupStatus `json:"status,omitempty"`
}

NifiUserGroup is the Schema for the nifiusergroups API.

func (*NifiUserGroup) ConvertFrom 

func (dst *NifiUserGroup) ConvertFrom(src conversion.Hub) error

ConvertFrom converts a v1 (Hub) to v1alpha1 (local).

func (*NifiUserGroup) ConvertTo 

func (src *NifiUserGroup) ConvertTo(dst conversion.Hub) error

ConvertTo converts a v1alpha1 to v1 (Hub).

func (*NifiUserGroup) DeepCopy 

func (in *NifiUserGroup) DeepCopy() *NifiUserGroup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserGroup.

func (*NifiUserGroup) DeepCopyInto 

func (in *NifiUserGroup) DeepCopyInto(out *NifiUserGroup)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiUserGroup) DeepCopyObject 

func (in *NifiUserGroup) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (NifiUserGroup) GetIdentity 

func (n NifiUserGroup) GetIdentity() string

func (*NifiUserGroup) SetupWebhookWithManager 

func (r *NifiUserGroup) SetupWebhookWithManager(mgr ctrl.Manager) error

type NifiUserGroupList 

type NifiUserGroupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiUserGroup `json:"items"`
}

NifiUserGroupList contains a list of NifiUserGroup.

func (*NifiUserGroupList) DeepCopy 

func (in *NifiUserGroupList) DeepCopy() *NifiUserGroupList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserGroupList.

func (*NifiUserGroupList) DeepCopyInto 

func (in *NifiUserGroupList) DeepCopyInto(out *NifiUserGroupList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiUserGroupList) DeepCopyObject 

func (in *NifiUserGroupList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiUserGroupSpec 

type NifiUserGroupSpec struct {
	// clusterRef contains the reference to the NifiCluster with the one the registry client is linked.
	ClusterRef ClusterReference `json:"clusterRef"`
	// userRef contains the list of reference to NifiUsers that are part to the group.
	UsersRef []UserReference `json:"usersRef,omitempty"`
	// accessPolicies defines the list of access policies that will be granted to the group.
	AccessPolicies []AccessPolicy `json:"accessPolicies,omitempty"`
}

NifiUserGroupSpec defines the desired state of NifiUserGroup.

func (*NifiUserGroupSpec) DeepCopy 

func (in *NifiUserGroupSpec) DeepCopy() *NifiUserGroupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserGroupSpec.

func (*NifiUserGroupSpec) DeepCopyInto 

func (in *NifiUserGroupSpec) DeepCopyInto(out *NifiUserGroupSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiUserGroupStatus 

type NifiUserGroupStatus struct {
	// The nifi usergroup's node id
	Id string `json:"id"`
	// The last nifi usergroup's node revision version catched
	Version int64 `json:"version"`
}

NifiUserGroupStatus defines the observed state of NifiUserGroup.

func (*NifiUserGroupStatus) DeepCopy 

func (in *NifiUserGroupStatus) DeepCopy() *NifiUserGroupStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserGroupStatus.

func (*NifiUserGroupStatus) DeepCopyInto 

func (in *NifiUserGroupStatus) DeepCopyInto(out *NifiUserGroupStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NifiUserList 

type NifiUserList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []NifiUser `json:"items"`
}

NifiUserList contains a list of NifiUser.

func (*NifiUserList) DeepCopy 

func (in *NifiUserList) DeepCopy() *NifiUserList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserList.

func (*NifiUserList) DeepCopyInto 

func (in *NifiUserList) DeepCopyInto(out *NifiUserList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiUserList) DeepCopyObject 

func (in *NifiUserList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NifiUserSpec 

type NifiUserSpec struct {
	// identity field is used to define the user identity on NiFi cluster side, when the user's name doesn't
	// suit with Kubernetes resource name.
	Identity string `json:"identity,omitempty"`
	// Name of the secret where all cert resources will be stored
	SecretName string `json:"secretName,omitempty"`
	// contains the reference to the NifiCluster with the one the user is linked
	ClusterRef ClusterReference `json:"clusterRef"`
	// List of DNSNames that the user will used to request the NifiCluster (allowing to create the right certificates associated)
	DNSNames []string `json:"dnsNames,omitempty"`
	// Whether or not the the operator also include a Java keystore format (JKS) with you secret
	IncludeJKS bool `json:"includeJKS,omitempty"`
	// Whether or not a certificate will be created for this user.
	CreateCert *bool `json:"createCert,omitempty"`
	// accessPolicies defines the list of access policies that will be granted to the group.
	AccessPolicies []AccessPolicy `json:"accessPolicies,omitempty"`
}

NifiUserSpec defines the desired state of NifiUser.

func (*NifiUserSpec) DeepCopy 

func (in *NifiUserSpec) DeepCopy() *NifiUserSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserSpec.

func (*NifiUserSpec) DeepCopyInto 

func (in *NifiUserSpec) DeepCopyInto(out *NifiUserSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NifiUserSpec) GetCreateCert 

func (u *NifiUserSpec) GetCreateCert() bool

type NifiUserStatus 

type NifiUserStatus struct {
	// The nifi user's node id
	Id string `json:"id"`
	// The last nifi  user's node revision version catched
	Version int64 `json:"version"`
}

NifiUserStatus defines the observed state of NifiUser.

func (*NifiUserStatus) DeepCopy 

func (in *NifiUserStatus) DeepCopy() *NifiUserStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NifiUserStatus.

func (*NifiUserStatus) DeepCopyInto 

func (in *NifiUserStatus) DeepCopyInto(out *NifiUserStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Node 

type Node struct {
	// Unique Node id
	Id int32 `json:"id"`
	// nodeConfigGroup can be used to ease the node configuration, if set only the id is required
	NodeConfigGroup string `json:"nodeConfigGroup,omitempty"`
	// readOnlyConfig can be used to pass Nifi node config https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html
	// which has type read-only these config changes will trigger rolling upgrade
	ReadOnlyConfig *ReadOnlyConfig `json:"readOnlyConfig,omitempty"`
	// node configuration
	NodeConfig *NodeConfig `json:"nodeConfig,omitempty"`
	// Labels are used to distinguish nodes from one another. They are also used by NifiNodeGroupAutoscaler
	// to be automatically scaled. See NifiNodeGroupAutoscaler.Spec.NodeLabelsSelector
	Labels map[string]string `json:"labels,omitempty"`
}

Node defines the nifi node basic configuration.

func (*Node) DeepCopy 

func (in *Node) DeepCopy() *Node

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Node.

func (*Node) DeepCopyInto 

func (in *Node) DeepCopyInto(out *Node)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type NodeConfig 

type NodeConfig struct {
	// provenanceStorage allow to specify the maximum amount of data provenance information to store at a time
	// https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#write-ahead-provenance-repository-properties
	ProvenanceStorage string `json:"provenanceStorage,omitempty"`
	// RunAsUser define the id of the user to run in the Nifi image
	// +kubebuilder:validation:Minimum=1
	RunAsUser *int64 `json:"runAsUser,omitempty"`
	// FSGroup define the id of the group for each volumes in Nifi image
	// +kubebuilder:validation:Minimum=1
	FSGroup *int64 `json:"fsGroup,omitempty"`
	// Set this to true if the instance is a node in a cluster.
	// https://nifi.apache.org/docs/nifi-docs/html/administration-guide.html#basic-cluster-setup
	IsNode *bool `json:"isNode,omitempty"`
	//  Docker image used by the operator to create the node associated
	//  https://hub.docker.com/r/apache/nifi/
	Image string `json:"image,omitempty"`
	// imagePullPolicy define the pull policy for NiFi cluster docker image
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
	// nodeAffinity can be specified, operator populates this value if new pvc added later to node
	NodeAffinity *corev1.NodeAffinity `json:"nodeAffinity,omitempty"`
	// storageConfigs specifies the node related configs
	StorageConfigs []StorageConfig `json:"storageConfigs,omitempty"`
	// externalVolumeConfigs specifies a list of volume to mount into the main container.
	ExternalVolumeConfigs []VolumeConfig `json:"externalVolumeConfigs,omitempty"`
	// serviceAccountName specifies the serviceAccount used for this specific node
	ServiceAccountName string `json:"serviceAccountName,omitempty"`
	// resourceRequirements works exactly like Container resources, the user can specify the limit and the requests
	// through this property
	// https://kubernetes.io/docs/concepts/configuration/manage-compute-resources-container/
	ResourcesRequirements *corev1.ResourceRequirements `json:"resourcesRequirements,omitempty"`
	// imagePullSecrets specifies the secret to use when using private registry
	// https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.11/#localobjectreference-v1-core
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	// nodeSelector can be specified, which set the pod to fit on a node
	// https://kubernetes.io/docs/concepts/configuration/assign-pod-node/#nodeselector
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
	// tolerations can be specified, which set the pod's tolerations
	// https://kubernetes.io/docs/concepts/configuration/taint-and-toleration/#concepts
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`
	// podMetadata allows to add additionnal metadata to the node pods
	PodMetadata Metadata `json:"podMetadata,omitempty"`
	// A list of host aliases to include in a pod's /etc/hosts configuration in the scenario where DNS is not available.
	// This list takes precedence of the one at the NifiCluster.Spec.PodPolicy level
	// +optional
	HostAliases []corev1.HostAlias `json:"hostAliases,omitempty"`
	// priorityClassName can be used to set the priority class applied to the node
	// +optional
	PriorityClassName *string `json:"priorityClassName,omitempty"`
}

NodeConfig defines the node configuration.

func (*NodeConfig) DeepCopy 

func (in *NodeConfig) DeepCopy() *NodeConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeConfig.

func (*NodeConfig) DeepCopyInto 

func (in *NodeConfig) DeepCopyInto(out *NodeConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NodeConfig) GetFSGroup 

func (nConfig *NodeConfig) GetFSGroup() *int64

func (*NodeConfig) GetImagePullPolicy 

func (nConfig *NodeConfig) GetImagePullPolicy() corev1.PullPolicy

GetImagePullPolicy returns the image pull policy to pull containers images.

func (*NodeConfig) GetImagePullSecrets 

func (nConfig *NodeConfig) GetImagePullSecrets() []corev1.LocalObjectReference

GetImagePullSecrets returns the list of Secrets needed to pull Containers images from private repositories.

func (*NodeConfig) GetIsNode 

func (nConfig *NodeConfig) GetIsNode() bool

func (*NodeConfig) GetNodeSelector 

func (nConfig *NodeConfig) GetNodeSelector() map[string]string

GetNodeSelector returns the node selector for the given node.

func (*NodeConfig) GetPodAnnotations 

func (nConfig *NodeConfig) GetPodAnnotations() map[string]string

func (*NodeConfig) GetPodLabels 

func (nConfig *NodeConfig) GetPodLabels() map[string]string

GetNodeLabels returns additional labels configured to be applied to each nifi node.

func (*NodeConfig) GetPriorityClass 

func (nConfig *NodeConfig) GetPriorityClass() string

GetPriorityClass returns the name of the priority class to use for the given node.

func (*NodeConfig) GetProvenanceStorage 

func (nConfig *NodeConfig) GetProvenanceStorage() string

func (*NodeConfig) GetResources 

func (nConfig *NodeConfig) GetResources() *corev1.ResourceRequirements

GetResources returns the nifi node specific Kubernetes resource.

func (*NodeConfig) GetRunAsUser 

func (nConfig *NodeConfig) GetRunAsUser() *int64

func (*NodeConfig) GetServiceAccount 

func (nConfig *NodeConfig) GetServiceAccount() string

GetServiceAccount returns the Kubernetes Service Account to use for Nifi Cluster.

func (*NodeConfig) GetTolerations 

func (nConfig *NodeConfig) GetTolerations() []corev1.Toleration

GetTolerations returns the tolerations for the given node.

type NodeGroupAutoscalerState 

type NodeGroupAutoscalerState string

NodeGroupAutoscalerState holds info autoscaler state.

type NodeState 

type NodeState struct {
	// GracefulActionState holds info about nifi cluster action status
	GracefulActionState GracefulActionState `json:"gracefulActionState"`
	// ConfigurationState holds info about the config
	ConfigurationState ConfigurationState `json:"configurationState"`
	// InitClusterNode contains if this nodes was part of the initial cluster
	InitClusterNode InitClusterNode `json:"initClusterNode"`
	// PodIsReady whether or not the associated pod is ready
	PodIsReady bool `json:"podIsReady"`
	// CreationTime is the time at which this node was created. This must be sortable.
	// +optional
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// LastUpdatedTime is the last time at which this node was updated. This must be sortable.
	// +optional
	LastUpdatedTime metav1.Time `json:"lastUpdatedTime,omitempty"`
}

NifiState holds information about nifi state.

func (*NodeState) DeepCopy 

func (in *NodeState) DeepCopy() *NodeState

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeState.

func (*NodeState) DeepCopyInto 

func (in *NodeState) DeepCopyInto(out *NodeState)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PKIBackend 

type PKIBackend string

PKIBackend represents an interface implementing the PKIManager. +kubebuilder:validation:Enum={"cert-manager","vault"} 

const (
	// PKIBackendCertManager invokes cert-manager for user certificate management.
	PKIBackendCertManager PKIBackend = "cert-manager"
)

type Pair 

type Pair struct {
	Key   string
	Value metav1.Time
}

func (*Pair) DeepCopy 

func (in *Pair) DeepCopy() *Pair

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pair.

func (*Pair) DeepCopyInto 

func (in *Pair) DeepCopyInto(out *Pair)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PairList 

type PairList []Pair

func (PairList) DeepCopy 

func (in PairList) DeepCopy() PairList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PairList.

func (PairList) DeepCopyInto 

func (in PairList) DeepCopyInto(out *PairList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (PairList) Len 

func (p PairList) Len() int

func (PairList) Less 

func (p PairList) Less(i, j int) bool

func (PairList) Swap 

func (p PairList) Swap(i, j int)

type Parameter 

type Parameter struct {
	// the name of the Parameter.
	Name string `json:"name"`
	// the value of the Parameter.
	Value *string `json:"value,omitempty"`
	// the description of the Parameter.
	Description string `json:"description,omitempty"`
	// Whether the parameter is sensitive or not.
	Sensitive bool `json:"sensitive,omitempty"`
}

func (*Parameter) DeepCopy 

func (in *Parameter) DeepCopy() *Parameter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Parameter.

func (*Parameter) DeepCopyInto 

func (in *Parameter) DeepCopyInto(out *Parameter)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ParameterContextReference 

type ParameterContextReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

ParameterContextReference states a reference to a parameter context for dataflow provisioning.

func (*ParameterContextReference) DeepCopy 

func (in *ParameterContextReference) DeepCopy() *ParameterContextReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParameterContextReference.

func (*ParameterContextReference) DeepCopyInto 

func (in *ParameterContextReference) DeepCopyInto(out *ParameterContextReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ParameterContextUpdateRequest 

type ParameterContextUpdateRequest struct {
	// the id of the update request.
	Id string `json:"id"`
	// the uri for this request.
	Uri string `json:"uri"`
	// the timestamp of when the request was submitted This property is read only.
	SubmissionTime string `json:"submissionTime"`
	// the last time this request was updated.
	LastUpdated string `json:"lastUpdated"`
	// whether or not this request has completed.
	Complete bool `json:"complete"`
	// an explication of why the request failed, or null if this request has not failed.
	FailureReason string `json:"failureReason"`
	// the percentage complete of the request, between 0 and 100.
	PercentCompleted int32 `json:"percentCompleted"`
	// the state of the request.
	State string `json:"state"`
}

func (*ParameterContextUpdateRequest) DeepCopy 

func (in *ParameterContextUpdateRequest) DeepCopy() *ParameterContextUpdateRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ParameterContextUpdateRequest.

func (*ParameterContextUpdateRequest) DeepCopyInto 

func (in *ParameterContextUpdateRequest) DeepCopyInto(out *ParameterContextUpdateRequest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PodPolicy 

type PodPolicy struct {
	// Annotations specifies the annotations to attach to pods the operator creates
	Annotations map[string]string `json:"annotations,omitempty"`
	// Labels specifies additional labels to attach to the pods the operator creates
	Labels map[string]string `json:"labels,omitempty"`
	// A list of host aliases to include in every pod's /etc/hosts configuration in the scenario where DNS is not available.
	HostAliases []corev1.HostAlias `json:"hostAliases,omitempty"`
}

func (*PodPolicy) DeepCopy 

func (in *PodPolicy) DeepCopy() *PodPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodPolicy.

func (*PodPolicy) DeepCopyInto 

func (in *PodPolicy) DeepCopyInto(out *PodPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PortConfig 

type PortConfig struct {
	// The port that will be exposed by this service.
	Port int32 `json:"port" protobuf:"varint,3,opt,name=port"`
	// The name of the listener which will be used as target container.
	InternalListenerName string `json:"internalListenerName"`
}

func (*PortConfig) DeepCopy 

func (in *PortConfig) DeepCopy() *PortConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PortConfig.

func (*PortConfig) DeepCopyInto 

func (in *PortConfig) DeepCopyInto(out *PortConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PrometheusReportingTaskStatus 

type PrometheusReportingTaskStatus struct {
	// The nifi reporting task's id
	Id string `json:"id"`
	// The last nifi reporting task revision version catched
	Version int64 `json:"version"`
}

func (*PrometheusReportingTaskStatus) DeepCopy 

func (in *PrometheusReportingTaskStatus) DeepCopy() *PrometheusReportingTaskStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusReportingTaskStatus.

func (*PrometheusReportingTaskStatus) DeepCopyInto 

func (in *PrometheusReportingTaskStatus) DeepCopyInto(out *PrometheusReportingTaskStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RackAwarenessState 

type RackAwarenessState string

RackAwarenessState stores info about rack awareness status.

type ReadOnlyConfig 

type ReadOnlyConfig struct {
	// MaximumTimerDrivenThreadCount define the maximum number of threads for timer driven processors available to the system.
	MaximumTimerDrivenThreadCount *int32 `json:"maximumTimerDrivenThreadCount,omitempty"`
	// MaximumEventDrivenThreadCount define the maximum number of threads for event driven processors available to the system.
	MaximumEventDrivenThreadCount *int32 `json:"maximumEventDrivenThreadCount,omitempty"`
	// AdditionalSharedEnvs define a set of additional env variables that will shared between all init containers and
	// containers in the pod.
	AdditionalSharedEnvs []corev1.EnvVar `json:"additionalSharedEnvs,omitempty"`
	// NifiProperties configuration that will be applied to the node.
	NifiProperties NifiProperties `json:"nifiProperties,omitempty"`
	// ZookeeperProperties configuration that will be applied to the node.
	ZookeeperProperties ZookeeperProperties `json:"zookeeperProperties,omitempty"`
	// BootstrapProperties configuration that will be applied to the node.
	BootstrapProperties BootstrapProperties `json:"bootstrapProperties,omitempty"`
	// Logback configuration that will be applied to the node.
	LogbackConfig LogbackConfig `json:"logbackConfig,omitempty"`
	// Authorizer configuration that will be applied to the node.
	AuthorizerConfig AuthorizerConfig `json:"authorizerConfig,omitempty"`
	// BootstrapNotificationServices configuration that will be applied to the node.
	BootstrapNotificationServicesReplaceConfig BootstrapNotificationServicesConfig `json:"bootstrapNotificationServicesConfig,omitempty"`
}

func (*ReadOnlyConfig) DeepCopy 

func (in *ReadOnlyConfig) DeepCopy() *ReadOnlyConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReadOnlyConfig.

func (*ReadOnlyConfig) DeepCopyInto 

func (in *ReadOnlyConfig) DeepCopyInto(out *ReadOnlyConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReadOnlyConfig) GetMaximumEventDrivenThreadCount 

func (nReadOnlyConfig *ReadOnlyConfig) GetMaximumEventDrivenThreadCount() int32

func (*ReadOnlyConfig) GetMaximumTimerDrivenThreadCount 

func (nReadOnlyConfig *ReadOnlyConfig) GetMaximumTimerDrivenThreadCount() int32

type RegistryClientReference 

type RegistryClientReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

RegistryClientReference states a reference to a registry client for dataflow provisioning.

func (*RegistryClientReference) DeepCopy 

func (in *RegistryClientReference) DeepCopy() *RegistryClientReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RegistryClientReference.

func (*RegistryClientReference) DeepCopyInto 

func (in *RegistryClientReference) DeepCopyInto(out *RegistryClientReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RollingUpgradeStatus 

type RollingUpgradeStatus struct {
	//
	LastSuccess string `json:"lastSuccess"`
	//
	ErrorCount int `json:"errorCount"`
}

RollingUpgradeStatus defines status of rolling upgrade.

func (*RollingUpgradeStatus) DeepCopy 

func (in *RollingUpgradeStatus) DeepCopy() *RollingUpgradeStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RollingUpgradeStatus.

func (*RollingUpgradeStatus) DeepCopyInto 

func (in *RollingUpgradeStatus) DeepCopyInto(out *RollingUpgradeStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SSLSecrets 

type SSLSecrets struct {
	// tlsSecretName should contain all ssl certs required by nifi including: caCert, caKey, clientCert, clientKey
	// serverCert, serverKey, peerCert, peerKey
	TLSSecretName string `json:"tlsSecretName,omitempty"`
	// create tells the installed cert manager to create the required certs keys
	Create bool `json:"create,omitempty"`
	// clusterScoped defines if the Issuer created is cluster or namespace scoped
	ClusterScoped bool `json:"clusterScoped,omitempty"`
	// issuerRef allow to use an existing issuer to act as CA:
	// https://cert-manager.io/docs/concepts/issuer/
	IssuerRef *cmmeta.ObjectReference `json:"issuerRef,omitempty"`
	// TODO: add vault
	PKIBackend PKIBackend `json:"pkiBackend,omitempty"`
}

SSLSecrets defines the Nifi SSL secrets.

func (*SSLSecrets) DeepCopy 

func (in *SSLSecrets) DeepCopy() *SSLSecrets

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SSLSecrets.

func (*SSLSecrets) DeepCopyInto 

func (in *SSLSecrets) DeepCopyInto(out *SSLSecrets)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SecretConfigReference 

type SecretConfigReference struct {
	// Name of the configmap that we want to refer.
	Name string `json:"name"`
	// Namespace where is located the secret that we want to refer.
	Namespace string `json:"namespace,omitempty"`
	// The key of the value,in data content, that we want use.
	Data string `json:"data"`
}

SecretConfigReference states a reference to a data into a secret.

func (*SecretConfigReference) DeepCopy 

func (in *SecretConfigReference) DeepCopy() *SecretConfigReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretConfigReference.

func (*SecretConfigReference) DeepCopyInto 

func (in *SecretConfigReference) DeepCopyInto(out *SecretConfigReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SecretReference 

type SecretReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

SecretReference states a reference to a secret for parameter context provisioning.

func (*SecretReference) DeepCopy 

func (in *SecretReference) DeepCopy() *SecretReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretReference.

func (*SecretReference) DeepCopyInto 

func (in *SecretReference) DeepCopyInto(out *SecretReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServicePolicy 

type ServicePolicy struct {
	// HeadlessEnabled specifies if the cluster should use headlessService for Nifi or individual services
	// using service per nodes may come a handy case of service mesh.
	HeadlessEnabled bool `json:"headlessEnabled"`
	// ServiceTemplate specifies the template to be used when naming the service (e.g. %s-mysuffix)
	ServiceTemplate string `json:"serviceTemplate,omitempty"`
	// Annotations specifies the annotations to attach to services the operator creates
	Annotations map[string]string `json:"annotations,omitempty"`
	// Labels specifies the labels to attach to services the operator creates
	Labels map[string]string `json:"labels,omitempty"`
}

func (*ServicePolicy) DeepCopy 

func (in *ServicePolicy) DeepCopy() *ServicePolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServicePolicy.

func (*ServicePolicy) DeepCopyInto 

func (in *ServicePolicy) DeepCopyInto(out *ServicePolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ServicePolicy) GetServiceTemplate 

func (service *ServicePolicy) GetServiceTemplate() string

type State 

type State string

State holds info about the state of action.

func (State) Complete 

func (r State) Complete() State

func (State) IsDownscale 

func (r State) IsDownscale() bool

func (State) IsRequiredState 

func (r State) IsRequiredState() bool

func (State) IsRunningState 

func (r State) IsRunningState() bool

func (State) IsUpscale 

func (r State) IsUpscale() bool

type StorageConfig 

type StorageConfig struct {
	// Name of the storage config, used to name PV to reuse into sidecars for example.
	// +kubebuilder:validation:Pattern=[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*
	Name string `json:"name"`
	// Path where the volume will be mount into the main nifi container inside the pod.
	MountPath string `json:"mountPath"`
	// Kubernetes PVC spec
	PVCSpec *corev1.PersistentVolumeClaimSpec `json:"pvcSpec"`
}

StorageConfig defines the node storage configuration.

func (*StorageConfig) DeepCopy 

func (in *StorageConfig) DeepCopy() *StorageConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageConfig.

func (*StorageConfig) DeepCopyInto 

func (in *StorageConfig) DeepCopyInto(out *StorageConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdateRequest 

type UpdateRequest struct {
	// defines the type of versioned flow update request.
	Type DataflowUpdateRequestType `json:"type"`
	// the id of the update request.
	Id string `json:"id"`
	// the uri for this request.
	Uri string `json:"uri"`
	// the last time this request was updated.
	LastUpdated string `json:"lastUpdated"`
	// whether or not this request has completed.
	Complete bool `json:"complete"`
	// an explication of why the request failed, or null if this request has not failed.
	FailureReason string `json:"failureReason"`
	// the percentage complete of the request, between 0 and 100.
	PercentCompleted int32 `json:"percentCompleted"`
	// the state of the request
	State string `json:"state"`
}

func (*UpdateRequest) DeepCopy 

func (in *UpdateRequest) DeepCopy() *UpdateRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateRequest.

func (*UpdateRequest) DeepCopyInto 

func (in *UpdateRequest) DeepCopyInto(out *UpdateRequest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UserReference 

type UserReference struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace,omitempty"`
}

UserReference states a reference to a user for user group provisioning.

func (*UserReference) DeepCopy 

func (in *UserReference) DeepCopy() *UserReference

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserReference.

func (*UserReference) DeepCopyInto 

func (in *UserReference) DeepCopyInto(out *UserReference)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UserState 

type UserState string

UserState defines the state of a NifiUser.

type VolumeConfig 

type VolumeConfig struct {
	// VolumeMount describes a mounting of a Volume within a container
	corev1.VolumeMount `json:",inline" protobuf:"bytes,2,opt,name=volumeMount"`
	// VolumeSource represents the location and type of the mounted volume.
	// If not specified, the Volume is implied to be an EmptyDir.
	// This implied behavior is deprecated and will be removed in a future version.
	corev1.VolumeSource `json:",inline" protobuf:"bytes,2,opt,name=volumeSource"`
}

func (*VolumeConfig) DeepCopy 

func (in *VolumeConfig) DeepCopy() *VolumeConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VolumeConfig.

func (*VolumeConfig) DeepCopyInto 

func (in *VolumeConfig) DeepCopyInto(out *VolumeConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VolumeConfig) GenerateVolumeAndVolumeMount 

func (vc *VolumeConfig) GenerateVolumeAndVolumeMount() (corev1.Volume, corev1.VolumeMount)

type ZookeeperProperties 

type ZookeeperProperties struct {
	// Additionnal zookeeper.properties configuration that will override the one produced based on template and
	// configuration
	OverrideConfigMap *ConfigmapReference `json:"overrideConfigMap,omitempty"`
	// Additionnal zookeeper.properties configuration that will override the one produced based
	// on template and configurations.
	OverrideConfigs string `json:"overrideConfigs,omitempty"`
	// Additionnal zookeeper.properties configuration that will override the one produced based
	// on template, configurations, overrideConfigMap and overrideConfigs.
	OverrideSecretConfig *SecretConfigReference `json:"overrideSecretConfig,omitempty"`
}

ZookeeperProperties configuration that will be applied to the node.

func (*ZookeeperProperties) DeepCopy 

func (in *ZookeeperProperties) DeepCopy() *ZookeeperProperties

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperProperties.

func (*ZookeeperProperties) DeepCopyInto 

func (in *ZookeeperProperties) DeepCopyInto(out *ZookeeperProperties)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.