operator

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2025 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package operator implements the capabilities used by CNPG

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InjectPluginVolumePodSpec 

func InjectPluginVolumePodSpec(spec *corev1.PodSpec, mainContainerName string)

InjectPluginVolumePodSpec injects the plugin volume into a CNPG Pod spec.

func Start 

func Start(ctx context.Context) error

Start starts the manager

Types

type CNPGI 

type CNPGI struct {
	Client         client.Client
	PluginPath     string
	ServerCertPath string
	ServerKeyPath  string
	ClientCertPath string
	ServerAddress  string
}

CNPGI is the implementation of the CNPG-i server

func (*CNPGI) Start 

func (c *CNPGI) Start(ctx context.Context) error

Start starts the GRPC server of the operator plugin

type IdentityImplementation 

type IdentityImplementation struct {
	identity.UnimplementedIdentityServer
}

IdentityImplementation is the implementation of the CNPG-i Identity entrypoint

func (IdentityImplementation) GetPluginCapabilities 

func (i IdentityImplementation) GetPluginCapabilities(
	_ context.Context,
	_ *identity.GetPluginCapabilitiesRequest,
) (*identity.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities implements identity

func (IdentityImplementation) GetPluginMetadata 

func (i IdentityImplementation) GetPluginMetadata(
	_ context.Context,
	_ *identity.GetPluginMetadataRequest,
) (*identity.GetPluginMetadataResponse, error)

GetPluginMetadata implements Identity

func (IdentityImplementation) Probe 

func (i IdentityImplementation) Probe(
	_ context.Context,
	_ *identity.ProbeRequest,
) (*identity.ProbeResponse, error)

Probe implements Identity

type LifecycleImplementation 

type LifecycleImplementation struct {
	lifecycle.UnimplementedOperatorLifecycleServer
	Client client.Client
}

LifecycleImplementation is the implementation of the lifecycle handler

func (LifecycleImplementation) GetCapabilities 

func (impl LifecycleImplementation) GetCapabilities(
	_ context.Context,
	_ *lifecycle.OperatorLifecycleCapabilitiesRequest,
) (*lifecycle.OperatorLifecycleCapabilitiesResponse, error)

GetCapabilities exposes the lifecycle capabilities

func (LifecycleImplementation) LifecycleHook 

func (impl LifecycleImplementation) LifecycleHook(
	ctx context.Context,
	request *lifecycle.OperatorLifecycleRequest,
) (*lifecycle.OperatorLifecycleResponse, error)

LifecycleHook is called when creating Kubernetes services

type ReconcilerImplementation 

type ReconcilerImplementation struct {
	Client client.Client
	reconciler.UnimplementedReconcilerHooksServer
}

ReconcilerImplementation implements the Reconciler capability

func (ReconcilerImplementation) GetCapabilities 

func (r ReconcilerImplementation) GetCapabilities(
	_ context.Context,
	_ *reconciler.ReconcilerHooksCapabilitiesRequest,
) (*reconciler.ReconcilerHooksCapabilitiesResult, error)

GetCapabilities implements the Reconciler interface

func (ReconcilerImplementation) Post 

func (r ReconcilerImplementation) Post(
	_ context.Context,
	_ *reconciler.ReconcilerHooksRequest,
) (*reconciler.ReconcilerHooksResult, error)

Post implements the reconciler interface

func (ReconcilerImplementation) Pre 

func (r ReconcilerImplementation) Pre(
	ctx context.Context,
	request *reconciler.ReconcilerHooksRequest,
) (*reconciler.ReconcilerHooksResult, error)

Pre implements the reconciler interface

Source Files

View all Source files

Directories

Path Synopsis
Package config contains the functions to parse the plugin configuration
 Package config contains the functions to parse the plugin configuration
Package specs contains the specification of the kubernetes objects that are created by the plugin
 Package specs contains the specification of the kubernetes objects that are created by the plugin

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.