tracepollerworker

Documentation

Index

• func NewEvaluatorWorker(eventEmitter executor.EventEmitter, newTraceDBFn tracedb.FactoryFunc, ...) *tracePollerEvaluatorWorker
• func NewFetcherWorker(eventEmitter executor.EventEmitter, newTraceDBFn tracedb.FactoryFunc, ...) *traceFetcherWorker
• func NewStarterWorker(eventEmitter executor.EventEmitter, newTraceDBFn tracedb.FactoryFunc, ...) *tracePollerStarterWorker
• type PollingStopStrategy
• type SelectorBasedPollingStopStrategy
  • func NewSelectorBasedPollingStopStrategy(eventEmitter executor.EventEmitter, strategy PollingStopStrategy) *SelectorBasedPollingStopStrategy
  • func (s *SelectorBasedPollingStopStrategy) Evaluate(ctx context.Context, job *executor.Job, traceDB tracedb.TraceDB) (bool, string)
• type SpanCountPollingStopStrategy
  • func NewSpanCountPollingStopStrategy() *SpanCountPollingStopStrategy
  • func (s *SpanCountPollingStopStrategy) Evaluate(ctx context.Context, job *executor.Job, traceDB tracedb.TraceDB) (bool, string)

Functions

func NewEvaluatorWorker

func NewEvaluatorWorker(
	eventEmitter executor.EventEmitter,
	newTraceDBFn tracedb.FactoryFunc,
	dsRepo resourcemanager.Current[datastore.DataStore],
	updater executor.RunUpdater,
	subscriptionManager *subscription.Manager,
	stopStrategy PollingStopStrategy,
	tracer trace.Tracer,
) *tracePollerEvaluatorWorker

func NewFetcherWorker

func NewFetcherWorker(
	eventEmitter executor.EventEmitter,
	newTraceDBFn tracedb.FactoryFunc,
	dsRepo resourcemanager.Current[datastore.DataStore],
	updater executor.RunUpdater,
	subscriptionManager *subscription.Manager,
	tracer trace.Tracer,
	enabled bool,
) *traceFetcherWorker

func NewStarterWorker

func NewStarterWorker(
	eventEmitter executor.EventEmitter,
	newTraceDBFn tracedb.FactoryFunc,
	dsRepo resourcemanager.Current[datastore.DataStore],
	updater executor.RunUpdater,
	subscriptionManager *subscription.Manager,
	tracer trace.Tracer,
) *tracePollerStarterWorker

Types

type PollingStopStrategy

type PollingStopStrategy interface {
	Evaluate(ctx context.Context, job *executor.Job, traceDB tracedb.TraceDB) (bool, string)
}

type SelectorBasedPollingStopStrategy

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

func NewSelectorBasedPollingStopStrategy

func NewSelectorBasedPollingStopStrategy(eventEmitter executor.EventEmitter, strategy PollingStopStrategy) *SelectorBasedPollingStopStrategy

func (*SelectorBasedPollingStopStrategy) Evaluate

func (s *SelectorBasedPollingStopStrategy) Evaluate(ctx context.Context, job *executor.Job, traceDB tracedb.TraceDB) (bool, string)

Evaluate implements PollingStopStrategy.

type SpanCountPollingStopStrategy

type SpanCountPollingStopStrategy struct{}

func NewSpanCountPollingStopStrategy

func NewSpanCountPollingStopStrategy() *SpanCountPollingStopStrategy

func (*SpanCountPollingStopStrategy) Evaluate

func (s *SpanCountPollingStopStrategy) Evaluate(ctx context.Context, job *executor.Job, traceDB tracedb.TraceDB) (bool, string)

Evaluate implements PollingStopStrategy.