Skip to content

Commit

Permalink
update depenencies version and small refactor Merge branch 'master' i…
Browse files Browse the repository at this point in the history
…nto update/deps/version

Signed-off-by: kpango <kpango@vdaas.org>
  • Loading branch information
kpango committed Aug 16, 2022
1 parent 97eed29 commit ae9a061
Showing 1 changed file with 20 additions and 21 deletions.
41 changes: 20 additions & 21 deletions internal/observability/trace/status.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,10 +25,9 @@ import (
)

const (
msgAttributeKey = attribute.Key("rpc.grpc.message")

StatusOK = ocodes.Ok
StatusError = ocodes.Error
grpcMsgAttributeKey = attribute.Key("rpc.grpc.message")
StatusOK = ocodes.Ok
StatusError = ocodes.Error
)

func FromGRPCStatus(code codes.Code, msg string) []attribute.KeyValue {
Expand Down Expand Up @@ -72,118 +71,118 @@ func FromGRPCStatus(code codes.Code, msg string) []attribute.KeyValue {
func StatusCodeOK(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeOk,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeCancelled(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeCancelled,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeUnknown(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeUnknown,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeInvalidArgument(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeInvalidArgument,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeDeadlineExceeded(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeDeadlineExceeded,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeNotFound(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeNotFound,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeAlreadyExists(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeAlreadyExists,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodePermissionDenied(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodePermissionDenied,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeResourceExhausted(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeResourceExhausted,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeFailedPrecondition(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeFailedPrecondition,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeAborted(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeAborted,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeOutOfRange(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeOutOfRange,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeUnimplemented(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeUnimplemented,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeInternal(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeInternal,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeUnavailable(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeUnavailable,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeDataLoss(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeDataLoss,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

func StatusCodeUnauthenticated(msg string) []attribute.KeyValue {
return []attribute.KeyValue{
semconv.RPCGRPCStatusCodeUnauthenticated,
msgAttributeKey.String(msg),
grpcMsgAttributeKey.String(msg),
}
}

0 comments on commit ae9a061

Please sign in to comment.