Skip to content

Commit

Permalink
Activate Google Pubsub receiver and exporter (#10580)
Browse files Browse the repository at this point in the history
  • Loading branch information
hex1848 authored Jun 7, 2022
1 parent 98d12b9 commit 174a628
Show file tree
Hide file tree
Showing 8 changed files with 41 additions and 0 deletions.
2 changes: 2 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,8 @@
- `flinkmetricsreceiver`: Add implementation of Flink Metric Receiver (#10121)
- `windowseventlogreceiver` Added implementation of Windows Event Log Receiver (#9228)
- `vcenterreceiver`: Add metrics receiver for new vcenterreceiver component (#9224)
- `googlecloudpubsubreceiver` Activate the Google Cloud Pubsub receiver. (#10580)
- `googlecloudpubsubexporter` Activate the Google Cloud Pubsub exporter. (#10580)

### 💡 Enhancements 💡

Expand Down
4 changes: 4 additions & 0 deletions cmd/configschema/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,10 @@ require (
bitbucket.org/atlassian/go-asap/v2 v2.6.0 // indirect
cloud.google.com/go v0.101.1 // indirect
cloud.google.com/go/compute v1.6.1 // indirect
cloud.google.com/go/iam v0.3.0 // indirect
cloud.google.com/go/logging v1.4.2 // indirect
cloud.google.com/go/monitoring v1.5.0 // indirect
cloud.google.com/go/pubsub v1.21.1 // indirect
cloud.google.com/go/spanner v1.33.0 // indirect
cloud.google.com/go/trace v1.2.0 // indirect
code.cloudfoundry.org/clock v1.0.0 // indirect
Expand Down Expand Up @@ -256,6 +258,7 @@ require (
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/f5cloudexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/fileexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudpubsubexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/honeycombexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/humioexporter v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/influxdbexporter v0.52.0 // indirect
Expand Down Expand Up @@ -355,6 +358,7 @@ require (
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/flinkmetricsreceiver v0.0.0-00010101000000-000000000000 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubreceiver v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudspannerreceiver v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/hostmetricsreceiver v0.52.0 // indirect
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver v0.52.0 // indirect
Expand Down
8 changes: 8 additions & 0 deletions cmd/configschema/go.sum

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

8 changes: 8 additions & 0 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ require (
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/f5cloudexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/fileexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudpubsubexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/honeycombexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/humioexporter v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/influxdbexporter v0.52.0
Expand Down Expand Up @@ -95,6 +96,7 @@ require (
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/flinkmetricsreceiver v0.0.0-00010101000000-000000000000
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubreceiver v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudspannerreceiver v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/hostmetricsreceiver v0.52.0
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver v0.52.0
Expand Down Expand Up @@ -150,8 +152,10 @@ require (
bitbucket.org/atlassian/go-asap/v2 v2.6.0 // indirect
cloud.google.com/go v0.101.1 // indirect
cloud.google.com/go/compute v1.6.1 // indirect
cloud.google.com/go/iam v0.3.0 // indirect
cloud.google.com/go/logging v1.4.2 // indirect
cloud.google.com/go/monitoring v1.5.0 // indirect
cloud.google.com/go/pubsub v1.21.1 // indirect
cloud.google.com/go/spanner v1.33.0 // indirect
cloud.google.com/go/trace v1.2.0 // indirect
code.cloudfoundry.org/clock v1.0.0 // indirect
Expand Down Expand Up @@ -602,6 +606,8 @@ replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/filee

replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudexporter => ./exporter/googlecloudexporter

replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudpubsubexporter => ./exporter/googlecloudpubsubexporter

replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/honeycombexporter => ./exporter/honeycombexporter

replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/humioexporter => ./exporter/humioexporter
Expand Down Expand Up @@ -780,6 +786,8 @@ replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluen

replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudspannerreceiver => ./receiver/googlecloudspannerreceiver

replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubreceiver => ./receiver/googlecloudpubsubreceiver

replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/hostmetricsreceiver => ./receiver/hostmetricsreceiver

replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/influxdbreceiver => ./receiver/influxdbreceiver
Expand Down
8 changes: 8 additions & 0 deletions go.sum

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 4 additions & 0 deletions internal/components/components.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,7 @@ import (
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/f5cloudexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/fileexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudpubsubexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/honeycombexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/humioexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/influxdbexporter"
Expand Down Expand Up @@ -115,6 +116,7 @@ import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/flinkmetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudspannerreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/hostmetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver"
Expand Down Expand Up @@ -208,6 +210,7 @@ func Components() (component.Factories, error) {
flinkmetricsreceiver.NewFactory(),
fluentforwardreceiver.NewFactory(),
googlecloudspannerreceiver.NewFactory(),
googlecloudpubsubreceiver.NewFactory(),
hostmetricsreceiver.NewFactory(),
influxdbreceiver.NewFactory(),
iisreceiver.NewFactory(),
Expand Down Expand Up @@ -277,6 +280,7 @@ func Components() (component.Factories, error) {
f5cloudexporter.NewFactory(),
fileexporter.NewFactory(),
googlecloudexporter.NewFactory(),
googlecloudpubsubexporter.NewFactory(),
honeycombexporter.NewFactory(),
humioexporter.NewFactory(),
influxdbexporter.NewFactory(),
Expand Down
3 changes: 3 additions & 0 deletions internal/components/exporters_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -340,6 +340,9 @@ func TestDefaultExporters(t *testing.T) {
exporter: "googlecloud",
skipLifecycle: true, // Requires credentials to be able to successfully load the exporter
},
{
exporter: "googlecloudpubsub",
},
{
exporter: "honeycomb",
getConfigFn: func() config.Exporter {
Expand Down
4 changes: 4 additions & 0 deletions internal/components/receivers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,6 +127,10 @@ func TestDefaultReceivers(t *testing.T) {
{
receiver: "googlecloudspanner",
},
{
receiver: "googlecloudpubsub",
skipLifecyle: true, // Requires a pubsub subscription
},
{
receiver: "hostmetrics",
},
Expand Down

0 comments on commit 174a628

Please sign in to comment.