defaultforwarder

package module
v0.58.0-rc.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 4, 2024 License: Apache-2.0 Imports: 36 Imported by: 3

README

package forwarder

This package is responsible for sending payloads to the backend. Payloads can come from different sources in different formats, the forwarder will not inspect them.

The forwarder can receive multiple domains with a list of API keys for each of them. Every payload will be sent to every domain/API keys couple, this became a Transaction. Transactions will be retried on error. The newest transactions will be retried first. Transactions are consumed by Workers asynchronously.

Usage


KeysPerDomains := map[string][]string{
	"http://api.datadog.com": {"my_secret_key_1", "my_secret_key_2"},
	"http://debug.api.com":   {"secret_api"},
}

forwarder := forwarder.NewForwarder(KeysPerDomains)
forwarder.NumberOfWorkers = 1 // default: config.GetInt("forwarder_num_workers")
forwarder.Start()

// ...

payload1 := []byte("some payload")
payload2 := []byte("another payload")
forwarder.SubmitSeries(Payloads{&payload1, &payload2}, ...)

// ...

forwarder.Stop()

Configuration

There are several settings that influence the behavior of the forwarder.

Exponential backoff and circuit breaker settings
  • forwarder_backoff_factor - This controls the overlap between consecutive retry interval ranges. When set to 2, there is a guarantee that there will be no overlap. The overlap will asymptotically approach 50% the higher the value is set. Values less then 2 are verboten as there will be range gaps. Default: 2
  • forwarder_backoff_base - This controls the rate of exponential growth. Also, you can calculate the start of the very first retry interval range by evaluating the following expression: forwarder_backoff_base / forwarder_backoff_factor * 2. Default: 2
  • forwarder_backoff_max - This is the maximum number of seconds to wait for a retry. Default: 64
  • forwarder_recovery_interval - This controls how many retry interval ranges to step down for an endpoint upon success. Default: 2
  • forwarder_recovery_reset - Whether or not a successful request should completely clear an endpoint's error count. Default: false

Internal

The forwarder is composed of multiple parts:

DefaultForwarder

DefaultForwarder it the default implementation of the Forwarder interface (and the only one for now). This class is in charge of receiving payloads, creating the HTTP transactions and distributing them among every domainForwarder.

domainForwarder

The agent can be configured to send the same payload to multiple destinations. Each destination (or domain) can be configured with 1 or more API keys. Every payload will be sent to each domain/API key pair.

A domainForwarder is in charge of sending payloads to one domain. This avoids slowing down every domain when one is down/slow. Each domainForwarder will have a number of dedicated Worker to process Transaction. We process new transactions first and then (when the workers have time) we retry the erroneous ones (newest transactions are retried first).

We start dropping transactions (oldest first) when the sum of all the payload sizes is bigger than forwarder_retry_queue_payloads_max_size (see the agent configuration).

Disclaimer: using multiple API keys with the Datadog backend will multiply your billing ! Most customers will only use one API key.

Worker

A Worker processes transactions coming from 2 queues: HighPrio and LowPrio. New transactions are sent to the HighPrio queue and the ones to retry are sent to LowPrio. A Worker is dedicated to on domain (ie: domainForwarder).

blockedEndpoints (or exponential backoff)

When a transaction fails to be sent to a backend we blacklist that particular endpoints for some time to avoid flooding an unavailable endpoint (the transactions will be retried later). A blacklist is specific to one endpoint on one domain (ie: "http(s):///"). The blacklist time will grow, up to a maximum, as more and more errors are encountered for that endpoint and is gradually cleared when a transaction is successful. The blacklist is shared by all workers.

Transaction

A HTTPTransaction contains every information about a payload and how/where to send it. On failure a transaction will be retried later (see blockedEndpoints).

Documentation

Overview

Package defaultforwarder implements a component to send payloads to the backend

Index

Constants

View Source 
const (
	// Stopped represent the internal state of an unstarted Forwarder.
	Stopped uint32 = iota
	// Started represent the internal state of an started Forwarder.
	Started
	// Disabled represent the internal state of a disabled Forwarder.
	Disabled
)

