-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add observe k8s attributes processor (#59)
### Description OB-34553 Add observek8sattributesprocessor ### Checklist - [ ] Created tests which fail without the change (if possible) - [ ] Extended the README / documentation, if necessary
- Loading branch information
1 parent
a70f4c0
commit 06c379d
Showing
244 changed files
with
32,248 additions
and
8,620 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,7 +1,7 @@ | ||
| # build | ||
| agent | ||
| output-logs | ||
| ./observe-agent | ||
| /observe-agent | ||
| dist/ | ||
| agent.exe | ||
| agent.exe~ | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -6,7 +6,7 @@ package diagnose | |
| import ( | ||
| "embed" | ||
| "fmt" | ||
| "observe/agent/cmd" | ||
| "observe-agent/cmd" | ||
| "os" | ||
| "text/template" | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
12 changes: 12 additions & 0 deletions
12
components/processors/observek8sattributesprocessor/README.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| # Observe K8s Attributes Processor | ||
| This processor operates on K8s resource logs from the `k8sobjectsreceiver` and adds additional attributes. | ||
|
|
||
|
|
||
| ## Caveats | ||
| This processor currently expects the `kind` field to be set at the base level of the event. In the case of `watch` events from the `k8sobjectsreceiver`, this field is instead present inside of the `object` field. This processor currently expects this field to be lifted from inside the `object` field to the base level by a transform processor earlier in the pipeline. If that isn't set up, this processor will only calculate status for `pull` events from the `k8sobjectsreceiver`. | ||
|
|
||
| ## Emitted Attributes | ||
|
|
||
| | Attribute Key | Description | | ||
| |-----------------------------------|--------------------------------------------------------------| | ||
| | `observe_transform.facets.status` | The derived Pod status based on the current Pod description. | |
8 changes: 8 additions & 0 deletions
8
components/processors/observek8sattributesprocessor/config.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,8 @@ | ||
| package observek8sattributesprocessor | ||
|
|
||
| type Config struct { | ||
| } | ||
|
|
||
| func (cfg *Config) Validate() error { | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
| //go:generate mdatagen metadata.yaml | ||
|
|
||
| // package observek8sattributesprocessor implements a processor which | ||
| // calculates and attaches additional k8s attributes | ||
| package observek8sattributesprocessor |
43 changes: 43 additions & 0 deletions
43
components/processors/observek8sattributesprocessor/factory.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,43 @@ | ||
| package observek8sattributesprocessor | ||
|
|
||
| import ( | ||
| "context" | ||
|
|
||
| "go.opentelemetry.io/collector/component" | ||
| "go.opentelemetry.io/collector/consumer" | ||
| "go.opentelemetry.io/collector/processor" | ||
| "go.opentelemetry.io/collector/processor/processorhelper" | ||
| ) | ||
|
|
||
| var processorCapabilities = consumer.Capabilities{MutatesData: true} | ||
|
|
||
| func NewFactory() processor.Factory { | ||
| return processor.NewFactory( | ||
| Type, | ||
| createDefaultConfig, | ||
| processor.WithLogs(createLogsProcessor, LogsStability), | ||
| ) | ||
| } | ||
|
|
||
| func createDefaultConfig() component.Config { | ||
| return &Config{} | ||
| } | ||
|
|
||
| func createLogsProcessor( | ||
| ctx context.Context, | ||
| set processor.Settings, | ||
| cfg component.Config, | ||
| nextConsumer consumer.Logs, | ||
| ) (processor.Logs, error) { | ||
| kep := newK8sEventsProcessor(set.Logger, cfg) | ||
| return processorhelper.NewLogsProcessor( | ||
| ctx, | ||
| set, | ||
| cfg, | ||
| nextConsumer, | ||
| kep.processLogs, | ||
| processorhelper.WithCapabilities(processorCapabilities), | ||
| processorhelper.WithStart(kep.Start), | ||
| processorhelper.WithShutdown(kep.Shutdown), | ||
| ) | ||
| } |
Oops, something went wrong.