pdb

type IJournal interface {
	// each pdb has one journal
	Version() uint32                // Version
	ConsensusID() util.IConsensusID // Consensus ID
	Domain() string                 // Domain Name
	// operations
	Append(r []util.IRecord) error     // append a list of records
	AppendRecord(r util.IRecord) error // append a record
}

type IMemTable interface {
	// SSTable Level Attributes
	Version() uint32                // Version
	ConsensusID() util.IConsensusID // Consensus ID
	Domain() string                 // Domain Name
	Table() string                  // Table Name
	// operations
	Get(key, scheme util.IData) util.IRecord
	Set(record util.IRecord) error
	Groups(key, scheme util.IData) []string
	Keys(key, scheme util.IData) []util.IData
}

type IPdb interface {
	// each pdb has one journal
	Version() uint32                // Version
	ConsensusID() util.IConsensusID // Consensus ID
	Domain() string                 // Domain Name
	// operations
	Get(table string, key util.IData, group string) util.IRecord
	Set(table string, record util.IRecord) error
	Groups(table string, key, scheme util.IData) util.IData
	Keys(table string, key, scheme util.IData) util.IData
}

type ISSTable interface {
	// SSTable Level Attributes
	Version() uint32                // Version
	ConsensusID() util.IConsensusID // Consensus ID
	Domain() string                 // Domain Name
	Table() string                  // Table Name
	StartTime() util.IConsensusTime // Start Time
	EndTime() util.IConsensusTime   // End Time
	StartKey() util.IData           // Start Key
	EndKey() util.IData             // End Key
	Level() uint32                  // Level
	Count() uint32                  // Record Count
	// Record Operations
	Get(key, group *util.IData) (util.IRecord, error) // get record with specified key and attribute group
	Groups(key, scheme util.IData) ([]string, error)
	Keys(key, scheme util.IData) ([]util.IData, error)
	Read(pos, suggest_offset uint32) ([]util.IRecord, uint32, error) // Batch scan and read operation, return a list of IRecord, bytes read, or error
	// Close the resource
	Close() error
}

type ITablet interface {
	// SSTable Level Attributes
	Version() uint32                // Version
	ConsensusID() util.IConsensusID // Consensus ID
	Domain() string                 // Domain Name
	Table() string                  // Table Name
	// operations
	Get(key, scheme util.IData) util.IRecord
	Set(record util.IRecord) error
	Groups(key, scheme util.IData) []string
	Keys(key, scheme util.IData) []util.IData
}

type JournalV1 struct {
}

type PdbV1 struct {
}

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

type Tablet struct {
}