Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

forwarder

package

Go to main page

Versions in this module

v0

v0.9.0

Oct 20, 2021

retracted

Changes in this version

+ func HasFeature(features, flag Features) bool

type DefaultForwarder

+ func (f *DefaultForwarder) SubmitAgentChecksMetadata(payload Payloads, extra http.Header) error

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

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

+ type Features uint8

+ const CoreFeatures

+ const ProcessFeatures

+ const SysProbeFeatures

+ const TraceFeatures

+ func ClearFeature(features, flag Features) Features

+ func SetFeature(features, flag Features) Features

+ func ToggleFeature(features, flag Features) Features

type Forwarder

+ SubmitAgentChecksMetadata func(payload Payloads, extra http.Header) error

+ SubmitOrchestratorChecks func(payload Payloads, extra http.Header, payloadType int) (chan Response, error)

+ SubmitProcessDiscoveryChecks func(payload Payloads, extra http.Header) (chan Response, error)

type Options

+ CompletionHandler transaction.HTTPCompletionHandler

+ EnabledFeatures Features

+ RetryQueuePayloadsTotalMaxSize int

+ type SyncForwarder struct

+ func NewSyncForwarder(keysPerDomains map[string][]string, timeout time.Duration) *SyncForwarder

+ func (f *SyncForwarder) Start() error

+ func (f *SyncForwarder) Stop()

+ func (f *SyncForwarder) SubmitAgentChecksMetadata(payload Payloads, extra http.Header) error

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

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

+ func (f *SyncForwarder) SubmitEvents(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitHostMetadata(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitMetadata(payload Payloads, extra http.Header) error

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

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

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

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

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

+ func (f *SyncForwarder) SubmitServiceChecks(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitSketchSeries(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitV1CheckRuns(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitV1Intake(payload Payloads, extra http.Header) error

+ func (f *SyncForwarder) SubmitV1Series(payload Payloads, extra http.Header) error

v0.8.0

Jul 23, 2020

retracted

Changes in this version

+ const Started

+ const Stopped

+ type DefaultForwarder struct

+ NumberOfWorkers int

+ func NewDefaultForwarder(options *Options) *DefaultForwarder

+ func (f *DefaultForwarder) Start() error

+ func (f *DefaultForwarder) State() uint32

+ func (f *DefaultForwarder) Stop()

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

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

+ func (f *DefaultForwarder) SubmitEvents(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitHostMetadata(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitMetadata(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitPodChecks(payload Payloads, extra http.Header) (chan Response, error)

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

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

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

+ func (f *DefaultForwarder) SubmitSeries(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitServiceChecks(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitSketchSeries(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitV1CheckRuns(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitV1Intake(payload Payloads, extra http.Header) error

+ func (f *DefaultForwarder) SubmitV1Series(payload Payloads, extra http.Header) error

+ type Forwarder interface

+ Start func() error

+ Stop func()

+ SubmitConnectionChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitContainerChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitEvents func(payload Payloads, extra http.Header) error

+ SubmitHostMetadata func(payload Payloads, extra http.Header) error

+ SubmitMetadata func(payload Payloads, extra http.Header) error

+ SubmitPodChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitProcessChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitRTContainerChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitRTProcessChecks func(payload Payloads, extra http.Header) (chan Response, error)

+ SubmitSeries func(payload Payloads, extra http.Header) error

+ SubmitServiceChecks func(payload Payloads, extra http.Header) error

+ SubmitSketchSeries func(payload Payloads, extra http.Header) error

+ SubmitV1CheckRuns func(payload Payloads, extra http.Header) error

+ SubmitV1Intake func(payload Payloads, extra http.Header) error

+ SubmitV1Series func(payload Payloads, extra http.Header) error

+ type HTTPAttemptHandler func(transaction *HTTPTransaction)

+ type HTTPCompletionHandler func(transaction *HTTPTransaction, statusCode int, body []byte, err error)

+ type HTTPTransaction struct

+ Domain string

+ Endpoint string

+ ErrorCount int

+ Headers http.Header

+ Payload *[]byte

+ func NewHTTPTransaction() *HTTPTransaction

+ func (t *HTTPTransaction) GetCreatedAt() time.Time

+ func (t *HTTPTransaction) GetTarget() string

+ func (t *HTTPTransaction) Process(ctx context.Context, client *http.Client) error

+ type MockedForwarder struct

+ func (tf *MockedForwarder) Start() error

+ func (tf *MockedForwarder) Stop()

+ func (tf *MockedForwarder) SubmitConnectionChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitContainerChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitEvents(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitHostMetadata(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitMetadata(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitPodChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitProcessChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitRTContainerChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitRTProcessChecks(payload Payloads, extra http.Header) (chan Response, error)

+ func (tf *MockedForwarder) SubmitSeries(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitServiceChecks(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitSketchSeries(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitV1CheckRuns(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitV1Intake(payload Payloads, extra http.Header) error

+ func (tf *MockedForwarder) SubmitV1Series(payload Payloads, extra http.Header) error

+ type Options struct

+ APIKeyValidationInterval time.Duration

+ ConnectionResetInterval time.Duration

+ DisableAPIKeyChecking bool

+ KeysPerDomain map[string][]string

+ NumberOfWorkers int

+ RetryQueueSize int

+ func NewOptions(keysPerDomain map[string][]string) *Options

+ type Payloads []*[]byte

+ type Response struct

+ Body []byte

+ Domain string

+ Err error

+ StatusCode int

+ type Transaction interface

+ GetCreatedAt func() time.Time

+ GetTarget func() string

+ Process func(ctx context.Context, client *http.Client) error

+ type Worker struct

+ Client *http.Client

+ HighPrio <-chan Transaction

+ LowPrio <-chan Transaction

+ RequeueChan chan<- Transaction

+ func NewWorker(highPrioChan <-chan Transaction, lowPrioChan <-chan Transaction, ...) *Worker

+ func (w *Worker) ScheduleConnectionReset()

+ func (w *Worker) Start()

+ func (w *Worker) Stop(purgeHighPrio bool)