export

Documentation

Index

• func ConvertHitsToCSV(hits []reader.Hit, columns []string, columnsLabel []string, ...) ([]byte, error)
• func CreatePasswordProtectedZipFile(zipFileName string, contents []byte) ([]byte, error)
• func ExportFactHits(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, ...) ([]reader.Hit, error)
• func ExportFactHitsFull(f engine.Fact) ([]reader.Hit, error)
• func ExportFactHitsFullV6(f engine.Fact) ([]reader.Hit, error)
• func ExportFactHitsFullV8(f engine.Fact) ([]reader.Hit, error)
• func ExportFactHitsV6(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, ...) ([]reader.Hit, error)
• func ExportFactHitsV8(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, ...) ([]reader.Hit, error)
• type StreamedExport
  • func NewStreamedExport() *StreamedExport
  • func (export StreamedExport) DrainChannel()
  • func (export StreamedExport) StreamedExportFactHitsFull(ctx context.Context, f engine.Fact, limit int64) error
  • func (export StreamedExport) StreamedExportFactHitsFullV8(ctx context.Context, f engine.Fact, limit int64) error

Functions

func ConvertHitsToCSV

func ConvertHitsToCSV(hits []reader.Hit, columns []string, columnsLabel []string, formatColumnsData map[string]string, separator rune) ([]byte, error)

func CreatePasswordProtectedZipFile

func CreatePasswordProtectedZipFile(zipFileName string, contents []byte) ([]byte, error)

func ExportFactHits

func ExportFactHits(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, offset int) ([]reader.Hit, error)

func ExportFactHitsFull

func ExportFactHitsFull(f engine.Fact) ([]reader.Hit, error)

func ExportFactHitsFullV6

func ExportFactHitsFullV6(f engine.Fact) ([]reader.Hit, error)

func ExportFactHitsFullV8

func ExportFactHitsFullV8(f engine.Fact) ([]reader.Hit, error)

func ExportFactHitsV6

func ExportFactHitsV6(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, offset int) ([]reader.Hit, error)

func ExportFactHitsV8

func ExportFactHitsV8(ti time.Time, f engine.Fact, placeholders map[string]string, nhit int, offset int) ([]reader.Hit, error)

Types

type StreamedExport

type StreamedExport struct {
	Data chan []reader.Hit
}

func NewStreamedExport

func NewStreamedExport() *StreamedExport

NewStreamedExport returns a pointer to a new StreamedExport instance One instance per StreamedExport since the channel Data will be closed after export is finished

func (StreamedExport) DrainChannel

func (export StreamedExport) DrainChannel()

DrainChannel Drains the Data channel without processing the remaining values

func (StreamedExport) StreamedExportFactHitsFull

func (export StreamedExport) StreamedExportFactHitsFull(ctx context.Context, f engine.Fact, limit int64) error

func (StreamedExport) StreamedExportFactHitsFullV8

func (export StreamedExport) StreamedExportFactHitsFullV8(ctx context.Context, f engine.Fact, limit int64) error

StreamedExportFactHitsFullV8 export data from ElasticSearch to a channel Please note that the channel is not closed when this function is executed