Skip to content

Commit 998864e

Browse files
tigrannajaryantigrannajaryan
authored
Fix typo in otelstef package name (#272)
Renamed oteltef -> otelstef (was missing "s").
1 parent e654e47 commit 998864e

File tree

199 files changed

+482
-1169
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

199 files changed

+482
-1169
lines changed

‎benchmarks/benchmarks_test.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ import (
1818
"github.com/splunk/stef/benchmarks/encodings/stef"
1919
"github.com/splunk/stef/benchmarks/generators"
2020
"github.com/splunk/stef/benchmarks/testutils"
21-
"github.com/splunk/stef/go/otel/oteltef"
21+
"github.com/splunk/stef/go/otel/otelstef"
2222
"github.com/splunk/stef/go/pdata/metrics"
2323
"github.com/splunk/stef/go/pkg"
2424
)
@@ -362,7 +362,7 @@ func BenchmarkSTEFReaderRead(b *testing.B) {
362362
b.ResetTimer()
363363
for i := 0; i < b.N; i++ {
364364
buf := bytes.NewBuffer(bodyBytes)
365-
reader, err := oteltef.NewMetricsReader(buf)
365+
reader, err := otelstef.NewMetricsReader(buf)
366366
if err != nil {
367367
log.Fatal(err)
368368
}
@@ -395,7 +395,7 @@ func BenchmarkSTEFSerializeMultipart(b *testing.B) {
395395
pointCount := 0
396396
for i := 0; i < b.N; i++ {
397397
outputBuf := &pkg.MemChunkWriter{}
398-
writer, err := oteltef.NewMetricsWriter(
398+
writer, err := otelstef.NewMetricsWriter(
399399
outputBuf, pkg.WriterOptions{Compression: pkg.CompressionZstd},
400400
)
401401
require.NoError(b, err)
@@ -430,7 +430,7 @@ func BenchmarkSTEFDeserializeMultipart(b *testing.B) {
430430
file,
431431
func(b *testing.B) {
432432
outputBuf := &pkg.MemChunkWriter{}
433-
writer, err := oteltef.NewMetricsWriter(
433+
writer, err := otelstef.NewMetricsWriter(
434434
outputBuf, pkg.WriterOptions{Compression: pkg.CompressionZstd},
435435
)
436436
require.NoError(b, err)

‎benchmarks/cmd/stats/main.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
"path"
1212
"time"
1313

14-
"github.com/splunk/stef/go/otel/oteltef"
14+
"github.com/splunk/stef/go/otel/otelstef"
1515
"github.com/splunk/stef/go/pkg"
1616

1717
"github.com/splunk/stef/benchmarks/cmd"
@@ -113,7 +113,7 @@ func collectSTEFFileStats(inputFilePath string, fileStats *MetricsStats) {
113113
log.Fatalf("Cannot read file %s: %v", inputFilePath, err)
114114
}
115115
defer func() { _ = inputFile.Close() }()
116-
reader, err := oteltef.NewMetricsReader(bufio.NewReaderSize(inputFile, 64*1024))
116+
reader, err := otelstef.NewMetricsReader(bufio.NewReaderSize(inputFile, 64*1024))
117117
if err != nil {
118118
log.Fatalf("Error reading file %s: %v", inputFilePath, err)
119119
}
@@ -125,7 +125,7 @@ func collectSTEFFileStats(inputFilePath string, fileStats *MetricsStats) {
125125
}
126126
}
127127

128-
func CollectRecordStats(reader *oteltef.MetricsReader, fileStats *MetricsStats) error {
128+
func CollectRecordStats(reader *otelstef.MetricsReader, fileStats *MetricsStats) error {
129129
tsMinTimestamp := uint64(math.MaxUint64)
130130
tsMaxTimestamp := uint64(0)
131131
var timeseriesDPCount uint64

‎benchmarks/cmd/stefbench/main.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ import (
1313
"github.com/splunk/stef/go/pkg"
1414

1515
"github.com/splunk/stef/benchmarks/cmd"
16-
"github.com/splunk/stef/go/otel/oteltef"
16+
"github.com/splunk/stef/go/otel/otelstef"
1717
)
1818

1919
var InputPath = ""
@@ -36,12 +36,12 @@ func main() {
3636
stefBench(InputPath)
3737
}
3838

39-
func openStef(inputFilePath string) (*oteltef.MetricsReader, func()) {
39+
func openStef(inputFilePath string) (*otelstef.MetricsReader, func()) {
4040
inputFile, err := os.Open(inputFilePath)
4141
if err != nil {
4242
log.Fatalf("Cannot read file %s: %v", inputFilePath, err)
4343
}
44-
reader, err := oteltef.NewMetricsReader(bufio.NewReaderSize(inputFile, 64*1024))
44+
reader, err := otelstef.NewMetricsReader(bufio.NewReaderSize(inputFile, 64*1024))
4545
if err != nil {
4646
log.Fatalf("Error reading file %s: %v", inputFilePath, err)
4747
}
@@ -90,7 +90,7 @@ func writeBench(inputFilePath string) {
9090
defer outputFile.Close()
9191

9292
outputBuf := &pkg.MemChunkWriter{}
93-
writer, err := oteltef.NewMetricsWriter(
93+
writer, err := otelstef.NewMetricsWriter(
9494
outputBuf, pkg.WriterOptions{
9595
Compression: reader.Header().Compression,
9696
},
@@ -169,8 +169,8 @@ func writeBench(inputFilePath string) {
169169
170170
var err2 error
171171
for {
172-
var record *oteltef.Metrics
173-
var record2 *oteltef.Metrics
172+
var record *otelstef.Metrics
173+
var record2 *otelstef.Metrics
174174
record, err = reader.Read()
175175
record2, err2 = reader2.Read()
176176
if err == io.EOF {

‎benchmarks/correctness_test.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ import (
1212

1313
"github.com/splunk/stef/benchmarks/encodings/stef"
1414
"github.com/splunk/stef/benchmarks/testutils"
15-
"github.com/splunk/stef/go/otel/oteltef"
15+
"github.com/splunk/stef/go/otel/otelstef"
1616
"github.com/splunk/stef/go/pdata/metrics"
1717
"github.com/splunk/stef/go/pdata/metrics/testtools"
1818
"github.com/splunk/stef/go/pkg"
@@ -40,7 +40,7 @@ func TestConvertSTEFFromToOTLP(t *testing.T) {
4040
srcCount := otlpDataSrc.DataPointCount()
4141

4242
buf := &pkg.MemChunkWriter{}
43-
writer, err := oteltef.NewMetricsWriter(buf, pkg.WriterOptions{})
43+
writer, err := otelstef.NewMetricsWriter(buf, pkg.WriterOptions{})
4444
require.NoError(t, err)
4545

4646
toStef := metrics.OtlpToStefSorted{}
@@ -50,7 +50,7 @@ func TestConvertSTEFFromToOTLP(t *testing.T) {
5050
err = writer.Flush()
5151
require.NoError(t, err)
5252

53-
reader, err := oteltef.NewMetricsReader(bytes.NewBuffer(buf.Bytes()))
53+
reader, err := otelstef.NewMetricsReader(bytes.NewBuffer(buf.Bytes()))
5454
require.NoError(t, err)
5555

5656
toOtlp := metrics.StefToOtlpUnsorted{}
@@ -102,7 +102,7 @@ func TestTEFMultiPart(t *testing.T) {
102102
tefBytes, err := tefStream.FinishStream()
103103
require.NoError(t, err)
104104

105-
tefReader, err := oteltef.NewMetricsReader(bytes.NewBuffer(tefBytes))
105+
tefReader, err := otelstef.NewMetricsReader(bytes.NewBuffer(tefBytes))
106106
require.NoError(t, err)
107107

108108
i := 0

‎benchmarks/encodings/parquet/parquet.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"go.opentelemetry.io/collector/pdata/pmetric"
1111

1212
"github.com/splunk/stef/benchmarks/encodings"
13-
"github.com/splunk/stef/go/otel/oteltef"
13+
"github.com/splunk/stef/go/otel/otelstef"
1414
"github.com/splunk/stef/go/pdata/metrics/sortedbymetric"
1515
)
1616

@@ -56,13 +56,13 @@ func (d *Encoding) FromOTLP(data pmetric.Metrics) (encodings.InMemoryData, error
5656

5757
var datums []Datum
5858
err = sorted.Iter(
59-
func(metric *oteltef.Metric, byMetric *sortedbymetric.ByMetric) error {
59+
func(metric *otelstef.Metric, byMetric *sortedbymetric.ByMetric) error {
6060
err := byMetric.Iter(
61-
func(resource *oteltef.Resource, byResource *sortedbymetric.ByResource) error {
61+
func(resource *otelstef.Resource, byResource *sortedbymetric.ByResource) error {
6262
err := byResource.Iter(
63-
func(scope *oteltef.Scope, byScope *sortedbymetric.ByScope) error {
63+
func(scope *otelstef.Scope, byScope *sortedbymetric.ByScope) error {
6464
err := byScope.Iter(
65-
func(attrs *oteltef.Attributes, points *sortedbymetric.Points) error {
65+
func(attrs *otelstef.Attributes, points *sortedbymetric.Points) error {
6666
for _, value := range *points {
6767
// TODO: histogram support
6868
datums = append(
@@ -126,7 +126,7 @@ func (d *Encoding) Encode(data encodings.InMemoryData) ([]byte, error) {
126126
return buf.Bytes(), nil
127127
}
128128

129-
func convertAttrs(attrs *oteltef.Attributes) (r []Attribute) {
129+
func convertAttrs(attrs *otelstef.Attributes) (r []Attribute) {
130130
for i := 0; i < attrs.Len(); i++ {
131131
attr := attrs.At(i)
132132
r = append(

‎benchmarks/encodings/parquet/parquetz.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import (
1010
"go.opentelemetry.io/collector/pdata/pmetric"
1111

1212
"github.com/splunk/stef/benchmarks/encodings"
13-
"github.com/splunk/stef/go/otel/oteltef"
13+
"github.com/splunk/stef/go/otel/otelstef"
1414
"github.com/splunk/stef/go/pdata/metrics/sortedbymetric"
1515
)
1616

@@ -142,13 +142,13 @@ func (d *EncodingZ) FromOTLP(data pmetric.Metrics) (encodings.InMemoryData, erro
142142

143143
var datums []DatumZ
144144
err = sorted.Iter(
145-
func(metric *oteltef.Metric, byMetric *sortedbymetric.ByMetric) error {
145+
func(metric *otelstef.Metric, byMetric *sortedbymetric.ByMetric) error {
146146
err := byMetric.Iter(
147-
func(resource *oteltef.Resource, byResource *sortedbymetric.ByResource) error {
147+
func(resource *otelstef.Resource, byResource *sortedbymetric.ByResource) error {
148148
err := byResource.Iter(
149-
func(scope *oteltef.Scope, byScope *sortedbymetric.ByScope) error {
149+
func(scope *otelstef.Scope, byScope *sortedbymetric.ByScope) error {
150150
err := byScope.Iter(
151-
func(attrs *oteltef.Attributes, points *sortedbymetric.Points) error {
151+
func(attrs *otelstef.Attributes, points *sortedbymetric.Points) error {
152152
for _, value := range *points {
153153
datums = append(
154154
datums, DatumZ{
@@ -209,7 +209,7 @@ func (d *EncodingZ) Encode(data encodings.InMemoryData) ([]byte, error) {
209209
return buf.Bytes(), nil
210210
}
211211

212-
func convertAttrsZ(attrs *oteltef.Attributes) (r []AttributeZ) {
212+
func convertAttrsZ(attrs *otelstef.Attributes) (r []AttributeZ) {
213213
for i := 0; i < attrs.Len(); i++ {
214214
attr := attrs.At(i)
215215
r = append(

‎benchmarks/encodings/stef/stef.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88

99
"github.com/splunk/stef/go/pkg"
1010

11-
"github.com/splunk/stef/go/otel/oteltef"
11+
"github.com/splunk/stef/go/otel/otelstef"
1212
otlpconvert "github.com/splunk/stef/go/pdata/metrics"
1313
"github.com/splunk/stef/go/pdata/metrics/sortedbymetric"
1414

@@ -27,7 +27,7 @@ func (d *STEFEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
2727
sorted := data.(*sortedbymetric.SortedTree)
2828

2929
outputBuf := &pkg.MemChunkWriter{}
30-
writer, err := oteltef.NewMetricsWriter(outputBuf, d.Opts)
30+
writer, err := otelstef.NewMetricsWriter(outputBuf, d.Opts)
3131
if err != nil {
3232
return nil, err
3333
}
@@ -47,7 +47,7 @@ func (d *STEFEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
4747

4848
func (d *STEFEncoding) Decode(b []byte) (any, error) {
4949
buf := bytes.NewBuffer(b)
50-
r, err := oteltef.NewMetricsReader(buf)
50+
r, err := otelstef.NewMetricsReader(buf)
5151
if err != nil {
5252
return nil, err
5353
}
@@ -67,7 +67,7 @@ func (d *STEFEncoding) Decode(b []byte) (any, error) {
6767

6868
func (*STEFEncoding) ToOTLP(data []byte) (pmetric.Metrics, error) {
6969
buf := bytes.NewBuffer(data)
70-
reader, err := oteltef.NewMetricsReader(buf)
70+
reader, err := otelstef.NewMetricsReader(buf)
7171
if err != nil {
7272
return pmetric.NewMetrics(), err
7373
}
@@ -100,7 +100,7 @@ func (e *STEFEncoding) StartMultipart(compression string) (encodings.MetricMulti
100100
opts.Compression = pkg.CompressionZstd
101101
}
102102

103-
writer, err := oteltef.NewMetricsWriter(
103+
writer, err := otelstef.NewMetricsWriter(
104104
outputBuf, opts,
105105
)
106106
if err != nil {
@@ -114,7 +114,7 @@ func (e *STEFEncoding) StartMultipart(compression string) (encodings.MetricMulti
114114

115115
type stefMultipart struct {
116116
outputBuf *pkg.MemChunkWriter
117-
writer *oteltef.MetricsWriter
117+
writer *otelstef.MetricsWriter
118118
}
119119

120120
func (s *stefMultipart) AppendPart(part pmetric.Metrics) error {

‎benchmarks/encodings/stef/stefs.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88

99
"github.com/splunk/stef/go/pkg"
1010

11-
"github.com/splunk/stef/go/otel/oteltef"
11+
"github.com/splunk/stef/go/otel/otelstef"
1212
otlpconvert "github.com/splunk/stef/go/pdata/metrics"
1313

1414
"github.com/splunk/stef/benchmarks/encodings"
@@ -30,7 +30,7 @@ func (d *STEFSEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
3030
metrics := data.(pmetric.Metrics)
3131

3232
outputBuf := &pkg.MemChunkWriter{}
33-
writer, err := oteltef.NewMetricsWriter(outputBuf, d.Opts)
33+
writer, err := otelstef.NewMetricsWriter(outputBuf, d.Opts)
3434
if err != nil {
3535
return nil, err
3636
}
@@ -51,7 +51,7 @@ func (d *STEFSEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
5151

5252
func (d *STEFSEncoding) Decode(b []byte) (any, error) {
5353
buf := bytes.NewBuffer(b)
54-
r, err := oteltef.NewMetricsReader(buf)
54+
r, err := otelstef.NewMetricsReader(buf)
5555
if err != nil {
5656
return nil, err
5757
}
@@ -71,7 +71,7 @@ func (d *STEFSEncoding) Decode(b []byte) (any, error) {
7171

7272
func (*STEFSEncoding) ToOTLP(data []byte) (pmetric.Metrics, error) {
7373
buf := bytes.NewBuffer(data)
74-
reader, err := oteltef.NewMetricsReader(buf)
74+
reader, err := otelstef.NewMetricsReader(buf)
7575
if err != nil {
7676
return pmetric.NewMetrics(), err
7777
}
@@ -100,7 +100,7 @@ func (e *STEFSEncoding) StartMultipart(compression string) (encodings.MetricMult
100100
opts.Compression = pkg.CompressionZstd
101101
}
102102

103-
writer, err := oteltef.NewMetricsWriter(
103+
writer, err := otelstef.NewMetricsWriter(
104104
outputBuf, opts,
105105
)
106106
if err != nil {
@@ -114,7 +114,7 @@ func (e *STEFSEncoding) StartMultipart(compression string) (encodings.MetricMult
114114

115115
type stefsMultipart struct {
116116
outputBuf *pkg.MemChunkWriter
117-
writer *oteltef.MetricsWriter
117+
writer *otelstef.MetricsWriter
118118
sorter otlpconvert.PDataSorter
119119
}
120120

‎benchmarks/encodings/stef/stefu.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88

99
"github.com/splunk/stef/go/pkg"
1010

11-
"github.com/splunk/stef/go/otel/oteltef"
11+
"github.com/splunk/stef/go/otel/otelstef"
1212
otlpconvert "github.com/splunk/stef/go/pdata/metrics"
1313

1414
"github.com/splunk/stef/benchmarks/encodings"
@@ -31,7 +31,7 @@ func (d *STEFUEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
3131
metrics := data.(pmetric.Metrics)
3232

3333
outputBuf := &pkg.MemChunkWriter{}
34-
writer, err := oteltef.NewMetricsWriter(outputBuf, d.Opts)
34+
writer, err := otelstef.NewMetricsWriter(outputBuf, d.Opts)
3535
if err != nil {
3636
return nil, err
3737
}
@@ -52,7 +52,7 @@ func (d *STEFUEncoding) Encode(data encodings.InMemoryData) ([]byte, error) {
5252

5353
func (d *STEFUEncoding) Decode(b []byte) (any, error) {
5454
buf := bytes.NewBuffer(b)
55-
r, err := oteltef.NewMetricsReader(buf)
55+
r, err := otelstef.NewMetricsReader(buf)
5656
if err != nil {
5757
return nil, err
5858
}
@@ -72,7 +72,7 @@ func (d *STEFUEncoding) Decode(b []byte) (any, error) {
7272

7373
func (*STEFUEncoding) ToOTLP(data []byte) (pmetric.Metrics, error) {
7474
buf := bytes.NewBuffer(data)
75-
reader, err := oteltef.NewMetricsReader(buf)
75+
reader, err := otelstef.NewMetricsReader(buf)
7676
if err != nil {
7777
return pmetric.NewMetrics(), err
7878
}
@@ -101,7 +101,7 @@ func (e *STEFUEncoding) StartMultipart(compression string) (encodings.MetricMult
101101
opts.Compression = pkg.CompressionZstd
102102
}
103103

104-
writer, err := oteltef.NewMetricsWriter(
104+
writer, err := otelstef.NewMetricsWriter(
105105
outputBuf, opts,
106106
)
107107
if err != nil {
@@ -115,7 +115,7 @@ func (e *STEFUEncoding) StartMultipart(compression string) (encodings.MetricMult
115115

116116
type stefuMultipart struct {
117117
outputBuf *pkg.MemChunkWriter
118-
writer *oteltef.MetricsWriter
118+
writer *otelstef.MetricsWriter
119119
}
120120

121121
func (s *stefuMultipart) AppendPart(part pmetric.Metrics) error {

‎benchmarks/otlp2sortedtree_test.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88
"modernc.org/b/v2"
99

1010
"github.com/splunk/stef/benchmarks/testutils"
11-
"github.com/splunk/stef/go/otel/oteltef"
11+
"github.com/splunk/stef/go/otel/otelstef"
1212
"github.com/splunk/stef/go/pdata/metrics/sortedbymetric"
1313
"github.com/splunk/stef/go/pkg"
1414
)
@@ -43,7 +43,7 @@ func TestConvertFromOTLP(t *testing.T) {
4343
require.NoError(t, err)
4444

4545
outputBuf := &pkg.MemChunkWriter{}
46-
writer, err := oteltef.NewMetricsWriter(outputBuf, pkg.WriterOptions{})
46+
writer, err := otelstef.NewMetricsWriter(outputBuf, pkg.WriterOptions{})
4747
require.NoError(t, err)
4848

4949
err = sorted.ToStef(writer)

0 commit comments

Comments
 (0)