workers

Documentation

Index

• type PollerOption
  • func WithInMemoryDatastore(datastore tracedb.TraceDB) PollerOption
• type PollerWorker
  • func NewPollerWorker(client *client.Client, opts ...PollerOption) *PollerWorker
  • func (w *PollerWorker) Poll(ctx context.Context, request *proto.PollingRequest) error
• type TestConnectionWorker
  • func NewTestConnectionWorker(client *client.Client) *TestConnectionWorker
  • func (w *TestConnectionWorker) Test(ctx context.Context, request *proto.DataStoreConnectionTestRequest) error
• type TriggerOption
  • func WithTraceCache(cache collector.TraceCache) TriggerOption
• type TriggerWorker
  • func NewTriggerWorker(client *client.Client, opts ...TriggerOption) *TriggerWorker
  • 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

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 TestConnectionWorker

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

func NewTestConnectionWorker

func NewTestConnectionWorker(client *client.Client) *TestConnectionWorker

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

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