worker

Documentation

Index

• type ResultMuxer
  • func (r *ResultMuxer) AcceptTable(ctx context.Context, metadata types.TableMetadata) (pxapi.TableRecordHandler, error)
• type Worker
  • func Build(ctx context.Context, cfg config.Worker, vz *pxapi.VizierClient, ...) Worker

Types

type ResultMuxer

type ResultMuxer struct {
	RecordHandler pxapi.TableRecordHandler
}

func (*ResultMuxer) AcceptTable

func (r *ResultMuxer) AcceptTable(ctx context.Context, metadata types.TableMetadata) (pxapi.TableRecordHandler, error)

type Worker

type Worker interface {
	Spans(adapter.SpansAdapter, *sync.WaitGroup)
	Metrics(adapter.MetricsAdapter, *sync.WaitGroup)
}

func Build

func Build(ctx context.Context, cfg config.Worker, vz *pxapi.VizierClient, exporter exporter.Exporter) Worker