config

package
v1.0.15 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultPoolName = "default"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Host            string
	Port            int
	AdminHost       string
	AdminPort       int
	LogLevel        string
	LogDir          string
	LogFormat       string
	Accounts        map[string]string
	EnableAccessLog bool
	AdminRedis      RedisConf
	Pool            RedisPool

	// Default publish params
	TTLSecond   int
	DelaySecond int
	TriesNum    int
	// Default consume params
	TTRSecond     int
	TimeoutSecond int
}

func MustLoad

func MustLoad(path string) (*Config, error)

MustLoad load config file with specified path, an error returned if any condition not met

type PresetConfigForTest added in v1.0.12

type PresetConfigForTest struct {
	*Config
	// contains filtered or unexported fields
}

func CreatePresetForTest added in v1.0.12

func CreatePresetForTest(version string, pools ...string) (*PresetConfigForTest, error)

func (*PresetConfigForTest) Destroy added in v1.0.12

func (presetConfig *PresetConfigForTest) Destroy()

type RedisConf

type RedisConf struct {
	Addr             string
	Password         string
	DB               int
	PoolSize         int
	MigrateTo        string // If this is not empty, all the PUBLISH will go to that pool
	MasterName       string
	Version          string
	SentinelPassword string
}

func (*RedisConf) IsSentinel

func (rc *RedisConf) IsSentinel() bool

IsSentinel return whether the pool was running in sentinel mode

type RedisPool

type RedisPool map[string]RedisConf

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL