opentelemetry

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

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) Flush

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

func (*FlusherOTLP) Init

func (f *FlusherOTLP) Init(ctx pipeline.Context) error

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)

func (*FlusherOTLP) Stop

func (f *FlusherOTLP) Stop() error

Stop ...

type Version

type Version string