mds

package
v3.26.0 Latest Latest
Warning

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

Go to latest
Published: Dec 12, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package mds contains the implementation of the SchemaManager interface.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewImporter

func NewImporter(mds MDS, qual dax.TableQualifier, tbl *dax.Table) *importer

func NewSchemaManager

func NewSchemaManager(mdsAddress dax.Address, qual dax.TableQualifier, logger logger.Logger) *schemaManager

Types

type MDS

type MDS interface {
	IngestPartition(ctx context.Context, qtid dax.QualifiedTableID, partition dax.PartitionNum) (dax.Address, error)
	IngestShard(ctx context.Context, qtid dax.QualifiedTableID, shard dax.ShardNum) (dax.Address, error)

	// Table was added so the `importer` instance (in this package) of the
	// batch.Importer interface could lookup up a table based on the name
	// provided in a method, as opposed to setting the table up front. This is
	// because in queryer, we don't know the table yet, because we haven't
	// parsed the sql yet.
	Table(ctx context.Context, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error)
}

MDS represents the MDS methods which importer uses.

Jump to

Keyboard shortcuts

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