config

Documentation

Index

• Constants
• Variables
• type Config
  • func MustLoad(path string) (*Config, error)
  • func (c *Config) HasSecondaryStorage() bool
• type PresetConfigForTest
  • func CreatePresetForTest(version string, pools ...string) (*PresetConfigForTest, error)
  • func (presetConfig *PresetConfigForTest) Destroy()
• type RedisConf
  • func (rc *RedisConf) IsSentinel() bool
• type RedisPool
• type SecondaryStorage
• type SpannerConfig

Constants

const (
	DefaultPoolName = "default"
)

Variables

var SpannerEmulator = &SpannerConfig{
	Project:   "test-project",
	Instance:  "test-instance",
	Database:  "test-db",
	TableName: "lmstfy_jobs",
}

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
	SecondaryStorage *SecondaryStorage

	// 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

func (*Config) HasSecondaryStorage

func (c *Config) HasSecondaryStorage() bool

type PresetConfigForTest

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

func CreatePresetForTest

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

func (*PresetConfigForTest) Destroy

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

	EnableSecondaryStorage bool

	// number of seconds. when job's delay second is greater than pumpStorageThresh,
	//it will be written to storage if enabled
	SecondaryStorageThresholdSeconds int64
}

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

type SecondaryStorage

type SecondaryStorage struct {
	Spanner *SpannerConfig
	// max number of jobs that storage pumps per batch
	MaxJobPumpBatchSize int64
}

type SpannerConfig

type SpannerConfig struct {
	Project         string
	Instance        string
	Database        string
	CredentialsFile string
	TableName       string
}