systemcatalog

package

v0.0.8 Latest Latest Go to latest Published: Jul 4, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation ¶

Index ¶

type SystemCatalog
- func NewSystemCatalog(config *config.Config, replicationContext *context.ReplicationContext, ...) (*SystemCatalog, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type SystemCatalog ¶

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

func NewSystemCatalog ¶

func NewSystemCatalog(config *config.Config, replicationContext *context.ReplicationContext,
	snapshotter *snapshotting.Snapshotter) (*SystemCatalog, error)

func (*SystemCatalog) ApplySchemaUpdate ¶

func (sc *SystemCatalog) ApplySchemaUpdate(hypertable *systemcatalog.Hypertable, columns []systemcatalog.Column) bool

func (*SystemCatalog) FindChunkById ¶

func (sc *SystemCatalog) FindChunkById(id int32) (chunk *systemcatalog.Chunk, present bool)

func (*SystemCatalog) FindChunkByName ¶

func (sc *SystemCatalog) FindChunkByName(schemaName, tableName string) (chunk *systemcatalog.Chunk, present bool)

func (*SystemCatalog) FindCompressedHypertableByHypertableId ¶

func (sc *SystemCatalog) FindCompressedHypertableByHypertableId(
	hypertableId int32) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) FindHypertableByChunkId ¶

func (sc *SystemCatalog) FindHypertableByChunkId(chunkId int32) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) FindHypertableByCompressedHypertableId ¶

func (sc *SystemCatalog) FindHypertableByCompressedHypertableId(
	compressedHypertableId int32) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) FindHypertableById ¶

func (sc *SystemCatalog) FindHypertableById(hypertableId int32) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) FindHypertableByName ¶

func (sc *SystemCatalog) FindHypertableByName(
	schema, name string) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) GetAllChunks ¶

func (sc *SystemCatalog) GetAllChunks() []systemcatalog.SystemEntity

func (*SystemCatalog) IsHypertableSelectedForReplication ¶

func (sc *SystemCatalog) IsHypertableSelectedForReplication(hypertableId int32) bool

func (*SystemCatalog) NewEventHandler ¶

func (sc *SystemCatalog) NewEventHandler() eventhandlers.SystemCatalogReplicationEventHandler

func (*SystemCatalog) RegisterChunk ¶

func (sc *SystemCatalog) RegisterChunk(chunk *systemcatalog.Chunk) error

func (*SystemCatalog) RegisterHypertable ¶

func (sc *SystemCatalog) RegisterHypertable(hypertable *systemcatalog.Hypertable) error

func (*SystemCatalog) ResolveOriginHypertable ¶

func (sc *SystemCatalog) ResolveOriginHypertable(
	chunk *systemcatalog.Chunk) (hypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) ResolveUncompressedHypertable ¶

func (sc *SystemCatalog) ResolveUncompressedHypertable(
	hypertableId int32) (uncompressedHypertable, compressedHypertable *systemcatalog.Hypertable, present bool)

func (*SystemCatalog) UnregisterChunk ¶

func (sc *SystemCatalog) UnregisterChunk(chunk *systemcatalog.Chunk) error

func (*SystemCatalog) UnregisterHypertable ¶

func (sc *SystemCatalog) UnregisterHypertable(hypertable *systemcatalog.Hypertable) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
snapshotting
tablefiltering

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL