idl

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

type AddReplicationEntriesRequest struct {
	Entries []*AddReplicationEntriesRequest_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

type AddReplicationEntriesRequest_Entry struct {
	DataDir   string   `protobuf:"bytes,1,opt,name=DataDir,proto3" json:"DataDir,omitempty"`
	User      string   `protobuf:"bytes,2,opt,name=User,proto3" json:"User,omitempty"`
	HostAddrs []string `protobuf:"bytes,3,rep,name=HostAddrs,proto3" json:"HostAddrs,omitempty"`
	// contains filtered or unexported fields
}

type AgentClient interface {
	CreateBackupDirectory(ctx context.Context, in *CreateBackupDirectoryRequest, opts ...grpc.CallOption) (*CreateBackupDirectoryReply, error)
	CheckDiskSpace(ctx context.Context, in *CheckSegmentDiskSpaceRequest, opts ...grpc.CallOption) (*CheckDiskSpaceReply, error)
	UpgradePrimaries(ctx context.Context, in *UpgradePrimariesRequest, opts ...grpc.CallOption) (*UpgradePrimariesReply, error)
	RenameDirectories(ctx context.Context, in *RenameDirectoriesRequest, opts ...grpc.CallOption) (*RenameDirectoriesReply, error)
	StopAgent(ctx context.Context, in *StopAgentRequest, opts ...grpc.CallOption) (*StopAgentReply, error)
	DeleteDataDirectories(ctx context.Context, in *DeleteDataDirectoriesRequest, opts ...grpc.CallOption) (*DeleteDataDirectoriesReply, error)
	DeleteBackupDirectory(ctx context.Context, in *DeleteBackupDirectoryRequest, opts ...grpc.CallOption) (*DeleteBackupDirectoryReply, error)
	DeleteStateDirectory(ctx context.Context, in *DeleteStateDirectoryRequest, opts ...grpc.CallOption) (*DeleteStateDirectoryReply, error)
	DeleteTablespaceDirectories(ctx context.Context, in *DeleteTablespaceRequest, opts ...grpc.CallOption) (*DeleteTablespaceReply, error)
	ArchiveLogDirectory(ctx context.Context, in *ArchiveLogDirectoryRequest, opts ...grpc.CallOption) (*ArchiveLogDirectoryReply, error)
	RsyncDataDirectories(ctx context.Context, in *RsyncRequest, opts ...grpc.CallOption) (*RsyncReply, error)
	RsyncTablespaceDirectories(ctx context.Context, in *RsyncRequest, opts ...grpc.CallOption) (*RsyncReply, error)
	RestorePrimariesPgControl(ctx context.Context, in *RestorePgControlRequest, opts ...grpc.CallOption) (*RestorePgControlReply, error)
	UpdateConfiguration(ctx context.Context, in *UpdateConfigurationRequest, opts ...grpc.CallOption) (*UpdateConfigurationReply, error)
	RenameTablespaces(ctx context.Context, in *RenameTablespacesRequest, opts ...grpc.CallOption) (*RenameTablespacesReply, error)
	CreateRecoveryConf(ctx context.Context, in *CreateRecoveryConfRequest, opts ...grpc.CallOption) (*CreateRecoveryConfReply, error)
	AddReplicationEntries(ctx context.Context, in *AddReplicationEntriesRequest, opts ...grpc.CallOption) (*AddReplicationEntriesReply, error)
}

type AgentServer interface {
	CreateBackupDirectory(context.Context, *CreateBackupDirectoryRequest) (*CreateBackupDirectoryReply, error)
	CheckDiskSpace(context.Context, *CheckSegmentDiskSpaceRequest) (*CheckDiskSpaceReply, error)
	UpgradePrimaries(context.Context, *UpgradePrimariesRequest) (*UpgradePrimariesReply, error)
	RenameDirectories(context.Context, *RenameDirectoriesRequest) (*RenameDirectoriesReply, error)
	StopAgent(context.Context, *StopAgentRequest) (*StopAgentReply, error)
	DeleteDataDirectories(context.Context, *DeleteDataDirectoriesRequest) (*DeleteDataDirectoriesReply, error)
	DeleteBackupDirectory(context.Context, *DeleteBackupDirectoryRequest) (*DeleteBackupDirectoryReply, error)
	DeleteStateDirectory(context.Context, *DeleteStateDirectoryRequest) (*DeleteStateDirectoryReply, error)
	DeleteTablespaceDirectories(context.Context, *DeleteTablespaceRequest) (*DeleteTablespaceReply, error)
	ArchiveLogDirectory(context.Context, *ArchiveLogDirectoryRequest) (*ArchiveLogDirectoryReply, error)
	RsyncDataDirectories(context.Context, *RsyncRequest) (*RsyncReply, error)
	RsyncTablespaceDirectories(context.Context, *RsyncRequest) (*RsyncReply, error)
	RestorePrimariesPgControl(context.Context, *RestorePgControlRequest) (*RestorePgControlReply, error)
	UpdateConfiguration(context.Context, *UpdateConfigurationRequest) (*UpdateConfigurationReply, error)
	RenameTablespaces(context.Context, *RenameTablespacesRequest) (*RenameTablespacesReply, error)
	CreateRecoveryConf(context.Context, *CreateRecoveryConfRequest) (*CreateRecoveryConfReply, error)
	AddReplicationEntries(context.Context, *AddReplicationEntriesRequest) (*AddReplicationEntriesReply, error)
}

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

type ArchiveLogDirectoryRequest struct {
	LogArchiveDir string `protobuf:"bytes,1,opt,name=logArchiveDir,proto3" json:"logArchiveDir,omitempty"`
	// contains filtered or unexported fields
}

type CheckDiskSpaceReply struct {
	Usages []*CheckDiskSpaceReply_DiskUsage `protobuf:"bytes,1,rep,name=usages,proto3" json:"usages,omitempty"`
	// contains filtered or unexported fields
}

type CheckDiskSpaceReply_DiskUsage struct {
	Fs        string `protobuf:"bytes,1,opt,name=fs,proto3" json:"fs,omitempty"`
	Host      string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Available uint64 `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	Required  uint64 `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

type CheckSegmentDiskSpaceRequest struct {
	DiskFreeRatio float64  `protobuf:"fixed64,1,opt,name=diskFreeRatio,proto3" json:"diskFreeRatio,omitempty"`
	Dirs          []string `protobuf:"bytes,2,rep,name=dirs,proto3" json:"dirs,omitempty"`
	// contains filtered or unexported fields
}

type Chunk struct {
	Buffer []byte     `protobuf:"bytes,1,opt,name=buffer,proto3" json:"buffer,omitempty"`
	Type   Chunk_Type `protobuf:"varint,2,opt,name=type,proto3,enum=idl.Chunk_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type Chunk_Type int32

type CliToHubClient interface {
	Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (CliToHub_InitializeClient, error)
	InitializeCreateCluster(ctx context.Context, in *InitializeCreateClusterRequest, opts ...grpc.CallOption) (CliToHub_InitializeCreateClusterClient, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (CliToHub_ExecuteClient, error)
	Finalize(ctx context.Context, in *FinalizeRequest, opts ...grpc.CallOption) (CliToHub_FinalizeClient, error)
	Revert(ctx context.Context, in *RevertRequest, opts ...grpc.CallOption) (CliToHub_RevertClient, error)
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigReply, error)
	RestartAgents(ctx context.Context, in *RestartAgentsRequest, opts ...grpc.CallOption) (*RestartAgentsReply, error)
	StopServices(ctx context.Context, in *StopServicesRequest, opts ...grpc.CallOption) (*StopServicesReply, error)
}

type CliToHubServer interface {
	Initialize(*InitializeRequest, CliToHub_InitializeServer) error
	InitializeCreateCluster(*InitializeCreateClusterRequest, CliToHub_InitializeCreateClusterServer) error
	Execute(*ExecuteRequest, CliToHub_ExecuteServer) error
	Finalize(*FinalizeRequest, CliToHub_FinalizeServer) error
	Revert(*RevertRequest, CliToHub_RevertServer) error
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigReply, error)
	RestartAgents(context.Context, *RestartAgentsRequest) (*RestartAgentsReply, error)
	StopServices(context.Context, *StopServicesRequest) (*StopServicesReply, error)
}

type CliToHub_ExecuteClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type CliToHub_ExecuteServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type CliToHub_FinalizeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type CliToHub_FinalizeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type CliToHub_InitializeClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type CliToHub_InitializeCreateClusterClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type CliToHub_InitializeCreateClusterServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type CliToHub_InitializeServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type CliToHub_RevertClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type CliToHub_RevertServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type ClusterDestination int32

type Connection struct {
	Conn          *grpc.ClientConn
	AgentClient   AgentClient
	Hostname      string
	CancelContext func()
}

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

type CreateBackupDirectoryRequest struct {
	BackupDir string `protobuf:"bytes,1,opt,name=backupDir,proto3" json:"backupDir,omitempty"`
	// contains filtered or unexported fields
}

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

type CreateRecoveryConfRequest struct {
	Connections []*CreateRecoveryConfRequest_Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

type CreateRecoveryConfRequest_Connection struct {
	MirrorDataDir string `protobuf:"bytes,2,opt,name=mirrorDataDir,proto3" json:"mirrorDataDir,omitempty"`
	User          string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	PrimaryHost   string `protobuf:"bytes,3,opt,name=primaryHost,proto3" json:"primaryHost,omitempty"`
	PrimaryPort   int32  `protobuf:"varint,4,opt,name=primaryPort,proto3" json:"primaryPort,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteBackupDirectoryRequest struct {
	BackupDir string `protobuf:"bytes,1,opt,name=backupDir,proto3" json:"backupDir,omitempty"`
	// contains filtered or unexported fields
}

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

type DeleteDataDirectoriesRequest struct {
	Datadirs []string `protobuf:"bytes,1,rep,name=datadirs,proto3" json:"datadirs,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type DeleteTablespaceRequest struct {
	Dirs []string `protobuf:"bytes,1,rep,name=dirs,proto3" json:"dirs,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteRequest struct {
	PgUpgradeVerbose    bool   `protobuf:"varint,1,opt,name=pgUpgradeVerbose,proto3" json:"pgUpgradeVerbose,omitempty"`
	SkipPgUpgradeChecks bool   `protobuf:"varint,2,opt,name=skipPgUpgradeChecks,proto3" json:"skipPgUpgradeChecks,omitempty"`
	ParentBackupDirs    string `protobuf:"bytes,3,opt,name=parentBackupDirs,proto3" json:"parentBackupDirs,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse struct {
	Intermediate []byte `protobuf:"bytes,1,opt,name=intermediate,proto3" json:"intermediate,omitempty"`
	// contains filtered or unexported fields
}

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

type FinalizeResponse struct {
	Target                                 []byte `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	LogArchiveDirectory                    string `protobuf:"bytes,2,opt,name=LogArchiveDirectory,proto3" json:"LogArchiveDirectory,omitempty"`
	ArchivedSourceCoordinatorDataDirectory string `` /* 129-byte string literal not displayed */
	UpgradeID                              string `protobuf:"bytes,4,opt,name=UpgradeID,proto3" json:"UpgradeID,omitempty"`
	// contains filtered or unexported fields
}

type GetConfigReply struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type GetConfigRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type InitializeCreateClusterRequest struct {
	DynamicLibraryPath  string `protobuf:"bytes,1,opt,name=dynamicLibraryPath,proto3" json:"dynamicLibraryPath,omitempty"`
	PgUpgradeVerbose    bool   `protobuf:"varint,2,opt,name=pgUpgradeVerbose,proto3" json:"pgUpgradeVerbose,omitempty"`
	SkipPgUpgradeChecks bool   `protobuf:"varint,3,opt,name=skipPgUpgradeChecks,proto3" json:"skipPgUpgradeChecks,omitempty"`
	// contains filtered or unexported fields
}

type InitializeRequest struct {
	DiskFreeRatio    float64 `protobuf:"fixed64,1,opt,name=diskFreeRatio,proto3" json:"diskFreeRatio,omitempty"`
	ParentBackupDirs string  `protobuf:"bytes,2,opt,name=parentBackupDirs,proto3" json:"parentBackupDirs,omitempty"`
	// contains filtered or unexported fields
}

type InitializeResponse struct {
	HasAllMirrorsAndStandby bool `protobuf:"varint,1,opt,name=HasAllMirrorsAndStandby,proto3" json:"HasAllMirrorsAndStandby,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {

	// Types that are assignable to Contents:
	//
	//	*Message_Chunk
	//	*Message_Status
	//	*Message_Response
	Contents isMessage_Contents `protobuf_oneof:"contents"`
	// contains filtered or unexported fields
}

type MessageSender interface {
	Send(*Message) error // matches gRPC streaming Send()
}

type Message_Chunk struct {
	Chunk *Chunk `protobuf:"bytes,1,opt,name=chunk,proto3,oneof"`
}

type Message_Response struct {
	Response *Response `protobuf:"bytes,3,opt,name=response,proto3,oneof"`
}

type Message_Status struct {
	Status *SubstepStatus `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type Mode int32

type NextActions struct {
	NextActions string `protobuf:"bytes,1,opt,name=nextActions,proto3" json:"nextActions,omitempty"`
	// contains filtered or unexported fields
}

type PgOptions struct {
	BackupDir           string                    `protobuf:"bytes,1,opt,name=backupDir,proto3" json:"backupDir,omitempty"`
	PgUpgradeVerbose    bool                      `protobuf:"varint,2,opt,name=pgUpgradeVerbose,proto3" json:"pgUpgradeVerbose,omitempty"`
	SkipPgUpgradeChecks bool                      `protobuf:"varint,3,opt,name=skipPgUpgradeChecks,proto3" json:"skipPgUpgradeChecks,omitempty"`
	PgUpgradeJobs       string                    `protobuf:"bytes,4,opt,name=pgUpgradeJobs,proto3" json:"pgUpgradeJobs,omitempty"`
	Action              PgOptions_Action          `protobuf:"varint,5,opt,name=action,proto3,enum=idl.PgOptions_Action" json:"action,omitempty"`
	Role                string                    `protobuf:"bytes,6,opt,name=role,proto3" json:"role,omitempty"`
	ContentID           int32                     `protobuf:"varint,7,opt,name=contentID,proto3" json:"contentID,omitempty"`
	PgUpgradeMode       PgOptions_PgUpgradeMode   `protobuf:"varint,8,opt,name=pgUpgradeMode,proto3,enum=idl.PgOptions_PgUpgradeMode" json:"pgUpgradeMode,omitempty"`
	OldOptions          string                    `protobuf:"bytes,9,opt,name=oldOptions,proto3" json:"oldOptions,omitempty"`
	Mode                Mode                      `protobuf:"varint,10,opt,name=mode,proto3,enum=idl.Mode" json:"mode,omitempty"`
	TargetVersion       string                    `protobuf:"bytes,11,opt,name=targetVersion,proto3" json:"targetVersion,omitempty"`
	OldBinDir           string                    `protobuf:"bytes,12,opt,name=oldBinDir,proto3" json:"oldBinDir,omitempty"`
	OldDataDir          string                    `protobuf:"bytes,13,opt,name=oldDataDir,proto3" json:"oldDataDir,omitempty"`
	OldPort             string                    `protobuf:"bytes,14,opt,name=oldPort,proto3" json:"oldPort,omitempty"`
	OldDBID             string                    `protobuf:"bytes,15,opt,name=oldDBID,proto3" json:"oldDBID,omitempty"`
	NewBinDir           string                    `protobuf:"bytes,16,opt,name=newBinDir,proto3" json:"newBinDir,omitempty"`
	NewDataDir          string                    `protobuf:"bytes,17,opt,name=newDataDir,proto3" json:"newDataDir,omitempty"`
	NewPort             string                    `protobuf:"bytes,18,opt,name=newPort,proto3" json:"newPort,omitempty"`
	NewDBID             string                    `protobuf:"bytes,19,opt,name=newDBID,proto3" json:"newDBID,omitempty"`
	Tablespaces         map[int32]*TablespaceInfo `` /* 165-byte string literal not displayed */
	PgUpgradeTimestamp  string                    `protobuf:"bytes,21,opt,name=pgUpgradeTimeStamp,proto3" json:"pgUpgradeTimeStamp,omitempty"`
	// contains filtered or unexported fields
}

type PgOptions_Action int32

type PgOptions_PgUpgradeMode int32

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

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

type RenameDirectories struct {
	Source string `protobuf:"bytes,1,opt,name=Source,proto3" json:"Source,omitempty"`
	Target string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"`
	// contains filtered or unexported fields
}

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

type RenameDirectoriesRequest struct {
	Dirs []*RenameDirectories `protobuf:"bytes,1,rep,name=Dirs,proto3" json:"Dirs,omitempty"`
	// contains filtered or unexported fields
}

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

type RenameTablespacesRequest struct {
	RenamePairs []*RenameTablespacesRequest_RenamePair `protobuf:"bytes,1,rep,name=renamePairs,proto3" json:"renamePairs,omitempty"`
	// contains filtered or unexported fields
}

type RenameTablespacesRequest_RenamePair struct {
	Source      string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {

	// Types that are assignable to Contents:
	//
	//	*Response_InitializeResponse
	//	*Response_ExecuteResponse
	//	*Response_FinalizeResponse
	//	*Response_RevertResponse
	Contents isResponse_Contents `protobuf_oneof:"contents"`
	// contains filtered or unexported fields
}

type Response_ExecuteResponse struct {
	ExecuteResponse *ExecuteResponse `protobuf:"bytes,4,opt,name=executeResponse,proto3,oneof"`
}

type Response_FinalizeResponse struct {
	FinalizeResponse *FinalizeResponse `protobuf:"bytes,5,opt,name=finalizeResponse,proto3,oneof"`
}

type Response_InitializeResponse struct {
	InitializeResponse *InitializeResponse `protobuf:"bytes,3,opt,name=initializeResponse,proto3,oneof"`
}

type Response_RevertResponse struct {
	RevertResponse *RevertResponse `protobuf:"bytes,6,opt,name=revertResponse,proto3,oneof"`
}

type RestartAgentsReply struct {
	AgentHosts []string `protobuf:"bytes,1,rep,name=agentHosts,proto3" json:"agentHosts,omitempty"`
	// contains filtered or unexported fields
}

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

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

type RestorePgControlRequest struct {
	Datadirs []string `protobuf:"bytes,1,rep,name=datadirs,proto3" json:"datadirs,omitempty"`
	// contains filtered or unexported fields
}

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

type RevertResponse struct {
	Source              []byte `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	LogArchiveDirectory string `protobuf:"bytes,2,opt,name=LogArchiveDirectory,proto3" json:"LogArchiveDirectory,omitempty"`
	// contains filtered or unexported fields
}

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

type RsyncRequest struct {
	Options []*RsyncRequest_RsyncOptions `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type RsyncRequest_RsyncOptions struct {
	Sources         []string `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	DestinationHost string   `protobuf:"bytes,2,opt,name=destinationHost,proto3" json:"destinationHost,omitempty"`
	Destination     string   `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	Options         []string `protobuf:"bytes,4,rep,name=options,proto3" json:"options,omitempty"`
	ExcludedFiles   []string `protobuf:"bytes,5,rep,name=excludedFiles,proto3" json:"excludedFiles,omitempty"`
	// contains filtered or unexported fields
}

type Schedule int32

type Status int32

type Step int32

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

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

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

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

type Substep int32

type SubstepStatus struct {
	Step   Substep `protobuf:"varint,1,opt,name=step,proto3,enum=idl.Substep" json:"step,omitempty"`
	Status Status  `protobuf:"varint,2,opt,name=status,proto3,enum=idl.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type TablespaceInfo struct {
	Location    string `protobuf:"bytes,1,opt,name=Location,proto3" json:"Location,omitempty"`
	UserDefined bool   `protobuf:"varint,2,opt,name=UserDefined,proto3" json:"UserDefined,omitempty"`
	// contains filtered or unexported fields
}