idl

package
v0.0.0-...-31509f8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CliToHub_Initialize_FullMethodName              = "/idl.CliToHub/Initialize"
	CliToHub_InitializeCreateCluster_FullMethodName = "/idl.CliToHub/InitializeCreateCluster"
	CliToHub_Execute_FullMethodName                 = "/idl.CliToHub/Execute"
	CliToHub_Finalize_FullMethodName                = "/idl.CliToHub/Finalize"
	CliToHub_Revert_FullMethodName                  = "/idl.CliToHub/Revert"
	CliToHub_GetConfig_FullMethodName               = "/idl.CliToHub/GetConfig"
	CliToHub_RestartAgents_FullMethodName           = "/idl.CliToHub/RestartAgents"
	CliToHub_StopServices_FullMethodName            = "/idl.CliToHub/StopServices"
)
View Source 
const (
	Agent_CreateBackupDirectory_FullMethodName       = "/idl.Agent/CreateBackupDirectory"
	Agent_CheckDiskSpace_FullMethodName              = "/idl.Agent/CheckDiskSpace"
	Agent_UpgradePrimaries_FullMethodName            = "/idl.Agent/UpgradePrimaries"
	Agent_RenameDirectories_FullMethodName           = "/idl.Agent/RenameDirectories"
	Agent_StopAgent_FullMethodName                   = "/idl.Agent/StopAgent"
	Agent_DeleteDataDirectories_FullMethodName       = "/idl.Agent/DeleteDataDirectories"
	Agent_DeleteBackupDirectory_FullMethodName       = "/idl.Agent/DeleteBackupDirectory"
	Agent_DeleteStateDirectory_FullMethodName        = "/idl.Agent/DeleteStateDirectory"
	Agent_DeleteTablespaceDirectories_FullMethodName = "/idl.Agent/DeleteTablespaceDirectories"
	Agent_ArchiveLogDirectory_FullMethodName         = "/idl.Agent/ArchiveLogDirectory"
	Agent_RsyncDataDirectories_FullMethodName        = "/idl.Agent/RsyncDataDirectories"
	Agent_RsyncTablespaceDirectories_FullMethodName  = "/idl.Agent/RsyncTablespaceDirectories"
	Agent_RestorePrimariesPgControl_FullMethodName   = "/idl.Agent/RestorePrimariesPgControl"
	Agent_UpdateConfiguration_FullMethodName         = "/idl.Agent/UpdateConfiguration"
	Agent_RenameTablespaces_FullMethodName           = "/idl.Agent/RenameTablespaces"
	Agent_CreateRecoveryConf_FullMethodName          = "/idl.Agent/CreateRecoveryConf"
	Agent_AddReplicationEntries_FullMethodName       = "/idl.Agent/AddReplicationEntries"
)

Variables

View Source 
var (
	Step_name = map[int32]string{
		0: "unknown_step",
		1: "initialize",
		2: "execute",
		3: "finalize",
		4: "revert",
		5: "stats",
	}
	Step_value = map[string]int32{
		"unknown_step": 0,
		"initialize":   1,
		"execute":      2,
		"finalize":     3,
		"revert":       4,
		"stats":        5,
	}
)

Enum value maps for Step.

View Source 
var (
	Substep_name = map[int32]string{
		0:  "unknown_substep",
		1:  "saving_source_cluster_config",
		2:  "start_hub",
		3:  "start_agents",
		4:  "check_environment",
		5:  "check_disk_space",
		6:  "generate_target_config",
		7:  "init_target_cluster",
		8:  "shutdown_target_cluster",
		9:  "backup_target_master",
		10: "check_upgrade",
		11: "shutdown_source_cluster",
		12: "upgrade_master",
		13: "copy_master",
		14: "upgrade_primaries",
		15: "start_target_cluster",
		16: "update_target_catalog",
		17: "update_data_directories",
		18: "update_target_conf_files",
		19: "upgrade_standby",
		20: "upgrade_mirrors",
		21: "delete_tablespaces",
		22: "delete_target_cluster_datadirs",
		23: "delete_segment_statedirs",
		24: "stop_hub_and_agents",
		25: "delete_master_statedir",
		26: "archive_log_directories",
		27: "restore_source_cluster",
		28: "start_source_cluster",
		29: "restore_pgcontrol",
		30: "recoverseg_source_cluster",
		31: "step_status",
		32: "wait_for_cluster_to_be_ready_after_adding_mirrors_and_standby",
		33: "wait_for_cluster_to_be_ready_after_updating_catalog",
		34: "setting_dynamic_library_path_on_target_cluster",
		35: "check_active_connections_on_source_cluster",
		36: "check_active_connections_on_target_cluster",
		37: "generate_data_migration_scripts",
		38: "execute_stats_data_migration_scripts",
		39: "execute_initialize_data_migration_scripts",
		40: "execute_finalize_data_migration_scripts",
		41: "execute_revert_data_migration_scripts",
		42: "create_backupdirs",
		43: "delete_backupdir",
		44: "analyze_target_cluster",
		45: "ensure_gpupgrade_agents_are_running",
		46: "verify_gpdb_versions",
		47: "verify_gpupgrade_is_installed_across_all_hosts",
		48: "initialize_wait_for_cluster_to_be_ready",
		49: "wait_for_cluster_to_be_ready_before_upgrade_master",
	}
	Substep_value = map[string]int32{
		"unknown_substep":                0,
		"saving_source_cluster_config":   1,
		"start_hub":                      2,
		"start_agents":                   3,
		"check_environment":              4,
		"check_disk_space":               5,
		"generate_target_config":         6,
		"init_target_cluster":            7,
		"shutdown_target_cluster":        8,
		"backup_target_master":           9,
		"check_upgrade":                  10,
		"shutdown_source_cluster":        11,
		"upgrade_master":                 12,
		"copy_master":                    13,
		"upgrade_primaries":              14,
		"start_target_cluster":           15,
		"update_target_catalog":          16,
		"update_data_directories":        17,
		"update_target_conf_files":       18,
		"upgrade_standby":                19,
		"upgrade_mirrors":                20,
		"delete_tablespaces":             21,
		"delete_target_cluster_datadirs": 22,
		"delete_segment_statedirs":       23,
		"stop_hub_and_agents":            24,
		"delete_master_statedir":         25,
		"archive_log_directories":        26,
		"restore_source_cluster":         27,
		"start_source_cluster":           28,
		"restore_pgcontrol":              29,
		"recoverseg_source_cluster":      30,
		"step_status":                    31,
		"wait_for_cluster_to_be_ready_after_adding_mirrors_and_standby": 32,
		"wait_for_cluster_to_be_ready_after_updating_catalog":           33,
		"setting_dynamic_library_path_on_target_cluster":                34,
		"check_active_connections_on_source_cluster":                    35,
		"check_active_connections_on_target_cluster":                    36,
		"generate_data_migration_scripts":                               37,
		"execute_stats_data_migration_scripts":                          38,
		"execute_initialize_data_migration_scripts":                     39,
		"execute_finalize_data_migration_scripts":                       40,
		"execute_revert_data_migration_scripts":                         41,
		"create_backupdirs":                                             42,
		"delete_backupdir":                                              43,
		"analyze_target_cluster":                                        44,
		"ensure_gpupgrade_agents_are_running":                           45,
		"verify_gpdb_versions":                                          46,
		"verify_gpupgrade_is_installed_across_all_hosts":                47,
		"initialize_wait_for_cluster_to_be_ready":                       48,
		"wait_for_cluster_to_be_ready_before_upgrade_master":            49,
	}
)

Enum value maps for Substep.

View Source 
var (
	Status_name = map[int32]string{
		0: "unknown_status",
		1: "running",
		2: "complete",
		3: "failed",
		4: "skipped",
		5: "quit",
	}
	Status_value = map[string]int32{
		"unknown_status": 0,
		"running":        1,
		"complete":       2,
		"failed":         3,
		"skipped":        4,
		"quit":           5,
	}
)

Enum value maps for Status.

View Source 
var (
	Chunk_Type_name = map[int32]string{
		0: "unknown",
		1: "stdout",
		2: "stderr",
	}
	Chunk_Type_value = map[string]int32{
		"unknown": 0,
		"stdout":  1,
		"stderr":  2,
	}
)

Enum value maps for Chunk_Type.

View Source 
var (
	Mode_name = map[int32]string{
		0: "unknown_mode",
		1: "copy",
		2: "link",
	}
	Mode_value = map[string]int32{
		"unknown_mode": 0,
		"copy":         1,
		"link":         2,
	}
)

Enum value maps for Mode.

View Source 
var (
	ClusterDestination_name = map[int32]string{
		0: "unknown_destination",
		1: "source",
		2: "intermediate",
		3: "target",
	}
	ClusterDestination_value = map[string]int32{
		"unknown_destination": 0,
		"source":              1,
		"intermediate":        2,
		"target":              3,
	}
)

Enum value maps for ClusterDestination.

View Source 
var (
	Schedule_name = map[int32]string{
		0: "unknown_schedule",
		1: "upgradeable_source_schedule",
		2: "upgradeable_target_schedule",
		3: "non_upgradeable_schedule",
		4: "migratable_source_schedule",
		5: "migratable_target_schedule",
	}
	Schedule_value = map[string]int32{
		"unknown_schedule":            0,
		"upgradeable_source_schedule": 1,
		"upgradeable_target_schedule": 2,
		"non_upgradeable_schedule":    3,
		"migratable_source_schedule":  4,
		"migratable_target_schedule":  5,
	}
)

Enum value maps for Schedule.

View Source 
var (
	PgOptions_PgUpgradeMode_name = map[int32]string{
		0: "unknown_pgUpgradeMode",
		1: "dispatcher",
		2: "segment",
	}
	PgOptions_PgUpgradeMode_value = map[string]int32{
		"unknown_pgUpgradeMode": 0,
		"dispatcher":            1,
		"segment":               2,
	}
)

Enum value maps for PgOptions_PgUpgradeMode.

View Source 
var (
	PgOptions_Action_name = map[int32]string{
		0: "unknown_action",
		1: "upgrade",
		2: "check",
	}
	PgOptions_Action_value = map[string]int32{
		"unknown_action": 0,
		"upgrade":        1,
		"check":          2,
	}
)

