config

Documentation

Index

• type AsyncStore
  • func (c *AsyncStore) Validate() error
• type IO
• type IOEngineType
• type Raft
  • func (c *Raft) Options() (opts []block.Option)
  • func (c *Raft) Validate() error
• type RaftExecutorParallel
• type SyncStore
  • func (c *SyncStore) Validate() error
• type VSB
  • func (c *VSB) Options() (opts []vsb.Option)
  • func (c *VSB) Validate() error
• type VSBExecutorParallel
• type WAL
  • func (c *WAL) Options() (opts []wal.Option)
  • func (c *WAL) Validate(minFileSize uint64) error

Types

type AsyncStore

type AsyncStore struct {
	WAL `yaml:"wal"`
}

func (*AsyncStore) Validate

func (c *AsyncStore) Validate() error

type IO

type IO struct {
	Engine   IOEngineType `yaml:"engine"`
	Parallel int          `yaml:"parallel"`
}

type IOEngineType

type IOEngineType string

const (
	Psync IOEngineType = "psync"
	Uring IOEngineType = "io_uring"
)

type Raft

type Raft struct {
	WAL      WAL                  `yaml:"wal"`
	Parallel RaftExecutorParallel `yaml:"parallel"`
}

func (*Raft) Options

func (c *Raft) Options() (opts []block.Option)

func (*Raft) Validate

func (c *Raft) Validate() error

type RaftExecutorParallel

type RaftExecutorParallel struct {
	Raft      int `yaml:"raft"`
	Append    int `yaml:"append"`
	Commit    int `yaml:"commit"`
	Persist   int `yaml:"persist"`
	Apply     int `yaml:"apply"`
	Transport int `yaml:"transport"`
}

type SyncStore

type SyncStore struct {
	WAL `yaml:"wal"`
}

func (*SyncStore) Validate

func (c *SyncStore) Validate() error

type VSB

type VSB struct {
	FlushBatchSize int                 `yaml:"flush_batch_size"`
	FlushDelayTime string              `yaml:"flush_delay_time"`
	Parallel       VSBExecutorParallel `yaml:"parallel"`
	IO             IO                  `yaml:"io"`
}

func (*VSB) Options

func (c *VSB) Options() (opts []vsb.Option)

func (*VSB) Validate

func (c *VSB) Validate() error

type VSBExecutorParallel

type VSBExecutorParallel struct {
	Callback int `yaml:"callback"`
}

type WAL

type WAL struct {
	BlockSize    int    `yaml:"block_size"`
	FileSize     uint64 `yaml:"file_size"`
	FlushTimeout string `yaml:"flush_timeout"`
	IO           `yaml:"io"`
}

func (*WAL) Options

func (c *WAL) Options() (opts []wal.Option)

func (*WAL) Validate

func (c *WAL) Validate(minFileSize uint64) error