Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
}
Click to show internal directories.
Click to hide internal directories.