Enum value maps for PgOptions_Action.

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "idl.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBackupDirectory",
			Handler:    _Agent_CreateBackupDirectory_Handler,
		},
		{
			MethodName: "CheckDiskSpace",
			Handler:    _Agent_CheckDiskSpace_Handler,
		},
		{
			MethodName: "UpgradePrimaries",
			Handler:    _Agent_UpgradePrimaries_Handler,
		},
		{
			MethodName: "RenameDirectories",
			Handler:    _Agent_RenameDirectories_Handler,
		},
		{
			MethodName: "StopAgent",
			Handler:    _Agent_StopAgent_Handler,
		},
		{
			MethodName: "DeleteDataDirectories",
			Handler:    _Agent_DeleteDataDirectories_Handler,
		},
		{
			MethodName: "DeleteBackupDirectory",
			Handler:    _Agent_DeleteBackupDirectory_Handler,
		},
		{
			MethodName: "DeleteStateDirectory",
			Handler:    _Agent_DeleteStateDirectory_Handler,
		},
		{
			MethodName: "DeleteTablespaceDirectories",
			Handler:    _Agent_DeleteTablespaceDirectories_Handler,
		},
		{
			MethodName: "ArchiveLogDirectory",
			Handler:    _Agent_ArchiveLogDirectory_Handler,
		},
		{
			MethodName: "RsyncDataDirectories",
			Handler:    _Agent_RsyncDataDirectories_Handler,
		},
		{
			MethodName: "RsyncTablespaceDirectories",
			Handler:    _Agent_RsyncTablespaceDirectories_Handler,
		},
		{
			MethodName: "RestorePrimariesPgControl",
			Handler:    _Agent_RestorePrimariesPgControl_Handler,
		},
		{
			MethodName: "UpdateConfiguration",
			Handler:    _Agent_UpdateConfiguration_Handler,
		},
		{
			MethodName: "RenameTablespaces",
			Handler:    _Agent_RenameTablespaces_Handler,
		},
		{
			MethodName: "CreateRecoveryConf",
			Handler:    _Agent_CreateRecoveryConf_Handler,
		},
		{
			MethodName: "AddReplicationEntries",
			Handler:    _Agent_AddReplicationEntries_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "hub_to_agent.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var CliToHub_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "idl.CliToHub",
	HandlerType: (*CliToHubServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetConfig",
			Handler:    _CliToHub_GetConfig_Handler,
		},
		{
			MethodName: "RestartAgents",
			Handler:    _CliToHub_RestartAgents_Handler,
		},
		{
			MethodName: "StopServices",
			Handler:    _CliToHub_StopServices_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Initialize",
			Handler:       _CliToHub_Initialize_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "InitializeCreateCluster",
			Handler:       _CliToHub_InitializeCreateCluster_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Execute",
			Handler:       _CliToHub_Execute_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Finalize",
			Handler:       _CliToHub_Finalize_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Revert",
			Handler:       _CliToHub_Revert_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cli_to_hub.proto",
}

CliToHub_ServiceDesc is the grpc.ServiceDesc for CliToHub service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_cli_to_hub_proto protoreflect.FileDescriptor
View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_hub_to_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

func RegisterCliToHubServer 

func RegisterCliToHubServer(s grpc.ServiceRegistrar, srv CliToHubServer)

func ServerAlreadyStopped 

func ServerAlreadyStopped(err error) bool

ServerAlreadyStopped checks the gRPC error to determine if the server is already stopped or not. When stopping a gRPC server that is already down we do not want to return an error since it is already stopped. However, there is no clean way to differentiate based on the gRPC error code if a server is already stopped versus generally unavailable. Thus, ignore the gRPC error returned when trying to access an already stopped gRPC server. See https://github.com/grpc/grpc/blob/v1.56.2/doc/statuscodes.md

Types

type AddReplicationEntriesReply 

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

func (*AddReplicationEntriesReply) Descriptor deprecated 

func (*AddReplicationEntriesReply) Descriptor() ([]byte, []int)

Deprecated: Use AddReplicationEntriesReply.ProtoReflect.Descriptor instead.

func (*AddReplicationEntriesReply) ProtoMessage 

func (*AddReplicationEntriesReply) ProtoMessage()

func (*AddReplicationEntriesReply) ProtoReflect 

func (x *AddReplicationEntriesReply) ProtoReflect() protoreflect.Message

func (*AddReplicationEntriesReply) Reset 

func (x *AddReplicationEntriesReply) Reset()

func (*AddReplicationEntriesReply) String 

func (x *AddReplicationEntriesReply) String() string

type AddReplicationEntriesRequest 

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

func (*AddReplicationEntriesRequest) Descriptor deprecated 

func (*AddReplicationEntriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddReplicationEntriesRequest.ProtoReflect.Descriptor instead.

func (*AddReplicationEntriesRequest) GetEntries 

func (x *AddReplicationEntriesRequest) GetEntries() []*AddReplicationEntriesRequest_Entry

func (*AddReplicationEntriesRequest) ProtoMessage 

func (*AddReplicationEntriesRequest) ProtoMessage()

func (*AddReplicationEntriesRequest) ProtoReflect 

func (x *AddReplicationEntriesRequest) ProtoReflect() protoreflect.Message

func (*AddReplicationEntriesRequest) Reset 

func (x *AddReplicationEntriesRequest) Reset()

func (*AddReplicationEntriesRequest) String 

func (x *AddReplicationEntriesRequest) String() string

type AddReplicationEntriesRequest_Entry 

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
}

func (*AddReplicationEntriesRequest_Entry) Descriptor deprecated 

func (*AddReplicationEntriesRequest_Entry) Descriptor() ([]byte, []int)

Deprecated: Use AddReplicationEntriesRequest_Entry.ProtoReflect.Descriptor instead.

func (*AddReplicationEntriesRequest_Entry) GetDataDir 

func (x *AddReplicationEntriesRequest_Entry) GetDataDir() string

func (*AddReplicationEntriesRequest_Entry) GetHostAddrs 

func (x *AddReplicationEntriesRequest_Entry) GetHostAddrs() []string

func (*AddReplicationEntriesRequest_Entry) GetUser 

func (x *AddReplicationEntriesRequest_Entry) GetUser() string

func (*AddReplicationEntriesRequest_Entry) ProtoMessage 

func (*AddReplicationEntriesRequest_Entry) ProtoMessage()

func (*AddReplicationEntriesRequest_Entry) ProtoReflect 

func (x *AddReplicationEntriesRequest_Entry) ProtoReflect() protoreflect.Message

func (*AddReplicationEntriesRequest_Entry) Reset 

func (x *AddReplicationEntriesRequest_Entry) Reset()

func (*AddReplicationEntriesRequest_Entry) String 

func (x *AddReplicationEntriesRequest_Entry) String() string

type AgentClient 

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)
}

AgentClient is the client API for Agent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

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)
}

AgentServer is the server API for Agent service. All implementations should embed UnimplementedAgentServer for forward compatibility

type ArchiveLogDirectoryReply 

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

func (*ArchiveLogDirectoryReply) Descriptor deprecated 

func (*ArchiveLogDirectoryReply) Descriptor() ([]byte, []int)

Deprecated: Use ArchiveLogDirectoryReply.ProtoReflect.Descriptor instead.

func (*ArchiveLogDirectoryReply) ProtoMessage 

func (*ArchiveLogDirectoryReply) ProtoMessage()

func (*ArchiveLogDirectoryReply) ProtoReflect 

func (x *ArchiveLogDirectoryReply) ProtoReflect() protoreflect.Message

func (*ArchiveLogDirectoryReply) Reset 

func (x *ArchiveLogDirectoryReply) Reset()

func (*ArchiveLogDirectoryReply) String 

func (x *ArchiveLogDirectoryReply) String() string

type ArchiveLogDirectoryRequest 

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

func (*ArchiveLogDirectoryRequest) Descriptor deprecated 

func (*ArchiveLogDirectoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use ArchiveLogDirectoryRequest.ProtoReflect.Descriptor instead.

func (*ArchiveLogDirectoryRequest) GetLogArchiveDir 

func (x *ArchiveLogDirectoryRequest) GetLogArchiveDir() string

func (*ArchiveLogDirectoryRequest) ProtoMessage 

func (*ArchiveLogDirectoryRequest) ProtoMessage()

func (*ArchiveLogDirectoryRequest) ProtoReflect 

func (x *ArchiveLogDirectoryRequest) ProtoReflect() protoreflect.Message

func (*ArchiveLogDirectoryRequest) Reset 

func (x *ArchiveLogDirectoryRequest) Reset()

func (*ArchiveLogDirectoryRequest) String 

func (x *ArchiveLogDirectoryRequest) String() string

type CheckDiskSpaceReply 

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

func (*CheckDiskSpaceReply) Descriptor deprecated 

func (*CheckDiskSpaceReply) Descriptor() ([]byte, []int)

Deprecated: Use CheckDiskSpaceReply.ProtoReflect.Descriptor instead.

func (*CheckDiskSpaceReply) GetUsages 

func (x *CheckDiskSpaceReply) GetUsages() []*CheckDiskSpaceReply_DiskUsage

func (*CheckDiskSpaceReply) ProtoMessage 

func (*CheckDiskSpaceReply) ProtoMessage()

func (*CheckDiskSpaceReply) ProtoReflect 

func (x *CheckDiskSpaceReply) ProtoReflect() protoreflect.Message

func (*CheckDiskSpaceReply) Reset 

func (x *CheckDiskSpaceReply) Reset()

func (*CheckDiskSpaceReply) String 

func (x *CheckDiskSpaceReply) String() string

type CheckDiskSpaceReply_DiskUsage 

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
}

func (*CheckDiskSpaceReply_DiskUsage) Descriptor deprecated 

func (*CheckDiskSpaceReply_DiskUsage) Descriptor() ([]byte, []int)

Deprecated: Use CheckDiskSpaceReply_DiskUsage.ProtoReflect.Descriptor instead.

func (*CheckDiskSpaceReply_DiskUsage) GetAvailable 

func (x *CheckDiskSpaceReply_DiskUsage) GetAvailable() uint64

func (*CheckDiskSpaceReply_DiskUsage) GetFs 

func (x *CheckDiskSpaceReply_DiskUsage) GetFs() string

func (*CheckDiskSpaceReply_DiskUsage) GetHost 

func (x *CheckDiskSpaceReply_DiskUsage) GetHost() string

func (*CheckDiskSpaceReply_DiskUsage) GetRequired 

