config

Documentation

Index

• Constants
• Variables
• type Config
• type FIOType
• type IndexerType
• type IteratorOptions
• type Options
• type RegionConfig
• type StoreConfig
• type TcpServerConfiguration
  • func Init() *TcpServerConfiguration
• type WriteBatchOptions

Constants

const (
	FileIOType = iota + 1 // Standard File IO
	BufIOType             // File IO with buffer
	MmapIOType            // Memory Mapping IO
)

const (
	DefaultAddr = "127.0.0.1:8999"
)

Variables

var DefaultIteratorOptions = IteratorOptions{
	Prefix:  nil,
	Reverse: false,
}

var DefaultOptions = Options{
	DirPath:      os.TempDir(),
	DataFileSize: 256 * 1024 * 1024,
	SyncWrite:    false,
	IndexType:    ART,
	FIOType:      MmapIOType,
}

var DefaultWriteBatchOptions = WriteBatchOptions{
	MaxBatchNum: 10000,
	SyncWrites:  true,
}

Types

type Config

type Config struct {
	ReplicationFactor   int
	ShardingStrategy    string
	SchedulingStrategy  string
	LogDataStorage      string
	LogDataStoragePath  string
	SnapshotStorage     string
	SnapshotStoragePath string
	LogDataStorageSize  int64
	HeartbeatInterval   time.Duration
	MetaNodes           []string
	StoreNodes          []string
}

type FIOType

type FIOType = int8

type IndexerType

type IndexerType = int8

const (
	// Btree
	Btree IndexerType = iota + 1

	// ART (Adpative Radix Tree)
	ART

	// SkipList
	SkipList
)

type IteratorOptions

type IteratorOptions struct {
	// Prefix specifies the prefix value for keys to iterate over. Default is empty.
	Prefix []byte
	// Reverse indicates whether to iterate in reverse order.
	// Default is false for forward iteration.
	Reverse bool
}

IteratorOptions is the configuration for index iteration.

type Options

type Options struct {
	DirPath      string // Database data directory
	DataFileSize int64  // Size of data files
	SyncWrite    bool   // Whether to persist data on every write
	IndexType    IndexerType
	FIOType      FIOType
}

type RegionConfig

type RegionConfig struct {
	Options Options
	Config  Config
	Id      int64
	Start   []byte
	End     []byte
}

type StoreConfig

type StoreConfig struct {
	Options Options
	Config  Config
	Id      int64
	Addr    string
}

type TcpServerConfiguration

type TcpServerConfiguration struct {
	Host       string
	Port       int
	MaxClients int
}

TcpServerConfiguration define global tcp server config

var Configuration *TcpServerConfiguration

Configuration is global tcp server config

func Init

func Init() *TcpServerConfiguration

Init global tcp server config

type WriteBatchOptions

type WriteBatchOptions struct {
	// MaxBatchNum is the maximum number of data entries in a batch.
	MaxBatchNum uint
	// SyncWrites indicates whether to sync (persist) the data on batch commit.
	SyncWrites bool
}

WriteBatchOptions is the configuration for batch writing.