input

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2021 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAvailableInputs

func GetAvailableInputs() []string

Types

type DryrunFileInput

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

func (DryrunFileInput) StartStream

func (input DryrunFileInput) StartStream(ch chan<- string)

type NamedPipeInput

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

func (NamedPipeInput) StartStream

func (input NamedPipeInput) StartStream(ch chan<- string)

type SocketInput

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

func (SocketInput) StartStream

func (socket SocketInput) StartStream(ch chan<- string)

type StdinInput added in v0.3.0

type StdinInput struct {
}

func (StdinInput) StartStream added in v0.3.0

func (input StdinInput) StartStream(ch chan<- string)

type StreamInput

type StreamInput interface {
	StartStream(ch chan<- string)
}

func NewInput

func NewInput(inputType string) (StreamInput, error)

type SyslogInput

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

func (SyslogInput) StartStream

func (input SyslogInput) StartStream(ch chan<- string)

type TailingFileInput

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

func (TailingFileInput) StartStream

func (input TailingFileInput) StartStream(ch chan<- string)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL