forked from open-telemetry/opentelemetry-collector
-
Notifications
You must be signed in to change notification settings - Fork 0
/
identifiable.go
106 lines (89 loc) · 3.44 KB
/
identifiable.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
// 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 config // import "go.opentelemetry.io/collector/config"
import (
"errors"
"fmt"
"strings"
)
// typeAndNameSeparator is the separator that is used between type and name in type/name composite keys.
const typeAndNameSeparator = "/"
// identifiable is an interface that all components configurations MUST embed.
type identifiable interface {
// ID returns the ID of the component that this configuration belongs to.
ID() ComponentID
// SetIDName updates the name part of the ID for the component that this configuration belongs to.
SetIDName(idName string)
}
// ComponentID represents the identity for a component. It combines two values:
// * type - the Type of the component.
// * name - the name of that component.
// The component ComponentID (combination type + name) is unique for a given component.Kind.
type ComponentID struct {
typeVal Type `mapstructure:"-"`
nameVal string `mapstructure:"-"`
}
// NewComponentID returns a new ComponentID with the given Type and empty name.
func NewComponentID(typeVal Type) ComponentID {
return ComponentID{typeVal: typeVal}
}
// NewComponentIDWithName returns a new ComponentID with the given Type and name.
func NewComponentIDWithName(typeVal Type, nameVal string) ComponentID {
return ComponentID{typeVal: typeVal, nameVal: nameVal}
}
// NewComponentIDFromString decodes a string in type[/name] format into ComponentID.
// The type and name components will have spaces trimmed, the "type" part must be present,
// the forward slash and "name" are optional.
// The returned ComponentID will be invalid if err is not-nil.
func NewComponentIDFromString(idStr string) (ComponentID, error) {
id := ComponentID{}
return id, id.UnmarshalText([]byte(idStr))
}
// Type returns the type of the component.
func (id ComponentID) Type() Type {
return id.typeVal
}
// Name returns the custom name of the component.
func (id ComponentID) Name() string {
return id.nameVal
}
// UnmarshalText implements the encoding.TextUnmarshaler interface.
func (id *ComponentID) UnmarshalText(text []byte) error {
idStr := string(text)
items := strings.SplitN(idStr, typeAndNameSeparator, 2)
if len(items) >= 1 {
id.typeVal = Type(strings.TrimSpace(items[0]))
}
if len(items) == 1 && id.typeVal == "" {
return errors.New("id must not be empty")
}
if id.typeVal == "" {
return fmt.Errorf("in %q id: the part before %s should not be empty", idStr, typeAndNameSeparator)
}
if len(items) > 1 {
// "name" part is present.
id.nameVal = strings.TrimSpace(items[1])
if id.nameVal == "" {
return fmt.Errorf("in %q id: the part after %s should not be empty", idStr, typeAndNameSeparator)
}
}
return nil
}
// String returns the ComponentID string representation as "type[/name]" format.
func (id ComponentID) String() string {
if id.nameVal == "" {
return string(id.typeVal)
}
return string(id.typeVal) + typeAndNameSeparator + id.nameVal
}