config

Documentation

Index

• type Config
• type DatabaseConfig
  • func (conf *DatabaseConfig) Complete()
  • func (dbConf *DatabaseConfig) DSN(dbName string) string
  • func (dbConf *DatabaseConfig) Validate() bool
• type ExporterConfig
  • func NewExporterConfig(confPath string) (*ExporterConfig, error)
  • func (conf *ExporterConfig) Complete()
  • func (conf *ExporterConfig) Validate() bool
• type ReceiverConfig
  • func NewReceiverConfig(confPath string) (*ReceiverConfig, error)
  • func (conf *ReceiverConfig) Complete()
  • func (conf *ReceiverConfig) Validate() bool
• type ResolverConfig
  • func (conf *ResolverConfig) Complete()
  • func (conf *ResolverConfig) Validate() bool
• type ResolverMgrConfig
  • func NewResolverMgrConfig(confPath string) (*ResolverMgrConfig, error)
  • func (conf *ResolverMgrConfig) Complete()
  • func (conf *ResolverMgrConfig) Validate() bool

Types

type Config

type Config interface {
	Validate() bool
	Complete()
}

type DatabaseConfig

type DatabaseConfig struct {
	Address  string `mapstructure:"address"`
	Username string `mapstructure:"username"`
	Password string `mapstructure:"password"`
}

func (*DatabaseConfig) Complete

func (conf *DatabaseConfig) Complete()

func (*DatabaseConfig) DSN

func (dbConf *DatabaseConfig) DSN(dbName string) string

func (*DatabaseConfig) Validate

func (dbConf *DatabaseConfig) Validate() bool

type ExporterConfig

type ExporterConfig struct {
	ExporterTag string `mapstructure:"exporter_tag"` // 作为 exporter 当前的唯一 Tag（如果唯一性验证失败会 panic），同时通过路径组装生成日志文件路径扫描日志文件

	ReceiverServerAddr string `mapstructure:"receiver_server_addr"` // receiver 服务地址

	PollInterval int `mapstructure:"poll_interval"` // 自定义 export 时间间隔，单位为 1ms，默认为 100ms，不宜设置过小

	FileKeepingDays int `mapstructure:"file_keeping_days"` // 已上报的日志，保留多久后会被删除

	InitProgress protocol.ExporterProgress `mapstructure:"init_progress"`
}

func NewExporterConfig

func NewExporterConfig(confPath string) (*ExporterConfig, error)

func (*ExporterConfig) Complete

func (conf *ExporterConfig) Complete()

func (*ExporterConfig) Validate

func (conf *ExporterConfig) Validate() bool

type ReceiverConfig

type ReceiverConfig struct {
	MetaServerAddr        string         `mapstructure:"meta_server_addr"`         // meta 服务地址，各种元信息以 kv 的方式由 meta 服务管理
	MqServerAddr          string         `mapstructure:"mq_server_addr"`           // receiver 服务在接收到消息后将消息放到 mq 中
	ResolverMgrServerAddr string         `mapstructure:"resolver_mgr_server_addr"` // resolver mgr 提供 resolver 的调度接口
	DatabaseConfig        DatabaseConfig `mapstructure:"database_config"`          // master
}

func NewReceiverConfig

func NewReceiverConfig(confPath string) (*ReceiverConfig, error)

func (*ReceiverConfig) Complete

func (conf *ReceiverConfig) Complete()

func (*ReceiverConfig) Validate

func (conf *ReceiverConfig) Validate() bool

type ResolverConfig

type ResolverConfig struct {
	MetaServerAddr string         `mapstructure:"meta_server_addr"` // meta 服务地址
	MqServerAddr   string         `mapstructure:"mq_server_addr"`   // mq 服务地址
	DatabaseConfig DatabaseConfig `mapstructure:"database_config"`  // master
}

func (*ResolverConfig) Complete

func (conf *ResolverConfig) Complete()

func (*ResolverConfig) Validate

func (conf *ResolverConfig) Validate() bool

type ResolverMgrConfig

type ResolverMgrConfig struct {
	MetaServerAddr string         `mapstructure:"meta_server_addr"` // meta 服务地址
	ResolverConfig ResolverConfig `mapstructure:"resolver_config"`  // resolver 的配置
}

func NewResolverMgrConfig

func NewResolverMgrConfig(confPath string) (*ResolverMgrConfig, error)

func (*ResolverMgrConfig) Complete

func (conf *ResolverMgrConfig) Complete()

func (*ResolverMgrConfig) Validate

func (conf *ResolverMgrConfig) Validate() bool