config

Documentation

Index

• func GetAbortFile(rootDir string) string
• func GetDelayOffsetStorePath(rootDir string) string
• func GetStoreCheckpoint(rootDir string) string
• func GetStorePathConsumeQueue(rootDir string) string
• func GetStorePathIndex(rootDir string) string
• func GetTranRedoLogStorePath(rootDir string) string
• func GetTranStateTableStorePath(rootDir string) string
• type BrokerRole
  • func ParseBrokerRole(desc string) (BrokerRole, error)
  • func (brokerRole BrokerRole) ToString() string
• type FlushDiskType
  • func ParseFlushDiskType(desc string) (FlushDiskType, error)
  • func (flushDiskType FlushDiskType) FlushDiskTypeString() string
• type SynchronizationType
  • func (synchronizationType SynchronizationType) SynchronizationTypeString() string

Functions

func GetAbortFile

func GetAbortFile(rootDir string) string

func GetDelayOffsetStorePath

func GetDelayOffsetStorePath(rootDir string) string

func GetStoreCheckpoint

func GetStoreCheckpoint(rootDir string) string

func GetStorePathConsumeQueue

func GetStorePathConsumeQueue(rootDir string) string

func GetStorePathIndex

func GetStorePathIndex(rootDir string) string

func GetTranRedoLogStorePath

func GetTranRedoLogStorePath(rootDir string) string

func GetTranStateTableStorePath

func GetTranStateTableStorePath(rootDir string) string

Types

type BrokerRole

type BrokerRole int

const (
	ASYNC_MASTER BrokerRole = iota // 异步复制Master
	SYNC_MASTER                    // 同步双写Master
	SLAVE                          // Slave
)

func ParseBrokerRole

func ParseBrokerRole(desc string) (BrokerRole, error)

func (BrokerRole) ToString

func (brokerRole BrokerRole) ToString() string

type FlushDiskType

type FlushDiskType int

const (
	// 同步刷盘
	SYNC_FLUSH FlushDiskType = iota
	// 异步刷盘
	ASYNC_FLUSH
)

func ParseFlushDiskType

func ParseFlushDiskType(desc string) (FlushDiskType, error)

func (FlushDiskType) FlushDiskTypeString

func (flushDiskType FlushDiskType) FlushDiskTypeString() string

type SynchronizationType

type SynchronizationType int

const (
	SYNCHRONIZATION_FULL SynchronizationType = iota // 同步所有文件的数据
	SYNCHRONIZATION_LAST                            // 同步最后一个文件的数据
)

func (SynchronizationType) SynchronizationTypeString

func (synchronizationType SynchronizationType) SynchronizationTypeString() string