func (x *CheckDiskSpaceReply_DiskUsage) GetRequired() uint64

func (*CheckDiskSpaceReply_DiskUsage) ProtoMessage 

func (*CheckDiskSpaceReply_DiskUsage) ProtoMessage()

func (*CheckDiskSpaceReply_DiskUsage) ProtoReflect 

func (x *CheckDiskSpaceReply_DiskUsage) ProtoReflect() protoreflect.Message

func (*CheckDiskSpaceReply_DiskUsage) Reset 

func (x *CheckDiskSpaceReply_DiskUsage) Reset()

func (*CheckDiskSpaceReply_DiskUsage) String 

func (x *CheckDiskSpaceReply_DiskUsage) String() string

type CheckSegmentDiskSpaceRequest 

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
}

func (*CheckSegmentDiskSpaceRequest) Descriptor deprecated 

func (*CheckSegmentDiskSpaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckSegmentDiskSpaceRequest.ProtoReflect.Descriptor instead.

func (*CheckSegmentDiskSpaceRequest) GetDirs 

func (x *CheckSegmentDiskSpaceRequest) GetDirs() []string

func (*CheckSegmentDiskSpaceRequest) GetDiskFreeRatio 

func (x *CheckSegmentDiskSpaceRequest) GetDiskFreeRatio() float64

func (*CheckSegmentDiskSpaceRequest) ProtoMessage 

func (*CheckSegmentDiskSpaceRequest) ProtoMessage()

func (*CheckSegmentDiskSpaceRequest) ProtoReflect 

func (x *CheckSegmentDiskSpaceRequest) ProtoReflect() protoreflect.Message

func (*CheckSegmentDiskSpaceRequest) Reset 

func (x *CheckSegmentDiskSpaceRequest) Reset()

func (*CheckSegmentDiskSpaceRequest) String 

func (x *CheckSegmentDiskSpaceRequest) String() string

type Chunk 

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
}

func (*Chunk) Descriptor deprecated 

func (*Chunk) Descriptor() ([]byte, []int)

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetBuffer 

func (x *Chunk) GetBuffer() []byte

func (*Chunk) GetType 

func (x *Chunk) GetType() Chunk_Type

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type Chunk_Type 

type Chunk_Type int32
const (
	Chunk_unknown Chunk_Type = 0
	Chunk_stdout  Chunk_Type = 1
	Chunk_stderr  Chunk_Type = 2
)

func (Chunk_Type) Descriptor 

func (Chunk_Type) Descriptor() protoreflect.EnumDescriptor

func (Chunk_Type) Enum 

func (x Chunk_Type) Enum() *Chunk_Type

func (Chunk_Type) EnumDescriptor deprecated 

func (Chunk_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Chunk_Type.Descriptor instead.

func (Chunk_Type) Number 

func (x Chunk_Type) Number() protoreflect.EnumNumber

func (Chunk_Type) String 

func (x Chunk_Type) String() string

func (Chunk_Type) Type 

func (Chunk_Type) Type() protoreflect.EnumType

type CliToHubClient 

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)
}

CliToHubClient is the client API for CliToHub service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCliToHubClient 

func NewCliToHubClient(cc grpc.ClientConnInterface) CliToHubClient

type CliToHubServer 

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)
}

CliToHubServer is the server API for CliToHub service. All implementations should embed UnimplementedCliToHubServer for forward compatibility

type CliToHub_ExecuteClient 

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

type CliToHub_ExecuteServer 

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

type CliToHub_FinalizeClient 

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

type CliToHub_FinalizeServer 

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

type CliToHub_InitializeClient 

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

type CliToHub_InitializeCreateClusterClient 

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

type CliToHub_InitializeCreateClusterServer 

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

type CliToHub_InitializeServer 

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

type CliToHub_RevertClient 

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

type CliToHub_RevertServer 

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

type ClusterDestination 

type ClusterDestination int32
const (
	ClusterDestination_unknown_destination ClusterDestination = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	ClusterDestination_source              ClusterDestination = 1
	ClusterDestination_intermediate        ClusterDestination = 2
	ClusterDestination_target              ClusterDestination = 3
)

func (ClusterDestination) Descriptor 

func (ClusterDestination) Descriptor() protoreflect.EnumDescriptor

func (ClusterDestination) Enum 

func (x ClusterDestination) Enum() *ClusterDestination

func (ClusterDestination) EnumDescriptor deprecated 

func (ClusterDestination) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClusterDestination.Descriptor instead.

func (ClusterDestination) Number 

func (x ClusterDestination) Number() protoreflect.EnumNumber

func (ClusterDestination) String 

func (x ClusterDestination) String() string

func (ClusterDestination) Type 

func (ClusterDestination) Type() protoreflect.EnumType

type Connection 

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

type CreateBackupDirectoryReply 

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

func (*CreateBackupDirectoryReply) Descriptor deprecated 

func (*CreateBackupDirectoryReply) Descriptor() ([]byte, []int)

Deprecated: Use CreateBackupDirectoryReply.ProtoReflect.Descriptor instead.

func (*CreateBackupDirectoryReply) ProtoMessage 

func (*CreateBackupDirectoryReply) ProtoMessage()

func (*CreateBackupDirectoryReply) ProtoReflect 

func (x *CreateBackupDirectoryReply) ProtoReflect() protoreflect.Message

func (*CreateBackupDirectoryReply) Reset 

func (x *CreateBackupDirectoryReply) Reset()

func (*CreateBackupDirectoryReply) String 

func (x *CreateBackupDirectoryReply) String() string

type CreateBackupDirectoryRequest 

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

func (*CreateBackupDirectoryRequest) Descriptor deprecated 

