agent

Documentation

Index

• Variables
• func AddReplicationEntriesToPgHbaConf(confs []*idl.AddReplicationEntriesRequest_Entry) error
• func RestoreTablespaces(backupDir string, tablespaces map[int32]*idl.TablespaceInfo, oldDBID string, ...) error
• type Server
  • func New() *Server
  • func (s *Server) AddReplicationEntries(ctx context.Context, req *idl.AddReplicationEntriesRequest) (*idl.AddReplicationEntriesReply, error)
  • func (s *Server) ArchiveLogDirectory(ctx context.Context, req *idl.ArchiveLogDirectoryRequest) (*idl.ArchiveLogDirectoryReply, error)
  • func (s *Server) CheckDiskSpace(ctx context.Context, in *idl.CheckSegmentDiskSpaceRequest) (*idl.CheckDiskSpaceReply, error)
  • func (s *Server) CreateBackupDirectory(ctx context.Context, req *idl.CreateBackupDirectoryRequest) (*idl.CreateBackupDirectoryReply, error)
  • func (s *Server) CreateRecoveryConf(ctx context.Context, req *idl.CreateRecoveryConfRequest) (*idl.CreateRecoveryConfReply, error)
  • func (s *Server) DeleteBackupDirectory(ctx context.Context, req *idl.DeleteBackupDirectoryRequest) (*idl.DeleteBackupDirectoryReply, error)
  • func (s *Server) DeleteDataDirectories(ctx context.Context, in *idl.DeleteDataDirectoriesRequest) (*idl.DeleteDataDirectoriesReply, error)
  • func (s *Server) DeleteStateDirectory(ctx context.Context, in *idl.DeleteStateDirectoryRequest) (*idl.DeleteStateDirectoryReply, error)
  • func (s *Server) DeleteTablespaceDirectories(ctx context.Context, in *idl.DeleteTablespaceRequest) (*idl.DeleteTablespaceReply, error)
  • func (s *Server) RenameDirectories(ctx context.Context, in *idl.RenameDirectoriesRequest) (*idl.RenameDirectoriesReply, error)
  • func (s *Server) RenameTablespaces(ctx context.Context, req *idl.RenameTablespacesRequest) (*idl.RenameTablespacesReply, error)
  • func (s *Server) RestorePrimariesPgControl(ctx context.Context, in *idl.RestorePgControlRequest) (*idl.RestorePgControlReply, error)
  • func (s *Server) RsyncDataDirectories(ctx context.Context, in *idl.RsyncRequest) (*idl.RsyncReply, error)
  • func (s *Server) RsyncTablespaceDirectories(ctx context.Context, in *idl.RsyncRequest) (*idl.RsyncReply, error)
  • func (s *Server) Start(port int, stateDir string, daemonize bool) error
  • func (s *Server) Stop()
  • func (s *Server) StopAgent(ctx context.Context, in *idl.StopAgentRequest) (*idl.StopAgentReply, error)
  • func (s *Server) UpdateConfiguration(ctx context.Context, req *idl.UpdateConfigurationRequest) (*idl.UpdateConfigurationReply, error)
  • func (s *Server) UpgradePrimaries(ctx context.Context, req *idl.UpgradePrimariesRequest) (*idl.UpgradePrimariesReply, error)

Variables

var DeleteDirectoriesFunc = upgrade.DeleteDirectories

var RenameDirectories = upgrade.RenameDirectories

Functions

func AddReplicationEntriesToPgHbaConf

func AddReplicationEntriesToPgHbaConf(confs []*idl.AddReplicationEntriesRequest_Entry) error

func RestoreTablespaces

func RestoreTablespaces(backupDir string, tablespaces map[int32]*idl.TablespaceInfo, oldDBID string, newDataDir string) error

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func New

func New() *Server

func (*Server) AddReplicationEntries

func (s *Server) AddReplicationEntries(ctx context.Context, req *idl.AddReplicationEntriesRequest) (*idl.AddReplicationEntriesReply, error)

func (*Server) ArchiveLogDirectory

func (s *Server) ArchiveLogDirectory(ctx context.Context, req *idl.ArchiveLogDirectoryRequest) (*idl.ArchiveLogDirectoryReply, error)

func (*Server) CheckDiskSpace

func (s *Server) CheckDiskSpace(ctx context.Context, in *idl.CheckSegmentDiskSpaceRequest) (*idl.CheckDiskSpaceReply, error)

func (*Server) CreateBackupDirectory

func (s *Server) CreateBackupDirectory(ctx context.Context, req *idl.CreateBackupDirectoryRequest) (*idl.CreateBackupDirectoryReply, error)

func (*Server) CreateRecoveryConf

func (s *Server) CreateRecoveryConf(ctx context.Context, req *idl.CreateRecoveryConfRequest) (*idl.CreateRecoveryConfReply, error)

func (*Server) DeleteBackupDirectory

func (s *Server) DeleteBackupDirectory(ctx context.Context, req *idl.DeleteBackupDirectoryRequest) (*idl.DeleteBackupDirectoryReply, error)

func (*Server) DeleteDataDirectories

func (s *Server) DeleteDataDirectories(ctx context.Context, in *idl.DeleteDataDirectoriesRequest) (*idl.DeleteDataDirectoriesReply, error)

func (*Server) DeleteStateDirectory

func (s *Server) DeleteStateDirectory(ctx context.Context, in *idl.DeleteStateDirectoryRequest) (*idl.DeleteStateDirectoryReply, error)

func (*Server) DeleteTablespaceDirectories

func (s *Server) DeleteTablespaceDirectories(ctx context.Context, in *idl.DeleteTablespaceRequest) (*idl.DeleteTablespaceReply, error)

func (*Server) RenameDirectories

func (s *Server) RenameDirectories(ctx context.Context, in *idl.RenameDirectoriesRequest) (*idl.RenameDirectoriesReply, error)

func (*Server) RenameTablespaces

func (s *Server) RenameTablespaces(ctx context.Context, req *idl.RenameTablespacesRequest) (*idl.RenameTablespacesReply, error)

func (*Server) RestorePrimariesPgControl

func (s *Server) RestorePrimariesPgControl(ctx context.Context, in *idl.RestorePgControlRequest) (*idl.RestorePgControlReply, error)

func (*Server) RsyncDataDirectories

func (s *Server) RsyncDataDirectories(ctx context.Context, in *idl.RsyncRequest) (*idl.RsyncReply, error)

func (*Server) RsyncTablespaceDirectories

func (s *Server) RsyncTablespaceDirectories(ctx context.Context, in *idl.RsyncRequest) (*idl.RsyncReply, error)

func (*Server) Start

func (s *Server) Start(port int, stateDir string, daemonize bool) error

func (*Server) Stop

func (s *Server) Stop()

func (*Server) StopAgent

func (s *Server) StopAgent(ctx context.Context, in *idl.StopAgentRequest) (*idl.StopAgentReply, error)

func (*Server) UpdateConfiguration

func (s *Server) UpdateConfiguration(ctx context.Context, req *idl.UpdateConfigurationRequest) (*idl.UpdateConfigurationReply, error)

func (*Server) UpgradePrimaries

func (s *Server) UpgradePrimaries(ctx context.Context, req *idl.UpgradePrimariesRequest) (*idl.UpgradePrimariesReply, error)