store

Documentation

Index

• Variables
• func NewVastoMergeOperator() gorocksdb.MergeOperator
• func RunStore(option *StoreOption)
• type StoreOption
  • func (o *StoreOption) GetAdminPort() int32
• type VastoServerId
• type VastoShardId

Variables

var (
	// VastoInternalKeyPrefix is a reserved key prefix for Vasto internal meta data
	VastoInternalKeyPrefix = []byte("_vasto.")
)

Functions

func NewVastoMergeOperator

func NewVastoMergeOperator() gorocksdb.MergeOperator

NewVastoMergeOperator creates a MergeOperator object for rocksdb.

func RunStore

func RunStore(option *StoreOption)

RunStore starts a store process

Types

type StoreOption

type StoreOption struct {
	Dir               *string
	Host              *string
	ListenHost        *string
	TcpPort           *int32
	Bootstrap         *bool
	DisableUnixSocket *bool
	Master            *string
	LogFileSizeMb     *int
	LogFileCount      *int
	DiskSizeGb        *int
	Tags              *string
	DisableUseEventIo *bool
	DisableBinLog     *bool
}

StoreOption has options to run a data store

func (*StoreOption) GetAdminPort

func (o *StoreOption) GetAdminPort() int32

GetAdminPort returns the admin port of the store, which is the data port plus 10000

type VastoServerId

type VastoServerId int

VastoServerId server id in vasto

type VastoShardId

type VastoShardId int

VastoShardId shard id in vasto