config

Documentation

Index

• Variables
• func GetOutboundIP() net.IP
• func InitReader() error
• func MustLoad(fpaths ...string)
• type Alerting
• type CallPlugin
• type CallScript
• type Config
  • func (c *Config) IsDebugMode() bool
• type HeartbeatConfig
• type Ibex
• type NoData
• type PromClient
  • func (pc *PromClient) Get() (string, prom.API)
  • func (pc *PromClient) GetCli() prom.API
  • func (pc *PromClient) GetClusterName() string
  • func (pc *PromClient) IsNil() bool
  • func (pc *PromClient) Reset()
  • func (pc *PromClient) Set(clusterName string, c prom.API)
• type PromOption
  • func (po *PromOption) Equal(target PromOption) bool
• type PromOptionsStruct
  • func (pos *PromOptionsStruct) Get(clusterName string) (PromOption, bool)
  • func (pos *PromOptionsStruct) Set(clusterName string, po PromOption)
  • func (pos *PromOptionsStruct) Sets(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

Functions

func GetOutboundIP

func GetOutboundIP() net.IP

Get preferred outbound ip of this machine

func InitReader

func InitReader() error

func MustLoad

func MustLoad(fpaths ...string)

Types

type Alerting

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

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

type PromClient struct {
	prom.API
	ClusterName string
	sync.RWMutex
}

var ReaderClient *PromClient = &PromClient{}

func (*PromClient) Get

func (pc *PromClient) Get() (string, prom.API)

func (*PromClient) GetCli

func (pc *PromClient) GetCli() prom.API

func (*PromClient) GetClusterName

func (pc *PromClient) GetClusterName() string

func (*PromClient) IsNil

func (pc *PromClient) IsNil() bool

func (*PromClient) Reset

func (pc *PromClient) Reset()

func (*PromClient) Set

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

type PromOption

type PromOption struct {
	Url           string
	BasicAuthUser string
	BasicAuthPass string

	Timeout     int64
	DialTimeout int64

	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) Get

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

func (*PromOptionsStruct) Set

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

func (*PromOptionsStruct) Sets

func (pos *PromOptionsStruct) Sets(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
}

type WriterOptions

type WriterOptions struct {
	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
}