Documentation ¶
Index ¶
- Constants
- type AggregatorOpenTelemetry
- func (p *AggregatorOpenTelemetry) Add(log *protocol.Log, ctx map[string]interface{}) error
- func (*AggregatorOpenTelemetry) Description() string
- func (p *AggregatorOpenTelemetry) Flush() []*protocol.LogGroup
- func (p *AggregatorOpenTelemetry) Init(context ilogtail.Context, que ilogtail.LogGroupQueue) (int, error)
- func (p *AggregatorOpenTelemetry) Reset()
Constants ¶
View Source
const ( MaxLogCount = 1024 MaxLogGroupSize = 3 * 1024 * 1024 )
View Source
const DefaultLogLogstore = "otlp-logs"
View Source
const DefaultMetricsLogstore = "otlp-metrics"
View Source
const DefaultTraceLogstore = "otlp-traces"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregatorOpenTelemetry ¶
type AggregatorOpenTelemetry struct { MaxLogGroupCount int MaxLogCount int PackFlag bool Topic string MetricsLogstore string TraceLogstore string LogLogstore string Lock *sync.Mutex // contains filtered or unexported fields }
func NewAggregatorOpenTelemetry ¶
func NewAggregatorOpenTelemetry() *AggregatorOpenTelemetry
func (*AggregatorOpenTelemetry) Add ¶
func (p *AggregatorOpenTelemetry) Add(log *protocol.Log, ctx map[string]interface{}) error
Add adds @log to aggregator. Add use first content as route key Add returns any error encountered, nil means success.
func (*AggregatorOpenTelemetry) Description ¶
func (*AggregatorOpenTelemetry) Description() string
func (*AggregatorOpenTelemetry) Flush ¶
func (p *AggregatorOpenTelemetry) Flush() []*protocol.LogGroup
func (*AggregatorOpenTelemetry) Init ¶
func (p *AggregatorOpenTelemetry) Init(context ilogtail.Context, que ilogtail.LogGroupQueue) (int, error)
func (*AggregatorOpenTelemetry) Reset ¶
func (p *AggregatorOpenTelemetry) Reset()
Click to show internal directories.
Click to hide internal directories.