Documentation ¶
Index ¶
- Constants
- func AddPlugin(plugin ik.Plugin) bool
- func GetPlugins() []ik.Plugin
- type ConnectionCountTopic
- type EntryCountTopic
- type FileOutput
- type FileOutputFactory
- type FileOutputPacker
- type ForwardInput
- type ForwardInputFactory
- type ForwardOutput
- type ForwardOutputFactory
- type MyBufferedReader
- type PathSet
- type StdoutOutput
- type StdoutOutputFactory
- type TailEventHandler
- type TailFileInfo
- type TailInput
- type TailInputFactory
- type TailPositionFile
- type TailPositionFileEntry
- type TailTarget
- type TailWatcher
Constants ¶
View Source
const DefaultBacklogSize = 2048
Variables ¶
This section is empty.
Functions ¶
func GetPlugins ¶
Types ¶
type ConnectionCountTopic ¶
type ConnectionCountTopic struct{}
func (*ConnectionCountTopic) Markup ¶
func (topic *ConnectionCountTopic) Markup(input_ ik.PluginInstance) (ik.Markup, error)
func (*ConnectionCountTopic) PlainText ¶
func (topic *ConnectionCountTopic) PlainText(input_ ik.PluginInstance) (string, error)
type EntryCountTopic ¶
type EntryCountTopic struct{}
func (*EntryCountTopic) Markup ¶
func (topic *EntryCountTopic) Markup(input_ ik.PluginInstance) (ik.Markup, error)
func (*EntryCountTopic) PlainText ¶
func (topic *EntryCountTopic) PlainText(input_ ik.PluginInstance) (string, error)
type FileOutput ¶
type FileOutput struct {
// contains filtered or unexported fields
}
func (*FileOutput) Dispose ¶
func (output *FileOutput) Dispose()
func (*FileOutput) Emit ¶
func (output *FileOutput) Emit(recordSets []ik.FluentRecordSet) error
func (*FileOutput) Factory ¶
func (output *FileOutput) Factory() ik.Plugin
func (*FileOutput) Run ¶
func (output *FileOutput) Run() error
func (*FileOutput) Shutdown ¶
func (output *FileOutput) Shutdown() error
type FileOutputFactory ¶
type FileOutputFactory struct { }
func (*FileOutputFactory) BindScorekeeper ¶
func (factory *FileOutputFactory) BindScorekeeper(scorekeeper *ik.Scorekeeper)
func (*FileOutputFactory) Name ¶
func (factory *FileOutputFactory) Name() string
func (*FileOutputFactory) New ¶
func (factory *FileOutputFactory) New(engine ik.Engine, config *ik.ConfigElement) (ik.Output, error)
type FileOutputPacker ¶
type FileOutputPacker struct {
// contains filtered or unexported fields
}
func (*FileOutputPacker) Pack ¶
func (packer *FileOutputPacker) Pack(record ik.FluentRecord) ([]byte, error)
type ForwardInput ¶
type ForwardInput struct {
// contains filtered or unexported fields
}
func (*ForwardInput) Dispose ¶
func (input *ForwardInput) Dispose()
func (*ForwardInput) Factory ¶
func (input *ForwardInput) Factory() ik.Plugin
func (*ForwardInput) Port ¶
func (input *ForwardInput) Port() ik.Port
func (*ForwardInput) Run ¶
func (input *ForwardInput) Run() error
func (*ForwardInput) Shutdown ¶
func (input *ForwardInput) Shutdown() error
type ForwardInputFactory ¶
type ForwardInputFactory struct { }
func (*ForwardInputFactory) BindScorekeeper ¶
func (factory *ForwardInputFactory) BindScorekeeper(scorekeeper *ik.Scorekeeper)
func (*ForwardInputFactory) Name ¶
func (factory *ForwardInputFactory) Name() string
func (*ForwardInputFactory) New ¶
func (factory *ForwardInputFactory) New(engine ik.Engine, config *ik.ConfigElement) (ik.Input, error)
type ForwardOutput ¶
type ForwardOutput struct {
// contains filtered or unexported fields
}
func (*ForwardOutput) Emit ¶
func (output *ForwardOutput) Emit(recordSet []ik.FluentRecordSet) error
func (*ForwardOutput) Factory ¶
func (output *ForwardOutput) Factory() ik.Plugin
func (*ForwardOutput) Run ¶
func (output *ForwardOutput) Run() error
func (*ForwardOutput) Shutdown ¶
func (output *ForwardOutput) Shutdown() error
type ForwardOutputFactory ¶
type ForwardOutputFactory struct { }
func (*ForwardOutputFactory) BindScorekeeper ¶
func (factory *ForwardOutputFactory) BindScorekeeper(scorekeeper *ik.Scorekeeper)
func (*ForwardOutputFactory) Name ¶
func (factory *ForwardOutputFactory) Name() string
func (*ForwardOutputFactory) New ¶
func (factory *ForwardOutputFactory) New(engine ik.Engine, config *ik.ConfigElement) (ik.Output, error)
type MyBufferedReader ¶
type MyBufferedReader struct {
// contains filtered or unexported fields
}
func NewMyBufferedReader ¶
func NewMyBufferedReader(reader io.Reader, bufSize int, position int64) *MyBufferedReader
func (*MyBufferedReader) Continue ¶
func (b *MyBufferedReader) Continue()
func (*MyBufferedReader) ReadLine ¶
func (b *MyBufferedReader) ReadLine() ([]byte, bool, bool, error)
func (*MyBufferedReader) ReadRest ¶
func (b *MyBufferedReader) ReadRest() []byte
func (*MyBufferedReader) Reset ¶
func (b *MyBufferedReader) Reset(position int64) error
type StdoutOutput ¶
type StdoutOutput struct {
// contains filtered or unexported fields
}
func (*StdoutOutput) Dispose ¶
func (output *StdoutOutput) Dispose()
func (*StdoutOutput) Emit ¶
func (output *StdoutOutput) Emit(recordSets []ik.FluentRecordSet) error
func (*StdoutOutput) Factory ¶
func (output *StdoutOutput) Factory() ik.Plugin
func (*StdoutOutput) Run ¶
func (output *StdoutOutput) Run() error
func (*StdoutOutput) Shutdown ¶
func (output *StdoutOutput) Shutdown() error
type StdoutOutputFactory ¶
type StdoutOutputFactory struct { }
func (*StdoutOutputFactory) BindScorekeeper ¶
func (factory *StdoutOutputFactory) BindScorekeeper(scorekeeper *ik.Scorekeeper)
func (*StdoutOutputFactory) Name ¶
func (factory *StdoutOutputFactory) Name() string
func (*StdoutOutputFactory) New ¶
func (factory *StdoutOutputFactory) New(engine ik.Engine, _ *ik.ConfigElement) (ik.Output, error)
type TailEventHandler ¶
type TailEventHandler struct {
// contains filtered or unexported fields
}
func NewTailEventHandler ¶
func NewTailEventHandler( logger ik.Logger, target TailTarget, position int64, rotateWait time.Duration, readBufferSize int, decoder func([]byte) (string, error), stateSaver func(target TailTarget, position int64) error, lineReceiver func(line string) error, closer func() error, ) (*TailEventHandler, error)
func (*TailEventHandler) Dispose ¶
func (handler *TailEventHandler) Dispose() error
type TailFileInfo ¶
type TailInputFactory ¶
type TailInputFactory struct { }
func (*TailInputFactory) BindScorekeeper ¶
func (factory *TailInputFactory) BindScorekeeper(*ik.Scorekeeper)
func (*TailInputFactory) Name ¶
func (factory *TailInputFactory) Name() string
func (*TailInputFactory) New ¶
func (factory *TailInputFactory) New(engine ik.Engine, config *ik.ConfigElement) (ik.Input, error)
type TailPositionFile ¶
type TailPositionFile struct {
// contains filtered or unexported fields
}
func (*TailPositionFile) Dispose ¶
func (positionFile *TailPositionFile) Dispose() error
func (*TailPositionFile) Get ¶
func (positionFile *TailPositionFile) Get(path string) TailFileInfo
type TailPositionFileEntry ¶
type TailPositionFileEntry struct {
// contains filtered or unexported fields
}
type TailTarget ¶
type TailTarget struct {
// contains filtered or unexported fields
}
func (*TailTarget) UpdatedOne ¶
func (target *TailTarget) UpdatedOne() (TailTarget, error)
type TailWatcher ¶
type TailWatcher struct {
// contains filtered or unexported fields
}
func (*TailWatcher) Run ¶
func (watcher *TailWatcher) Run() error
func (*TailWatcher) Shutdown ¶
func (watcher *TailWatcher) Shutdown() error
Click to show internal directories.
Click to hide internal directories.