Import of template processor and receiver

distributions/elastic-components/manifest.yaml

@@ -7,23 +7,32 @@ dist:
   otelcol_version: 0.105.0
 
 extensions:
+  - gomod: github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension v0.0.0
 
 connectors:
   - gomod: github.com/elastic/opentelemetry-collector-components/connector/spanmetricsconnectorv2 v0.0.0
 
 converters:
 
 receivers:
+  - gomod: github.com/elastic/opentelemetry-collector-components/receiver/templatereceiver v0.0.0
   - gomod: go.opentelemetry.io/collector/receiver/nopreceiver v0.105.0
 
 processors:
   - gomod: github.com/elastic/opentelemetry-collector-components/processor/elasticinframetricsprocessor v0.0.0
   - gomod: github.com/elastic/opentelemetry-collector-components/processor/elastictraceprocessor v0.0.0
+  - gomod: github.com/elastic/opentelemetry-collector-components/processor/templateprocessor v0.0.0
 
 exporters:
   - gomod: go.opentelemetry.io/collector/exporter/nopexporter v0.105.0
+  - gomod: go.opentelemetry.io/collector/exporter/debugexporter v0.105.0
 
 replaces:
+  - github.com/elastic/opentelemetry-collector-components/connector/spanmetricsconnectorv2 => ../connector/spanmetricsconnectorv2
+  - github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension => ../extension/filetemplateextension
   - github.com/elastic/opentelemetry-collector-components/processor/elasticinframetricsprocessor => ../processor/elasticinframetricsprocessor
   - github.com/elastic/opentelemetry-collector-components/processor/elastictraceprocessor => ../processor/elastictraceprocessor
-  - github.com/elastic/opentelemetry-collector-components/connector/spanmetricsconnectorv2 => ../connector/spanmetricsconnectorv2
+  - github.com/elastic/opentelemetry-collector-components/processor/templateprocessor => ../processor/templateprocessor
+  - github.com/elastic/opentelemetry-collector-components/receiver/templatereceiver => ../receiver/templatereceiver
+  - github.com/elastic/opentelemetry-collector-components/pkg/templates => ../pkg/templates
+

extension/filetemplateextension/Makefile

@@ -0,0 +1 @@
+include ../../Makefile.Common

extension/filetemplateextension/config.go

@@ -0,0 +1,43 @@
+// Licensed to Elasticsearch B.V. under one or more contributor
+// license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright
+// ownership. Elasticsearch B.V. licenses this file to you 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 filetemplateextension // import "github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension"
+
+import (
+	"errors"
+	"fmt"
+	"os"
+)
+
+type Config struct {
+	Path string `mapstructure:"path"`
+}
+
+func (c *Config) Validate() error {
+	if c.Path == "" {
+		return errors.New("path is required")
+	}
+	info, err := os.Stat(c.Path)
+	if err != nil {
+		return err
+	}
+	if !info.IsDir() {
+		return fmt.Errorf("path (%s) must be a directory", c.Path)
+	}
+
+	return nil
+}

extension/filetemplateextension/extension.go

@@ -0,0 +1,79 @@
+// Licensed to Elasticsearch B.V. under one or more contributor
+// license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright
+// ownership. Elasticsearch B.V. licenses this file to you 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 filetemplateextension // import "github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension"
+
+import (
+	"context"
+	"errors"
+	"io/fs"
+	"os"
+	"path/filepath"
+
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/confmap"
+	"go.opentelemetry.io/collector/confmap/provider/fileprovider"
+
+	"github.com/elastic/opentelemetry-collector-components/pkg/templates"
+)
+
+type fileTemplateExtension struct {
+	config *Config
+}
+
+var _ templates.TemplateFinder = &fileTemplateExtension{}
+
+func newFileTemplateExtension(config *Config) *fileTemplateExtension {
+	return &fileTemplateExtension{
+		config: config,
+	}
+}
+
+func (e *fileTemplateExtension) FindTemplate(ctx context.Context, name, version string) (templates.Template, error) {
+	path := filepath.Join(e.config.Path, name+".yml")
+	_, err := os.Stat(path)
+	if errors.Is(err, fs.ErrNotExist) {
+		return nil, templates.ErrNotFound
+	}
+	if err != nil {
+		return nil, err
+	}
+
+	return &templateFile{
+		path: path,
+	}, nil
+}
+
+func (*fileTemplateExtension) Start(context.Context, component.Host) error {
+	return nil
+}
+
+func (*fileTemplateExtension) Shutdown(context.Context) error {
+	return nil
+}
+
+type templateFile struct {
+	path string
+}
+
+func (t *templateFile) URI() string {
+	return "file:" + t.path
+}
+
+func (t *templateFile) ProviderFactory() confmap.ProviderFactory {
+	return fileprovider.NewFactory()
+}

