Add exprfilterprocessor skeleton

processor/exprfilterprocessor/config.go

@@ -0,0 +1,23 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "go.opentelemetry.io/collector/config/configmodels"
+)
+
+type Config struct {
+ configmodels.ProcessorSettings `mapstructure:",squash"`
+}

processor/exprfilterprocessor/config_test.go

@@ -0,0 +1,50 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "path"
+ "testing"
+
+ "github.com/stretchr/testify/assert"
+ "github.com/stretchr/testify/require"
+
+ "go.opentelemetry.io/collector/component/componenttest"
+ "go.opentelemetry.io/collector/config/configmodels"
+ "go.opentelemetry.io/collector/config/configtest"
+)
+
+func TestLoadConfig(t *testing.T) {
+ factories, err := componenttest.ExampleComponents()
+ require.NoError(t, err)
+
+ factory := NewFactory()
+ cfgType := configmodels.Type("exprfilter")
+ factories.Processors[cfgType] = factory
+
+ cfgPath := path.Join("testdata", "config.yaml")
+ cfg, err := configtest.LoadConfigFile(t, cfgPath, factories)
+ require.NoError(t, err)
+ require.NotNil(t, cfg)
+
+ procCfg := cfg.Processors["exprfilter"]
+ require.NotNil(t, procCfg)
+
+ flProcCfg := procCfg.(*Config)
+ require.NotNil(t, flProcCfg)
+
+ assert.Equal(t, cfgType, flProcCfg.TypeVal)
+ assert.Equal(t, "exprfilter", flProcCfg.NameVal)
+}

processor/exprfilterprocessor/factory.go

@@ -0,0 +1,62 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "context"
+
+ "go.opentelemetry.io/collector/component"
+ "go.opentelemetry.io/collector/config/configmodels"
+ "go.opentelemetry.io/collector/consumer"
+ "go.opentelemetry.io/collector/processor/processorhelper"
+)
+
+const (
+ typeStr = "exprfilter"
+)
+
+func NewFactory() component.ProcessorFactory {
+ return processorhelper.NewFactory(
+ typeStr,
+ createDefaultConfig,
+ processorhelper.WithMetrics(createProcessor),
+ )
+}
+
+func createDefaultConfig() configmodels.Processor {
+ return &Config{
+ ProcessorSettings: configmodels.ProcessorSettings{
+ TypeVal: typeStr,
+ NameVal: typeStr,
+ },
+ }
+}
+
+func createProcessor(
+ _ context.Context,
+ _ component.ProcessorCreateParams,
+ cfg configmodels.Processor,
+ nextConsumer consumer.MetricsConsumer,
+) (component.MetricsProcessor, error) {
+ proc := newProcessor(cfg.(*Config))
+ return processorhelper.NewMetricsProcessor(
+ cfg,
+ nextConsumer,
+ proc,
+ processorhelper.WithCapabilities(
+ component.ProcessorCapabilities{MutatesConsumedData: false},
+ ),
+ )
+}

processor/exprfilterprocessor/factory_test.go

@@ -0,0 +1,70 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "context"
+ "testing"
+
+ "github.com/stretchr/testify/assert"
+ "github.com/stretchr/testify/require"
+ "go.uber.org/zap"
+
+ "go.opentelemetry.io/collector/component"
+ "go.opentelemetry.io/collector/config/configcheck"
+ "go.opentelemetry.io/collector/config/configmodels"
+ "go.opentelemetry.io/collector/exporter/exportertest"
+)
+
+func TestType(t *testing.T) {
+ factory := NewFactory()
+ typ := factory.Type()
+ require.Equal(t, typ, configmodels.Type("exprfilter"))
+}
+
+func TestCreateDefaultConfig(t *testing.T) {
+ factory := NewFactory()
+ cfg := factory.CreateDefaultConfig()
+ assert.Equal(t, cfg, &Config{
+ ProcessorSettings: configmodels.ProcessorSettings{
+ NameVal: typeStr,
+ TypeVal: typeStr,
+ },
+ })
+ assert.NoError(t, configcheck.ValidateConfig(cfg))
+}
+
+func TestCreateProcessor(t *testing.T) {
+ factory := NewFactory()
+ cfg := factory.CreateDefaultConfig()
+ ctx := context.Background()
+ params := component.ProcessorCreateParams{Logger: zap.NewNop()}
+ tp, err := factory.CreateTraceProcessor(
+ ctx,
+ params,
+ cfg,
+ exportertest.NewNopTraceExporter(),
+ )
+ assert.Nil(t, tp)
+ assert.Error(t, err)
+
+ lp, err := factory.CreateLogsProcessor(ctx, params, cfg, exportertest.NewNopLogsExporter())
+ assert.Nil(t, lp)
+ assert.Error(t, err)
+
+ mp, err := factory.CreateMetricsProcessor(ctx, params, cfg, exportertest.NewNopMetricsExporter())
+ assert.NotNil(t, mp)
+ assert.NoError(t, err)
+}

processor/exprfilterprocessor/processor.go

@@ -0,0 +1,36 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "context"
+
+ "go.opentelemetry.io/collector/consumer/pdata"
+ "go.opentelemetry.io/collector/processor/processorhelper"
+)
+
+type processor struct {
+ cfg *Config
+}
+
+var _ processorhelper.MProcessor = (*processor)(nil)
+
+func newProcessor(cfg *Config) *processor {
+ return &processor{cfg: cfg}
+}
+
+func (p *processor) ProcessMetrics(ctx context.Context, metrics pdata.Metrics) (pdata.Metrics, error) {
+ return metrics, nil
+}

processor/exprfilterprocessor/processor_test.go

@@ -0,0 +1,31 @@
+// Copyright The OpenTelemetry Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package exprfilterprocessor
+
+import (
+ "context"
+ "testing"
+
+ "github.com/stretchr/testify/require"
+
+ "go.opentelemetry.io/collector/consumer/pdata"
+)
+
+func TestProcessor(t *testing.T) {
+ proc := newProcessor(&Config{})
+ in := pdata.NewMetrics()
+ out, _ := proc.ProcessMetrics(context.Background(), in)
+ require.Equal(t, in, out)
+}

processor/exprfilterprocessor/testdata/config.yaml

@@ -0,0 +1,15 @@
+receivers:
+ examplereceiver:
+
+processors:
+ exprfilter:
+
+exporters:
+ exampleexporter:
+
+service:
+ pipelines:
+ metrics:
+ receivers: [examplereceiver]
+ processors: [exprfilter]
+ exporters: [exampleexporter]