instance

Documentation

Overview

Package instance implements the capabilities used by the operator sidecar

Index

• func Start(ctx context.Context) error
• type BackupServiceImplementation
  • func (b BackupServiceImplementation) Backup(ctx context.Context, request *backup.BackupRequest) (*backup.BackupResult, error)
  • func (b BackupServiceImplementation) GetCapabilities(_ context.Context, _ *backup.BackupCapabilitiesRequest) (*backup.BackupCapabilitiesResult, error)
• type CNPGI
  • func (c *CNPGI) Start(ctx context.Context) error
• 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)

Functions

func Start

func Start(ctx context.Context) error

Start starts the sidecar informers and CNPG-i server

Types

type BackupServiceImplementation

type BackupServiceImplementation struct {
	Client       client.Client
	InstanceName string
	backup.UnimplementedBackupServer
}

BackupServiceImplementation is the implementation of the Backup CNPG capability

func (BackupServiceImplementation) Backup

func (b BackupServiceImplementation) Backup(
	ctx context.Context,
	request *backup.BackupRequest,
) (*backup.BackupResult, error)

Backup implements the Backup interface

func (BackupServiceImplementation) GetCapabilities

func (b BackupServiceImplementation) GetCapabilities(
	_ context.Context, _ *backup.BackupCapabilitiesRequest,
) (*backup.BackupCapabilitiesResult, error)

GetCapabilities implements the BackupService interface

type CNPGI

type CNPGI struct {
	Client         client.Client
	PGDataPath     string
	PGWALPath      string
	SpoolDirectory string
	// mutually exclusive with serverAddress
	PluginPath   string
	InstanceName string
}

CNPGI is the implementation of the PostgreSQL sidecar

func (*CNPGI) Start

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

Start starts the GRPC service

type IdentityImplementation

type IdentityImplementation struct {
	identity.UnimplementedIdentityServer
	Client client.Client
}

IdentityImplementation implements IdentityServer

func (IdentityImplementation) GetPluginCapabilities

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

GetPluginCapabilities implements IdentityServer

func (IdentityImplementation) GetPluginMetadata

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

GetPluginMetadata implements IdentityServer

func (IdentityImplementation) Probe

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

Probe implements IdentityServer