node

package

v0.0.0-...-1a50177 Latest Latest Go to latest Published: Jan 4, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zncdatadev/nifi-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewConfigReconciler(client *client.Client, clusterConfig *nifiv1alpha1.ClusterConfigSpec, ...) *reconciler.SimpleResourceReconciler[builder.ConfigBuilder]
func NewServiceReconciler(client *client.Client, name string, ports []corev1.ContainerPort, ...) *reconciler.Service
func NewStatefulSetReconciler(client *client.Client, roleGroupInfo reconciler.RoleGroupInfo, ...) (*reconciler.StatefulSet, error)
type NifiConfigMapBuilder
- func NewNifiConfigBuilder(client *client.Client, clusterConfig *nifiv1alpha1.ClusterConfigSpec, ...) *NifiConfigMapBuilder
- func (b *NifiConfigMapBuilder) Build(ctx context.Context) (ctrlclient.Object, error)
type Reconciler
- func NewReconciler(client *resourceClient.Client, clusterStopped bool, ...) *Reconciler
- func (r *Reconciler) RegisterResourceWithRoleGroup(ctx context.Context, replicas *int32, info reconciler.RoleGroupInfo, ...) ([]reconciler.Reconciler, error)
- func (r *Reconciler) RegisterResources(ctx context.Context) error
type ServiceBuilder
- func NewServiceBuilder(client *client.Client, name string, ports []corev1.ContainerPort, ...) *ServiceBuilder
- func (b *ServiceBuilder) Build(_ context.Context) (ctrlclient.Object, error)
type StatefulSetBuilder
- func (b *StatefulSetBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

Constants ¶

View Source

const (
	DefaultServerTlsStorePassword = "changeit"
	DefaultServerTlsKeyPassword   = "changeit"
)

View Source

const (
	NifiConfigVolumeName        = "nifi-config"
	NifiAdminPasswordVolumeName = "nifi-admin-password"
	EmptyDirVolumeName          = "empty-dir"
)

Variables ¶

View Source

var (
	NifiRoot                 = path.Join(constants.KubedoopRoot, "nifi")
	NifiConfigDir            = path.Join(NifiRoot, "conf")
	NifiSensitivePropertyDir = path.Join(NifiRoot, "sensitiveproperty")
	NifiServerTlsDir         = path.Join(NifiRoot, "server-tls")
)

View Source

var NifiRepositoryMouhtPath = map[string]string{
	"database":   path.Join(constants.KubedoopDataDir, nifiRepository("data")),
	"flowfile":   path.Join(constants.KubedoopDataDir, nifiRepository("flowfile")),
	"content":    path.Join(constants.KubedoopDataDir, nifiRepository("content")),
	"provenance": path.Join(constants.KubedoopDataDir, nifiRepository("provenance")),
	"state":      path.Join(constants.KubedoopDataDir, nifiRepository("state")),
	"status":     path.Join(constants.KubedoopDataDir, nifiRepository("status")),
	"server-tls": path.Join(constants.KubedoopDataDir, nifiRepository("server_tls")),
}

View Source

var (
	Ports = []corev1.ContainerPort{
		{
			Name:          "http",
			ContainerPort: 8088,
		},
		{
			Name:          "https",
			ContainerPort: 9443,
		},
		{
			Name:          "protocol",
			ContainerPort: 9088,
		},
		{
			Name:          "balance",
			ContainerPort: 6243,
		},
		{
			Name:          "metrics",
			ContainerPort: 8081,
		},
	}
)

Functions ¶

func NewConfigReconciler ¶

func NewConfigReconciler(
	client *client.Client,
	clusterConfig *nifiv1alpha1.ClusterConfigSpec,
	roleGroupInfo reconciler.RoleGroupInfo,
	config *nifiv1alpha1.ConfigSpec,
	authentication *security.Authentication,
) *reconciler.SimpleResourceReconciler[builder.ConfigBuilder]

func NewServiceReconciler ¶

func NewServiceReconciler(
	client *client.Client,
	name string,
	ports []corev1.ContainerPort,
	options ...builder.ServiceBuilderOption,
) *reconciler.Service

func NewStatefulSetReconciler ¶

func NewStatefulSetReconciler(
	client *client.Client,
	roleGroupInfo reconciler.RoleGroupInfo,
	clusterConfig *nifiv1alpha1.ClusterConfigSpec,
	ports []corev1.ContainerPort,
	image *util.Image,
	replicas *int32,
	stopped bool,
	authentication *security.Authentication,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *nifiv1alpha1.ConfigSpec,
) (*reconciler.StatefulSet, error)

Types ¶

type NifiConfigMapBuilder ¶

type NifiConfigMapBuilder struct {
	builder.ConfigMapBuilder

	ClusterConfig *nifiv1alpha1.ClusterConfigSpec

	ClusterName    string
	RoleName       string
	RoleGroupName  string
	Config         *nifiv1alpha1.ConfigSpec
	Authentication *security.Authentication
}

func NewNifiConfigBuilder ¶

func NewNifiConfigBuilder(
	client *client.Client,
	clusterConfig *nifiv1alpha1.ClusterConfigSpec,
	roleGroupInfo reconciler.RoleGroupInfo,
	config *nifiv1alpha1.ConfigSpec,
	authentication *security.Authentication,
) *NifiConfigMapBuilder

func (*NifiConfigMapBuilder) Build ¶

func (b *NifiConfigMapBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

type Reconciler ¶

type Reconciler struct {
	reconciler.BaseRoleReconciler[*nifiv1alpha1.NodesSpec]
	ClusterConfig *nifiv1alpha1.ClusterConfigSpec
	Image         *util.Image
}

func NewReconciler ¶

func NewReconciler(
	client *resourceClient.Client,
	clusterStopped bool,
	clusterConfig *nifiv1alpha1.ClusterConfigSpec,
	roleInfo reconciler.RoleInfo,
	image *util.Image,
	spec *nifiv1alpha1.NodesSpec,
) *Reconciler

func (*Reconciler) RegisterResourceWithRoleGroup ¶

func (r *Reconciler) RegisterResourceWithRoleGroup(
	ctx context.Context,
	replicas *int32,
	info reconciler.RoleGroupInfo,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *nifiv1alpha1.ConfigSpec,
) ([]reconciler.Reconciler, error)

func (*Reconciler) RegisterResources ¶

func (r *Reconciler) RegisterResources(ctx context.Context) error

type ServiceBuilder ¶

type ServiceBuilder struct {
	*builder.BaseServiceBuilder
}

func NewServiceBuilder ¶

func NewServiceBuilder(
	client *client.Client,
	name string,
	ports []corev1.ContainerPort,
	options ...builder.ServiceBuilderOption,
) *ServiceBuilder

func (*ServiceBuilder) Build ¶

func (b *ServiceBuilder) Build(_ context.Context) (ctrlclient.Object, error)

type StatefulSetBuilder ¶

type StatefulSetBuilder struct {
	builder.StatefulSet
	Ports          []corev1.ContainerPort
	ClusterConfig  *nifiv1alpha1.ClusterConfigSpec
	ClusterName    string
	RoleName       string
	Authentication *security.Authentication
}

func (*StatefulSetBuilder) Build ¶

func (b *StatefulSetBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL