internal

Documentation

Index

• type HauserService
  • func NewHauserService(config *config.Config, fsClient client.DataExportClient, ...) *HauserService
  • func (h *HauserService) BackoffOnError(err error) bool
  • func (h *HauserService) Init(ctx context.Context) error
  • func (h *HauserService) InitDatabase(_ context.Context) error
  • func (h *HauserService) LoadBundles(ctx context.Context, filename string, startTime, endTime time.Time) error
  • func (h *HauserService) ProcessNext(ctx context.Context) (time.Duration, error)
  • func (h *HauserService) Run(ctx context.Context)
  • func (h *HauserService) WriteBundleToCSV(stream io.Reader, csvOut *csv.Writer) (numRecords int, err error)
• type Record

Types

type HauserService

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

func NewHauserService

func NewHauserService(config *config.Config, fsClient client.DataExportClient, storage warehouse.Storage, db warehouse.Database) *HauserService

func (*HauserService) BackoffOnError

func (h *HauserService) BackoffOnError(err error) bool

func (*HauserService) Init

func (h *HauserService) Init(ctx context.Context) error

func (*HauserService) InitDatabase

func (h *HauserService) InitDatabase(_ context.Context) error

func (*HauserService) LoadBundles

func (h *HauserService) LoadBundles(ctx context.Context, filename string, startTime, endTime time.Time) error

func (*HauserService) ProcessNext

func (h *HauserService) ProcessNext(ctx context.Context) (time.Duration, error)

ProcessNext will process the next export, or return a duration until the next export is ready.

func (*HauserService) Run

func (h *HauserService) Run(ctx context.Context)

func (*HauserService) WriteBundleToCSV

func (h *HauserService) WriteBundleToCSV(stream io.Reader, csvOut *csv.Writer) (numRecords int, err error)

WriteBundleToCSV writes the bundle corresponding to the given bundleID to the csv Writer

type Record

type Record map[string]interface{}

Record represents a single export row in the export file