Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.