input

Documentation

Index

• Variables
• func NewFileInput(rawCfg map[string]interface{}) (api.Input, error)
• type FileInput
  • func (f *FileInput) Start(ctx context.Context) error
  • func (f *FileInput) To(writer api.Writer)
• type FileInputConfig
• type InputFactory

Variables

var Inputs map[string]InputFactory

Functions

func NewFileInput

func NewFileInput(rawCfg map[string]interface{}) (api.Input, error)

Types

type FileInput

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

func (*FileInput) Start

func (f *FileInput) Start(ctx context.Context) error

func (*FileInput) To

func (f *FileInput) To(writer api.Writer)

type FileInputConfig

type FileInputConfig struct {
	Path string
}

type InputFactory

type InputFactory func(map[string]interface{}) (api.Input, error)