output

Documentation

Index

• type APIWriter
  • func NewAPIWriter(wc *config.WriterConfig) *APIWriter
  • func (f *APIWriter) Write(items chan map[string]interface{}, wg *sync.WaitGroup)
• type StdoutWriter
  • func (s *StdoutWriter) Write(items chan map[string]interface{}, wg *sync.WaitGroup)
• type Writer

Types

type APIWriter

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

The APIWriter is meant to write to a custom API and assumes many things. So currently, it is better not to use this APIWriter.

func NewAPIWriter

func NewAPIWriter(wc *config.WriterConfig) *APIWriter

NewAPIWriter returns a new APIWriter

func (*APIWriter) Write

func (f *APIWriter) Write(items chan map[string]interface{}, wg *sync.WaitGroup)

type StdoutWriter

type StdoutWriter struct{}

func (*StdoutWriter) Write

func (s *StdoutWriter) Write(items chan map[string]interface{}, wg *sync.WaitGroup)

type Writer

type Writer interface {
	Write(itemsList chan map[string]interface{}, wg *sync.WaitGroup)
}