/
errors.go
64 lines (50 loc) · 1.63 KB
/
errors.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
package decoders
import "github.com/stephane-martin/skewer/utils/eerrors"
func ErrorUnknownFormat(format string) error {
return DecodingError(eerrors.Errorf("Unknown decoder: '%s'", format))
}
func InvalidTopicError(topic string) error {
return DecodingError(
eerrors.Errorf("The topic name is invalid: '%s'", topic),
)
}
func DecodingError(err error) error {
return eerrors.WithTypes(
eerrors.Wrap(err, "Error decoding message"),
"Decoding",
)
}
var EmptyMessageError = DecodingError(eerrors.New("Empty message"))
func UnmarshalJsonError(err error) error {
return DecodingError(
eerrors.Wrap(err, "Error unmarshaling the message from JSON"),
)
}
var ErrInvalidTimestamp = DecodingError(eerrors.New("TimeReported and TimeGenerated should be formatted in RFC3339 format"))
func InvalidCharsetError(err error) error {
return DecodingError(
eerrors.Wrap(err, "The input message was not properly encoded with specified charset"),
)
}
func InfluxDecodingError(err error) error {
return DecodingError(
eerrors.Wrap(err, "Error decoding InfluxDB line protocol"),
)
}
func RFC5424DecodingError(err error) error {
return DecodingError(
eerrors.Wrap(err, "Error decoding RFC5424 message"),
)
}
func W3CDecodingError(err error) error {
return DecodingError(
eerrors.Wrap(err, "Error decoding Extended Log Format message"),
)
}
var ErrInvalidSD = DecodingError(eerrors.New("Invalid structured data"))
var ErrInvalidPriority = DecodingError(eerrors.New("Invalid priority field"))
func NotEnoughPartsError(nb int) error {
return DecodingError(
eerrors.Errorf("The message does not have enough parts: %d, but minimum is 7", nb),
)
}