func (*CreateBackupDirectoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateBackupDirectoryRequest.ProtoReflect.Descriptor instead.

func (*CreateBackupDirectoryRequest) GetBackupDir 

func (x *CreateBackupDirectoryRequest) GetBackupDir() string

func (*CreateBackupDirectoryRequest) ProtoMessage 

func (*CreateBackupDirectoryRequest) ProtoMessage()

func (*CreateBackupDirectoryRequest) ProtoReflect 

func (x *CreateBackupDirectoryRequest) ProtoReflect() protoreflect.Message

func (*CreateBackupDirectoryRequest) Reset 

func (x *CreateBackupDirectoryRequest) Reset()

func (*CreateBackupDirectoryRequest) String 

func (x *CreateBackupDirectoryRequest) String() string

type CreateRecoveryConfReply 

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

func (*CreateRecoveryConfReply) Descriptor deprecated 

func (*CreateRecoveryConfReply) Descriptor() ([]byte, []int)

Deprecated: Use CreateRecoveryConfReply.ProtoReflect.Descriptor instead.

func (*CreateRecoveryConfReply) ProtoMessage 

func (*CreateRecoveryConfReply) ProtoMessage()

func (*CreateRecoveryConfReply) ProtoReflect 

func (x *CreateRecoveryConfReply) ProtoReflect() protoreflect.Message

func (*CreateRecoveryConfReply) Reset 

func (x *CreateRecoveryConfReply) Reset()

func (*CreateRecoveryConfReply) String 

func (x *CreateRecoveryConfReply) String() string

type CreateRecoveryConfRequest 

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

func (*CreateRecoveryConfRequest) Descriptor deprecated 

func (*CreateRecoveryConfRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRecoveryConfRequest.ProtoReflect.Descriptor instead.

func (*CreateRecoveryConfRequest) GetConnections 

func (x *CreateRecoveryConfRequest) GetConnections() []*CreateRecoveryConfRequest_Connection

func (*CreateRecoveryConfRequest) ProtoMessage 

func (*CreateRecoveryConfRequest) ProtoMessage()

func (*CreateRecoveryConfRequest) ProtoReflect 

func (x *CreateRecoveryConfRequest) ProtoReflect() protoreflect.Message

func (*CreateRecoveryConfRequest) Reset 

func (x *CreateRecoveryConfRequest) Reset()

func (*CreateRecoveryConfRequest) String 

func (x *CreateRecoveryConfRequest) String() string

type CreateRecoveryConfRequest_Connection 

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
}

func (*CreateRecoveryConfRequest_Connection) Descriptor deprecated 

func (*CreateRecoveryConfRequest_Connection) Descriptor() ([]byte, []int)

Deprecated: Use CreateRecoveryConfRequest_Connection.ProtoReflect.Descriptor instead.

func (*CreateRecoveryConfRequest_Connection) GetMirrorDataDir 

func (x *CreateRecoveryConfRequest_Connection) GetMirrorDataDir() string

func (*CreateRecoveryConfRequest_Connection) GetPrimaryHost 

func (x *CreateRecoveryConfRequest_Connection) GetPrimaryHost() string

func (*CreateRecoveryConfRequest_Connection) GetPrimaryPort 

func (x *CreateRecoveryConfRequest_Connection) GetPrimaryPort() int32

func (*CreateRecoveryConfRequest_Connection) GetUser 

func (x *CreateRecoveryConfRequest_Connection) GetUser() string

func (*CreateRecoveryConfRequest_Connection) ProtoMessage 

func (*CreateRecoveryConfRequest_Connection) ProtoMessage()

func (*CreateRecoveryConfRequest_Connection) ProtoReflect 

func (x *CreateRecoveryConfRequest_Connection) ProtoReflect() protoreflect.Message

func (*CreateRecoveryConfRequest_Connection) Reset 

func (x *CreateRecoveryConfRequest_Connection) Reset()

func (*CreateRecoveryConfRequest_Connection) String 

func (x *CreateRecoveryConfRequest_Connection) String() string

type DeleteBackupDirectoryReply 

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

func (*DeleteBackupDirectoryReply) Descriptor deprecated 

func (*DeleteBackupDirectoryReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBackupDirectoryReply.ProtoReflect.Descriptor instead.

func (*DeleteBackupDirectoryReply) ProtoMessage 

func (*DeleteBackupDirectoryReply) ProtoMessage()

func (*DeleteBackupDirectoryReply) ProtoReflect 

func (x *DeleteBackupDirectoryReply) ProtoReflect() protoreflect.Message

func (*DeleteBackupDirectoryReply) Reset 

func (x *DeleteBackupDirectoryReply) Reset()

func (*DeleteBackupDirectoryReply) String 

func (x *DeleteBackupDirectoryReply) String() string

type DeleteBackupDirectoryRequest 

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

func (*DeleteBackupDirectoryRequest) Descriptor deprecated 

func (*DeleteBackupDirectoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteBackupDirectoryRequest.ProtoReflect.Descriptor instead.

func (*DeleteBackupDirectoryRequest) GetBackupDir 

func (x *DeleteBackupDirectoryRequest) GetBackupDir() string

func (*DeleteBackupDirectoryRequest) ProtoMessage 

func (*DeleteBackupDirectoryRequest) ProtoMessage()

func (*DeleteBackupDirectoryRequest) ProtoReflect 

func (x *DeleteBackupDirectoryRequest) ProtoReflect() protoreflect.Message

func (*DeleteBackupDirectoryRequest) Reset 

func (x *DeleteBackupDirectoryRequest) Reset()

func (*DeleteBackupDirectoryRequest) String 

func (x *DeleteBackupDirectoryRequest) String() string

type DeleteDataDirectoriesReply 

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

func (*DeleteDataDirectoriesReply) Descriptor deprecated 

func (*DeleteDataDirectoriesReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataDirectoriesReply.ProtoReflect.Descriptor instead.

func (*DeleteDataDirectoriesReply) ProtoMessage 

func (*DeleteDataDirectoriesReply) ProtoMessage()

func (*DeleteDataDirectoriesReply) ProtoReflect 

func (x *DeleteDataDirectoriesReply) ProtoReflect() protoreflect.Message

func (*DeleteDataDirectoriesReply) Reset 

func (x *DeleteDataDirectoriesReply) Reset()

func (*DeleteDataDirectoriesReply) String 

func (x *DeleteDataDirectoriesReply) String() string

type DeleteDataDirectoriesRequest 

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

func (*DeleteDataDirectoriesRequest) Descriptor deprecated 

func (*DeleteDataDirectoriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDataDirectoriesRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataDirectoriesRequest) GetDatadirs 

func (x *DeleteDataDirectoriesRequest) GetDatadirs() []string

func (*DeleteDataDirectoriesRequest) ProtoMessage 

func (*DeleteDataDirectoriesRequest) ProtoMessage()

func (*DeleteDataDirectoriesRequest) ProtoReflect 

func (x *DeleteDataDirectoriesRequest) ProtoReflect() protoreflect.Message

func (*DeleteDataDirectoriesRequest) Reset 

func (x *DeleteDataDirectoriesRequest) Reset()

func (*DeleteDataDirectoriesRequest) String 

func (x *DeleteDataDirectoriesRequest) String() string

type DeleteStateDirectoryReply 

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

func (*DeleteStateDirectoryReply) Descriptor deprecated 

func (*DeleteStateDirectoryReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStateDirectoryReply.ProtoReflect.Descriptor instead.

func (*DeleteStateDirectoryReply) ProtoMessage 

func (*DeleteStateDirectoryReply) ProtoMessage()

func (*DeleteStateDirectoryReply) ProtoReflect 

func (x *DeleteStateDirectoryReply) ProtoReflect() protoreflect.Message

func (*DeleteStateDirectoryReply) Reset 

func (x *DeleteStateDirectoryReply) Reset()

func (*DeleteStateDirectoryReply) String 

func (x *DeleteStateDirectoryReply) String() string

type DeleteStateDirectoryRequest 

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

func (*DeleteStateDirectoryRequest) Descriptor deprecated 

func (*DeleteStateDirectoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStateDirectoryRequest.ProtoReflect.Descriptor instead.

func (*DeleteStateDirectoryRequest) ProtoMessage 

func (*DeleteStateDirectoryRequest) ProtoMessage()

func (*DeleteStateDirectoryRequest) ProtoReflect 

func (x *DeleteStateDirectoryRequest) ProtoReflect() protoreflect.Message

func (*DeleteStateDirectoryRequest) Reset 

func (x *DeleteStateDirectoryRequest) Reset()

func (*DeleteStateDirectoryRequest) String 

func (x *DeleteStateDirectoryRequest) String() string

type DeleteTablespaceReply 

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

func (*DeleteTablespaceReply) Descriptor deprecated 

func (*DeleteTablespaceReply) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTablespaceReply.ProtoReflect.Descriptor instead.

func (*DeleteTablespaceReply) ProtoMessage 

func (*DeleteTablespaceReply) ProtoMessage()

func (*DeleteTablespaceReply) ProtoReflect 

func (x *DeleteTablespaceReply) ProtoReflect() protoreflect.Message

func (*DeleteTablespaceReply) Reset 

func (x *DeleteTablespaceReply) Reset()

func (*DeleteTablespaceReply) String 

func (x *DeleteTablespaceReply) String() string

type DeleteTablespaceRequest 

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

func (*DeleteTablespaceRequest) Descriptor deprecated 

func (*DeleteTablespaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTablespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteTablespaceRequest) GetDirs 

func (x *DeleteTablespaceRequest) GetDirs() []string

func (*DeleteTablespaceRequest) ProtoMessage 

func (*DeleteTablespaceRequest) ProtoMessage()

func (*DeleteTablespaceRequest) ProtoReflect 

func (x *DeleteTablespaceRequest) ProtoReflect() protoreflect.Message

func (*DeleteTablespaceRequest) Reset 

func (x *DeleteTablespaceRequest) Reset()

func (*DeleteTablespaceRequest) String 

func (x *DeleteTablespaceRequest) String() string

type ExecuteRequest 

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
}

func (*ExecuteRequest) Descriptor deprecated 

func (*ExecuteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetParentBackupDirs 

func (x *ExecuteRequest) GetParentBackupDirs() string

func (*ExecuteRequest) GetPgUpgradeVerbose 

func (x *ExecuteRequest) GetPgUpgradeVerbose() bool

func (*ExecuteRequest) GetSkipPgUpgradeChecks 

func (x *ExecuteRequest) GetSkipPgUpgradeChecks() bool

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteResponse 

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

func (*ExecuteResponse) Descriptor deprecated 

func (*ExecuteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetIntermediate 

func (x *ExecuteResponse) GetIntermediate() []byte

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type FinalizeRequest 

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

func (*FinalizeRequest) Descriptor deprecated 

func (*FinalizeRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeRequest.ProtoReflect.Descriptor instead.

func (*FinalizeRequest) ProtoMessage 

func (*FinalizeRequest) ProtoMessage()

func (*FinalizeRequest) ProtoReflect 

func (x *FinalizeRequest) ProtoReflect() protoreflect.Message

func (*FinalizeRequest) Reset 

func (x *FinalizeRequest) Reset()

func (*FinalizeRequest) String 

func (x *FinalizeRequest) String() string

type FinalizeResponse 

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
}

func (*FinalizeResponse) Descriptor deprecated 

func (*FinalizeResponse) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeResponse.ProtoReflect.Descriptor instead.

func (*FinalizeResponse) GetArchivedSourceCoordinatorDataDirectory 

func (x *FinalizeResponse) GetArchivedSourceCoordinatorDataDirectory() string

func (*FinalizeResponse) GetLogArchiveDirectory 

func (x *FinalizeResponse) GetLogArchiveDirectory() string

func (*FinalizeResponse) GetTarget 

func (x *FinalizeResponse) GetTarget() []byte

func (*FinalizeResponse) GetUpgradeID 

func (x *FinalizeResponse) GetUpgradeID() string

func (*FinalizeResponse) ProtoMessage 

func (*FinalizeResponse) ProtoMessage()

func (*FinalizeResponse) ProtoReflect 

func (x *FinalizeResponse) ProtoReflect() protoreflect.Message

func (*FinalizeResponse) Reset 

func (x *FinalizeResponse) Reset()

func (*FinalizeResponse) String 

func (x *FinalizeResponse) String() string

type GetConfigReply 

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

func (*GetConfigReply) Descriptor deprecated 

func (*GetConfigReply) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigReply.ProtoReflect.Descriptor instead.

func (*GetConfigReply) GetValue 

func (x *GetConfigReply) GetValue() string

func (*GetConfigReply) ProtoMessage 

func (*GetConfigReply) ProtoMessage()

func (*GetConfigReply) ProtoReflect 

func (x *GetConfigReply) ProtoReflect() protoreflect.Message

func (*GetConfigReply) Reset 

func (x *GetConfigReply) Reset()

func (*GetConfigReply) String 

func (x *GetConfigReply) String() string

type GetConfigRequest 

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

func (*GetConfigRequest) Descriptor deprecated 

func (*GetConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) GetName 

func (x *GetConfigRequest) GetName() string

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect 

func (x *GetConfigRequest) ProtoReflect() protoreflect.Message

func (*GetConfigRequest) Reset 

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (x *GetConfigRequest) String() string

type InitializeCreateClusterRequest 

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
}

func (*InitializeCreateClusterRequest) Descriptor deprecated 

func (*InitializeCreateClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitializeCreateClusterRequest.ProtoReflect.Descriptor instead.

func (*InitializeCreateClusterRequest) GetDynamicLibraryPath 

func (x *InitializeCreateClusterRequest) GetDynamicLibraryPath() string

func (*InitializeCreateClusterRequest) GetPgUpgradeVerbose 

func (x *InitializeCreateClusterRequest) GetPgUpgradeVerbose() bool

func (*InitializeCreateClusterRequest) GetSkipPgUpgradeChecks 

func (x *InitializeCreateClusterRequest) GetSkipPgUpgradeChecks() bool

func (*InitializeCreateClusterRequest) ProtoMessage 

func (*InitializeCreateClusterRequest) ProtoMessage()

func (*InitializeCreateClusterRequest) ProtoReflect 

func (x *InitializeCreateClusterRequest) ProtoReflect() protoreflect.Message

func (*InitializeCreateClusterRequest) Reset 

func (x *InitializeCreateClusterRequest) Reset()

func (*InitializeCreateClusterRequest) String 

func (x *InitializeCreateClusterRequest) String() string

type InitializeRequest 

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
}

func (*InitializeRequest) Descriptor deprecated 

func (*InitializeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitializeRequest.ProtoReflect.Descriptor instead.

func (*InitializeRequest) GetDiskFreeRatio 

func (x *InitializeRequest) GetDiskFreeRatio() float64

func (*InitializeRequest) GetParentBackupDirs 

func (x *InitializeRequest) GetParentBackupDirs() string

func (*InitializeRequest) ProtoMessage 

func (*InitializeRequest) ProtoMessage()

func (*InitializeRequest) ProtoReflect 

func (x *InitializeRequest) ProtoReflect() protoreflect.Message

func (*InitializeRequest) Reset 

func (x *InitializeRequest) Reset()

func (*InitializeRequest) String 

func (x *InitializeRequest) String() string

type InitializeResponse 

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

func (*InitializeResponse) Descriptor deprecated 

func (*InitializeResponse) Descriptor() ([]byte, []int)

Deprecated: Use InitializeResponse.ProtoReflect.Descriptor instead.

func (*InitializeResponse) GetHasAllMirrorsAndStandby 

func (x *InitializeResponse) GetHasAllMirrorsAndStandby() bool

func (*InitializeResponse) ProtoMessage 

func (*InitializeResponse) ProtoMessage()

func (*InitializeResponse) ProtoReflect 

func (x *InitializeResponse) ProtoReflect() protoreflect.Message

func (*InitializeResponse) Reset 

func (x *InitializeResponse) Reset()

func (*InitializeResponse) String 

func (x *InitializeResponse) String() string

type Message 

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
}

func (*Message) Descriptor deprecated 

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetChunk 

func (x *Message) GetChunk() *Chunk

func (*Message) GetContents 

func (m *Message) GetContents() isMessage_Contents

func (*Message) GetResponse 

func (x *Message) GetResponse() *Response

func (*Message) GetStatus 

func (x *Message) GetStatus() *SubstepStatus

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageSender 

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

MessageSender is an interface common to all gRPC streaming server implementations that allows the sending of a Message struct.

type Message_Chunk 

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

type Message_Response 

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

type Message_Status 

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

type Mode 

type Mode int32
const (
	Mode_unknown_mode Mode = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	Mode_copy         Mode = 1
	Mode_link         Mode = 2
)

func (Mode) Descriptor 

func (Mode) Descriptor() protoreflect.EnumDescriptor

func (Mode) Enum 

func (x Mode) Enum() *Mode

func (Mode) EnumDescriptor deprecated 

func (Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Mode.Descriptor instead.

func (Mode) Number 

func (x Mode) Number() protoreflect.EnumNumber

func (Mode) String 

func (x Mode) String() string

func (Mode) Type 

func (Mode) Type() protoreflect.EnumType

type NextActions 

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

Used to set the gRPC status details that the CLI converts to a NextActions error type to be displayed to the user.

func (*NextActions) Descriptor deprecated 

func (*NextActions) Descriptor() ([]byte, []int)

Deprecated: Use NextActions.ProtoReflect.Descriptor instead.

func (*NextActions) GetNextActions 

func (x *NextActions) GetNextActions() string

func (*NextActions) ProtoMessage 

func (*NextActions) ProtoMessage()

func (*NextActions) ProtoReflect 

func (x *NextActions) ProtoReflect() protoreflect.Message

func (*NextActions) Reset 

func (x *NextActions) Reset()

func (*NextActions) String 

func (x *NextActions) String() string

type PgOptions 

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
}

func (*PgOptions) Descriptor deprecated 

func (*PgOptions) Descriptor() ([]byte, []int)

Deprecated: Use PgOptions.ProtoReflect.Descriptor instead.

func (*PgOptions) GetAction 

func (x *PgOptions) GetAction() PgOptions_Action

func (*PgOptions) GetBackupDir 

func (x *PgOptions) GetBackupDir() string

func (*PgOptions) GetContentID 

func (x *PgOptions) GetContentID() int32

func (*PgOptions) GetMode 

func (x *PgOptions) GetMode() Mode

func (*PgOptions) GetNewBinDir 

func (x *PgOptions) GetNewBinDir() string

func (*PgOptions) GetNewDBID 

func (x *PgOptions) GetNewDBID() string

func (*PgOptions) GetNewDataDir 

func (x *PgOptions) GetNewDataDir() string

func (*PgOptions) GetNewPort 

func (x *PgOptions) GetNewPort() string

func (*PgOptions) GetOldBinDir 

func (x *PgOptions) GetOldBinDir() string

func (*PgOptions) GetOldDBID 

func (x *PgOptions) GetOldDBID() string

func (*PgOptions) GetOldDataDir 

func (x *PgOptions) GetOldDataDir() string

func (*PgOptions) GetOldOptions 

func (x *PgOptions) GetOldOptions() string

func (*PgOptions) GetOldPort 

func (x *PgOptions) GetOldPort() string

func (*PgOptions) GetPgUpgradeJobs 

func (x *PgOptions) GetPgUpgradeJobs() string

func (*PgOptions) GetPgUpgradeMode 

func (x *PgOptions) GetPgUpgradeMode() PgOptions_PgUpgradeMode

func (*PgOptions) GetPgUpgradeTimeStamp 

func (x *PgOptions) GetPgUpgradeTimeStamp() string

func (*PgOptions) GetPgUpgradeVerbose 

func (x *PgOptions) GetPgUpgradeVerbose() bool

func (*PgOptions) GetRole 

func (x *PgOptions) GetRole() string

func (*PgOptions) GetSkipPgUpgradeChecks 

func (x *PgOptions) GetSkipPgUpgradeChecks() bool

func (*PgOptions) GetTablespaces 

func (x *PgOptions) GetTablespaces() map[int32]*TablespaceInfo

func (*PgOptions) GetTargetVersion 

func (x *PgOptions) GetTargetVersion() string

func (*PgOptions) ProtoMessage 

func (*PgOptions) ProtoMessage()

func (*PgOptions) ProtoReflect 

func (x *PgOptions) ProtoReflect() protoreflect.Message

func (*PgOptions) Reset 

func (x *PgOptions) Reset()

func (*PgOptions) String 

func (x *PgOptions) String() string

type PgOptions_Action 

type PgOptions_Action int32
const (
	PgOptions_unknown_action PgOptions_Action = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	PgOptions_upgrade        PgOptions_Action = 1
	PgOptions_check          PgOptions_Action = 2
)

func (PgOptions_Action) Descriptor 

func (PgOptions_Action) Descriptor() protoreflect.EnumDescriptor

func (PgOptions_Action) Enum 

func (x PgOptions_Action) Enum() *PgOptions_Action

func (PgOptions_Action) EnumDescriptor deprecated 

func (PgOptions_Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use PgOptions_Action.Descriptor instead.

func (PgOptions_Action) Number 

func (x PgOptions_Action) Number() protoreflect.EnumNumber

func (PgOptions_Action) String 

func (x PgOptions_Action) String() string

func (PgOptions_Action) Type 

func (PgOptions_Action) Type() protoreflect.EnumType

type PgOptions_PgUpgradeMode 

type PgOptions_PgUpgradeMode int32
const (
	PgOptions_unknown_pgUpgradeMode PgOptions_PgUpgradeMode = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	PgOptions_dispatcher            PgOptions_PgUpgradeMode = 1
	PgOptions_segment               PgOptions_PgUpgradeMode = 2
)

func (PgOptions_PgUpgradeMode) Descriptor 

func (PgOptions_PgUpgradeMode) Descriptor() protoreflect.EnumDescriptor

func (PgOptions_PgUpgradeMode) Enum 

func (x PgOptions_PgUpgradeMode) Enum() *PgOptions_PgUpgradeMode

func (PgOptions_PgUpgradeMode) EnumDescriptor deprecated 

func (PgOptions_PgUpgradeMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use PgOptions_PgUpgradeMode.Descriptor instead.

func (PgOptions_PgUpgradeMode) Number 

func (x PgOptions_PgUpgradeMode) Number() protoreflect.EnumNumber

func (PgOptions_PgUpgradeMode) String 

func (x PgOptions_PgUpgradeMode) String() string

func (PgOptions_PgUpgradeMode) Type 

func (PgOptions_PgUpgradeMode) Type() protoreflect.EnumType

type PrepareInitClusterReply 

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

func (*PrepareInitClusterReply) Descriptor deprecated 

func (*PrepareInitClusterReply) Descriptor() ([]byte, []int)

Deprecated: Use PrepareInitClusterReply.ProtoReflect.Descriptor instead.

func (*PrepareInitClusterReply) ProtoMessage 

func (*PrepareInitClusterReply) ProtoMessage()

func (*PrepareInitClusterReply) ProtoReflect 

func (x *PrepareInitClusterReply) ProtoReflect() protoreflect.Message

func (*PrepareInitClusterReply) Reset 

func (x *PrepareInitClusterReply) Reset()

func (*PrepareInitClusterReply) String 

func (x *PrepareInitClusterReply) String() string

type PrepareInitClusterRequest 

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

func (*PrepareInitClusterRequest) Descriptor deprecated 

func (*PrepareInitClusterRequest) Descriptor() ([]byte, []int)

Deprecated: Use PrepareInitClusterRequest.ProtoReflect.Descriptor instead.

func (*PrepareInitClusterRequest) ProtoMessage 

func (*PrepareInitClusterRequest) ProtoMessage()

func (*PrepareInitClusterRequest) ProtoReflect 

func (x *PrepareInitClusterRequest) ProtoReflect() protoreflect.Message

func (*PrepareInitClusterRequest) Reset 

func (x *PrepareInitClusterRequest) Reset()

func (*PrepareInitClusterRequest) String 

func (x *PrepareInitClusterRequest) String() string

type RenameDirectories 

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
}

func (*RenameDirectories) Descriptor deprecated 

func (*RenameDirectories) Descriptor() ([]byte, []int)

Deprecated: Use RenameDirectories.ProtoReflect.Descriptor instead.

func (*RenameDirectories) GetSource 

func (x *RenameDirectories) GetSource() string

func (*RenameDirectories) GetTarget 

func (x *RenameDirectories) GetTarget() string

func (*RenameDirectories) ProtoMessage 

func (*RenameDirectories) ProtoMessage()

func (*RenameDirectories) ProtoReflect 

func (x *RenameDirectories) ProtoReflect() protoreflect.Message

func (*RenameDirectories) Reset 

func (x *RenameDirectories) Reset()

func (*RenameDirectories) String 

func (x *RenameDirectories) String() string

type RenameDirectoriesReply 

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

func (*RenameDirectoriesReply) Descriptor deprecated 

func (*RenameDirectoriesReply) Descriptor() ([]byte, []int)

Deprecated: Use RenameDirectoriesReply.ProtoReflect.Descriptor instead.

func (*RenameDirectoriesReply) ProtoMessage 

func (*RenameDirectoriesReply) ProtoMessage()

func (*RenameDirectoriesReply) ProtoReflect 

func (x *RenameDirectoriesReply) ProtoReflect() protoreflect.Message

func (*RenameDirectoriesReply) Reset 

func (x *RenameDirectoriesReply) Reset()

func (*RenameDirectoriesReply) String 

func (x *RenameDirectoriesReply) String() string

type RenameDirectoriesRequest 

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

func (*RenameDirectoriesRequest) Descriptor deprecated 

func (*RenameDirectoriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameDirectoriesRequest.ProtoReflect.Descriptor instead.

func (*RenameDirectoriesRequest) GetDirs 

func (x *RenameDirectoriesRequest) GetDirs() []*RenameDirectories

func (*RenameDirectoriesRequest) ProtoMessage 

func (*RenameDirectoriesRequest) ProtoMessage()

func (*RenameDirectoriesRequest) ProtoReflect 

func (x *RenameDirectoriesRequest) ProtoReflect() protoreflect.Message

func (*RenameDirectoriesRequest) Reset 

func (x *RenameDirectoriesRequest) Reset()

func (*RenameDirectoriesRequest) String 

func (x *RenameDirectoriesRequest) String() string

type RenameTablespacesReply 

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

func (*RenameTablespacesReply) Descriptor deprecated 

func (*RenameTablespacesReply) Descriptor() ([]byte, []int)

Deprecated: Use RenameTablespacesReply.ProtoReflect.Descriptor instead.

func (*RenameTablespacesReply) ProtoMessage 

func (*RenameTablespacesReply) ProtoMessage()

func (*RenameTablespacesReply) ProtoReflect 

func (x *RenameTablespacesReply) ProtoReflect() protoreflect.Message

func (*RenameTablespacesReply) Reset 

func (x *RenameTablespacesReply) Reset()

func (*RenameTablespacesReply) String 

func (x *RenameTablespacesReply) String() string

type RenameTablespacesRequest 

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

func (*RenameTablespacesRequest) Descriptor deprecated 

func (*RenameTablespacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameTablespacesRequest.ProtoReflect.Descriptor instead.

func (*RenameTablespacesRequest) GetRenamePairs 

func (x *RenameTablespacesRequest) GetRenamePairs() []*RenameTablespacesRequest_RenamePair

func (*RenameTablespacesRequest) ProtoMessage 

func (*RenameTablespacesRequest) ProtoMessage()

func (*RenameTablespacesRequest) ProtoReflect 

func (x *RenameTablespacesRequest) ProtoReflect() protoreflect.Message

func (*RenameTablespacesRequest) Reset 

func (x *RenameTablespacesRequest) Reset()

func (*RenameTablespacesRequest) String 

func (x *RenameTablespacesRequest) String() string

type RenameTablespacesRequest_RenamePair 

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
}

func (*RenameTablespacesRequest_RenamePair) Descriptor deprecated 

func (*RenameTablespacesRequest_RenamePair) Descriptor() ([]byte, []int)

Deprecated: Use RenameTablespacesRequest_RenamePair.ProtoReflect.Descriptor instead.

func (*RenameTablespacesRequest_RenamePair) GetDestination 

func (x *RenameTablespacesRequest_RenamePair) GetDestination() string

func (*RenameTablespacesRequest_RenamePair) GetSource 

func (x *RenameTablespacesRequest_RenamePair) GetSource() string

func (*RenameTablespacesRequest_RenamePair) ProtoMessage 

func (*RenameTablespacesRequest_RenamePair) ProtoMessage()

func (*RenameTablespacesRequest_RenamePair) ProtoReflect 

func (x *RenameTablespacesRequest_RenamePair) ProtoReflect() protoreflect.Message

func (*RenameTablespacesRequest_RenamePair) Reset 

func (x *RenameTablespacesRequest_RenamePair) Reset()

func (*RenameTablespacesRequest_RenamePair) String 

func (x *RenameTablespacesRequest_RenamePair) String() string

type Response 

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
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetContents 

func (m *Response) GetContents() isResponse_Contents

func (*Response) GetExecuteResponse 

func (x *Response) GetExecuteResponse() *ExecuteResponse

func (*Response) GetFinalizeResponse 

func (x *Response) GetFinalizeResponse() *FinalizeResponse

func (*Response) GetInitializeResponse 

func (x *Response) GetInitializeResponse() *InitializeResponse

func (*Response) GetRevertResponse 

func (x *Response) GetRevertResponse() *RevertResponse

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_ExecuteResponse 

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

type Response_FinalizeResponse 

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

type Response_InitializeResponse 

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

type Response_RevertResponse 

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

type RestartAgentsReply 

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

func (*RestartAgentsReply) Descriptor deprecated 

func (*RestartAgentsReply) Descriptor() ([]byte, []int)

Deprecated: Use RestartAgentsReply.ProtoReflect.Descriptor instead.

func (*RestartAgentsReply) GetAgentHosts 

func (x *RestartAgentsReply) GetAgentHosts() []string

func (*RestartAgentsReply) ProtoMessage 

func (*RestartAgentsReply) ProtoMessage()

func (*RestartAgentsReply) ProtoReflect 

func (x *RestartAgentsReply) ProtoReflect() protoreflect.Message

func (*RestartAgentsReply) Reset 

func (x *RestartAgentsReply) Reset()

func (*RestartAgentsReply) String 

func (x *RestartAgentsReply) String() string

type RestartAgentsRequest 

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

func (*RestartAgentsRequest) Descriptor deprecated 

func (*RestartAgentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestartAgentsRequest.ProtoReflect.Descriptor instead.

func (*RestartAgentsRequest) ProtoMessage 

func (*RestartAgentsRequest) ProtoMessage()

func (*RestartAgentsRequest) ProtoReflect 

func (x *RestartAgentsRequest) ProtoReflect() protoreflect.Message

func (*RestartAgentsRequest) Reset 

func (x *RestartAgentsRequest) Reset()

func (*RestartAgentsRequest) String 

func (x *RestartAgentsRequest) String() string

type RestorePgControlReply 

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

func (*RestorePgControlReply) Descriptor deprecated 

func (*RestorePgControlReply) Descriptor() ([]byte, []int)

Deprecated: Use RestorePgControlReply.ProtoReflect.Descriptor instead.

func (*RestorePgControlReply) ProtoMessage 

func (*RestorePgControlReply) ProtoMessage()

func (*RestorePgControlReply) ProtoReflect 

func (x *RestorePgControlReply) ProtoReflect() protoreflect.Message

func (*RestorePgControlReply) Reset 

func (x *RestorePgControlReply) Reset()

func (*RestorePgControlReply) String 

func (x *RestorePgControlReply) String() string

type RestorePgControlRequest 

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

func (*RestorePgControlRequest) Descriptor deprecated 

func (*RestorePgControlRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestorePgControlRequest.ProtoReflect.Descriptor instead.

func (*RestorePgControlRequest) GetDatadirs 

func (x *RestorePgControlRequest) GetDatadirs() []string

func (*RestorePgControlRequest) ProtoMessage 

func (*RestorePgControlRequest) ProtoMessage()

func (*RestorePgControlRequest) ProtoReflect 

func (x *RestorePgControlRequest) ProtoReflect() protoreflect.Message

func (*RestorePgControlRequest) Reset 

func (x *RestorePgControlRequest) Reset()

func (*RestorePgControlRequest) String 

func (x *RestorePgControlRequest) String() string

type RevertRequest 

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

func (*RevertRequest) Descriptor deprecated 

func (*RevertRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertRequest.ProtoReflect.Descriptor instead.

func (*RevertRequest) ProtoMessage 

func (*RevertRequest) ProtoMessage()

func (*RevertRequest) ProtoReflect 

func (x *RevertRequest) ProtoReflect() protoreflect.Message

func (*RevertRequest) Reset 

func (x *RevertRequest) Reset()

func (*RevertRequest) String 

func (x *RevertRequest) String() string

type RevertResponse 

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
}

func (*RevertResponse) Descriptor deprecated 

func (*RevertResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertResponse.ProtoReflect.Descriptor instead.

func (*RevertResponse) GetLogArchiveDirectory 

func (x *RevertResponse) GetLogArchiveDirectory() string

func (*RevertResponse) GetSource 

func (x *RevertResponse) GetSource() []byte

func (*RevertResponse) ProtoMessage 

func (*RevertResponse) ProtoMessage()

func (*RevertResponse) ProtoReflect 

func (x *RevertResponse) ProtoReflect() protoreflect.Message

func (*RevertResponse) Reset 

func (x *RevertResponse) Reset()

func (*RevertResponse) String 

func (x *RevertResponse) String() string

type RsyncReply 

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

func (*RsyncReply) Descriptor deprecated 

func (*RsyncReply) Descriptor() ([]byte, []int)

Deprecated: Use RsyncReply.ProtoReflect.Descriptor instead.

func (*RsyncReply) ProtoMessage 

func (*RsyncReply) ProtoMessage()

func (*RsyncReply) ProtoReflect 

func (x *RsyncReply) ProtoReflect() protoreflect.Message

func (*RsyncReply) Reset 

func (x *RsyncReply) Reset()

func (*RsyncReply) String 

func (x *RsyncReply) String() string

type RsyncRequest 

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

func (*RsyncRequest) Descriptor deprecated 

func (*RsyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use RsyncRequest.ProtoReflect.Descriptor instead.

func (*RsyncRequest) GetOptions 

func (x *RsyncRequest) GetOptions() []*RsyncRequest_RsyncOptions

func (*RsyncRequest) ProtoMessage 

func (*RsyncRequest) ProtoMessage()

func (*RsyncRequest) ProtoReflect 

func (x *RsyncRequest) ProtoReflect() protoreflect.Message

func (*RsyncRequest) Reset 

func (x *RsyncRequest) Reset()

func (*RsyncRequest) String 

func (x *RsyncRequest) String() string

type RsyncRequest_RsyncOptions 

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
}

func (*RsyncRequest_RsyncOptions) Descriptor deprecated 

func (*RsyncRequest_RsyncOptions) Descriptor() ([]byte, []int)

Deprecated: Use RsyncRequest_RsyncOptions.ProtoReflect.Descriptor instead.

func (*RsyncRequest_RsyncOptions) GetDestination 

func (x *RsyncRequest_RsyncOptions) GetDestination() string

func (*RsyncRequest_RsyncOptions) GetDestinationHost 

func (x *RsyncRequest_RsyncOptions) GetDestinationHost() string

func (*RsyncRequest_RsyncOptions) GetExcludedFiles 

func (x *RsyncRequest_RsyncOptions) GetExcludedFiles() []string

func (*RsyncRequest_RsyncOptions) GetOptions 

func (x *RsyncRequest_RsyncOptions) GetOptions() []string

func (*RsyncRequest_RsyncOptions) GetSources 

func (x *RsyncRequest_RsyncOptions) GetSources() []string

func (*RsyncRequest_RsyncOptions) ProtoMessage 

func (*RsyncRequest_RsyncOptions) ProtoMessage()

func (*RsyncRequest_RsyncOptions) ProtoReflect 

func (x *RsyncRequest_RsyncOptions) ProtoReflect() protoreflect.Message

func (*RsyncRequest_RsyncOptions) Reset 

func (x *RsyncRequest_RsyncOptions) Reset()

func (*RsyncRequest_RsyncOptions) String 

func (x *RsyncRequest_RsyncOptions) String() string

type Schedule 

type Schedule int32
const (
	Schedule_unknown_schedule            Schedule = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	Schedule_upgradeable_source_schedule Schedule = 1
	Schedule_upgradeable_target_schedule Schedule = 2
	Schedule_non_upgradeable_schedule    Schedule = 3
	Schedule_migratable_source_schedule  Schedule = 4
	Schedule_migratable_target_schedule  Schedule = 5
)

func (Schedule) Descriptor 

func (Schedule) Descriptor() protoreflect.EnumDescriptor

func (Schedule) Enum 

func (x Schedule) Enum() *Schedule

func (Schedule) EnumDescriptor deprecated 

func (Schedule) EnumDescriptor() ([]byte, []int)

Deprecated: Use Schedule.Descriptor instead.

func (Schedule) Number 

func (x Schedule) Number() protoreflect.EnumNumber

func (Schedule) String 

func (x Schedule) String() string

func (Schedule) Type 

func (Schedule) Type() protoreflect.EnumType

type Status 

type Status int32
const (
	Status_unknown_status Status = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	Status_running        Status = 1
	Status_complete       Status = 2
	Status_failed         Status = 3
	Status_skipped        Status = 4
	Status_quit           Status = 5
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type Step 

type Step int32
const (
	Step_unknown_step Step = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	Step_initialize   Step = 1
	Step_execute      Step = 2
	Step_finalize     Step = 3
	Step_revert       Step = 4
	Step_stats        Step = 5 // used for data migration script phase
)

func (Step) Descriptor 

func (Step) Descriptor() protoreflect.EnumDescriptor

func (Step) Enum 

func (x Step) Enum() *Step

func (Step) EnumDescriptor deprecated 

func (Step) EnumDescriptor() ([]byte, []int)

Deprecated: Use Step.Descriptor instead.

func (Step) Number 

func (x Step) Number() protoreflect.EnumNumber

func (Step) String 

func (x Step) String() string

func (Step) Type 

func (Step) Type() protoreflect.EnumType

type StopAgentReply 

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

func (*StopAgentReply) Descriptor deprecated 

func (*StopAgentReply) Descriptor() ([]byte, []int)

Deprecated: Use StopAgentReply.ProtoReflect.Descriptor instead.

func (*StopAgentReply) ProtoMessage 

func (*StopAgentReply) ProtoMessage()

func (*StopAgentReply) ProtoReflect 

func (x *StopAgentReply) ProtoReflect() protoreflect.Message

func (*StopAgentReply) Reset 

func (x *StopAgentReply) Reset()

func (*StopAgentReply) String 

func (x *StopAgentReply) String() string

type StopAgentRequest 

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

func (*StopAgentRequest) Descriptor deprecated 

func (*StopAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopAgentRequest.ProtoReflect.Descriptor instead.

func (*StopAgentRequest) ProtoMessage 

func (*StopAgentRequest) ProtoMessage()

func (*StopAgentRequest) ProtoReflect 

func (x *StopAgentRequest) ProtoReflect() protoreflect.Message

func (*StopAgentRequest) Reset 

func (x *StopAgentRequest) Reset()

func (*StopAgentRequest) String 

func (x *StopAgentRequest) String() string

type StopServicesReply 

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

func (*StopServicesReply) Descriptor deprecated 

func (*StopServicesReply) Descriptor() ([]byte, []int)

Deprecated: Use StopServicesReply.ProtoReflect.Descriptor instead.

func (*StopServicesReply) ProtoMessage 

func (*StopServicesReply) ProtoMessage()

func (*StopServicesReply) ProtoReflect 

func (x *StopServicesReply) ProtoReflect() protoreflect.Message

func (*StopServicesReply) Reset 

func (x *StopServicesReply) Reset()

func (*StopServicesReply) String 

func (x *StopServicesReply) String() string

type StopServicesRequest 

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

func (*StopServicesRequest) Descriptor deprecated 

func (*StopServicesRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopServicesRequest.ProtoReflect.Descriptor instead.

func (*StopServicesRequest) ProtoMessage 

func (*StopServicesRequest) ProtoMessage()

func (*StopServicesRequest) ProtoReflect 

func (x *StopServicesRequest) ProtoReflect() protoreflect.Message

func (*StopServicesRequest) Reset 

func (x *StopServicesRequest) Reset()

func (*StopServicesRequest) String 

func (x *StopServicesRequest) String() string

type Substep 

type Substep int32
const (
	Substep_unknown_substep                                               Substep = 0 // http://androiddevblog.com/protocol-buffers-pitfall-adding-enum-values/
	Substep_saving_source_cluster_config                                  Substep = 1
	Substep_start_hub                                                     Substep = 2
	Substep_start_agents                                                  Substep = 3
	Substep_check_environment                                             Substep = 4
	Substep_check_disk_space                                              Substep = 5
	Substep_generate_target_config                                        Substep = 6
	Substep_init_target_cluster                                           Substep = 7
	Substep_shutdown_target_cluster                                       Substep = 8
	Substep_backup_target_master                                          Substep = 9
	Substep_check_upgrade                                                 Substep = 10
	Substep_shutdown_source_cluster                                       Substep = 11
	Substep_upgrade_master                                                Substep = 12
	Substep_copy_master                                                   Substep = 13
	Substep_upgrade_primaries                                             Substep = 14
	Substep_start_target_cluster                                          Substep = 15
	Substep_update_target_catalog                                         Substep = 16
	Substep_update_data_directories                                       Substep = 17
	Substep_update_target_conf_files                                      Substep = 18
	Substep_upgrade_standby                                               Substep = 19
	Substep_upgrade_mirrors                                               Substep = 20
	Substep_delete_tablespaces                                            Substep = 21
	Substep_delete_target_cluster_datadirs                                Substep = 22
	Substep_delete_segment_statedirs                                      Substep = 23
	Substep_stop_hub_and_agents                                           Substep = 24
	Substep_delete_master_statedir                                        Substep = 25
	Substep_archive_log_directories                                       Substep = 26
	Substep_restore_source_cluster                                        Substep = 27
	Substep_start_source_cluster                                          Substep = 28
	Substep_restore_pgcontrol                                             Substep = 29
	Substep_recoverseg_source_cluster                                     Substep = 30
	Substep_step_status                                                   Substep = 31
	Substep_wait_for_cluster_to_be_ready_after_adding_mirrors_and_standby Substep = 32
	Substep_wait_for_cluster_to_be_ready_after_updating_catalog           Substep = 33
	Substep_setting_dynamic_library_path_on_target_cluster                Substep = 34
	Substep_check_active_connections_on_source_cluster                    Substep = 35
	Substep_check_active_connections_on_target_cluster                    Substep = 36
	Substep_generate_data_migration_scripts                               Substep = 37
	Substep_execute_stats_data_migration_scripts                          Substep = 38
	Substep_execute_initialize_data_migration_scripts                     Substep = 39
	Substep_execute_finalize_data_migration_scripts                       Substep = 40
	Substep_execute_revert_data_migration_scripts                         Substep = 41
	Substep_create_backupdirs                                             Substep = 42
	Substep_delete_backupdir                                              Substep = 43
	Substep_analyze_target_cluster                                        Substep = 44
	Substep_ensure_gpupgrade_agents_are_running                           Substep = 45
	Substep_verify_gpdb_versions                                          Substep = 46
	Substep_verify_gpupgrade_is_installed_across_all_hosts                Substep = 47
	Substep_initialize_wait_for_cluster_to_be_ready                       Substep = 48
	Substep_wait_for_cluster_to_be_ready_before_upgrade_master            Substep = 49
)

func (Substep) Descriptor 

func (Substep) Descriptor() protoreflect.EnumDescriptor

func (Substep) Enum 

func (x Substep) Enum() *Substep

func (Substep) EnumDescriptor deprecated 

func (Substep) EnumDescriptor() ([]byte, []int)

Deprecated: Use Substep.Descriptor instead.

func (Substep) Number 

func (x Substep) Number() protoreflect.EnumNumber

func (Substep) String 

func (x Substep) String() string

func (Substep) Type 

func (Substep) Type() protoreflect.EnumType

type SubstepStatus 

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
}

func (*SubstepStatus) Descriptor deprecated 

func (*SubstepStatus) Descriptor() ([]byte, []int)

Deprecated: Use SubstepStatus.ProtoReflect.Descriptor instead.

func (*SubstepStatus) GetStatus 

func (x *SubstepStatus) GetStatus() Status

func (*SubstepStatus) GetStep 

func (x *SubstepStatus) GetStep() Substep

func (*SubstepStatus) ProtoMessage 

func (*SubstepStatus) ProtoMessage()

func (*SubstepStatus) ProtoReflect 

func (x *SubstepStatus) ProtoReflect() protoreflect.Message

func (*SubstepStatus) Reset 

func (x *SubstepStatus) Reset()

func (*SubstepStatus) String 

func (x *SubstepStatus) String() string

type TablespaceInfo 

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
}

func (*TablespaceInfo) Descriptor deprecated 

func (*TablespaceInfo) Descriptor() ([]byte, []int)

Deprecated: Use TablespaceInfo.ProtoReflect.Descriptor instead.

func (*TablespaceInfo) GetLocation 

func (x *TablespaceInfo) GetLocation() string

func (*TablespaceInfo) GetUserDefined 

func (x *TablespaceInfo) GetUserDefined() bool

func (*TablespaceInfo) ProtoMessage 

func (*TablespaceInfo) ProtoMessage()

func (*TablespaceInfo) ProtoReflect 

func (x *TablespaceInfo) ProtoReflect() protoreflect.Message

func (*TablespaceInfo) Reset 

func (x *TablespaceInfo) Reset()

func (*TablespaceInfo) String 

func (x *TablespaceInfo) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) AddReplicationEntries 

func (UnimplementedAgentServer) AddReplicationEntries(context.Context, *AddReplicationEntriesRequest) (*AddReplicationEntriesReply, error)

func (UnimplementedAgentServer) ArchiveLogDirectory 

func (UnimplementedAgentServer) ArchiveLogDirectory(context.Context, *ArchiveLogDirectoryRequest) (*ArchiveLogDirectoryReply, error)

func (UnimplementedAgentServer) CheckDiskSpace 

func (UnimplementedAgentServer) CheckDiskSpace(context.Context, *CheckSegmentDiskSpaceRequest) (*CheckDiskSpaceReply, error)

func (UnimplementedAgentServer) CreateBackupDirectory 

func (UnimplementedAgentServer) CreateBackupDirectory(context.Context, *CreateBackupDirectoryRequest) (*CreateBackupDirectoryReply, error)

func (UnimplementedAgentServer) CreateRecoveryConf 

func (UnimplementedAgentServer) CreateRecoveryConf(context.Context, *CreateRecoveryConfRequest) (*CreateRecoveryConfReply, error)

func (UnimplementedAgentServer) DeleteBackupDirectory 

func (UnimplementedAgentServer) DeleteBackupDirectory(context.Context, *DeleteBackupDirectoryRequest) (*DeleteBackupDirectoryReply, error)

func (UnimplementedAgentServer) DeleteDataDirectories 

func (UnimplementedAgentServer) DeleteDataDirectories(context.Context, *DeleteDataDirectoriesRequest) (*DeleteDataDirectoriesReply, error)

func (UnimplementedAgentServer) DeleteStateDirectory 

func (UnimplementedAgentServer) DeleteStateDirectory(context.Context, *DeleteStateDirectoryRequest) (*DeleteStateDirectoryReply, error)

func (UnimplementedAgentServer) DeleteTablespaceDirectories 

func (UnimplementedAgentServer) DeleteTablespaceDirectories(context.Context, *DeleteTablespaceRequest) (*DeleteTablespaceReply, error)

func (UnimplementedAgentServer) RenameDirectories 

func (UnimplementedAgentServer) RenameDirectories(context.Context, *RenameDirectoriesRequest) (*RenameDirectoriesReply, error)

func (UnimplementedAgentServer) RenameTablespaces 

func (UnimplementedAgentServer) RenameTablespaces(context.Context, *RenameTablespacesRequest) (*RenameTablespacesReply, error)

func (UnimplementedAgentServer) RestorePrimariesPgControl 

func (UnimplementedAgentServer) RestorePrimariesPgControl(context.Context, *RestorePgControlRequest) (*RestorePgControlReply, error)

func (UnimplementedAgentServer) RsyncDataDirectories 

func (UnimplementedAgentServer) RsyncDataDirectories(context.Context, *RsyncRequest) (*RsyncReply, error)

func (UnimplementedAgentServer) RsyncTablespaceDirectories 

func (UnimplementedAgentServer) RsyncTablespaceDirectories(context.Context, *RsyncRequest) (*RsyncReply, error)

func (UnimplementedAgentServer) StopAgent 

func (UnimplementedAgentServer) StopAgent(context.Context, *StopAgentRequest) (*StopAgentReply, error)

func (UnimplementedAgentServer) UpdateConfiguration 

func (UnimplementedAgentServer) UpdateConfiguration(context.Context, *UpdateConfigurationRequest) (*UpdateConfigurationReply, error)

func (UnimplementedAgentServer) UpgradePrimaries 

func (UnimplementedAgentServer) UpgradePrimaries(context.Context, *UpgradePrimariesRequest) (*UpgradePrimariesReply, error)

type UnimplementedCliToHubServer 

type UnimplementedCliToHubServer struct {
}

UnimplementedCliToHubServer should be embedded to have forward compatible implementations.

func (UnimplementedCliToHubServer) Execute 

func (UnimplementedCliToHubServer) Execute(*ExecuteRequest, CliToHub_ExecuteServer) error

func (UnimplementedCliToHubServer) Finalize 

func (UnimplementedCliToHubServer) Finalize(*FinalizeRequest, CliToHub_FinalizeServer) error

func (UnimplementedCliToHubServer) GetConfig 

func (UnimplementedCliToHubServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigReply, error)

func (UnimplementedCliToHubServer) Initialize 

func (UnimplementedCliToHubServer) Initialize(*InitializeRequest, CliToHub_InitializeServer) error

func (UnimplementedCliToHubServer) InitializeCreateCluster 

func (UnimplementedCliToHubServer) InitializeCreateCluster(*InitializeCreateClusterRequest, CliToHub_InitializeCreateClusterServer) error

func (UnimplementedCliToHubServer) RestartAgents 

func (UnimplementedCliToHubServer) RestartAgents(context.Context, *RestartAgentsRequest) (*RestartAgentsReply, error)

func (UnimplementedCliToHubServer) Revert 

func (UnimplementedCliToHubServer) Revert(*RevertRequest, CliToHub_RevertServer) error

func (UnimplementedCliToHubServer) StopServices 

func (UnimplementedCliToHubServer) StopServices(context.Context, *StopServicesRequest) (*StopServicesReply, error)

type UnsafeAgentServer 

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.

type UnsafeCliToHubServer 

type UnsafeCliToHubServer interface {
	// contains filtered or unexported methods
}

UnsafeCliToHubServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CliToHubServer will result in compilation errors.

type UpdateConfigurationReply 

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

func (*UpdateConfigurationReply) Descriptor deprecated 

func (*UpdateConfigurationReply) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigurationReply.ProtoReflect.Descriptor instead.

func (*UpdateConfigurationReply) ProtoMessage 

func (*UpdateConfigurationReply) ProtoMessage()

func (*UpdateConfigurationReply) ProtoReflect 

func (x *UpdateConfigurationReply) ProtoReflect() protoreflect.Message

func (*UpdateConfigurationReply) Reset 

func (x *UpdateConfigurationReply) Reset()

func (*UpdateConfigurationReply) String 

func (x *UpdateConfigurationReply) String() string

type UpdateConfigurationRequest 

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

func (*UpdateConfigurationRequest) Descriptor deprecated 

func (*UpdateConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigurationRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigurationRequest) GetOptions 

func (x *UpdateConfigurationRequest) GetOptions() []*UpdateFileConfOptions

func (*UpdateConfigurationRequest) ProtoMessage 

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) ProtoReflect 

func (x *UpdateConfigurationRequest) ProtoReflect() protoreflect.Message

func (*UpdateConfigurationRequest) Reset 

func (x *UpdateConfigurationRequest) Reset()

func (*UpdateConfigurationRequest) String 

func (x *UpdateConfigurationRequest) String() string

type UpdateFileConfOptions 

type UpdateFileConfOptions struct {
	Path        string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Pattern     string `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Replacement string `protobuf:"bytes,3,opt,name=replacement,proto3" json:"replacement,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateFileConfOptions) Descriptor deprecated 

func (*UpdateFileConfOptions) Descriptor() ([]byte, []int)

Deprecated: Use UpdateFileConfOptions.ProtoReflect.Descriptor instead.

func (*UpdateFileConfOptions) GetPath 

func (x *UpdateFileConfOptions) GetPath() string

func (*UpdateFileConfOptions) GetPattern 

func (x *UpdateFileConfOptions) GetPattern() string

func (*UpdateFileConfOptions) GetReplacement 

func (x *UpdateFileConfOptions) GetReplacement() string

func (*UpdateFileConfOptions) ProtoMessage 

func (*UpdateFileConfOptions) ProtoMessage()

func (*UpdateFileConfOptions) ProtoReflect 

func (x *UpdateFileConfOptions) ProtoReflect() protoreflect.Message

func (*UpdateFileConfOptions) Reset 

func (x *UpdateFileConfOptions) Reset()

func (*UpdateFileConfOptions) String 

func (x *UpdateFileConfOptions) String() string

type UpgradePrimariesReply 

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

func (*UpgradePrimariesReply) Descriptor deprecated 

func (*UpgradePrimariesReply) Descriptor() ([]byte, []int)

Deprecated: Use UpgradePrimariesReply.ProtoReflect.Descriptor instead.

func (*UpgradePrimariesReply) ProtoMessage 

func (*UpgradePrimariesReply) ProtoMessage()

func (*UpgradePrimariesReply) ProtoReflect 

func (x *UpgradePrimariesReply) ProtoReflect() protoreflect.Message

func (*UpgradePrimariesReply) Reset 

func (x *UpgradePrimariesReply) Reset()

func (*UpgradePrimariesReply) String 

func (x *UpgradePrimariesReply) String() string

type UpgradePrimariesRequest 

type UpgradePrimariesRequest struct {
	Action PgOptions_Action `protobuf:"varint,1,opt,name=action,proto3,enum=idl.PgOptions_Action" json:"action,omitempty"`
	Opts   []*PgOptions     `protobuf:"bytes,2,rep,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*UpgradePrimariesRequest) Descriptor deprecated 

func (*UpgradePrimariesRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpgradePrimariesRequest.ProtoReflect.Descriptor instead.

func (*UpgradePrimariesRequest) GetAction 

func (x *UpgradePrimariesRequest) GetAction() PgOptions_Action

func (*UpgradePrimariesRequest) GetOpts 

func (x *UpgradePrimariesRequest) GetOpts() []*PgOptions

func (*UpgradePrimariesRequest) ProtoMessage 

func (*UpgradePrimariesRequest) ProtoMessage()

func (*UpgradePrimariesRequest) ProtoReflect 

func (x *UpgradePrimariesRequest) ProtoReflect() protoreflect.Message

func (*UpgradePrimariesRequest) Reset 

func (x *UpgradePrimariesRequest) Reset()

func (*UpgradePrimariesRequest) String 

func (x *UpgradePrimariesRequest) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package mock_idl is a generated GoMock package.
 Package mock_idl is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.