toc

Documentation

Index

• func GetIncludedPartitionRoots(tocDataEntries []CoordinatorDataEntry, includeRelations []string) []string
• type AOEntry
• type CoordinatorDataEntry
• type IncrementalEntries
• type MetadataEntry
• type SegmentDataEntry
• type SegmentTOC
  • func NewSegmentTOC(filename string) *SegmentTOC
  • func (toc *SegmentTOC) AddSegmentDataEntry(oid uint, startByte uint64, endByte uint64)
  • func (toc *SegmentTOC) WriteToFileAndMakeReadOnly(filename string) error
• type StatementWithType
  • func RemoveActiveRole(activeUser string, statements []StatementWithType) []StatementWithType
  • func SubstituteRedirectDatabaseInStatements(statements []StatementWithType, oldQuotedName string, newQuotedName string) []StatementWithType
• type TOC
  • func NewTOC(filename string) *TOC
  • func (toc *TOC) AddCoordinatorDataEntry(schema string, name string, oid uint32, attributeString string, ...)
  • func (toc *TOC) AddMetadataEntry(section string, entry MetadataEntry, start, end uint64)
  • func (toc *TOC) GetDataEntriesMatching(includeSchemas []string, excludeSchemas []string, includeTableFQNs []string, ...) []CoordinatorDataEntry
  • func (toc *TOC) GetSQLStatementForObjectTypes(section string, metadataFile io.ReaderAt, includeObjectTypes []string, ...) []StatementWithType
  • func (toc *TOC) InitializeMetadataEntryMap()
  • func (toc *TOC) WriteToFileAndMakeReadOnly(filename string)
• type TOCObject
• type TOCObjectWithMetadata

Functions

func GetIncludedPartitionRoots

func GetIncludedPartitionRoots(tocDataEntries []CoordinatorDataEntry, includeRelations []string) []string

Types

type AOEntry

type AOEntry struct {
	Modcount         int64
	LastDDLTimestamp string
}

type CoordinatorDataEntry

type CoordinatorDataEntry struct {
	Schema          string
	Name            string
	Oid             uint32
	AttributeString string
	RowsCopied      int64
	PartitionRoot   string
	IsReplicated    bool
}

type IncrementalEntries

type IncrementalEntries struct {
	AO map[string]AOEntry
}

type MetadataEntry

type MetadataEntry struct {
	Schema          string
	Name            string
	ObjectType      string
	ReferenceObject string
	StartByte       uint64
	EndByte         uint64
}

type SegmentDataEntry

type SegmentDataEntry struct {
	StartByte uint64
	EndByte   uint64
}

type SegmentTOC

type SegmentTOC struct {
	DataEntries map[uint]SegmentDataEntry
}

func NewSegmentTOC

func NewSegmentTOC(filename string) *SegmentTOC

func (*SegmentTOC) AddSegmentDataEntry

func (toc *SegmentTOC) AddSegmentDataEntry(oid uint, startByte uint64, endByte uint64)

func (*SegmentTOC) WriteToFileAndMakeReadOnly

func (toc *SegmentTOC) WriteToFileAndMakeReadOnly(filename string) error

type StatementWithType

type StatementWithType struct {
	Schema          string
	Name            string
	ObjectType      string
	ReferenceObject string
	Statement       string
}

func RemoveActiveRole

func RemoveActiveRole(activeUser string, statements []StatementWithType) []StatementWithType

func SubstituteRedirectDatabaseInStatements

func SubstituteRedirectDatabaseInStatements(statements []StatementWithType, oldQuotedName string, newQuotedName string) []StatementWithType

type TOC

type TOC struct {
	GlobalEntries       []MetadataEntry
	PredataEntries      []MetadataEntry
	PostdataEntries     []MetadataEntry
	StatisticsEntries   []MetadataEntry
	DataEntries         []CoordinatorDataEntry
	IncrementalMetadata IncrementalEntries
	// contains filtered or unexported fields
}

func NewTOC

func NewTOC(filename string) *TOC

func (*TOC) AddCoordinatorDataEntry

func (toc *TOC) AddCoordinatorDataEntry(schema string, name string, oid uint32, attributeString string, rowsCopied int64, PartitionRoot string, distPolicy string)

func (*TOC) AddMetadataEntry

func (toc *TOC) AddMetadataEntry(section string, entry MetadataEntry, start, end uint64)

func (*TOC) GetDataEntriesMatching

func (toc *TOC) GetDataEntriesMatching(includeSchemas []string, excludeSchemas []string,
	includeTableFQNs []string, excludeTableFQNs []string, restorePlanTableFQNs []string) []CoordinatorDataEntry

func (*TOC) GetSQLStatementForObjectTypes

func (toc *TOC) GetSQLStatementForObjectTypes(section string, metadataFile io.ReaderAt, includeObjectTypes []string, excludeObjectTypes []string, includeSchemas []string, excludeSchemas []string, includeRelations []string, excludeRelations []string) []StatementWithType

func (*TOC) InitializeMetadataEntryMap

func (toc *TOC) InitializeMetadataEntryMap()

func (*TOC) WriteToFileAndMakeReadOnly

func (toc *TOC) WriteToFileAndMakeReadOnly(filename string)

type TOCObject

type TOCObject interface {
	GetMetadataEntry() (string, MetadataEntry)
}

type TOCObjectWithMetadata

type TOCObjectWithMetadata interface {
	GetMetadataEntry() (string, MetadataEntry)
	FQN() string
}