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 (*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 (*AddReplicationEntriesRequest) ProtoMessage

func (*AddReplicationEntriesRequest) ProtoMessage()

func (*AddReplicationEntriesRequest) ProtoReflect

func (*AddReplicationEntriesRequest) Reset

func (x *AddReplicationEntriesRequest) Reset()

func (*AddReplicationEntriesRequest) 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 (*AddReplicationEntriesRequest_Entry) GetHostAddrs

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

func (*AddReplicationEntriesRequest_Entry) GetUser

func (*AddReplicationEntriesRequest_Entry) ProtoMessage

func (*AddReplicationEntriesRequest_Entry) ProtoMessage()

func (*AddReplicationEntriesRequest_Entry) ProtoReflect

func (*AddReplicationEntriesRequest_Entry) Reset

func (*AddReplicationEntriesRequest_Entry) 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 (*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 (*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 (*CheckDiskSpaceReply_DiskUsage) GetHost

func (*CheckDiskSpaceReply_DiskUsage) GetRequired

func (x *CheckDiskSpaceReply_DiskUsage) GetRequired() uint64

func (*CheckDiskSpaceReply_DiskUsage) ProtoMessage

func (*CheckDiskSpaceReply_DiskUsage) ProtoMessage()

func (*CheckDiskSpaceReply_DiskUsage) ProtoReflect

func (*CheckDiskSpaceReply_DiskUsage) Reset

func (x *CheckDiskSpaceReply_DiskUsage) Reset()

func (*CheckDiskSpaceReply_DiskUsage) 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 (*CheckSegmentDiskSpaceRequest) Reset

func (x *CheckSegmentDiskSpaceRequest) Reset()

func (*CheckSegmentDiskSpaceRequest) 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

type CliToHubClient

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

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

func (ClusterDestination) EnumDescriptor deprecated

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

Deprecated: Use ClusterDestination.Descriptor instead.

func (ClusterDestination) Number

func (ClusterDestination) String

func (x ClusterDestination) String() string

func (ClusterDestination) Type

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 (*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 (*CreateBackupDirectoryRequest) Reset

func (x *CreateBackupDirectoryRequest) Reset()

func (*CreateBackupDirectoryRequest) 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 (*CreateRecoveryConfRequest) ProtoMessage

func (*CreateRecoveryConfRequest) ProtoMessage()

func (*CreateRecoveryConfRequest) ProtoReflect

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 (*CreateRecoveryConfRequest_Connection) ProtoMessage

func (*CreateRecoveryConfRequest_Connection) ProtoMessage()

func (*CreateRecoveryConfRequest_Connection) ProtoReflect

func (*CreateRecoveryConfRequest_Connection) Reset

func (*CreateRecoveryConfRequest_Connection) 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 (*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 (*DeleteBackupDirectoryRequest) Reset

func (x *DeleteBackupDirectoryRequest) Reset()

func (*DeleteBackupDirectoryRequest) 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 (*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 (*DeleteDataDirectoriesRequest) Reset

func (x *DeleteDataDirectoriesRequest) Reset()

func (*DeleteDataDirectoriesRequest) 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 (*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 (*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 (*InitializeCreateClusterRequest) Reset

func (x *InitializeCreateClusterRequest) Reset()

func (*InitializeCreateClusterRequest) 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) Enum

func (PgOptions_Action) EnumDescriptor deprecated

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

Deprecated: Use PgOptions_Action.Descriptor instead.

func (PgOptions_Action) Number

func (PgOptions_Action) String

func (x PgOptions_Action) String() string

func (PgOptions_Action) Type

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

func (PgOptions_PgUpgradeMode) EnumDescriptor deprecated

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

Deprecated: Use PgOptions_PgUpgradeMode.Descriptor instead.

func (PgOptions_PgUpgradeMode) Number

func (PgOptions_PgUpgradeMode) String

func (x PgOptions_PgUpgradeMode) String() string

func (PgOptions_PgUpgradeMode) Type

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 (*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 (*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 (*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 (*RenameTablespacesRequest_RenamePair) ProtoMessage

func (*RenameTablespacesRequest_RenamePair) ProtoMessage()

func (*RenameTablespacesRequest_RenamePair) ProtoReflect

func (*RenameTablespacesRequest_RenamePair) Reset

func (*RenameTablespacesRequest_RenamePair) 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 (*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

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

func (UnimplementedAgentServer) DeleteTablespaceDirectories

func (UnimplementedAgentServer) RenameDirectories

func (UnimplementedAgentServer) RenameTablespaces

func (UnimplementedAgentServer) RestorePrimariesPgControl

func (UnimplementedAgentServer) RsyncDataDirectories

func (UnimplementedAgentServer) RsyncTablespaceDirectories

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

func (UnimplementedAgentServer) StopAgent

func (UnimplementedAgentServer) UpgradePrimaries

type UnimplementedCliToHubServer

type UnimplementedCliToHubServer struct {
}

UnimplementedCliToHubServer should be embedded to have forward compatible implementations.

func (UnimplementedCliToHubServer) Execute

func (UnimplementedCliToHubServer) Finalize

func (UnimplementedCliToHubServer) GetConfig

func (UnimplementedCliToHubServer) Initialize

func (UnimplementedCliToHubServer) RestartAgents

func (UnimplementedCliToHubServer) Revert

func (UnimplementedCliToHubServer) StopServices

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 (*UpdateConfigurationRequest) ProtoMessage

func (*UpdateConfigurationRequest) ProtoMessage()

func (*UpdateConfigurationRequest) ProtoReflect

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 (*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

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