exporter

Documentation

Index

• type Exporter
  • func New(opts Opts) (*Exporter, error)
  • func (s *Exporter) IsRunning() bool
  • func (s *Exporter) Run()
• type Opts
• type Request

Types

type Exporter

type Exporter struct {
	// ExportQueue for queuing the exports
	// Exports happen serially, with only one happening at once
	ExportQueue chan Request
	// contains filtered or unexported fields
}

Exporter schedules and executes exports

func New

func New(opts Opts) (*Exporter, error)

New creates exporter

func (*Exporter) IsRunning

func (s *Exporter) IsRunning() bool

IsRunning returns true if there is an export in progress

func (*Exporter) Run

func (s *Exporter) Run()

Run starts processing ExportQueue. This is a blocking call.

type Opts

type Opts struct {
	Logger hclog.Logger
	// LogLevelSubcommands specifies the log level to pass to sub commands.
	// Pass the same as used for logger.
	// We need it here, because there is no way to get it from logger.
	LogLevelSubcommands hclog.Level

	PinpointRoot string
	FSConf       fsconf.Locs
	Conf         agentconf.Config

	PPEncryptionKey string
	AgentConfig     cmdintegration.AgentConfig
}

Opts are the options for Exporter

type Request

type Request struct {
	// Data is the ExportRequest data received from the server
	Data *agent.ExportRequest
	// MessageID is the message id received from the server in headers
	MessageID string
}

Request is the export request to put into the ExportQueue