entity

type FileWatcher struct {
	Path    string
	File    *os.File
	Offset  int64
	Watcher *fsnotify.Watcher
}

type Handler struct {
	ScriptPath string     `mapstructure:"script_path"`
	AddData    *sync.Map  `mapstructure:"add_data"`
	Lua        *lua.State `mapstructure:"-"`
}

type Input struct {
	Type          string // file or docker
	Path          string
	CName         []string // 容器名称
	Files         []string
	Format        string
	Regex         string
	CompiledRegex *regexp.Regexp
	DockerLogPath string            `mapstructure:"docker_log_path"`
	FileMap       map[string]string // file 与 containerName 之间的映射
}

type Message struct {
	Service   string
	Source    string
	Table     string
	Container string
	AddData   map[string]interface{}
	Message   interface{}
	HostName  string
}

type Output struct {
	Type          string
	HttpURL       string            `mapstructure:"http_url"`
	HttpHeaders   map[string]string `mapstructure:"http_headers"`
	RedisAddr     string            `mapstructure:"redis_addr"`
	RedisDB       int               `mapstructure:"redis_db"`
	RedisKey      string            `mapstructure:"redis_key"`
	MySQLHost     string            `mapstructure:"mysql_host"`
	MySQLPort     int               `mapstructure:"mysql_port"`
	MySQLDb       string            `mapstructure:"mysql_db"`
	MySQLUser     string            `mapstructure:"mysql_user"`
	MySQLPassword string            `mapstructure:"mysql_password"`
	HostName      string
}