introduce streaming

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

Streaming adoption example for text encoding extension

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: naming consistency

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove context from decode calls

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove stream buffer option and rely on user set bufio reader

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: renaming, use functional type & introduce xstream module

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: fix go version to minor

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: move stream helper under pkg, and rename to xstreamencoding

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: Introduce offset handling

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: method name, doc comment & text encoding offset tracking

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

introduce streaming

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

Streaming adoption example for text encoding extension

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: naming consistenct

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove context from decode calls

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove stream buffer option and rely on user set bufio reader

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: renaming, use functional type & introduce xstream module

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: fix go version to minor

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: move stream helper under pkg, and rename to xstreamencoding

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

introduce streaming

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

Streaming adoption example for text encoding extension

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: naming consistenct

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove context from decode calls

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: remove stream buffer option and rely on user set bufio reader

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

review changes: renaming, use functional type & introduce xstream module

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

introduce streaming

Signed-off-by: Kavindu Dodanduwa <kavindu.dodanduwa@elastic.co>

Author: Kavindu-Dodan

.chloggen/config.yaml

@@ -179,6 +179,7 @@ components:
     - pkg/translator/zipkin
     - pkg/winperfcounters
     - pkg/xk8stest
+    - pkg/xstreamencoding
     - processor/akamaidetector
     - processor/alibabaecsdetector
     - processor/attributes

.chloggen/encoding-extension-stream-package.yaml

@@ -0,0 +1,27 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. receiver/filelog)
+component: extension/encoding
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Introduce experimental xstream module under encoding module. Module contains experimental streaming helpers.
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [38780]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

.chloggen/feat_encoding-extension-streaming.yaml

@@ -0,0 +1,27 @@
+# Use this changelog template to create an entry for release notes.
+
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. receiver/filelog)
+component: extension/encoding
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: Introduce streaming support for encoding extensions
+
+# Mandatory: One or more tracking issues related to the change. You can use the PR number here if no issue exists.
+issues: [38780]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:
+
+# If your change doesn't affect end users or the exported elements of any package,
+# you should instead start your pull request title with [chore] or use the "Skip Changelog" label.
+# Optional: The change log or logs in which this entry should be included.
+# e.g. '[user]' or '[user, api]'
+# Include 'user' if the change is relevant to end users.
+# Include 'api' if there is a change to a library API.
+# Default: '[user]'
+change_logs: []

.github/CODEOWNERS

@@ -110,6 +110,7 @@ extension/encoding/jsonlogencodingextension/                     @open-telemetry
 extension/encoding/otlpencodingextension/                        @open-telemetry/collector-contrib-approvers @dao-jun @VihasMakwana
 extension/encoding/skywalkingencodingextension/                  @open-telemetry/collector-contrib-approvers @JaredTan95
 extension/encoding/textencodingextension/                        @open-telemetry/collector-contrib-approvers @MovieStoreGuy @atoulme
+extension/encoding/xstream/                                      @open-telemetry/collector-contrib-approvers @Kavindu-Dodan @axw
 extension/encoding/zipkinencodingextension/                      @open-telemetry/collector-contrib-approvers @MovieStoreGuy @dao-jun
 extension/googleclientauthextension/                             @open-telemetry/collector-contrib-approvers @dashpole @aabmass @braydonk @jsuereth @psx95 @ridwanmsharif
 extension/headerssetterextension/                                @open-telemetry/collector-contrib-approvers @VihasMakwana
@@ -193,6 +194,7 @@ pkg/translator/splunk/                                           @open-telemetry
 pkg/translator/zipkin/                                           @open-telemetry/collector-contrib-approvers @MovieStoreGuy @andrzej-stencel @crobert-1
 pkg/winperfcounters/                                             @open-telemetry/collector-contrib-approvers @dashpole @Mrod1598 @alxbl @pjanotti
 pkg/xk8stest/                                                    @open-telemetry/collector-contrib-approvers @crobert-1
+pkg/xstreamencoding/                                             @open-telemetry/collector-contrib-approvers @Kavindu-Dodan @axw
 processor/attributesprocessor/                                   @open-telemetry/collector-contrib-approvers @boostchicken
 processor/coralogixprocessor/                                    @open-telemetry/collector-contrib-approvers @crobert-1 @povilasv @iblancasa
 processor/cumulativetodeltaprocessor/                            @open-telemetry/collector-contrib-approvers @TylerHelmuth