Variables

This section is empty.

Functions

func HasFeature 

func HasFeature(features, flag Features) bool

HasFeature lets you know if a specific feature flag is set in a feature set

func MockModule 

func MockModule() fxutil.Module

MockModule defines the fx options for the mock component.

func ModulWithOptionTMP added in v0.58.0 

func ModulWithOptionTMP(option fx.Option) fxutil.Module

ModulWithOptionTMP defines the fx options for this component with an option. This is a temporary function to until configsync is cleanup.

func Module 

func Module(params Params) fxutil.Module

Module defines the fx options for this component.

func NewForwarder 

func NewForwarder(config config.Component, log log.Component, lc fx.Lifecycle, ignoreLifeCycleError bool, options *Options, useNoopForwarder bool) provides

NewForwarder returns a new forwarder component.

func NewHTTPClient 

func NewHTTPClient(config config.Component) *http.Client

NewHTTPClient creates a new http.Client

func WithDisableAPIKeyChecking added in v0.58.0 

func WithDisableAPIKeyChecking() option

WithDisableAPIKeyChecking disables the API key checking

func WithFeatures added in v0.58.0 

func WithFeatures(features ...Features) option

WithFeatures sets a features to the forwarder

func WithNoopForwarder added in v0.58.0 

func WithNoopForwarder() option

WithNoopForwarder sets the forwarder to use the noop forwarder

func WithResolvers added in v0.58.0 

func WithResolvers() option

WithResolvers enables the forwarder to use resolvers

Types

type Component 

type Component interface {
	// TODO: (components) When the code of the forwarder will be
	// in /comp/forwarder move the content of forwarder.Forwarder inside this interface.
	Forwarder
}

Component is the component type.

type DefaultForwarder 

type DefaultForwarder struct {

	// NumberOfWorkers Number of concurrent HTTP request made by the DefaultForwarder (default 4).
	NumberOfWorkers int
	// contains filtered or unexported fields
}

DefaultForwarder is the default implementation of the Forwarder.

func NewDefaultForwarder 

func NewDefaultForwarder(config config.Component, log log.Component, options *Options) *DefaultForwarder

NewDefaultForwarder returns a new DefaultForwarder. TODO: (components) Remove this method and other exported methods in comp/forwarder.

func (*DefaultForwarder) Start 

func (f *DefaultForwarder) Start() error

Start initialize and runs the forwarder.

func (*DefaultForwarder) State 

func (f *DefaultForwarder) State() uint32

State returns the internal state of the forwarder (Started or Stopped)

func (*DefaultForwarder) Stop 

func (f *DefaultForwarder) Stop()

Stop all the component of a forwarder and free resources

func (*DefaultForwarder) SubmitAgentChecksMetadata 

func (f *DefaultForwarder) SubmitAgentChecksMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitAgentChecksMetadata will send a agentchecks_metadata tag type payload to Datadog backend.

func (*DefaultForwarder) SubmitConnectionChecks 

func (f *DefaultForwarder) SubmitConnectionChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitConnectionChecks sends connection checks

func (*DefaultForwarder) SubmitContainerChecks 

func (f *DefaultForwarder) SubmitContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitContainerChecks sends container checks

func (*DefaultForwarder) SubmitHostMetadata 

func (f *DefaultForwarder) SubmitHostMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitHostMetadata will send a host_metadata tag type payload to Datadog backend.

func (*DefaultForwarder) SubmitMetadata 

func (f *DefaultForwarder) SubmitMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitMetadata will send a metadata type payload to Datadog backend.

func (*DefaultForwarder) SubmitOrchestratorChecks 

func (f *DefaultForwarder) SubmitOrchestratorChecks(payload transaction.BytesPayloads, extra http.Header, payloadType int) (chan Response, error)

SubmitOrchestratorChecks sends orchestrator checks

func (*DefaultForwarder) SubmitOrchestratorManifests 

