reader

Documentation

Index

• type ReaderType
  • func (reader *ReaderType) Init(inputMap map[string]inputs.MothershipConfig) error
  • func (reader *ReaderType) PrintReaderEvent(event common.MapStr)
  • func (reader *ReaderType) Run(output chan common.MapStr) error

Types

type ReaderType

type ReaderType struct {
	Index string
	Input []inputs.InputInterface
	Queue chan common.MapStr
	// contains filtered or unexported fields
}

var Reader ReaderType

func (*ReaderType) Init

func (reader *ReaderType) Init(inputMap map[string]inputs.MothershipConfig) error

func (*ReaderType) PrintReaderEvent

func (reader *ReaderType) PrintReaderEvent(event common.MapStr)

func (*ReaderType) Run

func (reader *ReaderType) Run(output chan common.MapStr) error