instance

package

v0.2.2 Latest Latest Go to latest Published: Oct 28, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Details

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

Repository

github.com/wal-g/cnpg-plugin-wal-g

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Start(ctx context.Context) error
type BackupServiceImplementation
- func (b BackupServiceImplementation) Backup(ctx context.Context, request *cnpgbackup.BackupRequest) (*cnpgbackup.BackupResult, error)
- func (b BackupServiceImplementation) GetCapabilities(_ context.Context, _ *cnpgbackup.BackupCapabilitiesRequest) (*cnpgbackup.BackupCapabilitiesResult, error)
type CNPGI
- func (c *CNPGI) Start(ctx context.Context) error
type IdentityImplementation
type RestoreJobHooksImpl
- func (r RestoreJobHooksImpl) GetCapabilities(_ context.Context, _ *restore.RestoreJobHooksCapabilitiesRequest) (*restore.RestoreJobHooksCapabilitiesResult, error)
- func (r RestoreJobHooksImpl) Restore(ctx context.Context, req *restore.RestoreRequest) (*restore.RestoreResponse, error)
type WALServiceImplementation

Constants ¶

View Source

const (
	// ScratchDataDirectory is the directory to be used for scratch data
	ScratchDataDirectory = "/controller"

	// RecoveryTemporaryDirectory provides a path to store temporary files
	// needed in the recovery process
	RecoveryTemporaryDirectory = ScratchDataDirectory + "/recovery"
)

Variables ¶

This section is empty.

Functions ¶

func Start ¶

func Start(ctx context.Context) error

Start starts the sidecar informers and CNPG-i server

Types ¶

type BackupServiceImplementation ¶

type BackupServiceImplementation struct {
	cnpgbackup.UnimplementedBackupServer
	Client client.Client
}

BackupServiceImplementation is the implementation of the Backup CNPG capability

func (BackupServiceImplementation) Backup ¶

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

Backup implements the Backup interface

func (BackupServiceImplementation) GetCapabilities ¶

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

GetCapabilities implements the BackupService interface

type CNPGI ¶

type CNPGI struct {
	Client       client.Client
	PGDataPath   string
	PGWALPath    string
	PluginPath   string
	InstanceName string
}

CNPGI is the implementation of the PostgreSQL instance sidecar plugin for CNPG-I

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

type RestoreJobHooksImpl ¶

type RestoreJobHooksImpl struct {
	restore.UnimplementedRestoreJobHooksServer

	Client client.Client
}

RestoreJobHooksImpl is the implementation of the restore job hooks

func (RestoreJobHooksImpl) GetCapabilities ¶

func (r RestoreJobHooksImpl) GetCapabilities(
	_ context.Context,
	_ *restore.RestoreJobHooksCapabilitiesRequest,
) (*restore.RestoreJobHooksCapabilitiesResult, error)

GetCapabilities returns the capabilities of the restore job hooks

func (RestoreJobHooksImpl) Restore ¶

func (r RestoreJobHooksImpl) Restore(
	ctx context.Context,
	req *restore.RestoreRequest,
) (*restore.RestoreResponse, error)

Restore restores the cluster from a backup

type WALServiceImplementation ¶

type WALServiceImplementation struct {
	wal.UnimplementedWALServer
	Client client.Client
}

WALServiceImplementation is the implementation of the WAL Service

func (WALServiceImplementation) Archive ¶

func (w WALServiceImplementation) Archive(
	ctx context.Context,
	request *wal.WALArchiveRequest,
) (*wal.WALArchiveResult, error)

Archive implements the WALService interface

func (WALServiceImplementation) GetCapabilities ¶

func (w WALServiceImplementation) GetCapabilities(
	_ context.Context,
	_ *wal.WALCapabilitiesRequest,
) (*wal.WALCapabilitiesResult, error)

GetCapabilities implements the WALService interface

func (WALServiceImplementation) Restore ¶

func (w WALServiceImplementation) Restore(
	ctx context.Context,
	request *wal.WALRestoreRequest,
) (*wal.WALRestoreResult, error)

Restore implements the WALService interface

func (WALServiceImplementation) SetFirstRequired ¶

func (w WALServiceImplementation) SetFirstRequired(
	_ context.Context,
	_ *wal.SetFirstRequiredRequest,
) (*wal.SetFirstRequiredResult, error)

SetFirstRequired implements the WALService interface

func (WALServiceImplementation) Status ¶

func (w WALServiceImplementation) Status(
	_ context.Context,
	_ *wal.WALStatusRequest,
) (*wal.WALStatusResult, error)

Status implements the WALService interface

Source Files ¶

View all Source files

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