writers

Documentation

Index

• type BigQueryWriter
  • func NewBigQueryWriter(project string, dataset string, table string, autodetect bool, tmpfile string) BigQueryWriter
  • func (w BigQueryWriter) Finalize() error
  • func (w BigQueryWriter) StoreApiResult(data interface{}) strategies.WriterStrategy
• type FileWriter
  • func (w FileWriter) Finalize() error
  • func (w FileWriter) StoreApiResult(data interface{}) strategies.WriterStrategy
• type GcsStorageWriter
  • func (w GcsStorageWriter) Finalize() error
  • func (w GcsStorageWriter) StoreApiResult(data interface{}) strategies.WriterStrategy
• type LogWriter
  • func (s LogWriter) Finalize() error
  • func (s LogWriter) StoreApiResult(data interface{}) strategies.WriterStrategy

Types

type BigQueryWriter

type BigQueryWriter struct {
	Project          string
	Dataset          string
	Table            string
	AutodetectSchema bool
	TmpFile          string
	// contains filtered or unexported fields
}

func NewBigQueryWriter

func NewBigQueryWriter(project string, dataset string, table string, autodetect bool, tmpfile string) BigQueryWriter

func (BigQueryWriter) Finalize

func (w BigQueryWriter) Finalize() error

func (BigQueryWriter) StoreApiResult

func (w BigQueryWriter) StoreApiResult(data interface{}) strategies.WriterStrategy

type FileWriter

type FileWriter struct {
	FileName string
	Format   string
}

func (FileWriter) Finalize

func (w FileWriter) Finalize() error

func (FileWriter) StoreApiResult

func (w FileWriter) StoreApiResult(data interface{}) strategies.WriterStrategy

type GcsStorageWriter

type GcsStorageWriter struct {
	Format     string
	BucketName string
	FileName   string
	// contains filtered or unexported fields
}

func (GcsStorageWriter) Finalize

func (w GcsStorageWriter) Finalize() error

func (GcsStorageWriter) StoreApiResult

func (w GcsStorageWriter) StoreApiResult(data interface{}) strategies.WriterStrategy

type LogWriter

type LogWriter struct {
	Format     string
	BucketName string
	FileName   string
}

func (LogWriter) Finalize

func (s LogWriter) Finalize() error

func (LogWriter) StoreApiResult

func (s LogWriter) StoreApiResult(data interface{}) strategies.WriterStrategy