func (f *DefaultForwarder) SubmitOrchestratorManifests(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitOrchestratorManifests sends orchestrator manifests

func (*DefaultForwarder) SubmitProcessChecks 

func (f *DefaultForwarder) SubmitProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessChecks sends process checks

func (*DefaultForwarder) SubmitProcessDiscoveryChecks 

func (f *DefaultForwarder) SubmitProcessDiscoveryChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessDiscoveryChecks sends process discovery checks

func (*DefaultForwarder) SubmitProcessEventChecks 

func (f *DefaultForwarder) SubmitProcessEventChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessEventChecks sends process events checks

func (*DefaultForwarder) SubmitRTContainerChecks 

func (f *DefaultForwarder) SubmitRTContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitRTContainerChecks sends real time container checks

func (*DefaultForwarder) SubmitRTProcessChecks 

func (f *DefaultForwarder) SubmitRTProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitRTProcessChecks sends real time process checks

func (*DefaultForwarder) SubmitSeries 

func (f *DefaultForwarder) SubmitSeries(payloads transaction.BytesPayloads, extra http.Header) error

SubmitSeries will send timeseries to the v2 endpoint

func (*DefaultForwarder) SubmitSketchSeries 

func (f *DefaultForwarder) SubmitSketchSeries(payload transaction.BytesPayloads, extra http.Header) error

SubmitSketchSeries will send payloads to Datadog backend - PROTOTYPE FOR PERCENTILE

func (*DefaultForwarder) SubmitV1CheckRuns 

func (f *DefaultForwarder) SubmitV1CheckRuns(payload transaction.BytesPayloads, extra http.Header) error

SubmitV1CheckRuns will send service checks to v1 endpoint (this will be removed once the backend handles v2 endpoints).

func (*DefaultForwarder) SubmitV1Intake 

func (f *DefaultForwarder) SubmitV1Intake(payload transaction.BytesPayloads, kind transaction.Kind, extra http.Header) error

SubmitV1Intake will send payloads to the universal `/intake/` endpoint used by Agent v.5

func (*DefaultForwarder) SubmitV1Series 

func (f *DefaultForwarder) SubmitV1Series(payloads transaction.BytesPayloads, extra http.Header) error

SubmitV1Series will send timeserie to v1 endpoint (this will be remove once the backend handles v2 endpoints).

type Features 

type Features uint8

Features is a bitmask to enable specific forwarder features 

const (
	// CoreFeatures bitmask to enable specific core features
	CoreFeatures Features = 1 << iota
	// TraceFeatures bitmask to enable specific trace features
	TraceFeatures
	// ProcessFeatures bitmask to enable specific process features
	ProcessFeatures
	// SysProbeFeatures bitmask to enable specific system-probe features
	SysProbeFeatures
)

func ClearFeature 

func ClearFeature(features, flag Features) Features

ClearFeature clears forwarder features from a feature set

func SetFeature 

func SetFeature(features, flag Features) Features

SetFeature sets forwarder features in a feature set

func ToggleFeature 

func ToggleFeature(features, flag Features) Features

ToggleFeature toggles forwarder features in a feature set

type Forwarder 

type Forwarder interface {
	SubmitV1Series(payload transaction.BytesPayloads, extra http.Header) error
	SubmitV1Intake(payload transaction.BytesPayloads, kind transaction.Kind, extra http.Header) error
	SubmitV1CheckRuns(payload transaction.BytesPayloads, extra http.Header) error
	SubmitSeries(payload transaction.BytesPayloads, extra http.Header) error
	SubmitSketchSeries(payload transaction.BytesPayloads, extra http.Header) error
	SubmitHostMetadata(payload transaction.BytesPayloads, extra http.Header) error
	SubmitAgentChecksMetadata(payload transaction.BytesPayloads, extra http.Header) error
	SubmitMetadata(payload transaction.BytesPayloads, extra http.Header) error
	SubmitProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitProcessDiscoveryChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitProcessEventChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitRTProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitRTContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitConnectionChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
	SubmitOrchestratorChecks(payload transaction.BytesPayloads, extra http.Header, payloadType int) (chan Response, error)
	SubmitOrchestratorManifests(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)
}

Forwarder interface allows packages to send payload to the backend

type Mock 

type Mock interface {
	Component
}

Mock implements mock-specific methods.

type NoopForwarder 

type NoopForwarder struct{}

NoopForwarder is a Forwarder doing nothing and not returning any responses.

func (NoopForwarder) Start 

func (f NoopForwarder) Start() error

Start does nothing.

func (NoopForwarder) Stop 

func (f NoopForwarder) Stop()

Stop does nothing.

func (NoopForwarder) SubmitAgentChecksMetadata 

func (f NoopForwarder) SubmitAgentChecksMetadata(_ transaction.BytesPayloads, _ http.Header) error

SubmitAgentChecksMetadata does nothing.

func (NoopForwarder) SubmitConnectionChecks 

func (f NoopForwarder) SubmitConnectionChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitConnectionChecks does nothing.

func (NoopForwarder) SubmitContainerChecks 

func (f NoopForwarder) SubmitContainerChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitContainerChecks does nothing.

func (NoopForwarder) SubmitHostMetadata 

func (f NoopForwarder) SubmitHostMetadata(_ transaction.BytesPayloads, _ http.Header) error

SubmitHostMetadata does nothing.

func (NoopForwarder) SubmitMetadata 

func (f NoopForwarder) SubmitMetadata(_ transaction.BytesPayloads, _ http.Header) error

SubmitMetadata does nothing.

func (NoopForwarder) SubmitOrchestratorChecks 

func (f NoopForwarder) SubmitOrchestratorChecks(_ transaction.BytesPayloads, _ http.Header, _ int) (chan Response, error)

SubmitOrchestratorChecks does nothing.

func (NoopForwarder) SubmitOrchestratorManifests 

func (f NoopForwarder) SubmitOrchestratorManifests(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitOrchestratorManifests does nothing.

func (NoopForwarder) SubmitProcessChecks 

func (f NoopForwarder) SubmitProcessChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitProcessChecks does nothing.

func (NoopForwarder) SubmitProcessDiscoveryChecks 

func (f NoopForwarder) SubmitProcessDiscoveryChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitProcessDiscoveryChecks does nothing.

func (NoopForwarder) SubmitProcessEventChecks 

func (f NoopForwarder) SubmitProcessEventChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitProcessEventChecks does nothing

func (NoopForwarder) SubmitRTContainerChecks 

func (f NoopForwarder) SubmitRTContainerChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitRTContainerChecks does nothing.

func (NoopForwarder) SubmitRTProcessChecks 

func (f NoopForwarder) SubmitRTProcessChecks(_ transaction.BytesPayloads, _ http.Header) (chan Response, error)

SubmitRTProcessChecks does nothing.

func (NoopForwarder) SubmitSeries 

func (f NoopForwarder) SubmitSeries(_ transaction.BytesPayloads, _ http.Header) error

SubmitSeries does nothing.

func (NoopForwarder) SubmitSketchSeries 

func (f NoopForwarder) SubmitSketchSeries(_ transaction.BytesPayloads, _ http.Header) error

SubmitSketchSeries does nothing.

func (NoopForwarder) SubmitV1CheckRuns 

func (f NoopForwarder) SubmitV1CheckRuns(_ transaction.BytesPayloads, _ http.Header) error

SubmitV1CheckRuns does nothing.

func (NoopForwarder) SubmitV1Intake 

func (f NoopForwarder) SubmitV1Intake(_ transaction.BytesPayloads, _ transaction.Kind, _ http.Header) error

SubmitV1Intake does nothing.

func (NoopForwarder) SubmitV1Series 

func (f NoopForwarder) SubmitV1Series(_ transaction.BytesPayloads, _ http.Header) error

SubmitV1Series does nothing.

type Options 

type Options struct {
	NumberOfWorkers                int
	RetryQueuePayloadsTotalMaxSize int
	DisableAPIKeyChecking          bool
	EnabledFeatures                Features
	APIKeyValidationInterval       time.Duration
	DomainResolvers                map[string]resolver.DomainResolver
	ConnectionResetInterval        time.Duration
	CompletionHandler              transaction.HTTPCompletionHandler
}

Options contain the configuration options for the DefaultForwarder

func NewOptions 

func NewOptions(config config.Component, log log.Component, keysPerDomain map[string][]string) *Options

NewOptions creates new Options with default values

func NewOptionsWithResolvers 

func NewOptionsWithResolvers(config config.Component, log log.Component, domainResolvers map[string]resolver.DomainResolver) *Options

NewOptionsWithResolvers creates new Options with default values

func (*Options) SetEnabledFeatures added in v0.58.0 

func (o *Options) SetEnabledFeatures(features []Features)

SetEnabledFeatures sets the features enabled

type Params 

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

Params contains the parameters to create a forwarder.

func NewParams 

func NewParams(options ...option) Params

NewParams initializes a new Params struct

type PointSuccessfullySent 

type PointSuccessfullySent interface {
	OnPointSuccessfullySent(int)
}

PointSuccessfullySent is called when sending successfully a point to the intake.

type Response 

type Response struct {
	Domain     string
	Body       []byte
	StatusCode int
	Err        error
}

Response contains the response details of a successfully posted transaction

type SyncForwarder 

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

SyncForwarder is a very simple Forwarder synchronously sending the data to the intake.

func NewSyncForwarder 

func NewSyncForwarder(config config.Component, log log.Component, keysPerDomain map[string][]string, timeout time.Duration) *SyncForwarder

NewSyncForwarder returns a new synchronous forwarder.

func (*SyncForwarder) Start 

func (f *SyncForwarder) Start() error

Start starts the sync forwarder: nothing to do.

func (*SyncForwarder) Stop 

func (f *SyncForwarder) Stop()

Stop stops the sync forwarder: nothing to do.

func (*SyncForwarder) SubmitAgentChecksMetadata 

func (f *SyncForwarder) SubmitAgentChecksMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitAgentChecksMetadata will send a agentchecks_metadata tag type payload to Datadog backend.

func (*SyncForwarder) SubmitConnectionChecks 

func (f *SyncForwarder) SubmitConnectionChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitConnectionChecks sends connection checks

func (*SyncForwarder) SubmitContainerChecks 

func (f *SyncForwarder) SubmitContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitContainerChecks sends container checks

func (*SyncForwarder) SubmitHostMetadata 

func (f *SyncForwarder) SubmitHostMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitHostMetadata will send a host_metadata tag type payload to Datadog backend.

func (*SyncForwarder) SubmitMetadata 

func (f *SyncForwarder) SubmitMetadata(payload transaction.BytesPayloads, extra http.Header) error

SubmitMetadata will send a metadata type payload to Datadog backend.

func (*SyncForwarder) SubmitOrchestratorChecks 

func (f *SyncForwarder) SubmitOrchestratorChecks(payload transaction.BytesPayloads, extra http.Header, payloadType int) (chan Response, error)

SubmitOrchestratorChecks sends orchestrator checks

func (*SyncForwarder) SubmitOrchestratorManifests 

func (f *SyncForwarder) SubmitOrchestratorManifests(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitOrchestratorManifests sends orchestrator manifests

func (*SyncForwarder) SubmitProcessChecks 

func (f *SyncForwarder) SubmitProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessChecks sends process checks

func (*SyncForwarder) SubmitProcessDiscoveryChecks 

func (f *SyncForwarder) SubmitProcessDiscoveryChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessDiscoveryChecks sends process discovery checks

func (*SyncForwarder) SubmitProcessEventChecks 

func (f *SyncForwarder) SubmitProcessEventChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitProcessEventChecks sends process events checks

func (*SyncForwarder) SubmitRTContainerChecks 

func (f *SyncForwarder) SubmitRTContainerChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitRTContainerChecks sends real time container checks

func (*SyncForwarder) SubmitRTProcessChecks 

func (f *SyncForwarder) SubmitRTProcessChecks(payload transaction.BytesPayloads, extra http.Header) (chan Response, error)

SubmitRTProcessChecks sends real time process checks

func (*SyncForwarder) SubmitSeries 

func (f *SyncForwarder) SubmitSeries(payload transaction.BytesPayloads, extra http.Header) error

SubmitSeries will send timeseries to the v2 endpoint

func (*SyncForwarder) SubmitSketchSeries 

func (f *SyncForwarder) SubmitSketchSeries(payload transaction.BytesPayloads, extra http.Header) error

SubmitSketchSeries will send payloads to Datadog backend - PROTOTYPE FOR PERCENTILE

func (*SyncForwarder) SubmitV1CheckRuns 

func (f *SyncForwarder) SubmitV1CheckRuns(payload transaction.BytesPayloads, extra http.Header) error

SubmitV1CheckRuns will send service checks to v1 endpoint (this will be removed once the backend handles v2 endpoints).

func (*SyncForwarder) SubmitV1Intake 

func (f *SyncForwarder) SubmitV1Intake(payload transaction.BytesPayloads, kind transaction.Kind, extra http.Header) error

SubmitV1Intake will send payloads to the universal `/intake/` endpoint used by Agent v.5

func (*SyncForwarder) SubmitV1Series 

func (f *SyncForwarder) SubmitV1Series(payload transaction.BytesPayloads, extra http.Header) error

SubmitV1Series will send timeserie to v1 endpoint (this will be remove once the backend handles v2 endpoints).

type Worker 

type Worker struct {

	// Client the http client used to processed transactions.
	Client *http.Client
	// HighPrio is the channel used to receive high priority transaction from the Forwarder.
	HighPrio <-chan transaction.Transaction
	// LowPrio is the channel used to receive low priority transaction from the Forwarder.
	LowPrio <-chan transaction.Transaction
	// RequeueChan is the channel used to send failed transaction back to the Forwarder.
	RequeueChan chan<- transaction.Transaction
	// contains filtered or unexported fields
}

Worker consumes Transaction (aka transactions) from the Forwarder and processes them. If the transaction fails to be processed the Worker will send it back to the Forwarder to be retried later.

func NewWorker 

func NewWorker(
	config config.Component,
	log log.Component,
	highPrioChan <-chan transaction.Transaction,
	lowPrioChan <-chan transaction.Transaction,
	requeueChan chan<- transaction.Transaction,
	blocked *blockedEndpoints,
	pointSuccessfullySent PointSuccessfullySent,
) *Worker

NewWorker returns a new worker to consume Transaction from inputChan and push back erroneous ones into requeueChan.

func (*Worker) ScheduleConnectionReset 

func (w *Worker) ScheduleConnectionReset()

ScheduleConnectionReset allows signaling the worker that all connections should be recreated before sending the next transaction. Returns immediately.

func (*Worker) Start 

func (w *Worker) Start()

Start starts a Worker.

func (*Worker) Stop 

func (w *Worker) Stop(purgeHighPrio bool)

Stop stops the worker.

Source Files

View all Source files

Directories

Path Synopsis
Package endpoints stores a collection of `transaction.Endpoint` mainly used by the forwarder package to send data to Datadog using the right request path for a given type of data.
 Package endpoints stores a collection of `transaction.Endpoint` mainly used by the forwarder package to send data to Datadog using the right request path for a given type of data.
internal
retry
Package retry provides retry mechanisms for the forwarder.
 Package retry provides retry mechanisms for the forwarder.
Package resolver contains logic to perform per `transaction.Endpoint` domain resolution.
 Package resolver contains logic to perform per `transaction.Endpoint` domain resolution.
Package transaction defines the transaction of the forwarder
 Package transaction defines the transaction of the forwarder

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.