Categorygithub.com/open-telemetry/opentelemetry-collector-contrib/extension/ackextension
modulepackage
0.121.0
Repository: https://github.com/open-telemetry/opentelemetry-collector-contrib.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
2
Files
142 SLOC

# README

Ack Extension

Status
Stabilityalpha
Distributionscontrib, k8s
IssuesOpen issues Closed issues
Code Owners@zpzhuSplunk, @splunkericl

This extension allows acking of data upon successful processing. The upstream agent can choose to send event again if ack fails.

Configuration

extensions:
  ack:
    storage:
    max_number_of_partition: 1000000
    max_number_of_pending_acks_per_partition: 1000000

receivers:
  splunk_hec:
    ack_extension: ack

service:
  extensions: [ack]
  pipelines:
    logs:
      receivers: [splunk_hec]

# Functions

NewFactory creates a factory for ack extension.

# Structs

Config defines configuration for ack extension.

# Interfaces

AckExtension is an extension that can be used by other otel components to support acking of data and can be queried against to check the status of given ack ids.