Documentation
¶
Index ¶
- Constants
- func Start(ctx context.Context) error
- type CNPGI
- type IdentityImplementation
- func (i IdentityImplementation) GetPluginCapabilities(_ context.Context, _ *identity.GetPluginCapabilitiesRequest) (*identity.GetPluginCapabilitiesResponse, error)
- func (i IdentityImplementation) GetPluginMetadata(_ context.Context, _ *identity.GetPluginMetadataRequest) (*identity.GetPluginMetadataResponse, error)
- func (i IdentityImplementation) Probe(_ context.Context, _ *identity.ProbeRequest) (*identity.ProbeResponse, error)
- type LifecycleImplementation
- func (impl LifecycleImplementation) GetCapabilities(_ context.Context, _ *lifecycle.OperatorLifecycleCapabilitiesRequest) (*lifecycle.OperatorLifecycleCapabilitiesResponse, error)
- func (impl LifecycleImplementation) LifecycleHook(ctx context.Context, request *lifecycle.OperatorLifecycleRequest) (*lifecycle.OperatorLifecycleResponse, error)
- type ReconcilerImplementation
- func (r ReconcilerImplementation) GetCapabilities(_ context.Context, _ *reconciler.ReconcilerHooksCapabilitiesRequest) (*reconciler.ReconcilerHooksCapabilitiesResult, error)
- func (r ReconcilerImplementation) Post(_ context.Context, _ *reconciler.ReconcilerHooksRequest) (*reconciler.ReconcilerHooksResult, error)
- func (r ReconcilerImplementation) Pre(ctx context.Context, request *reconciler.ReconcilerHooksRequest) (*reconciler.ReconcilerHooksResult, error)
Constants ¶
View Source
const ( // WebhookSecretName is the name of the secret where the certificates // for the webhook server are stored WebhookSecretName = "cnpg-plugin-wal-g-webhook-cert" // #nosec // WebhookServiceName is the name of the service where the webhook server // is reachable WebhookServiceName = "cnpg-plugin-wal-g-webhook-service" // #nosec // MutatingWebhookConfigurationName is the name of the mutating webhook configuration MutatingWebhookConfigurationName = "cnpg-plugin-wal-g-mutating-webhook-configuration" // ValidatingWebhookConfigurationName is the name of the validating webhook configuration ValidatingWebhookConfigurationName = "cnpg-plugin-wal-g-validating-webhook-configuration" // CaSecretName is the name of the secret which is hosting the Operator CA CaSecretName = "cnpg-plugin-wal-g-ca-secret" // #nosec // OperatorDeploymentLabelSelector is the labelSelector to be used to get the operators deployment OperatorDeploymentLabelSelector = "app.kubernetes.io/name=cnpg-plugin-wal-g" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CNPGI ¶
type CNPGI struct {
Client client.Client
ServerAddress string
PluginPath string
ServerCertPath string
ServerCertName string
ServerCertKey string
ClientCertPath string
ClientCertName string
}
CNPGI is the implementation of the CNPG-i server for operator
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 on Kubernetes Pods / Jobs creation by CNPG
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
Click to show internal directories.
Click to hide internal directories.