storage

Documentation

Index

• Constants
• type CacheCfg
• type IterOptions
• type MetaCfg
• type MetaCleanerCfg
• type Options
  • func (o *Options) CreateCatalog(dirname string) (*metadata.Catalog, error)
  • func (o *Options) FillDefaults(dirname string) *Options
• type SchedulerCfg

Constants

const (
	DefaultIndexCacheSize = 128 * common.M
	DefaultMTCacheSize    = 4 * common.G
	DefaultSSTCacheSize   = 4 * common.G

	DefaultBlockMaxRows     = uint64(40000)
	DefaultBlocksPerSegment = uint64(40)

	DefaultCleanInterval = 5

	DefaultBlockWriters     = uint16(8)
	DefaultSegmentWriters   = uint16(4)
	DefaultStatelessWorkers = uint16(1)
)

Types

type CacheCfg

type CacheCfg struct {
	IndexCapacity  uint64 `toml:"index-cache-size"`
	InsertCapacity uint64 `toml:"insert-cache-size"`
	DataCapacity   uint64 `toml:"data-cache-size"`
}

type IterOptions

type IterOptions struct {
	TableName  string
	TableID    uint64
	All        bool
	ColIdxes   []int
	SegmentIds []uint64
}

type MetaCfg

type MetaCfg struct {
	BlockMaxRows     uint64 `toml:"block-max-rows"`
	SegmentMaxBlocks uint64 `toml:"segment-max-blocks"`
}

type MetaCleanerCfg

type MetaCleanerCfg struct {
	Interval time.Duration
}

type Options

type Options struct {
	EventListener event.Listener

	Mu sync.RWMutex

	Scheduler    iface.DBScheduler
	SchedulerCfg *SchedulerCfg `toml:"scheduler-cfg"`

	WalRole wal.Role
	Wal     wal.ShardAwareWal

	Meta struct {
		Conf    *MetaCfg
		Catalog *metadata.Catalog
	}

	GC struct {
		Conf     *gci.WorkerCfg
		Acceptor gci.IAcceptor
	}

	CacheCfg *CacheCfg `toml:"cache-cfg"`

	MetaCleanerCfg *MetaCleanerCfg
}

func (*Options) CreateCatalog

func (o *Options) CreateCatalog(dirname string) (*metadata.Catalog, error)

func (*Options) FillDefaults

func (o *Options) FillDefaults(dirname string) *Options

type SchedulerCfg

type SchedulerCfg struct {
	BlockWriters     uint16 `toml:"block-writers"`
	SegmentWriters   uint16 `toml:"segment-writers"`
	StatelessWorkers uint16 `toml:"stateless-workers"`
}