workers

package
v0.15.10-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2024 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewProcessStopper added in v0.15.4 

func NewProcessStopper() processStopper

Types

type PollerOption 

type PollerOption func(*PollerWorker)

func WithInMemoryDatastore 

func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption

func WithPollerLogger added in v0.15.9 

func WithPollerLogger(logger *zap.Logger) PollerOption

func WithPollerMeter added in v0.16.0 

func WithPollerMeter(meter metric.Meter) PollerOption

func WithPollerObserver added in v0.15.9 

func WithPollerObserver(observer event.Observer) PollerOption

func WithPollerStoppableProcessRunner added in v0.15.4 

func WithPollerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) PollerOption

func WithPollerTracer added in v0.15.9 

func WithPollerTracer(tracer trace.Tracer) PollerOption

type PollerWorker 

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

func NewPollerWorker 

func NewPollerWorker(client *client.Client, opts ...PollerOption) *PollerWorker

func (*PollerWorker) Poll 

func (w *PollerWorker) Poll(ctx context.Context, request *proto.PollingRequest) error

type StoppableProcessRunner added in v0.15.4 

type StoppableProcessRunner func(parentCtx context.Context, testID string, runID int32, worker func(context.Context), stopedCallback func(cause string))

type StopperOption added in v0.15.4 

type StopperOption func(*StopperWorker)

func WithStopperCancelFuncList added in v0.15.4 

func WithStopperCancelFuncList(cancelContexts *cancelCauseFuncMap) StopperOption

func WithStopperLogger added in v0.16.0 

func WithStopperLogger(logger *zap.Logger) StopperOption

func WithStopperMeter added in v0.16.0 

func WithStopperMeter(meter metric.Meter) StopperOption

func WithStopperObserver added in v0.15.4 

func WithStopperObserver(observer event.Observer) StopperOption

func WithStopperTracer added in v0.15.9 

func WithStopperTracer(tracer trace.Tracer) StopperOption

type StopperWorker added in v0.15.4 

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

func NewStopperWorker added in v0.15.4 

func NewStopperWorker(opts ...StopperOption) *StopperWorker

func (*StopperWorker) Stop added in v0.15.4 

func (w *StopperWorker) Stop(ctx context.Context, stopRequest *proto.StopRequest) error

type TestConnectionOption added in v0.15.9 

type TestConnectionOption func(*TestConnectionWorker)

func WithTestConnectionLogger added in v0.15.9 

func WithTestConnectionLogger(logger *zap.Logger) TestConnectionOption

func WithTestConnectionMeter added in v0.16.0 

func WithTestConnectionMeter(meter metric.Meter) TestConnectionOption

func WithTestConnectionObserver added in v0.15.9 

func WithTestConnectionObserver(observer event.Observer) TestConnectionOption

func WithTestConnectionTracer added in v0.15.9 

func WithTestConnectionTracer(tracer trace.Tracer) TestConnectionOption

type TestConnectionWorker 

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

func NewTestConnectionWorker 

func NewTestConnectionWorker(client *client.Client, opts ...TestConnectionOption) *TestConnectionWorker

func (*TestConnectionWorker) Test 

func (w *TestConnectionWorker) Test(ctx context.Context, request *proto.DataStoreConnectionTestRequest) error

type TriggerOption 

type TriggerOption func(*TriggerWorker)

func WithSensor added in v0.15.6 

func WithSensor(sensor sensors.Sensor) TriggerOption

func WithTraceCache 

func WithTraceCache(cache collector.TraceCache) TriggerOption

func WithTriggerLogger added in v0.15.9 

func WithTriggerLogger(logger *zap.Logger) TriggerOption

func WithTriggerMeter added in v0.16.0 

func WithTriggerMeter(meter metric.Meter) TriggerOption

func WithTriggerObserver added in v0.14.8 

func WithTriggerObserver(observer event.Observer) TriggerOption

func WithTriggerStoppableProcessRunner added in v0.15.4 

func WithTriggerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) TriggerOption

func WithTriggerTracer added in v0.15.9 

func WithTriggerTracer(tracer trace.Tracer) TriggerOption

type TriggerWorker 

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

func NewTriggerWorker 

func NewTriggerWorker(client *client.Client, opts ...TriggerOption) *TriggerWorker

func (*TriggerWorker) Trigger 

func (w *TriggerWorker) Trigger(ctx context.Context, triggerRequest *proto.TriggerRequest) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.