Documentation
¶
Index ¶
- type FlusherOTLP
- func (f *FlusherOTLP) Description() string
- func (f *FlusherOTLP) Export(pipelinegroupeEventSlice []*models.PipelineGroupEvents, ...) error
- func (f *FlusherOTLP) Flush(projectName string, logstoreName string, configName string, ...) error
- func (f *FlusherOTLP) Init(ctx pipeline.Context) error
- func (f *FlusherOTLP) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
- func (f *FlusherOTLP) SetUrgent(flag bool)
- func (f *FlusherOTLP) Stop() error
- type Version
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlusherOTLP ¶
type FlusherOTLP struct {
Version Version `json:"Version"`
Logs *helper.GrpcClientConfig `json:"Logs"`
Metrics *helper.GrpcClientConfig `json:"Metrics"`
Traces *helper.GrpcClientConfig `json:"Traces"`
// contains filtered or unexported fields
}
func (*FlusherOTLP) Description ¶
func (f *FlusherOTLP) Description() string
func (*FlusherOTLP) Export ¶
func (f *FlusherOTLP) Export(pipelinegroupeEventSlice []*models.PipelineGroupEvents, ctx pipeline.PipelineContext) error
Export data to destination, such as gRPC, console, file, etc. It is expected to return no error at most time because IsReady will be called before it to make sure there is space for next data.
func (*FlusherOTLP) IsReady ¶
func (f *FlusherOTLP) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
IsReady is ready to flush
func (*FlusherOTLP) SetUrgent ¶
func (f *FlusherOTLP) SetUrgent(flag bool)
Source Files
Click to show internal directories.
Click to hide internal directories.