Documentation
¶
Index ¶
Constants ¶
View Source
const (
LatestCommitTimestampFile = "/pgdata/latest_commit_timestamp.txt"
)
Variables ¶
View Source
var ( LatestTimestampFileNotFound = errors.Errorf("%s not found in container", LatestCommitTimestampFile) PrimaryPodNotFound = errors.New("primary pod not found") LatestTimestampIsBeforeBackupStart = errors.New("latest commit timestamp is before backup start timestamp") )
Functions ¶
func GetLatestCommitTimestamp ¶
func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *clientcmd.Client, cr *pgv2.PerconaPGCluster, backup *pgv2.PerconaPGBackup) (*metav1.Time, error)
GetLatestCommitTimestamp gets the timestamp of the latest commit.
func WatchCommitTimestamps ¶
func WatchCommitTimestamps(ctx context.Context, cli client.Client, eventChan chan event.GenericEvent, stopChan chan event.DeleteEvent, cr *pgv2.PerconaPGCluster)
Types ¶
type WALWatcher ¶
type WALWatcher func(context.Context, client.Client, chan event.GenericEvent, chan event.DeleteEvent, *pgv2.PerconaPGCluster)
func GetWALWatcher ¶
func GetWALWatcher(cr *pgv2.PerconaPGCluster) (string, WALWatcher)
Source Files
Click to show internal directories.
Click to hide internal directories.