writers

package
v0.1.21 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2025 License: BSD-2-Clause Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CsvWriter 

type CsvWriter struct {
	FilePath string
	// contains filtered or unexported fields
}

CsvWriter writes CSV files

func NewCsvWriter 

func NewCsvWriter(destination string) (*CsvWriter, error)

NewCsvWriter gets a new CsvWriter

func (*CsvWriter) Finish 

func (cw *CsvWriter) Finish() error

func (*CsvWriter) Write 

func (cw *CsvWriter) Write(result *models.Result) error

Write a CSV line

func (*CsvWriter) WriteFqdn added in v0.1.15 

func (cw *CsvWriter) WriteFqdn(result *models.FQDNData) error

type DbWriter 

type DbWriter struct {
	URI string
	// contains filtered or unexported fields
}

DbWriter is a Database writer

func NewDbWriter 

func NewDbWriter(uri string, debug bool) (*DbWriter, error)

NewDbWriter initialises a database writer

func (*DbWriter) Finish 

func (dw *DbWriter) Finish() error

func (*DbWriter) Write 

func (dw *DbWriter) Write(result *models.Result) error

Write results to the database

func (*DbWriter) WriteFqdn added in v0.1.15 

func (dw *DbWriter) WriteFqdn(fqdn *models.FQDNData) error

type ElasticWriter 

type ElasticWriter struct {
	Client *elk.Client
	Index  string
	// contains filtered or unexported fields
}

JsonWriter is a JSON lines writer

func NewElasticWriter 

func NewElasticWriter(uri string) (*ElasticWriter, error)

NewJsonWriter return a new Json lines writer

func (*ElasticWriter) CreateDoc 

func (ew *ElasticWriter) CreateDoc(index string, data []byte, doc_id string) error

func (*ElasticWriter) CreateDocBulk 

func (ew *ElasticWriter) CreateDocBulk(index string, docs map[string][]byte) error

func (*ElasticWriter) CreateIndex 

func (ew *ElasticWriter) CreateIndex(index string, mapping string) error

func (*ElasticWriter) Finish 

func (ew *ElasticWriter) Finish() error

func (*ElasticWriter) Marshal 

func (ew *ElasticWriter) Marshal(v any) ([]byte, error)

func (*ElasticWriter) MarshalAppend 

func (ew *ElasticWriter) MarshalAppend(marshalled []byte, new_data map[string]interface{}) ([]byte, error)

func (*ElasticWriter) Write 

func (ew *ElasticWriter) Write(result *models.Result) error

Write JSON lines to a file

func (*ElasticWriter) WriteFqdn added in v0.1.15 

func (ew *ElasticWriter) WriteFqdn(result *models.FQDNData) error

type Interceptor added in v0.1.19 

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

func (Interceptor) RoundTrip added in v0.1.19 

func (i Interceptor) RoundTrip(req *http.Request) (*http.Response, error)

type JsonWriter 

type JsonWriter struct {
	FilePath string
}

JsonWriter is a JSON lines writer

func NewJsonWriter 

func NewJsonWriter(destination string) (*JsonWriter, error)

NewJsonWriter return a new Json lines writer

func (*JsonWriter) Finish 

func (jw *JsonWriter) Finish() error

func (*JsonWriter) Write 

func (jw *JsonWriter) Write(result *models.Result) error

Write JSON lines to a file

func (*JsonWriter) WriteFqdn added in v0.1.15 

func (jw *JsonWriter) WriteFqdn(result *models.FQDNData) error

type MemoryWriter 

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

MemoryWriter is a memory-based results queue with a maximum slot count

func NewMemoryWriter 

func NewMemoryWriter(slots int) (*MemoryWriter, error)

NewMemoryWriter initializes a MemoryWriter with the specified number of slots

func (*MemoryWriter) Finish 

func (s *MemoryWriter) Finish() error

func (*MemoryWriter) GetAllResults 

func (s *MemoryWriter) GetAllResults() []*models.Result

GetAllResults returns a copy of all current results.

func (*MemoryWriter) GetFirst 

func (s *MemoryWriter) GetFirst() *models.Result

GetFirst retrieves the oldest result in the MemoryWriter.

func (*MemoryWriter) GetLatest 

func (s *MemoryWriter) GetLatest() *models.Result

GetLatest retrieves the most recently added result.

func (*MemoryWriter) Write 

func (s *MemoryWriter) Write(result *models.Result) error

Write adds a new result to the MemoryWriter.

func (*MemoryWriter) WriteFqdn added in v0.1.15 

func (s *MemoryWriter) WriteFqdn(result *models.FQDNData) error

type NoneWriter 

type NoneWriter struct {
}

NoneWriter is a None writer

func NewNoneWriter 

func NewNoneWriter() (*NoneWriter, error)

NewNoneWriter initialises a none writer

func (*NoneWriter) Finish 

func (s *NoneWriter) Finish() error

func (*NoneWriter) Write 

func (s *NoneWriter) Write(result *models.Result) error

Write does nothing

func (*NoneWriter) WriteFqdn added in v0.1.15 

func (s *NoneWriter) WriteFqdn(result *models.FQDNData) error

type StdoutWriter 

type StdoutWriter struct {
	WriteAll   bool
	IsTerminal bool
}

StdoutWriter is a Stdout writer

func NewStdoutWriter 

func NewStdoutWriter() (*StdoutWriter, error)

NewStdoutWriter initialises a stdout writer

func (*StdoutWriter) Finish 

func (s *StdoutWriter) Finish() error

func (*StdoutWriter) Write 

func (s *StdoutWriter) Write(result *models.Result) error

Write results to stdout

func (*StdoutWriter) WriteFqdn added in v0.1.15 

func (s *StdoutWriter) WriteFqdn(result *models.FQDNData) error

type TextWriter 

type TextWriter struct {
	FilePath string
	// contains filtered or unexported fields
}

StdoutWriter is a Stdout writer

func NewTextWriter 

func NewTextWriter(destination string) (*TextWriter, error)

NewStdoutWriter initialises a stdout writer

func (*TextWriter) Finish 

func (t *TextWriter) Finish() error

func (*TextWriter) Write 

func (t *TextWriter) Write(result *models.Result) error

Write results to stdout

func (*TextWriter) WriteFqdn added in v0.1.15 

func (t *TextWriter) WriteFqdn(result *models.FQDNData) error

type Writer 

type Writer interface {
	Write(*models.Result) error
	WriteFqdn(*models.FQDNData) error
	Finish() error
}

Writer is a results writer

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.