http

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Mar 22, 2023 License: Apache-2.0 Imports: 17 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
	// 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