config

Documentation

Index

• Variables
• func DealConfigCrypto(key string)
• func GetOutboundIP() net.IP
• func InitReader() error
• func MustLoad(key string, fpaths ...string)
• type Alerting
  • func (a *Alerting) ListTpls() (map[string]*template.Template, error)
• type CallPlugin
• type CallScript
• type Config
  • func (c *Config) IsDebugMode() bool
• type HeartbeatConfig
• type Ibex
• type NoData
• type PromClientMap
  • func (pc *PromClientMap) Del(cluster string)
  • func (pc *PromClientMap) GetCli(cluster string) prom.API
  • func (pc *PromClientMap) GetClusterNames() []string
  • func (pc *PromClientMap) Hit(cluster string) []string
  • func (pc *PromClientMap) IsNil(cluster string) bool
  • func (pc *PromClientMap) Reset()
  • func (pc *PromClientMap) Set(clusterName string, c prom.API)
• type PromOption
  • func (po *PromOption) Equal(target PromOption) bool
• type PromOptionsStruct
  • func (pos *PromOptionsStruct) Del(clusterName string)
  • func (pos *PromOptionsStruct) Get(clusterName string) (PromOption, bool)
  • func (pos *PromOptionsStruct) Set(clusterName string, po PromOption)
• type RedisPub
• type SMTPConfig
• type Webhook
• type WriterGlobalOpt
• type WriterOptions

Variables

var (
	C = new(Config)
)

var PromOptions = &PromOptionsStruct{Data: make(map[string]PromOption)}

Data key is cluster name

var ReaderClients = &PromClientMap{Clients: make(map[string]prom.API)}

Functions

func DealConfigCrypto

func DealConfigCrypto(key string)

func GetOutboundIP

func GetOutboundIP() net.IP

Get preferred outbound ip of this machine

func InitReader

func InitReader() error

func MustLoad

func MustLoad(key string, fpaths ...string)

Types

type Alerting

type Alerting struct {
	Timeout               int64
	TemplatesDir          string
	NotifyConcurrency     int
	NotifyBuiltinChannels []string
	CallScript            CallScript
	CallPlugin            CallPlugin
	RedisPub              RedisPub
	Webhook               Webhook
}

func (*Alerting) ListTpls

func (a *Alerting) ListTpls() (map[string]*template.Template, error)

type CallPlugin

type CallPlugin struct {
	Enable     bool
	PluginPath string
	Caller     string
}

type CallScript

type CallScript struct {
	Enable     bool
	ScriptPath string
}

type Config

type Config struct {
	RunMode            string
	ClusterName        string // 监控对象上报时，指定的集群名称
	BusiGroupLabelKey  string
	EngineDelay        int64
	DisableUsageReport bool
	ReaderFrom         string
	LabelRewrite       bool
	ForceUseServerTS   bool
	Log                logx.Config
	HTTP               httpx.Config
	BasicAuth          gin.Accounts
	SMTP               SMTPConfig
	Heartbeat          HeartbeatConfig
	Alerting           Alerting
	NoData             NoData
	Redis              storage.RedisConfig
	DB                 ormx.DBConfig
	WriterOpt          WriterGlobalOpt
	Writers            []WriterOptions
	Reader             PromOption
	Readers            []PromOption
	Ibex               Ibex
}

func (*Config) IsDebugMode

func (c *Config) IsDebugMode() bool

type HeartbeatConfig

type HeartbeatConfig struct {
	IP       string
	Interval int64
	Endpoint string
}

type Ibex

type Ibex struct {
	Address       string
	BasicAuthUser string
	BasicAuthPass string
	Timeout       int64
}

type NoData

type NoData struct {
	Metric   string
	Interval int64
}

type PromClientMap

type PromClientMap struct {
	sync.RWMutex
	Clients map[string]prom.API
}

func (*PromClientMap) Del

func (pc *PromClientMap) Del(cluster string)

func (*PromClientMap) GetCli

func (pc *PromClientMap) GetCli(cluster string) prom.API

func (*PromClientMap) GetClusterNames

func (pc *PromClientMap) GetClusterNames() []string

func (*PromClientMap) Hit

func (pc *PromClientMap) Hit(cluster string) []string

Hit 根据当前有效的cluster和规则的cluster配置计算有效的cluster列表

func (*PromClientMap) IsNil

func (pc *PromClientMap) IsNil(cluster string) bool

func (*PromClientMap) Reset

func (pc *PromClientMap) Reset()

func (*PromClientMap) Set

func (pc *PromClientMap) Set(clusterName string, c prom.API)

type PromOption

type PromOption struct {
	ClusterName   string
	Url           string
	BasicAuthUser string
	BasicAuthPass string

	Timeout     int64
	DialTimeout int64

	UseTLS bool
	tls.ClientConfig

	MaxIdleConnsPerHost int

	Headers []string
}

func (*PromOption) Equal

func (po *PromOption) Equal(target PromOption) bool

type PromOptionsStruct

type PromOptionsStruct struct {
	Data map[string]PromOption
	sync.RWMutex
}

func (*PromOptionsStruct) Del

func (pos *PromOptionsStruct) Del(clusterName string)

func (*PromOptionsStruct) Get

func (pos *PromOptionsStruct) Get(clusterName string) (PromOption, bool)

func (*PromOptionsStruct) Set

func (pos *PromOptionsStruct) Set(clusterName string, po PromOption)

type RedisPub

type RedisPub struct {
	Enable        bool
	ChannelPrefix string
	ChannelKey    string
}

type SMTPConfig

type SMTPConfig struct {
	Host               string
	Port               int
	User               string
	Pass               string
	From               string
	InsecureSkipVerify bool
	Batch              int
}

type Webhook

type Webhook struct {
	Enable          bool
	Url             string
	BasicAuthUser   string
	BasicAuthPass   string
	Timeout         string
	TimeoutDuration time.Duration
	Headers         []string
}

type WriterGlobalOpt

type WriterGlobalOpt struct {
	QueueCount   int
	QueueMaxSize int
	QueuePopSize int
	ShardingKey  string
}

type WriterOptions

type WriterOptions struct {
	ClusterName   string
	Url           string
	BasicAuthUser string
	BasicAuthPass string

	Timeout               int64
	DialTimeout           int64
	TLSHandshakeTimeout   int64
	ExpectContinueTimeout int64
	IdleConnTimeout       int64
	KeepAlive             int64

	MaxConnsPerHost     int
	MaxIdleConns        int
	MaxIdleConnsPerHost int

	Headers []string

	WriteRelabels []*models.RelabelConfig
}