util

type Data []byte

type GC struct {
	SysGC  *conf.GC
	TikvGC *conf.TikvGC
	// contains filtered or unexported fields
}

type HashMap interface {
	Get(key string) ([]byte, error)
	Delete(key string) error
	Destroy() error
	Exists() bool
	GetAll() (map[string][]byte, error)
	Set(key string, val []byte) error
}

type KvMeta struct {
	Value map[string][]byte
	// contains filtered or unexported fields
}

type Object struct {
	ID   []byte
	Type ObjectType
}

type ObjectType byte

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

type PubsubMeta struct {
	*Object
}

type ScanHandler func(offset *incr_uuid.Offset, data Data) (bool, error)

type SysGC struct {
	BatchLimit     int64
	Enable         bool
	Interval       time.Duration
	LeaderLifeTime time.Duration
}

type TikvGC struct {
	Enable            bool
	Interval          time.Duration
	LeaderLifeTime    time.Duration
	SafePointLifeTime time.Duration
	Concurrency       int
}