http

package
v1.8.8 Latest Latest
Warning

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

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlusherHTTP

type FlusherHTTP struct {
	RemoteURL           string                       // RemoteURL to request
	Headers             map[string]string            // Headers to append to the http request
	Query               map[string]string            // Query parameters to append to the http request
	Timeout             time.Duration                // Request timeout, default is 60s
	Retry               retryConfig                  // Retry strategy, default is retry 3 times with delay time begin from 1second, max to 30 seconds
	Convert             helper.ConvertConfig         // Convert defines which protocol and format to convert to
	Concurrency         int                          // How many requests can be performed in concurrent
	Authenticator       *extensions.ExtensionConfig  // name and options of the extensions.ClientAuthenticator extension to use
	FlushInterceptor    *extensions.ExtensionConfig  // name and options of the extensions.FlushInterceptor extension to use
	RequestInterceptors []extensions.ExtensionConfig // custom request interceptor settings
	// contains filtered or unexported fields
}

func (*FlusherHTTP) Description

func (f *FlusherHTTP) Description() string

func (*FlusherHTTP) Export

func (f *FlusherHTTP) Export(groupEventsArray []*models.PipelineGroupEvents, ctx pipeline.PipelineContext) error

func (*FlusherHTTP) Flush

func (f *FlusherHTTP) Flush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

func (*FlusherHTTP) Init

func (f *FlusherHTTP) Init(context pipeline.Context) error

func (*FlusherHTTP) IsReady

func (f *FlusherHTTP) IsReady(projectName string, logstoreName string, logstoreKey int64) bool

func (*FlusherHTTP) SetUrgent

func (f *FlusherHTTP) SetUrgent(flag bool)

func (*FlusherHTTP) Stop

func (f *FlusherHTTP) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL