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
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) 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
Click to show internal directories.
Click to hide internal directories.