exporter

Documentation

Overview

Package exporter contains methods of extracting data from DB.

Index

• type Exporter
  • func NewExporter(cfg configuration.Exporter) *Exporter
  • func (e *Exporter) Export(ctx context.Context, fromPulse core.PulseNumber, size int) (*core.StorageExportResult, error)

Types

type Exporter

type Exporter struct {
	DB            storage.DBContext     `inject:""`
	JetStorage    storage.JetStorage    `inject:""`
	ObjectStorage storage.ObjectStorage `inject:""`
	PulseTracker  storage.PulseTracker  `inject:""`
	PulseStorage  core.PulseStorage     `inject:""`
	// contains filtered or unexported fields
}

Exporter provides methods for fetching data view from storage.

func NewExporter

func NewExporter(cfg configuration.Exporter) *Exporter

NewExporter creates new StorageExporter instance.

func (*Exporter) Export

func (e *Exporter) Export(ctx context.Context, fromPulse core.PulseNumber, size int) (*core.StorageExportResult, error)

Export returns data view from storage.