exporter

Documentation

Index

• func NewExporter(ctx context.Context, opt *connectors.Options, name string, ...) (exporter.Exporter, error)
• type Exporter
  • func (p *Exporter) Close(ctx context.Context) error
  • func (p *Exporter) Export(ctx context.Context, records <-chan *connectors.Record, ...) (ret error)
  • func (p *Exporter) Flags() location.Flags
  • func (p *Exporter) Origin() string
  • func (p *Exporter) Ping(ctx context.Context) error
  • func (p *Exporter) Root() string
  • func (p *Exporter) Type() string

Functions

func NewExporter

func NewExporter(ctx context.Context, opt *connectors.Options, name string, config map[string]string) (exporter.Exporter, error)

Types

type Exporter

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

func (*Exporter) Close

func (p *Exporter) Close(ctx context.Context) error

func (*Exporter) Export

func (p *Exporter) Export(ctx context.Context, records <-chan *connectors.Record, results chan<- *connectors.Result) (ret error)

func (*Exporter) Flags

func (p *Exporter) Flags() location.Flags

func (*Exporter) Origin

func (p *Exporter) Origin() string

func (*Exporter) Ping

func (p *Exporter) Ping(ctx context.Context) error

func (*Exporter) Root

func (p *Exporter) Root() string

func (*Exporter) Type

func (p *Exporter) Type() string