http

Documentation

Index

• type FlusherHTTP
  • func (f *FlusherHTTP) Description() string
  • func (f *FlusherHTTP) Export(groupEventsArray []*models.PipelineGroupEvents, ctx pipeline.PipelineContext) error
  • func (f *FlusherHTTP) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (f *FlusherHTTP) Init(context pipeline.Context) error
  • func (f *FlusherHTTP) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (f *FlusherHTTP) SetUrgent(flag bool)
  • func (f *FlusherHTTP) Stop() error

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