// 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 resource // import "go.opentelemetry.io/otel/sdk/resource" import ( "go.opentelemetry.io/otel/label" ) // Resource describes an entity about which identifying information // and metadata is exposed. Resource is an immutable object, // equivalent to a map from key to unique value. // // Resources should be passed and stored as pointers // (`*resource.Resource`). The `nil` value is equivalent to an empty // Resource. type Resource struct { labels label.Set } var emptyResource Resource // NewWithAttributes creates a resource from a set of attributes. If there are // duplicate keys present in the list of attributes, then the last // value found for the key is preserved. func NewWithAttributes(kvs ...label.KeyValue) *Resource { return &Resource{ labels: label.NewSet(kvs...), } } // String implements the Stringer interface and provides a // human-readable form of the resource. // // Avoid using this representation as the key in a map of resources, // use Equivalent() as the key instead. func (r *Resource) String() string { if r == nil { return "" } return r.labels.Encoded(label.DefaultEncoder()) } // Attributes returns a copy of attributes from the resource in a sorted order. // To avoid allocating a new slice, use an iterator. func (r *Resource) Attributes() []label.KeyValue { if r == nil { r = Empty() } return r.labels.ToSlice() } // Iter returns an interator of the Resource attributes. // This is ideal to use if you do not want a copy of the attributes. func (r *Resource) Iter() label.Iterator { if r == nil { r = Empty() } return r.labels.Iter() } // Equal returns true when a Resource is equivalent to this Resource. func (r *Resource) Equal(eq *Resource) bool { if r == nil { r = Empty() } if eq == nil { eq = Empty() } return r.Equivalent() == eq.Equivalent() } // Merge creates a new resource by combining resource a and b. // // If there are common keys between resource a and b, then the value // from resource b will overwrite the value from resource a, even // if resource b's value is empty. func Merge(a, b *Resource) *Resource { if a == nil && b == nil { return Empty() } if a == nil { return b } if b == nil { return a } // Note: 'b' labels will overwrite 'a' with last-value-wins in label.Key() // Meaning this is equivalent to: append(a.Attributes(), b.Attributes()...) mi := label.NewMergeIterator(b.LabelSet(), a.LabelSet()) combine := make([]label.KeyValue, 0, a.Len()+b.Len()) for mi.Next() { combine = append(combine, mi.Label()) } return NewWithAttributes(combine...) } // Empty returns an instance of Resource with no attributes. It is // equivalent to a `nil` Resource. func Empty() *Resource { return &emptyResource } // Equivalent returns an object that can be compared for equality // between two resources. This value is suitable for use as a key in // a map. func (r *Resource) Equivalent() label.Distinct { return r.LabelSet().Equivalent() } // LabelSet returns the equivalent *label.Set. func (r *Resource) LabelSet() *label.Set { if r == nil { r = Empty() } return &r.labels } // MarshalJSON encodes labels as a JSON list of { "Key": "...", "Value": ... } // pairs in order sorted by key. func (r *Resource) MarshalJSON() ([]byte, error) { if r == nil { r = Empty() } return r.labels.MarshalJSON() } // Len returns the number of unique key-values in this Resource. func (r *Resource) Len() int { if r == nil { return 0 } return r.labels.Len() } // Encoded returns an encoded representation of the resource by // applying a label encoder. The result is cached by the underlying // label set. func (r *Resource) Encoded(enc label.Encoder) string { if r == nil { return "" } return r.labels.Encoded(enc) }