.github/ISSUE_TEMPLATE/beta_stability.yaml

@@ -107,6 +107,7 @@ body:
       - extension/encoding/otlpencoding
       - extension/encoding/skywalkingencoding
       - extension/encoding/textencoding
+      - extension/encoding/xstream
       - extension/encoding/zipkinencoding
       - extension/googleclientauth
       - extension/headerssetter
@@ -190,6 +191,7 @@ body:
       - pkg/translator/zipkin
       - pkg/winperfcounters
       - pkg/xk8stest
+      - pkg/xstreamencoding
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta

.github/ISSUE_TEMPLATE/bug_report.yaml

@@ -110,6 +110,7 @@ body:
       - extension/encoding/otlpencoding
       - extension/encoding/skywalkingencoding
       - extension/encoding/textencoding
+      - extension/encoding/xstream
       - extension/encoding/zipkinencoding
       - extension/googleclientauth
       - extension/headerssetter
@@ -193,6 +194,7 @@ body:
       - pkg/translator/zipkin
       - pkg/winperfcounters
       - pkg/xk8stest
+      - pkg/xstreamencoding
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta

.github/ISSUE_TEMPLATE/feature_request.yaml

@@ -104,6 +104,7 @@ body:
       - extension/encoding/otlpencoding
       - extension/encoding/skywalkingencoding
       - extension/encoding/textencoding
+      - extension/encoding/xstream
       - extension/encoding/zipkinencoding
       - extension/googleclientauth
       - extension/headerssetter
@@ -187,6 +188,7 @@ body:
       - pkg/translator/zipkin
       - pkg/winperfcounters
       - pkg/xk8stest
+      - pkg/xstreamencoding
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta

.github/ISSUE_TEMPLATE/other.yaml

@@ -104,6 +104,7 @@ body:
       - extension/encoding/otlpencoding
       - extension/encoding/skywalkingencoding
       - extension/encoding/textencoding
+      - extension/encoding/xstream
       - extension/encoding/zipkinencoding
       - extension/googleclientauth
       - extension/headerssetter
@@ -187,6 +188,7 @@ body:
       - pkg/translator/zipkin
       - pkg/winperfcounters
       - pkg/xk8stest
+      - pkg/xstreamencoding
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta

.github/ISSUE_TEMPLATE/unmaintained.yaml

@@ -109,6 +109,7 @@ body:
       - extension/encoding/otlpencoding
       - extension/encoding/skywalkingencoding
       - extension/encoding/textencoding
+      - extension/encoding/xstream
       - extension/encoding/zipkinencoding
       - extension/googleclientauth
       - extension/headerssetter
@@ -192,6 +193,7 @@ body:
       - pkg/translator/zipkin
       - pkg/winperfcounters
       - pkg/xk8stest
+      - pkg/xstreamencoding
       - processor/attributes
       - processor/coralogix
       - processor/cumulativetodelta

.github/component_labels.txt

@@ -91,6 +91,7 @@ extension/encoding/jsonlogencodingextension extension/encoding/jsonlogencoding
 extension/encoding/otlpencodingextension extension/encoding/otlpencoding
 extension/encoding/skywalkingencodingextension extension/encoding/skywalkingencoding
 extension/encoding/textencodingextension extension/encoding/textencoding
+extension/encoding/xstream extension/encoding/xstream
 extension/encoding/zipkinencodingextension extension/encoding/zipkinencoding
 extension/googleclientauthextension extension/googleclientauth
 extension/headerssetterextension extension/headerssetter
@@ -174,6 +175,7 @@ pkg/translator/splunk pkg/translator/splunk
 pkg/translator/zipkin pkg/translator/zipkin
 pkg/winperfcounters pkg/winperfcounters
 pkg/xk8stest pkg/xk8stest
+pkg/xstreamencoding pkg/xstreamencoding
 processor/attributesprocessor processor/attributes
 processor/coralogixprocessor processor/coralogix
 processor/cumulativetodeltaprocessor processor/cumulativetodelta