workers

Documentation

Index

• type PollerOption
  • func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption
  • func WithObserver(observer event.Observer) 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 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
• 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

Types

type PollerOption

type PollerOption func(*PollerWorker)

func WithInMemoryDatastore

func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption

func WithObserver

func WithObserver(observer event.Observer) 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 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

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