Documentation
¶
Index ¶
- func NewProcessStopper() processStopper
- type PollerOption
- func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption
- func WithPollerLogger(logger *zap.Logger) PollerOption
- func WithPollerObserver(observer event.Observer) PollerOption
- func WithPollerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) PollerOption
- func WithPollerTracer(tracer trace.Tracer) PollerOption
- type PollerWorker
- type StoppableProcessRunner
- type StopperOption
- type StopperWorker
- type TestConnectionOption
- type TestConnectionWorker
- type TriggerOption
- func WithSensor(sensor sensors.Sensor) TriggerOption
- func WithTraceCache(cache collector.TraceCache) TriggerOption
- func WithTriggerLogger(logger *zap.Logger) TriggerOption
- func WithTriggerObserver(observer event.Observer) TriggerOption
- func WithTriggerStoppableProcessRunner(stoppableProcessRunner StoppableProcessRunner) TriggerOption
- func WithTriggerTracer(tracer trace.Tracer) TriggerOption
- type TriggerWorker
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 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 StopperOption ¶ added in v0.15.4
type StopperOption func(*StopperWorker)
func WithStopperCancelFuncList ¶ added in v0.15.4
func WithStopperCancelFuncList(cancelContexts *cancelCauseFuncMap) 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) SetLogger ¶ added in v0.15.4
func (w *StopperWorker) SetLogger(logger *zap.Logger)
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 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 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
¶
Directories
Click to show internal directories.
Click to hide internal directories.