computation

Documentation

Index

• type ComputationHandler

Types

type ComputationHandler

type ComputationHandler interface {
	CreateDatabase(epoch uint64, dbName string, typ int) (uint64, error)

	DropDatabase(epoch uint64, dbName string) error

	GetDatabase(dbName string) (*descriptor.DatabaseDesc, error)

	ListDatabases() ([]*descriptor.DatabaseDesc, error)

	CreateTable(epoch, dbId uint64, tableDesc *descriptor.RelationDesc) (uint64, error)

	DropTable(epoch, dbId uint64, tableName string) (uint64, error)

	DropTableByDesc(epoch, dbId uint64, tableDesc *descriptor.RelationDesc) (uint64, error)

	ListTables(dbId uint64) ([]*descriptor.RelationDesc, error)

	GetTable(dbId uint64, name string) (*descriptor.RelationDesc, error)

	Read(readCtx interface{}) (*batch.Batch, error)

	Write(writeCtx interface{}, bat *batch.Batch) error

	RemoveDeletedTable(epoch uint64) (int, error)

	GetNodesHoldTheTable(dbId uint64, desc *descriptor.RelationDesc) (engine.Nodes, interface{}, error)

	ParallelReader() bool

	MultiNode() bool
}