workers

Documentation

Index

• func NewProcessStopper() processStopper
• type PollerOption
  • func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption
  • func WithObserver(observer event.Observer) PollerOption
  • func WithPollerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) PollerOption
• type PollerWorker
  • func NewPollerWorker(client *client.Client, opts ...PollerOption) *PollerWorker
  • func (w *PollerWorker) Poll(ctx context.Context, request *proto.PollingRequest) error
  • func (w *PollerWorker) SetLogger(logger *zap.Logger)
• type StoppableProcessRunner
• type StopperOption
  • func WithStopperCancelFuncList(cancelContexts *cancelCauseFuncMap) StopperOption
  • func WithStopperObserver(observer event.Observer) StopperOption
• type StopperWorker
  • func NewStopperWorker(opts ...StopperOption) *StopperWorker
  • func (w *StopperWorker) SetLogger(logger *zap.Logger)
  • func (w *StopperWorker) Stop(ctx context.Context, stopRequest *proto.StopRequest) error
• type TestConnectionWorker
  • func NewTestConnectionWorker(client *client.Client, observer event.Observer) *TestConnectionWorker
  • func (w *TestConnectionWorker) SetLogger(logger *zap.Logger)
  • func (w *TestConnectionWorker) Test(ctx context.Context, request *proto.DataStoreConnectionTestRequest) error
• type TriggerOption
  • func WithTraceCache(cache collector.TraceCache) TriggerOption
  • func WithTriggerObserver(observer event.Observer) TriggerOption
  • func WithTriggerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) TriggerOption
• type TriggerWorker
  • func NewTriggerWorker(client *client.Client, opts ...TriggerOption) *TriggerWorker
  • func (w *TriggerWorker) SetLogger(logger *zap.Logger)
  • func (w *TriggerWorker) Trigger(ctx context.Context, triggerRequest *proto.TriggerRequest) error

Functions

func NewProcessStopper

func NewProcessStopper() processStopper

Types

type PollerOption

type PollerOption func(*PollerWorker)

func WithInMemoryDatastore

func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption

func WithObserver

func WithObserver(observer event.Observer) PollerOption

func WithPollerStoppableProcessRunner

func WithPollerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) 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

func (*PollerWorker) SetLogger

func (w *PollerWorker) SetLogger(logger *zap.Logger)

type StoppableProcessRunner

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

type StopperOption

type StopperOption func(*StopperWorker)

func WithStopperCancelFuncList

func WithStopperCancelFuncList(cancelContexts *cancelCauseFuncMap) StopperOption

func WithStopperObserver

func WithStopperObserver(observer event.Observer) StopperOption

type StopperWorker

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

func NewStopperWorker

func NewStopperWorker(opts ...StopperOption) *StopperWorker

func (*StopperWorker) SetLogger

func (w *StopperWorker) SetLogger(logger *zap.Logger)

func (*StopperWorker) Stop

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

type TestConnectionWorker

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

func NewTestConnectionWorker

func NewTestConnectionWorker(client *client.Client, observer event.Observer) *TestConnectionWorker

func (*TestConnectionWorker) SetLogger

func (w *TestConnectionWorker) SetLogger(logger *zap.Logger)

func (*TestConnectionWorker) Test

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

type TriggerOption

type TriggerOption func(*TriggerWorker)

func WithTraceCache

func WithTraceCache(cache collector.TraceCache) TriggerOption

func WithTriggerObserver

func WithTriggerObserver(observer event.Observer) TriggerOption

func WithTriggerStoppableProcessRunner

func WithTriggerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) TriggerOption

type TriggerWorker

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

func NewTriggerWorker

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

func (*TriggerWorker) SetLogger

func (w *TriggerWorker) SetLogger(logger *zap.Logger)

func (*TriggerWorker) Trigger

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