util

Documentation

Index

• Constants
• func AddressFunc(getClient func() HAKeeperClient) func(context.Context, bool) (string, error)
• func DumpConfig(cfg any, defCfg any) (map[string]*logservicepb.ConfigItem, error)
• func Fastrand64() uint64
• func MergeConfig(dst *ConfigData, src map[string]*logservicepb.ConfigItem)
• func SetUUIDNodeID(ctx context.Context, nodeUuid []byte) error
• type ConfigData
  • func NewConfigData(data map[string]*logservicepb.ConfigItem) *ConfigData
  • func (cd *ConfigData) DecrCount()
  • func (cd *ConfigData) GetData() *logservicepb.ConfigData
• type HAKeeperClient
• type RunResult

Constants

const LOGGING_CN_LABEL = "logging_cn"

Functions

func AddressFunc

func AddressFunc(getClient func() HAKeeperClient) func(context.Context, bool) (string, error)

func DumpConfig

func DumpConfig(cfg any, defCfg any) (map[string]*logservicepb.ConfigItem, error)

func Fastrand64

func Fastrand64() uint64

Fastrand64 returns a lock free uint64 value. Compared to rand.Int63(), this implementation scales.

func MergeConfig

func MergeConfig(dst *ConfigData, src map[string]*logservicepb.ConfigItem)

MergeConfig copy all items from src to dst and overwrite the existed item.

func SetUUIDNodeID

func SetUUIDNodeID(ctx context.Context, nodeUuid []byte) error

SetUUIDNodeID set all uuid generator's node_id

Types

type ConfigData

type ConfigData struct {
	// contains filtered or unexported fields
}

func NewConfigData

func NewConfigData(data map[string]*logservicepb.ConfigItem) *ConfigData

func (*ConfigData) DecrCount

func (cd *ConfigData) DecrCount()

func (*ConfigData) GetData

func (cd *ConfigData) GetData() *logservicepb.ConfigData

type HAKeeperClient

type HAKeeperClient interface {
	// GetClusterDetails queries the HAKeeper and return CN and TN nodes that are
	// known to the HAKeeper.
	GetClusterDetails(ctx context.Context) (pb.ClusterDetails, error)
}

HAKeeperClient is an interface which is mainly used to avoid cycle import.

type RunResult

type RunResult struct {
	AffectRows uint64
}