hydra

Jan 6, 2017

Changes in this version

+ const StdinFilename

+ var RegexpApache = regexp.MustCompile(...)

+ var RegexpApacheError = regexp.MustCompile(...)

+ var RegexpNginx = regexp.MustCompile(...)

+ var RegexpSyslog = regexp.MustCompile(...)

+ var TimeEpoch = time.Unix(0, 0)

+ var TimeFormatApache = TimeFormat("02/Jan/2006:15:04:05 -0700")

+ var TimeFormatNginx = TimeFormat("02/Jan/2006:15:04:05 -0700")

+ var TimeFormatSyslog = TimeFormat("Jan 02 15:04:05")

+ var TimeFormatUnix = TimeFormat("unix")

+ func NewFluentRecordJSON(key string, line []byte) *fluent.TinyFluentRecord

+ func NewFluentRecordLTSV(key string, line []byte) *fluent.TinyFluentRecord

+ func NewFluentRecordRegexp(key string, line []byte, r *Regexp) *fluent.TinyFluentRecord

type Config

+ SubSecondTime bool

type ConfigLogfile

+ Regexp *Regexp

+ func (cl *ConfigLogfile) IsStdin() bool

+ type Context struct

+ ControlCh chan interface{}

+ InputProcess sync.WaitGroup

+ MessageCh chan *fluent.FluentRecordSet

+ MonitorCh chan Stat

+ OutputProcess sync.WaitGroup

+ StartProcess sync.WaitGroup

+ func NewContext() *Context

+ func Run(config *Config) *Context

+ func (c *Context) RunProcess(p Process)

+ func (c *Context) Shutdown()

type File

+ Regexp *Regexp

type FileFormat

+ const FormatJSON

+ const FormatLTSV

+ const FormatNone

+ const FormatRegexp

type InTail

+ func (t *InTail) TailStdin(c *Context) error

+ type Process interface

+ Run func(*Context)

+ type Regexp struct

+ func (r *Regexp) UnmarshalText(text []byte) error

+ type Signal struct

+ func NewSignal(message string) Signal

+ func (s Signal) Error() string

+ func (s Signal) Signal()

+ func (s Signal) String() string

+ type TimeFormat string

+ func (t *TimeFormat) UnmarshalText(text []byte) error

Oct 24, 2015

Changes in this version

+ const ConvertTypeBool

+ const ConvertTypeFloat

+ const ConvertTypeInt

+ const ConvertTypeString

type ConvertMap

+ ConverterMap map[string]Converter

+ TypeMap map[string]ConvertType

+ type ConvertType int

Jun 5, 2015

Changes in this version

type SentStat

+ Sents int64

May 26, 2015

Changes in this version

+ const DefaultTimeFormat

+ const DefaultTimeKey

+ type BoolConverter int

+ func (c BoolConverter) Convert(v string) (interface{}, error)

type ConfigLogfile

+ TimeFormat string

+ TimeKey string

+ TimeParse bool

type ConvertMap

+ func (c ConvertMap) ConvertTypes(data map[string]interface{})

type Converter

+ Convert func(string) (interface{}, error)

type File

+ RecordModifier *RecordModifier

+ type FloatConverter int

+ func (c FloatConverter) Convert(v string) (interface{}, error)

+ type IntConverter int

+ func (c IntConverter) Convert(v string) (interface{}, error)

+ type RecordModifier struct

+ func (m *RecordModifier) Modify(r *fluent.TinyFluentRecord)

+ type TimeConverter string

+ func (c TimeConverter) Convert(v string) (time.Time, error)

Jan 7, 2015

Changes in this version

+ const LTSVColSeparatorStr

+ const LTSVDataSeparatorStr

+ const LineSeparatorStr

+ func ConvertTypes(data map[string]interface{}, convertMap ConvertMap)

+ func NewFluentRecordSetJSON(tag string, buffer []byte) *fluent.FluentRecordSet

+ func NewFluentRecordSetLTSV(tag string, convertMap ConvertMap, buffer []byte) *fluent.FluentRecordSet

type Config

+ ServerRoundRobin bool

type ConfigLogfile

+ ConvertMap ConvertMap

+ Format FileFormat

+ type ConvertMap map[string]Converter

+ func NewConvertMap(config string) ConvertMap

+ func (c *ConvertMap) UnmarshalText(text []byte) error

+ type Converter int

+ const ConvertBool

+ const ConvertFloat

+ const ConvertInt

+ func (i Converter) String() string

type File

+ ConvertMap ConvertMap

+ FileStat *FileStat

+ Format FileFormat

+ func (f *File) UpdateStat() *FileStat

+ type FileFormat int

+ const JSON

+ const LTSV

+ const None

+ func (f *FileFormat) UnmarshalText(text []byte) error

+ func (i FileFormat) String() string

type OutForward

