Documentation ¶
Index ¶
- Constants
- Variables
- 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
- type ConfigLogfile
- type ConfigMonitor
- type ConfigReceiver
- type ConfigServer
- type File
- type FileStat
- type InForward
- type InTail
- type MessageQueue
- type Monitor
- type OutForward
- type ReceiverStat
- type SentStat
- type ServerStat
- type ShutdownType
- type Stat
- type Stats
- type Watcher
Constants ¶
View Source
const ( DefaultFluentdPort = 24224 DefaultFieldName = "message" DefaultMaxBufferMessages = 1024 * 1024 )
View Source
const ( OpenRetryInterval = 1 * time.Second SEEK_TAIL = int64(-1) SEEK_HEAD = int64(0) DEBUG = false )
View Source
const ( MessageChannelBufferLen = 1 MonitorChannelBufferLen = 256 )
View Source
const ( DefaultMonitorPort = 24223 DefaultMonitorHost = "localhost" )
View Source
const (
FlashInterval = 200 * time.Millisecond
)
View Source
const (
TailInterval = 200 * time.Millisecond
)
Variables ¶
View Source
var (
LineSeparator = []byte{'\n'}
)
View Source
var (
ReadBufferSize = 1024 * 1024
)
Functions ¶
func NewChannel ¶
func NewChannel() (chan *fluent.FluentRecordSet, chan Stat)
NewChannel create channel for using by OutForward() and InTail().
func NewFluentRecordSet ¶
func NewFluentRecordSet(tag string, key string, buffer *[]byte) *fluent.FluentRecordSet
Types ¶
type Config ¶
type Config struct { TagPrefix string FieldName string Servers []*ConfigServer Logs []*ConfigLogfile Receiver *ConfigReceiver Monitor *ConfigMonitor }
func NewConfigByArgs ¶
func ReadConfig ¶
type ConfigLogfile ¶
func (*ConfigLogfile) Restrict ¶
func (cl *ConfigLogfile) Restrict(c *Config)
type ConfigMonitor ¶ added in v0.0.4
func (*ConfigMonitor) Restrict ¶ added in v0.0.4
func (cr *ConfigMonitor) Restrict(c *Config)
type ConfigReceiver ¶
func (*ConfigReceiver) Restrict ¶
func (cr *ConfigReceiver) Restrict(c *Config)
type ConfigServer ¶
func (*ConfigServer) Address ¶
func (cs *ConfigServer) Address() string
func (*ConfigServer) Restrict ¶
func (cs *ConfigServer) Restrict(c *Config)
type File ¶
type FileStat ¶
type InForward ¶
func NewInForward ¶
func NewInForward(config *ConfigReceiver, messageCh chan *fluent.FluentRecordSet, monitorCh chan Stat) (*InForward, error)
type InTail ¶
type InTail struct {
// contains filtered or unexported fields
}
func NewInTail ¶
func NewInTail(config *ConfigLogfile, watcher *Watcher, messageCh chan *fluent.FluentRecordSet, monitorCh chan Stat) (*InTail, error)
type MessageQueue ¶
type MessageQueue struct {
// contains filtered or unexported fields
}
func NewMessageQueue ¶
func NewMessageQueue(maxMessages int) *MessageQueue
func (*MessageQueue) Dequeue ¶
func (q *MessageQueue) Dequeue() (*fluent.FluentRecordSet, bool)
func (*MessageQueue) Enqueue ¶
func (q *MessageQueue) Enqueue(recordSet *fluent.FluentRecordSet) int64
func (*MessageQueue) Len ¶
func (q *MessageQueue) Len() int
type OutForward ¶
type OutForward struct {
// contains filtered or unexported fields
}
func NewOutForward ¶
func NewOutForward(configServers []*ConfigServer, messageCh chan *fluent.FluentRecordSet, monitorCh chan Stat) (*OutForward, error)
OutForward ... recieve FluentRecordSet from channel, and send it to passed loggers until success.
func (*OutForward) Run ¶
func (f *OutForward) Run()
type ReceiverStat ¶ added in v0.0.2
type ReceiverStat struct { Address string `json:"address"` Connections int `json:"-"` TotalConnections int `json:"total_connections"` CurrentConnections int `json:"current_connections"` Messages int64 `json:"messages"` Disposed int64 `json:"disposed"` Buffered int64 `json:"buffered"` MaxBufferMessages int64 `json:"max_buffer_messages"` }
func (*ReceiverStat) ApplyTo ¶ added in v0.0.2
func (s *ReceiverStat) ApplyTo(ss *Stats)
type SentStat ¶
type ServerStat ¶
type ServerStat struct { Index int `json:"-"` Address string `json:"address"` Alive bool `json:"alive"` Error string `json:"error"` }
func (*ServerStat) ApplyTo ¶
func (s *ServerStat) ApplyTo(ss *Stats)
type ShutdownType ¶
type ShutdownType struct {
// contains filtered or unexported fields
}
func (*ShutdownType) Error ¶
func (s *ShutdownType) Error() string
type Stats ¶
type Stats struct { Sent map[string]*SentStat `json:"sent"` Files map[string]*FileStat `json:"files"` Servers []*ServerStat `json:"servers"` Receiver *ReceiverStat `json:"receiver"` // contains filtered or unexported fields }
func (*Stats) WriteJSON ¶
func (ss *Stats) WriteJSON(w http.ResponseWriter)
Click to show internal directories.
Click to hide internal directories.