app

Documentation

Index

• Variables
• func SaveInElasticsearch(ctx context.Context, client *elastic.Client, filename string, typeName string, ...) error
• type BatchIterator
  • func NewBatchIterator(batchSize int, s *bufio.Scanner) BatchIterator
  • func (it *BatchIterator) Err() error
  • func (it *BatchIterator) Next() bool
  • func (it *BatchIterator) Value() []string

Variables

var (
	// Version contains the current version.
	Version = "dev"
	// BuildDate contains a string with the build date.
	BuildDate = "unknown"
)

Functions

func SaveInElasticsearch

func SaveInElasticsearch(ctx context.Context, client *elastic.Client, filename string, typeName string, indexName string, batchSize int) error

Types

type BatchIterator

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

BatchIterator provides a convenient interface for reading lines in batches

func NewBatchIterator

func NewBatchIterator(batchSize int, s *bufio.Scanner) BatchIterator

NewBatchIterator returns a new batch iterator reading from s.

func (*BatchIterator) Err

func (it *BatchIterator) Err() error

Err returns error

func (*BatchIterator) Next

func (it *BatchIterator) Next() bool

Next advances to next batch

func (*BatchIterator) Value

func (it *BatchIterator) Value() []string

Value returns current batch