+ RoundRobin bool

Aug 19, 2014

Changes in this version

type Config

+ ReadBufferSize int

Aug 18, 2014

Changes in this version

+ const DefaultMonitorHost

+ const DefaultMonitorPort

type Config

+ Monitor *ConfigMonitor

+ type ConfigMonitor struct

+ Host string

+ Port int

+ func (cr *ConfigMonitor) Restrict(c *Config)

type ReceiverStat

+ MaxBufferMessages int64

Aug 14, 2014

Changes in this version

+ const DefaultMaxBufferMessages

+ const FlashInterval

type Config

+ Receiver *ConfigReceiver

type ConfigReceiver

+ MaxBufferMessages int

+ type ReceiverStat struct

+ Address string

+ Buffered int64

+ Connections int

+ CurrentConnections int

+ Disposed int64

+ Messages int64

+ TotalConnections int

+ func (s *ReceiverStat) ApplyTo(ss *Stats)

type Stats

+ Receiver *ReceiverStat

Aug 10, 2014

Changes in this version

+ const DEBUG

+ const DefaultFieldName

+ const DefaultFluentdPort

+ const MessageChannelBufferLen

+ const MonitorChannelBufferLen

+ const OpenRetryInterval

+ const SEEK_HEAD

+ const SEEK_TAIL

+ const TailInterval

+ var LineSeparator = []byte

+ var ReadBufferSize = 64 * 1024

+ func NewChannel() (chan *fluent.FluentRecordSet, chan Stat)

+ func NewFluentRecordSet(tag string, key string, buffer *[]byte) *fluent.FluentRecordSet

+ func Rel2Abs(filename string) (string, error)

+ type Config struct

+ FieldName string

+ Logs []*ConfigLogfile

+ MonitorAddress string

+ Receivers []*ConfigReceiver

+ Servers []*ConfigServer

+ TagPrefix string

+ func NewConfigByArgs(args []string, fieldName string, monitorAddr string) *Config

+ func ReadConfig(filename string) (*Config, error)

+ func (c *Config) Restrict()

+ type ConfigLogfile struct

+ FieldName string

+ File string

+ Tag string

+ func (cl *ConfigLogfile) Restrict(c *Config)

+ type ConfigReceiver struct

+ Host string

+ Port int

+ func (cr *ConfigReceiver) Restrict(c *Config)

+ type ConfigServer struct

+ Host string

+ Port int

+ func (cs *ConfigServer) Address() string

+ func (cs *ConfigServer) Restrict(c *Config)

+ type File struct

+ FieldName string

+ Path string

+ Position int64

+ Tag string

+ func (f *File) NewStat() *FileStat

+ type FileStat struct

+ Error string

+ File string

+ Position int64

+ Tag string

+ func (s *FileStat) ApplyTo(ss *Stats)

+ type InForward struct

+ Addr net.Addr

+ func NewInForward(config *ConfigReceiver, messageCh chan *fluent.FluentRecordSet, ...) (*InForward, error)

+ func (f *InForward) Run()

+ type InTail struct

+ func NewInTail(config *ConfigLogfile, watcher *Watcher, ...) (*InTail, error)

+ func (t *InTail) Run()

+ type MessageQueue struct

+ func NewMessageQueue(maxLength int, drain bool) *MessageQueue

+ func (q *MessageQueue) Dequeue() (interface{}, bool)

+ func (q *MessageQueue) Disposed() int

+ func (q *MessageQueue) Enqueue(value interface{}) error

+ func (q *MessageQueue) Len() int

+ type Monitor struct

+ Addr net.Addr

+ func NewMonitor(config *Config, monitorCh chan Stat) (*Monitor, error)

+ func (m *Monitor) Run()

+ type OutForward struct

+ func NewOutForward(configServers []*ConfigServer, messageCh chan *fluent.FluentRecordSet, ...) (*OutForward, error)

+ func (f *OutForward) Run()

+ type SentStat struct

+ Bytes int64

+ Messages int64

+ Tag string

+ func (s *SentStat) ApplyTo(ss *Stats)

+ type ServerStat struct

+ Address string

+ Alive bool

+ Error string

+ Index int

+ func (s *ServerStat) ApplyTo(ss *Stats)

+ type ShutdownType struct

+ func (s *ShutdownType) Error() string

+ type Stat interface

+ ApplyTo func(*Stats)

+ type Stats struct

+ Files map[string]*FileStat

+ Sent map[string]*SentStat

+ Servers []*ServerStat

+ func (ss *Stats) Run(ch chan Stat)

+ func (ss *Stats) WriteJSON(w http.ResponseWriter)

+ type Watcher struct

+ func NewWatcher() (*Watcher, error)

+ func (w *Watcher) Run()

+ func (w *Watcher) WatchFile(filename string) (chan *fsnotify.FileEvent, error)