Skip to content

Commit fbbad1d

Browse files
committed
move PartialError to xconsumererror
1 parent 69e2696 commit fbbad1d

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

consumer/consumererror/partial.go renamed to consumer/consumererror/xconsumererror/partial.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,13 @@
11
// Copyright The OpenTelemetry Authors
22
// SPDX-License-Identifier: Apache-2.0
33

4-
package consumererror // import "go.opentelemetry.io/collector/consumer/consumererror"
4+
package xconsumererror // import "go.opentelemetry.io/collector/consumer/consumererror/xconsumererror"
55

6-
import "errors"
6+
import (
7+
"errors"
8+
9+
"go.opentelemetry.io/collector/consumer/consumererror"
10+
)
711

812
type partialError struct {
913
inner error
@@ -29,7 +33,7 @@ func (pe partialError) Failed() int {
2933
// to be written, but it is not possible to tell which particular items
3034
// failed.
3135
func NewPartial(err error, failed int) error {
32-
return NewPermanent(partialError{
36+
return consumererror.NewPermanent(partialError{
3337
inner: err,
3438
failed: failed,
3539
})

consumer/consumererror/partial_test.go renamed to consumer/consumererror/xconsumererror/partial_test.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,19 +1,20 @@
11
// Copyright The OpenTelemetry Authors
22
// SPDX-License-Identifier: Apache-2.0
33

4-
package consumererror
4+
package xconsumererror
55

66
import (
77
"errors"
88
"testing"
99

1010
"github.com/stretchr/testify/assert"
11+
"go.opentelemetry.io/collector/consumer/consumererror"
1112
)
1213

1314
func TestPartial(t *testing.T) {
1415
internalErr := errors.New("some points failed")
1516
err := NewPartial(internalErr, 5)
16-
assert.True(t, IsPermanent(err))
17+
assert.True(t, consumererror.IsPermanent(err))
1718
partialErr, ok := AsPartial(err)
1819
assert.True(t, ok)
1920
assert.Equal(t, 5, partialErr.Failed())

0 commit comments

Comments
 (0)