extension/filetemplateextension/factory.go

@@ -0,0 +1,53 @@
+// Licensed to Elasticsearch B.V. under one or more contributor
+// license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright
+// ownership. Elasticsearch B.V. licenses this file to you 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 filetemplateextension // import "github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension"
+
+import (
+	"context"
+
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/extension"
+)
+
+var (
+	extensionType = component.MustNewType("file_templates")
+)
+
+const (
+	extensionStability = component.StabilityLevelAlpha
+)
+
+// NewFactory creates a factory for ack extension.
+func NewFactory() extension.Factory {
+	return extension.NewFactory(
+		extensionType,
+		createDefaultConfig,
+		createExtension,
+		extensionStability,
+	)
+}
+
+func createDefaultConfig() component.Config {
+	return &Config{
+		Path: "templates",
+	}
+}
+
+func createExtension(_ context.Context, _ extension.Settings, cfg component.Config) (extension.Extension, error) {
+	return newFileTemplateExtension(cfg.(*Config)), nil
+}

extension/filetemplateextension/go.mod

@@ -0,0 +1,43 @@
+module github.com/elastic/opentelemetry-collector-components/extension/filetemplateextension
+
+go 1.22.1
+
+require (
+	github.com/elastic/opentelemetry-collector-components/pkg/templates v0.0.0
+	go.opentelemetry.io/collector/component v0.105.0
+	go.opentelemetry.io/collector/confmap v0.105.0
+	go.opentelemetry.io/collector/confmap/provider/fileprovider v0.105.0
+	go.opentelemetry.io/collector/extension v0.105.0
+)
+
+require (
+	github.com/go-viper/mapstructure/v2 v2.1.0 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/hashicorp/go-version v1.7.0 // indirect
+	github.com/knadh/koanf/maps v0.1.1 // indirect
+	github.com/knadh/koanf/providers/confmap v0.1.0 // indirect
+	github.com/knadh/koanf/v2 v2.1.1 // indirect
+	github.com/mitchellh/copystructure v1.2.0 // indirect
+	github.com/mitchellh/reflectwalk v1.0.2 // indirect
+	github.com/rogpeppe/go-internal v1.12.0 // indirect
+	go.opentelemetry.io/collector/config/configtelemetry v0.105.0 // indirect
+	go.opentelemetry.io/collector/featuregate v1.13.0 // indirect
+	go.opentelemetry.io/collector/internal/globalgates v0.105.0 // indirect
+	go.opentelemetry.io/collector/pdata v1.13.0 // indirect
+	go.opentelemetry.io/otel v1.28.0 // indirect
+	go.opentelemetry.io/otel/metric v1.28.0 // indirect
+	go.opentelemetry.io/otel/trace v1.28.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
+	go.uber.org/zap v1.27.0 // indirect
+	golang.org/x/net v0.28.0 // indirect
+	golang.org/x/sys v0.24.0 // indirect
+	golang.org/x/text v0.17.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20240812133136-8ffd90a71988 // indirect
+	google.golang.org/grpc v1.65.0 // indirect
+	google.golang.org/protobuf v1.34.2 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)
+
+replace github.com/elastic/opentelemetry-collector-components/receiver/templatereceiver => ../../receiver/templatereceiver
+
+replace github.com/elastic/opentelemetry-collector-components/pkg/templates => ../../pkg/templates