Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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
Click to show internal directories.
Click to hide internal directories.