plugins

package
v0.0.0-...-b9d044a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 14, 2015 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultBacklogSize = 2048

Variables

This section is empty.

Functions

func AddPlugin 

func AddPlugin(plugin ik.Plugin) bool

func GetPlugins 

func GetPlugins() []ik.Plugin

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 PathSet 

type PathSet struct {
	// contains filtered or unexported fields
}

func (*PathSet) Expand 

func (pathSet *PathSet) Expand() (map[string]struct{}, 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

func (*TailEventHandler) OnChange 

func (handler *TailEventHandler) OnChange(now time.Time) error

type TailFileInfo 

type TailFileInfo interface {
	GetPosition() int64
	SetPosition(int64)
	GetFileId() fileid.FileId
	SetFileId(fileid.FileId)
	Path() string
	IsNew() bool
	Save() error
	Duplicate() TailFileInfo
	Dispose() error
}

type TailInput 

type TailInput struct {
	// contains filtered or unexported fields
}

func (*TailInput) Dispose 

func (input *TailInput) Dispose() error

func (*TailInput) Factory 

func (input *TailInput) Factory() ik.Plugin

func (*TailInput) Port 

func (input *TailInput) Port() ik.Port

func (*TailInput) Run 

func (input *TailInput) Run() error

func (*TailInput) Shutdown 

func (input *TailInput) Shutdown() error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.