Versions in this module Expand all Collapse all v1 v1.0.2 Dec 7, 2023 v1.0.1 Nov 21, 2023 v1.0.0 Nov 21, 2023 Changes in this version + const Complete + const Deferred + const FILE + const GPFDIST + const GPHDFS + const HTTP + const PG_LOCK_NOT_AVAILABLE + const READABLE + const READABLE_WEB + const S3 + const SNAPSHOT_GPDB_MIN_VERSION + const Unknown + const WRITABLE + const WRITABLE_WEB + var ACLRegex = regexp.MustCompile(`^(.*)=([a-zA-Z\*]*)/(.*)$`) + var CleanupGroup *sync.WaitGroup + var FIRST_NORMAL_OBJECT_ID uint32 = 16384 + var PG_AGGREGATE_OID uint32 = 1255 + var PG_AUTHID_OID uint32 = 1260 + var PG_CAST_OID uint32 = 2605 + var PG_CLASS_OID uint32 = 1259 + var PG_COLLATION_OID uint32 = 3456 + var PG_CONSTRAINT_OID uint32 = 2606 + var PG_CONVERSION_OID uint32 = 2607 + var PG_DATABASE_OID uint32 = 1262 + var PG_EVENT_TRIGGER uint32 = 3466 + var PG_EXTENSION_OID uint32 = 3079 + var PG_EXTPROTOCOL_OID uint32 = 7175 + var PG_FOREIGN_DATA_WRAPPER_OID uint32 = 2328 + var PG_FOREIGN_SERVER_OID uint32 = 1417 + var PG_INDEX_OID uint32 = 2610 + var PG_LANGUAGE_OID uint32 = 2612 + var PG_NAMESPACE_OID uint32 = 2615 + var PG_OPCLASS_OID uint32 = 2616 + var PG_OPERATOR_OID uint32 = 2617 + var PG_OPFAMILY_OID uint32 = 2753 + var PG_PROC_OID uint32 = 1255 + var PG_RESGROUP_OID uint32 = 6436 + var PG_RESQUEUE_OID uint32 = 6026 + var PG_REWRITE_OID uint32 = 2618 + var PG_STATISTIC_EXT_OID uint32 = 3381 + var PG_TABLESPACE_OID uint32 = 1213 + var PG_TRANSFORM_OID uint32 = 3576 + var PG_TRIGGER_OID uint32 = 2620 + var PG_TS_CONFIG_OID uint32 = 3602 + var PG_TS_DICT_OID uint32 = 3600 + var PG_TS_PARSER_OID uint32 = 3601 + var PG_TS_TEMPLATE_OID uint32 = 3764 + var PG_TYPE_OID uint32 = 1247 + var PG_USER_MAPPING_OID uint32 = 1418 + func AddProtocolDependenciesForGPDB4(depMap DependencyMap, tables []Table, protocols []ExternalProtocol) + func AddTableDataEntriesToTOC(tables []Table, rowsCopiedMaps []map[uint32]int64) + func AnyValues(any pq.StringArray, typ string) string + func AppendExtPartSuffix(name string) string + func BackupSingleTableData(table Table, rowsCopiedMap map[uint32]int64, counters *BackupProgressCounters, ...) error + func ConstructImplicitIndexOidList(connectionPool *dbconn.DBConn) string + func ConstructTableAttributesList(columnDefs []ColumnDefinition) string + func CopyTableOut(connectionPool *dbconn.DBConn, table Table, destinationToWrite string, ...) (int64, error) + func CreateInitialSegmentPipes(oidList []string, c *cluster.Cluster, connectionPool *dbconn.DBConn, ...) int + func DetermineExternalTableCharacteristics(extTableDef ExternalTableDefinition) (int, int) + func DoBackup() + func DoCleanup(backupFailed bool) + func DoFlagValidation(cmd *cobra.Command) + func DoInit(cmd *cobra.Command) + func DoSetup() + func DoTeardown() + func ExtensionFilterClause(namespace string) string + func ExtractLanguageFunctions(funcDefs []Function, procLangs []ProceduralLanguage) ([]Function, []Function) + func FlagChanged(flagName string) bool + func GenerateAttributeStatisticsQueries(table Table, attStat AttributeStatistic) []string + func GenerateFormatStatement(extTableDef ExternalTableDefinition) string + func GenerateTableBatches(tables []Relation, batchSize int) []string + func GenerateTupleStatisticsQuery(table Table, tupleStat TupleStatistic) string + func GetAOIncrementalMetadata(connectionPool *dbconn.DBConn) map[string]toc.AOEntry + func GetAttachPartitionInfo(connectionPool *dbconn.DBConn) map[uint32]AttachPartitionInfo + func GetAttributeStatistics(connectionPool *dbconn.DBConn, tables []Table) map[uint32][]AttributeStatistic + func GetColumnDefinitions(connectionPool *dbconn.DBConn) map[uint32][]ColumnDefinition + func GetDBSize(connectionPool *dbconn.DBConn) string + func GetDatabaseGUCs(connectionPool *dbconn.DBConn) []string + func GetDistributionPolicies(connectionPool *dbconn.DBConn) map[uint32]string + func GetExternalTableDefinitions(connectionPool *dbconn.DBConn) map[uint32]ExternalTableDefinition + func GetForceRowSecurity(connectionPool *dbconn.DBConn) map[uint32]bool + func GetForeignTableDefinitions(connectionPool *dbconn.DBConn) map[uint32]ForeignTableDefinition + func GetFunctionArgsAndIdentArgs(connectionPool *dbconn.DBConn) (map[uint32]string, map[uint32]string) + func GetFunctionOidToInfoMap(connectionPool *dbconn.DBConn) map[uint32]FunctionInfo + func GetFunctionReturnTypes(connectionPool *dbconn.DBConn) map[uint32]Function + func GetLatestMatchingBackupConfig(history *history.History, currentBackupConfig *history.BackupConfig) *history.BackupConfig + func GetLatestMatchingBackupTimestamp() string + func GetOperatorClassFunctions(connectionPool *dbconn.DBConn) map[uint32][]OperatorClassFunction + func GetOperatorClassOperators(connectionPool *dbconn.DBConn) map[uint32][]OperatorClassOperator + func GetPartitionAlteredSchema(connectionPool *dbconn.DBConn) map[uint32][]AlteredPartitionRelation + func GetPartitionDetails(connectionPool *dbconn.DBConn) (map[uint32]string, map[uint32]string) + func GetPartitionKeyDefs(connectionPool *dbconn.DBConn) map[uint32]string + func GetPartitionTableMap(connectionPool *dbconn.DBConn) map[uint32]PartitionLevelInfo + func GetRenameExchangedPartitionQuery(connection *dbconn.DBConn) string + func GetReport() *report.Report + func GetRoleGUCs(connectionPool *dbconn.DBConn) map[string][]RoleGUC + func GetSegmentTablespaces(connectionPool *dbconn.DBConn, Oid uint32) []string + func GetSynchronizedSnapshot(connectionPool *dbconn.DBConn) (string, error) + func GetTableAccessMethod(connectionPool *dbconn.DBConn) map[uint32]string + func GetTableInheritance(connectionPool *dbconn.DBConn, tables []Relation) map[uint32][]string + func GetTableReplicaIdentity(connectionPool *dbconn.DBConn) map[uint32]string + func GetTableStorage(connectionPool *dbconn.DBConn) (map[uint32]string, map[uint32]string) + func GetTableType(connectionPool *dbconn.DBConn) map[uint32]string + func GetTargetBackupTimestamp() string + func GetTupleStatistics(connectionPool *dbconn.DBConn, tables []Table) map[uint32]TupleStatistic + func GetTypeMetadataEntry(schema string, name string) (string, toc.MetadataEntry) + func GetUnloggedTables(connectionPool *dbconn.DBConn) map[uint32]bool + func GetVersion() string + func InitializeMetadataParams(connectionPool *dbconn.DBConn) + func LockTableNoWait(dataTable Table, connNum int) error + func LockTables(connectionPool *dbconn.DBConn, tables []Relation) + func MustGetFlagBool(flagName string) bool + func MustGetFlagInt(flagName string) int + func MustGetFlagString(flagName string) string + func MustGetFlagStringArray(flagName string) []string + func MustGetFlagStringSlice(flagName string) []string + func NewBackupConfig(dbName string, dbVersion string, backupVersion string, plugin string, ...) *history.BackupConfig + func PopulateRestorePlan(changedTables []Table, restorePlan []history.RestorePlanEntry, ...) []history.RestorePlanEntry + func PostProcessFunctionConfigs(allFunctions []Function) error + func PrintAccessMethodStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintAlterSequenceStatements(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC, sequences []Sequence) + func PrintConstraintStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, constraint Constraint, ...) + func PrintCreateAggregateStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, aggDef Aggregate, ...) + func PrintCreateBaseTypeStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, base BaseType, ...) + func PrintCreateCastStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, castDef Cast, ...) + func PrintCreateCollationStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, collations []Collation, ...) + func PrintCreateCompositeTypeStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, composite CompositeType, ...) + func PrintCreateConversionStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, conversions []Conversion, ...) + func PrintCreateDatabaseStatement(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC, defaultDB Database, ...) + func PrintCreateDomainStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, domain Domain, ...) + func PrintCreateEnumTypeStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, enums []EnumType, ...) + func PrintCreateEventTriggerStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateExtendedStatistics(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateExtensionStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, extensionDefs []Extension, ...) + func PrintCreateExternalProtocolStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, protocol ExternalProtocol, ...) + func PrintCreateForeignDataWrapperStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, fdw ForeignDataWrapper, ...) + func PrintCreateFunctionStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, funcDef Function, ...) + func PrintCreateIndexStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, indexes []IndexDefinition, ...) + func PrintCreateLanguageStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateOperatorClassStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateOperatorFamilyStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateOperatorStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, operator Operator, ...) + func PrintCreatePolicyStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, policies []RLSPolicy, ...) + func PrintCreateRangeTypeStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, rangeType RangeType, ...) + func PrintCreateResourceGroupStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, resGroups []ResourceGroup, ...) + func PrintCreateResourceQueueStatements(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC, ...) + func PrintCreateRoleStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, roles []Role, ...) + func PrintCreateRuleStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, rules []RuleDefinition, ...) + func PrintCreateSchemaStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, schemas []Schema, ...) + func PrintCreateSequenceStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, sequences []Sequence, ...) + func PrintCreateServerStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, server ForeignServer, ...) + func PrintCreateShellTypeStatements(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC, ...) + func PrintCreateTableStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, table Table, ...) + func PrintCreateTablespaceStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, tablespaces []Tablespace, ...) + func PrintCreateTextSearchConfigurationStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateTextSearchDictionaryStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateTextSearchParserStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, parser TextSearchParser, ...) + func PrintCreateTextSearchTemplateStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateTransformStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, transform Transform, ...) + func PrintCreateTriggerStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintCreateUserMappingStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, mapping UserMapping) + func PrintCreateViewStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, view View, ...) + func PrintDatabaseGUCs(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC, gucs []string, ...) + func PrintDefaultPrivilegesStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintDependentObjectStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, objects []Sortable, ...) + func PrintExchangeExternalPartitionStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintExternalTableCreateStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, table Table) + func PrintExternalTableStatements(metadataFile *utils.FileWithByteCount, tableName string, ...) + func PrintFunctionBodyOrPath(metadataFile *utils.FileWithByteCount, funcDef Function) + func PrintFunctionModifiers(metadataFile *utils.FileWithByteCount, funcDef Function) + func PrintIdentityColumns(metadataFile *utils.FileWithByteCount, toc *toc.TOC, sequences []Sequence) + func PrintObjectMetadata(metadataFile *utils.FileWithByteCount, toc *toc.TOC, metadata ObjectMetadata, ...) + func PrintPostCreateTableStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, table Table, ...) + func PrintRegularTableCreateStatement(metadataFile *utils.FileWithByteCount, toc *toc.TOC, table Table) + func PrintResetResourceGroupStatements(metadataFile *utils.FileWithByteCount, tocfile *toc.TOC) + func PrintRoleGUCStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, ...) + func PrintRoleMembershipStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, roleMembers []RoleMember) + func PrintSessionGUCs(metadataFile *utils.FileWithByteCount, toc *toc.TOC, gucs SessionGUCs) + func PrintStatements(metadataFile *utils.FileWithByteCount, toc *toc.TOC, obj toc.TOCObject, ...) + func PrintStatisticsStatements(statisticsFile *utils.FileWithByteCount, tocfile *toc.TOC, tables []Table, ...) + func QuoteGUCValue(name, value string) string + func RenameExchangedPartitionConstraints(connectionPool *dbconn.DBConn, constraints *[]Constraint) + func RenameExchangedPartitionIndexes(connectionPool *dbconn.DBConn, indexes *[]IndexDefinition) + func RetrieveAndProcessTables() ([]Table, []Table) + func SchemaFilterClause(namespace string) string + func SchemaFilterClauseWithAlteredPartitionSchemas(namespace string, partitionAlteredSchemas map[string]bool) string + func SetCluster(cluster *cluster.Cluster) + func SetCmdFlags(flagSet *pflag.FlagSet) + func SetConnection(conn *dbconn.DBConn) + func SetFPInfo(fpInfo filepath.FilePathInfo) + func SetFilterRelationClause(filterClause string) + func SetLoggerVerbosity() + func SetPluginConfig(config *utils.PluginConfig) + func SetQuotedRoleNames(quotedRoles map[string]string) + func SetReport(report *report.Report) + func SetSessionGUCs(connNum int) + func SetSynchronizedSnapshot(connectionPool *dbconn.DBConn, connNum int, snapshotId string) error + func SetTOC(toc *toc.TOC) + func SetVersion(v string) + func SliceToPostgresArray(slice []string) string + func SplitTablesByPartitionType(tables []Table, includeList []string) ([]Table, []Table) + func UnescapeDoubleQuote(value string) string + func ValidateSchemasExist(connectionPool *dbconn.DBConn, schemaList []string, excludeSet bool) + func ValidateTablesExist(conn *dbconn.DBConn, tableList []string, excludeSet bool) + type ACL struct + Connect bool + ConnectWithGrant bool + Create bool + CreateWithGrant bool + Delete bool + DeleteWithGrant bool + Execute bool + ExecuteWithGrant bool + Grantee string + Insert bool + InsertWithGrant bool + References bool + ReferencesWithGrant bool + Select bool + SelectWithGrant bool + Temporary bool + TemporaryWithGrant bool + Trigger bool + TriggerWithGrant bool + Truncate bool + TruncateWithGrant bool + Update bool + UpdateWithGrant bool + Usage bool + UsageWithGrant bool + func ParseACL(aclStr string) *ACL + type AccessMethod struct + Handler string + Name string + Oid uint32 + Type string + func GetAccessMethods(connectionPool *dbconn.DBConn) []AccessMethod + func (a AccessMethod) FQN() string + func (a AccessMethod) GetMetadataEntry() (string, toc.MetadataEntry) + func (a AccessMethod) GetUniqueID() UniqueID + type Aggregate struct + Arguments sql.NullString + CombineFunction uint32 + DeserialFunction uint32 + FinalFuncExtra bool + FinalFunction uint32 + Finalmodify string + Hypothetical bool + IdentArgs sql.NullString + InitValIsNull bool + InitialValue string + IsOrdered bool + Kind string + MFinalFuncExtra bool + MFinalFunction uint32 + MInitValIsNull bool + MInitialValue string + MInverseTransitionFunction uint32 + MTransitionDataSize int + MTransitionDataType string + MTransitionFunction uint32 + Mfinalmodify string + Name string + Oid uint32 + Parallel string + PreliminaryFunction uint32 + Schema string + SerialFunction uint32 + SortOperator string + SortOperatorSchema string + TransitionDataSize int + TransitionDataType string + TransitionFunction uint32 + func GetAggregates(connectionPool *dbconn.DBConn) []Aggregate + func (a Aggregate) FQN() string + func (a Aggregate) GetMetadataEntry() (string, toc.MetadataEntry) + func (a Aggregate) GetUniqueID() UniqueID + type AlteredPartitionRelation struct + Name string + NewSchema string + OldSchema string + type AttachPartitionInfo struct + Expr string + Oid uint32 + Parent string + Relname string + type Attribute struct + Collation string + Comment string + CompositeTypeOid uint32 + Name string + Type string + type AttributeStatistic struct + AttName string + AttNumber int + Collation1 uint32 + Collation2 uint32 + Collation3 uint32 + Collation4 uint32 + Collation5 uint32 + Distinct float64 + Inherit bool + Kind1 int + Kind2 int + Kind3 int + Kind4 int + Kind5 int + NullFraction float64 + Numbers1 pq.StringArray + Numbers2 pq.StringArray + Numbers3 pq.StringArray + Numbers4 pq.StringArray + Numbers5 pq.StringArray + Oid uint32 + Operator1 uint32 + Operator2 uint32 + Operator3 uint32 + Operator4 uint32 + Operator5 uint32 + Relid uint32 + Schema string + Table string + Type string + Values1 pq.StringArray + Values2 pq.StringArray + Values3 pq.StringArray + Values4 pq.StringArray + Values5 pq.StringArray + Width int + type BackupProgressCounters struct + NumRegTables int64 + ProgressBar utils.ProgressBar + TotalRegTables int64 + type BaseType struct + Alignment string + Category string + Collatable bool + Collation string + DefaultVal string + Delimiter string + Element string + Input string + InternalLength int + IsPassedByValue bool + ModIn string + ModOut string + Name string + Oid uint32 + Output string + Preferred bool + Receive string + Schema string + Send string + Storage string + StorageOptions string + func GetBaseTypes(connectionPool *dbconn.DBConn) []BaseType + func (t BaseType) FQN() string + func (t BaseType) GetMetadataEntry() (string, toc.MetadataEntry) + func (t BaseType) GetUniqueID() UniqueID + type Cast struct + CastContext string + CastMethod string + FunctionArgs string + FunctionName string + FunctionOid uint32 + FunctionSchema string + Oid uint32 + SourceTypeFQN string + TargetTypeFQN string + func GetCasts(connectionPool *dbconn.DBConn) []Cast + func (c Cast) FQN() string + func (c Cast) GetMetadataEntry() (string, toc.MetadataEntry) + func (c Cast) GetUniqueID() UniqueID + type Collation struct + Collate string + Ctype string + IsDeterministic string + Name string + Oid uint32 + Provider string + Schema string + func GetCollations(connectionPool *dbconn.DBConn) []Collation + func (c Collation) FQN() string + func (c Collation) GetMetadataEntry() (string, toc.MetadataEntry) + func (c Collation) GetUniqueID() UniqueID + type ColumnDefinition struct + AttGenerated string + Collation string + Comment string + DefaultVal string + Encoding string + FdwOptions string + HasDefault bool + Kind string + Name string + NotNull bool + Num int + Oid uint32 + Options string + Privileges sql.NullString + SecurityLabel string + SecurityLabelProvider string + StatTarget int + StorageType string + Type string + type CompositeType struct + Attributes []Attribute + Name string + Oid uint32 + Schema string + func GetCompositeTypes(connectionPool *dbconn.DBConn) []CompositeType + func (t CompositeType) FQN() string + func (t CompositeType) GetMetadataEntry() (string, toc.MetadataEntry) + func (t CompositeType) GetUniqueID() UniqueID + type Constraint struct + ConIsLocal bool + ConType string + Def sql.NullString + IsDomainConstraint bool + IsPartitionParent bool + Name string + Oid uint32 + OwningObject string + Schema string + func GetConstraints(connectionPool *dbconn.DBConn, includeTables ...Relation) []Constraint + func (c Constraint) FQN() string + func (c Constraint) GetMetadataEntry() (string, toc.MetadataEntry) + func (c Constraint) GetUniqueID() UniqueID + type Conversion struct + ConversionFunction string + ForEncoding string + IsDefault bool + Name string + Oid uint32 + Schema string + ToEncoding string + func GetConversions(connectionPool *dbconn.DBConn) []Conversion + func (c Conversion) FQN() string + func (c Conversion) GetMetadataEntry() (string, toc.MetadataEntry) + func (c Conversion) GetUniqueID() UniqueID + type Database struct + CType string + Collate string + Encoding string + Name string + Oid uint32 + Tablespace string + func GetDatabaseInfo(connectionPool *dbconn.DBConn) Database + func GetDefaultDatabaseEncodingInfo(connectionPool *dbconn.DBConn) Database + func (db Database) FQN() string + func (db Database) GetMetadataEntry() (string, toc.MetadataEntry) + func (db Database) GetUniqueID() UniqueID + type DefaultPrivileges struct + ObjectType string + Owner string + Privileges []ACL + Schema string + func ConstructDefaultPrivileges(results []DefaultPrivilegesQueryStruct) []DefaultPrivileges + func GetDefaultPrivileges(connectionPool *dbconn.DBConn) []DefaultPrivileges + func (dp DefaultPrivileges) GetMetadataEntry() (string, toc.MetadataEntry) + type DefaultPrivilegesQueryStruct struct + Kind string + ObjectType string + Oid uint32 + Owner string + Privileges sql.NullString + Schema string + type Dependency struct + Oid uint32 + ReferencedObject string + type DependencyMap map[UniqueID]map[UniqueID]bool + func GetDependencies(connectionPool *dbconn.DBConn, backupSet map[UniqueID]bool, tables []Table) DependencyMap + type Domain struct + BaseType string + Collation string + DefaultVal string + Name string + NotNull bool + Oid uint32 + Schema string + func GetDomainTypes(connectionPool *dbconn.DBConn) []Domain + func (t Domain) FQN() string + func (t Domain) GetMetadataEntry() (string, toc.MetadataEntry) + func (t Domain) GetUniqueID() UniqueID + type EnumType struct + EnumLabels string + Name string + Oid uint32 + Schema string + func GetEnumTypes(connectionPool *dbconn.DBConn) []EnumType + func (t EnumType) FQN() string + func (t EnumType) GetMetadataEntry() (string, toc.MetadataEntry) + func (t EnumType) GetUniqueID() UniqueID + type EventTrigger struct + Enabled string + Event string + EventTags string + FunctionName string + Name string + Oid uint32 + func GetEventTriggers(connectionPool *dbconn.DBConn) []EventTrigger + func (et EventTrigger) FQN() string + func (et EventTrigger) GetMetadataEntry() (string, toc.MetadataEntry) + func (et EventTrigger) GetUniqueID() UniqueID + type ExchangedPartitionName struct + NewName string + OrigName string + type Extension struct + Name string + Oid uint32 + Schema string + func GetExtensions(connectionPool *dbconn.DBConn) []Extension + func (e Extension) FQN() string + func (e Extension) GetMetadataEntry() (string, toc.MetadataEntry) + func (e Extension) GetUniqueID() UniqueID + type ExternalProtocol struct + Name string + Oid uint32 + Owner string + ReadFunction uint32 + Trusted bool + Validator uint32 + WriteFunction uint32 + func GetExternalProtocols(connectionPool *dbconn.DBConn) []ExternalProtocol + func (p ExternalProtocol) FQN() string + func (p ExternalProtocol) GetMetadataEntry() (string, toc.MetadataEntry) + func (p ExternalProtocol) GetUniqueID() UniqueID + type ExternalTableDefinition struct + Command string + Encoding string + ErrTableName string + ErrTableSchema string + ExecLocation string + FormatOpts string + FormatType string + Location sql.NullString + LogErrPersist bool + LogErrors bool + Oid uint32 + Protocol int + RejectLimit int + RejectLimitType string + Type int + URIs []string + Writable bool + type ForeignDataWrapper struct + Handler uint32 + Name string + Oid uint32 + Options string + Validator uint32 + func GetForeignDataWrappers(connectionPool *dbconn.DBConn) []ForeignDataWrapper + func (fdw ForeignDataWrapper) FQN() string + func (fdw ForeignDataWrapper) GetMetadataEntry() (string, toc.MetadataEntry) + func (fdw ForeignDataWrapper) GetUniqueID() UniqueID + type ForeignServer struct + ForeignDataWrapper string + Name string + Oid uint32 + Options string + Type string + Version string + func GetForeignServers(connectionPool *dbconn.DBConn) []ForeignServer + func (fs ForeignServer) FQN() string + func (fs ForeignServer) GetMetadataEntry() (string, toc.MetadataEntry) + func (fs ForeignServer) GetUniqueID() UniqueID + type ForeignTableDefinition struct + Oid uint32 + Options string + Server string + type Function struct + Arguments sql.NullString + BinaryPath string + Config string + Cost float32 + DataAccess string + ExecLocation string + FunctionBody string + IdentArgs sql.NullString + IsLeakProof bool + IsSecurityDefiner bool + IsStrict bool + IsWindow bool + Kind string + Language string + Name string + NumRows float32 + Oid uint32 + Parallel string + PlannerSupport string + ResultType sql.NullString + ReturnsSet bool + Schema string + TransformTypes string + Volatility string + func GetFunctions(connectionPool *dbconn.DBConn) []Function + func GetFunctions4(connectionPool *dbconn.DBConn) []Function + func GetFunctionsAllVersions(connectionPool *dbconn.DBConn) []Function + func (f Function) FQN() string + func (f Function) GetMetadataEntry() (string, toc.MetadataEntry) + func (f Function) GetUniqueID() UniqueID + type FunctionInfo struct + Arguments sql.NullString + IdentArgs sql.NullString + IsInternal bool + Name string + Oid uint32 + QualifiedName string + Schema string + func (info FunctionInfo) FQN() string + func (info FunctionInfo) GetMetadataEntry() (string, toc.MetadataEntry) + type IndexDefinition struct + Def sql.NullString + IsClustered bool + IsReplicaIdentity bool + Name string + Oid uint32 + OwningSchema string + OwningTable string + ParentIndex uint32 + ParentIndexFQN string + StatisticsColumns string + StatisticsValues string + SupportsConstraint bool + Tablespace string + func GetIndexes(connectionPool *dbconn.DBConn) []IndexDefinition + func (i IndexDefinition) FQN() string + func (i IndexDefinition) GetMetadataEntry() (string, toc.MetadataEntry) + func (i IndexDefinition) GetUniqueID() UniqueID + type MetadataMap map[UniqueID]ObjectMetadata + func ConstructMetadataMap(results []MetadataQueryStruct) MetadataMap + func GetCommentsForObjectType(connectionPool *dbconn.DBConn, params MetadataQueryParams) MetadataMap + func GetMetadataForObjectType(connectionPool *dbconn.DBConn, params MetadataQueryParams) MetadataMap + type MetadataQueryParams struct + ACLField string + CatalogTable string + CommentTable string + FilterClause string + NameField string + ObjectType string + OidField string + OidTable string + OwnerField string + SchemaField string + Shared bool + var TYPE_ACCESS_METHOD MetadataQueryParams + var TYPE_AGGREGATE MetadataQueryParams + var TYPE_CAST MetadataQueryParams + var TYPE_COLLATION MetadataQueryParams + var TYPE_CONSTRAINT MetadataQueryParams + var TYPE_CONVERSION MetadataQueryParams + var TYPE_DATABASE MetadataQueryParams + var TYPE_EVENTTRIGGER MetadataQueryParams + var TYPE_EXTENSION MetadataQueryParams + var TYPE_FOREIGNDATAWRAPPER MetadataQueryParams + var TYPE_FOREIGNSERVER MetadataQueryParams + var TYPE_FUNCTION MetadataQueryParams + var TYPE_INDEX MetadataQueryParams + var TYPE_OPERATOR MetadataQueryParams + var TYPE_OPERATORCLASS MetadataQueryParams + var TYPE_OPERATORFAMILY MetadataQueryParams + var TYPE_POLICY MetadataQueryParams + var TYPE_PROCLANGUAGE MetadataQueryParams + var TYPE_PROTOCOL MetadataQueryParams + var TYPE_RELATION MetadataQueryParams + var TYPE_RESOURCEGROUP MetadataQueryParams + var TYPE_RESOURCEQUEUE MetadataQueryParams + var TYPE_ROLE MetadataQueryParams + var TYPE_RULE MetadataQueryParams + var TYPE_SCHEMA MetadataQueryParams + var TYPE_STATISTIC_EXT MetadataQueryParams + var TYPE_TABLESPACE MetadataQueryParams + var TYPE_TRANSFORM MetadataQueryParams + var TYPE_TRIGGER MetadataQueryParams + var TYPE_TSCONFIGURATION MetadataQueryParams + var TYPE_TSDICTIONARY MetadataQueryParams + var TYPE_TSPARSER MetadataQueryParams + var TYPE_TSTEMPLATE MetadataQueryParams + var TYPE_TYPE MetadataQueryParams + type MetadataQueryStruct struct + Comment string + Kind string + Name string + ObjectType string + Owner string + Privileges sql.NullString + Schema string + SecurityLabel string + SecurityLabelProvider string + type ObjectMetadata struct + Comment string + ObjectType string + Owner string + Privileges []ACL + SecurityLabel string + SecurityLabelProvider string + func (obj ObjectMetadata) GetCommentStatement(objectName string, objectType string, owningTable string) string + func (obj ObjectMetadata) GetOwnerStatement(objectName string, objectType string) string + func (obj ObjectMetadata) GetPrivilegesStatements(objectName string, objectType string, columnName ...string) string + func (obj ObjectMetadata) GetSecurityLabelStatement(objectName string, objectType string) string + type Operator struct + CanHash bool + CanMerge bool + CommutatorOp string + JoinFunction string + LeftArgType string + Name string + NegatorOp string + Oid uint32 + Procedure string + RestrictFunction string + RightArgType string + Schema string + func GetOperators(connectionPool *dbconn.DBConn) []Operator + func (o Operator) FQN() string + func (o Operator) GetMetadataEntry() (string, toc.MetadataEntry) + func (o Operator) GetUniqueID() UniqueID + type OperatorClass struct + Default bool + FamilyName string + FamilySchema string + Functions []OperatorClassFunction + IndexMethod string + Name string + Oid uint32 + Operators []OperatorClassOperator + Schema string + StorageType string + Type string + func GetOperatorClasses(connectionPool *dbconn.DBConn) []OperatorClass + func (opc OperatorClass) FQN() string + func (opc OperatorClass) GetMetadataEntry() (string, toc.MetadataEntry) + func (opc OperatorClass) GetUniqueID() UniqueID + type OperatorClassFunction struct + ClassOid uint32 + FunctionName string + LeftType string + RightType string + SupportNumber int + type OperatorClassOperator struct + ClassOid uint32 + Operator string + OrderByFamily string + Recheck bool + StrategyNumber int + type OperatorFamily struct + IndexMethod string + Name string + Oid uint32 + Schema string + func GetOperatorFamilies(connectionPool *dbconn.DBConn) []OperatorFamily + func (opf OperatorFamily) FQN() string + func (opf OperatorFamily) GetMetadataEntry() (string, toc.MetadataEntry) + func (opf OperatorFamily) GetUniqueID() UniqueID + type ParserTokenType struct + Alias string + TokenID uint32 + type ParserTokenTypes struct + func NewParserTokenTypes() *ParserTokenTypes + func (tokenTypes *ParserTokenTypes) TokenName(connectionPool *dbconn.DBConn, parserOid uint32, tokenTypeID uint32) string + type PartitionInfo struct + IsExternal bool + ParentRelationName string + ParentRelationOid uint32 + ParentSchema string + PartitionName string + PartitionParentRuleOid uint32 + PartitionRank int + PartitionRuleOid uint32 + RelationOid uint32 + func GetExternalPartitionInfo(connectionPool *dbconn.DBConn) ([]PartitionInfo, map[uint32]PartitionInfo) + func (pi PartitionInfo) GetMetadataEntry() (string, toc.MetadataEntry) + type PartitionLevelInfo struct + Level string + Oid uint32 + RootName string + type ProceduralLanguage struct + Handler uint32 + Inline uint32 + IsPl bool + Name string + Oid uint32 + Owner string + PlTrusted bool + Validator uint32 + func GetProceduralLanguages(connectionPool *dbconn.DBConn) []ProceduralLanguage + func (pl ProceduralLanguage) FQN() string + func (pl ProceduralLanguage) GetMetadataEntry() (string, toc.MetadataEntry) + func (pl ProceduralLanguage) GetUniqueID() UniqueID + type RLSPolicy struct + Cmd string + Name string + Oid uint32 + Permissive string + Qual string + Roles string + Schema string + Table string + WithCheck string + func GetPolicies(connectionPool *dbconn.DBConn) []RLSPolicy + func (p RLSPolicy) FQN() string + func (p RLSPolicy) GetMetadataEntry() (string, toc.MetadataEntry) + func (p RLSPolicy) GetUniqueID() UniqueID + type RangeType struct + Canonical string + Collation string + Name string + Oid uint32 + Schema string + SubType string + SubTypeDiff string + SubTypeOpClass string + func GetRangeTypes(connectionPool *dbconn.DBConn) []RangeType + func (t RangeType) FQN() string + func (t RangeType) GetMetadataEntry() (string, toc.MetadataEntry) + func (t RangeType) GetUniqueID() UniqueID + type Relation struct + Name string + Oid uint32 + Schema string + SchemaOid uint32 + func GetForeignTableRelations(connectionPool *dbconn.DBConn) []Relation + func GetIncludedUserTableRelations(connectionPool *dbconn.DBConn, includedRelationsQuoted []string) []Relation + func (r Relation) FQN() string + func (r Relation) GetUniqueID() UniqueID + type ResourceGroup struct + CPURateLimit string + Concurrency string + Cpuset string + MemoryAuditor string + MemoryLimit string + MemorySharedQuota string + MemorySpillRatio string + Name string + Oid uint32 + func GetResourceGroups(connectionPool *dbconn.DBConn) []ResourceGroup + func (rg ResourceGroup) FQN() string + func (rg ResourceGroup) GetMetadataEntry() (string, toc.MetadataEntry) + func (rg ResourceGroup) GetUniqueID() UniqueID + type ResourceQueue struct + ActiveStatements int + CostOvercommit bool + MaxCost string + MemoryLimit string + MinCost string + Name string + Oid uint32 + Priority string + func GetResourceQueues(connectionPool *dbconn.DBConn) []ResourceQueue + func (rq ResourceQueue) FQN() string + func (rq ResourceQueue) GetMetadataEntry() (string, toc.MetadataEntry) + func (rq ResourceQueue) GetUniqueID() UniqueID + type Role struct + CanLogin bool + ConnectionLimit int + CreateDB bool + CreateRole bool + Createrextgpfd bool + Createrexthdfs bool + Createrexthttp bool + Createwextgpfd bool + Createwexthdfs bool + Inherit bool + Name string + Oid uint32 + Password string + Replication bool + ResGroup string + ResQueue string + Super bool + TimeConstraints []TimeConstraint + ValidUntil string + func GetRoles(connectionPool *dbconn.DBConn) []Role + func (r Role) FQN() string + func (r Role) GetMetadataEntry() (string, toc.MetadataEntry) + func (r Role) GetUniqueID() UniqueID + type RoleGUC struct + Config string + DbName string + RoleName string + func (rg RoleGUC) GetMetadataEntry() (string, toc.MetadataEntry) + type RoleMember struct + Grantor string + IsAdmin bool + Member string + Role string + func GetRoleMembers(connectionPool *dbconn.DBConn) []RoleMember + func (rm RoleMember) GetMetadataEntry() (string, toc.MetadataEntry) + type RuleDefinition struct + Def sql.NullString + Name string + Oid uint32 + OwningSchema string + OwningTable string + func GetRules(connectionPool *dbconn.DBConn) []RuleDefinition + func (r RuleDefinition) FQN() string + func (r RuleDefinition) GetMetadataEntry() (string, toc.MetadataEntry) + func (r RuleDefinition) GetUniqueID() UniqueID + type Schema struct + Name string + Oid uint32 + func GetAllUserSchemas(connectionPool *dbconn.DBConn, partitionAlteredSchemas map[string]bool) []Schema + func (s Schema) FQN() string + func (s Schema) GetMetadataEntry() (string, toc.MetadataEntry) + func (s Schema) GetUniqueID() UniqueID + type Sequence struct + Definition SequenceDefinition + IsIdentity bool + OwningColumn string + OwningColumnAttIdentity string + OwningTable string + OwningTableOid string + OwningTableSchema string + UnqualifiedOwningColumn string + func GetAllSequences(connectionPool *dbconn.DBConn) []Sequence + func (s Sequence) GetMetadataEntry() (string, toc.MetadataEntry) + type SequenceDefinition struct + CacheVal int64 + Increment int64 + IsCalled bool + IsCycled bool + LastVal int64 + MaxVal int64 + MinVal int64 + OwningTable string + StartVal int64 + Type string + func GetSequenceDefinition(connectionPool *dbconn.DBConn, seqName string) SequenceDefinition + type SessionGUCs struct + ClientEncoding string + func GetSessionGUCs(connectionPool *dbconn.DBConn) SessionGUCs + func (sg SessionGUCs) GetMetadataEntry() (string, toc.MetadataEntry) + type ShellType struct + Name string + Oid uint32 + Schema string + func GetShellTypes(connectionPool *dbconn.DBConn) []ShellType + func (t ShellType) FQN() string + func (t ShellType) GetMetadataEntry() (string, toc.MetadataEntry) + func (t ShellType) GetUniqueID() UniqueID + type Sortable interface + FQN func() string + GetUniqueID func() UniqueID + func TopologicalSort(slice []Sortable, dependencies DependencyMap) []Sortable + type SortableDependency struct + ClassID uint32 + ObjID uint32 + RefClassID uint32 + RefObjID uint32 + type StatisticExt struct + Definition string + Name string + Namespace string + Oid uint32 + Owner string + TableName string + TableSchema string + func GetExtendedStatistics(connectionPool *dbconn.DBConn) []StatisticExt + func (se StatisticExt) FQN() string + func (se StatisticExt) GetMetadataEntry() (string, toc.MetadataEntry) + func (se StatisticExt) GetUniqueID() UniqueID + type Table struct + func ConstructDefinitionsForTables(connectionPool *dbconn.DBConn, tableRelations []Relation) []Table + func FilterTablesForIncremental(lastBackupTOC, currentTOC *toc.TOC, tables []Table) []Table + func GetBackupDataSet(tables []Table) ([]Table, int64) + func (t Table) GetMetadataEntry() (string, toc.MetadataEntry) + func (t Table) SkipDataBackup() bool + type TableDefinition struct + AccessMethodName string + AttachPartitionInfo AttachPartitionInfo + ColumnDefs []ColumnDefinition + DistPolicy string + ExtTableDef ExternalTableDefinition + ForceRowSecurity bool + ForeignDef ForeignTableDefinition + Inherits []string + IsExternal bool + IsUnlogged bool + PartDef string + PartTemplateDef string + PartitionAlteredSchemas []AlteredPartitionRelation + PartitionKeyDef string + PartitionLevelInfo PartitionLevelInfo + ReplicaIdentity string + StorageOpts string + TableType string + TablespaceName string + type TableLocks struct + Application string + Database string + Granted string + Mode string + Oid uint32 + Pid string + Relation string + User string + type Tablespace struct + FileLocation string + Oid uint32 + Options string + SegmentLocations []string + Tablespace string + func GetTablespaces(connectionPool *dbconn.DBConn) []Tablespace + func (t Tablespace) FQN() string + func (t Tablespace) GetMetadataEntry() (string, toc.MetadataEntry) + func (t Tablespace) GetUniqueID() UniqueID + type TextSearchConfiguration struct + Name string + Oid uint32 + Parser string + Schema string + TokenToDicts map[string][]string + func GetTextSearchConfigurations(connectionPool *dbconn.DBConn) []TextSearchConfiguration + func (tsc TextSearchConfiguration) FQN() string + func (tsc TextSearchConfiguration) GetMetadataEntry() (string, toc.MetadataEntry) + func (tsc TextSearchConfiguration) GetUniqueID() UniqueID + type TextSearchDictionary struct + InitOption string + Name string + Oid uint32 + Schema string + Template string + func GetTextSearchDictionaries(connectionPool *dbconn.DBConn) []TextSearchDictionary + func (tsd TextSearchDictionary) FQN() string + func (tsd TextSearchDictionary) GetMetadataEntry() (string, toc.MetadataEntry) + func (tsd TextSearchDictionary) GetUniqueID() UniqueID + type TextSearchParser struct + EndFunc string + HeadlineFunc string + LexTypesFunc string + Name string + Oid uint32 + Schema string + StartFunc string + TokenFunc string + func GetTextSearchParsers(connectionPool *dbconn.DBConn) []TextSearchParser + func (tsp TextSearchParser) FQN() string + func (tsp TextSearchParser) GetMetadataEntry() (string, toc.MetadataEntry) + func (tsp TextSearchParser) GetUniqueID() UniqueID + type TextSearchTemplate struct + InitFunc string + LexizeFunc string + Name string + Oid uint32 + Schema string + func GetTextSearchTemplates(connectionPool *dbconn.DBConn) []TextSearchTemplate + func (tst TextSearchTemplate) FQN() string + func (tst TextSearchTemplate) GetMetadataEntry() (string, toc.MetadataEntry) + func (tst TextSearchTemplate) GetUniqueID() UniqueID + type TimeConstraint struct + EndDay int + EndTime string + Oid uint32 + StartDay int + StartTime string + type Transform struct + FromSQLFunc uint32 + LanguageName string + Oid uint32 + ToSQLFunc uint32 + TypeName string + TypeNamespace string + func GetTransforms(connectionPool *dbconn.DBConn) []Transform + func (trf Transform) FQN() string + func (trf Transform) GetMetadataEntry() (string, toc.MetadataEntry) + func (trf Transform) GetUniqueID() UniqueID + type TriggerDefinition RuleDefinition + func GetTriggers(connectionPool *dbconn.DBConn) []TriggerDefinition + func (t TriggerDefinition) FQN() string + func (t TriggerDefinition) GetMetadataEntry() (string, toc.MetadataEntry) + func (t TriggerDefinition) GetUniqueID() UniqueID + type TupleStatistic struct + Oid uint32 + RelPages int + RelTuples float64 + Schema string + Table string + type TypeMapping struct + ConfigOid uint32 + Dictionary string + TokenType uint32 + type UniqueID struct + ClassID uint32 + Oid uint32 + type UserMapping struct + Oid uint32 + Options string + Server string + User string + func GetUserMappings(connectionPool *dbconn.DBConn) []UserMapping + func (um UserMapping) FQN() string + func (um UserMapping) GetMetadataEntry() (string, toc.MetadataEntry) + func (um UserMapping) GetUniqueID() UniqueID + type View struct + Definition sql.NullString + DistPolicy string + IsMaterialized bool + Name string + Oid uint32 + Options string + Schema string + Tablespace string + func GetAllViews(connectionPool *dbconn.DBConn) []View + func (v View) FQN() string + func (v View) GetMetadataEntry() (string, toc.MetadataEntry) + func (v View) GetUniqueID() UniqueID + func (v View) ObjectType() string
Go to main page