db

type AccessInfo struct {
	AccountID uint32
	UserID    uint32
	RoleID    uint32
}

type CreateDatabaseReq struct {
	AccessInfo AccessInfo
	Name       string
	CreateSql  string
	//Global unique, allocated by CN .
	DatabaseId uint64
}

type CreateDatabaseResp struct {
	ID uint64
}

type CreateRelationReq struct {
	AccessInfo   AccessInfo
	DatabaseID   uint64
	DatabaseName string
	Name         string
	RelationId   uint64
	Type         RelationType
	Defs         []engine.TableDef
}

type CreateRelationResp struct {
	ID uint64
}

type DB struct {
	Dir  string
	Opts *options.Options

	Catalog *catalog.Catalog

	MTBufMgr  base.INodeManager
	TxnBufMgr base.INodeManager

	TxnMgr        *txnbase.TxnManager
	TransferTable *model.HashPageTable

	LogtailMgr *logtail.LogtailMgr
	Wal        wal.Driver

	Scheduler tasks.TaskScheduler

	BGScanner          wb.IHeartbeater
	BGCheckpointRunner checkpoint.Runner

	Fs *objectio.ObjectFS

	DBLocker io.Closer

	Closed *atomic.Value
}

type DBScanner interface {
	base.IHBHandle
	RegisterOp(ScannerOp)
}

type DropDatabaseReq struct {
	Name string
	ID   uint64
}

type DropDatabaseResp struct {
	ID uint64
}

type DropOrTruncateRelationReq struct {
	IsDrop       bool
	DatabaseID   uint64
	DatabaseName string
	Name         string
	ID           uint64
	NewId        uint64
}

type DropOrTruncateRelationResp struct {
}

type EntryType int32

type ErrHandler interface {
	OnBlockErr(entry *catalog.BlockEntry, err error) error
	OnSegmentErr(entry *catalog.SegmentEntry, err error) error
	OnTableErr(entry *catalog.TableEntry, err error) error
	OnDatabaseErr(entry *catalog.DBEntry, err error) error
}

type FlushTable struct {
	AccessInfo AccessInfo
	DatabaseID uint64
	TableID    uint64
}

type NoopErrHandler struct{}

type RelationType uint8

type Replayer struct {
	DataFactory *tables.DataFactory
	// contains filtered or unexported fields
}

type Request interface {
	CreateDatabaseReq |
		DropDatabaseReq |
		CreateRelationReq |
		DropOrTruncateRelationReq |
		WriteReq |
		apipb.SyncLogTailReq
}

type Response interface {
	CreateDatabaseResp |
		DropDatabaseResp |
		CreateRelationResp |
		DropOrTruncateRelationResp
	WriteResp |
		apipb.SyncLogTailResp
}

type ScannerOp interface {
	catalog.Processor
	PreExecute() error
	PostExecute() error
}

type ScheduledTxnTask struct {
	*tasks.BaseTask
	// contains filtered or unexported fields
}

type Stats struct {
	WalStats *WalStats
	// contains filtered or unexported fields
}

type WalStats struct {
	MaxLSN     uint64
	MaxCkped   uint64
	PendingCnt uint64
}

type WriteReq struct {
	Type         EntryType
	DatabaseId   uint64
	TableID      uint64
	DatabaseName string
	TableName    string
	FileName     string
	BlockID      uint64
	Batch        *batch.Batch
}

type WriteResp struct {
}