@@ -969,7 +969,8 @@ type LoaderInterceptor struct {
969
969
}
970
970
971
971
func (i * LoaderInterceptor ) UnaryInterceptor (ctx context.Context , method string , req interface {}, reply interface {}, cc * grpc.ClientConn ,
972
- invoker grpc.UnaryInvoker , opts ... grpc.CallOption ) error {
972
+ invoker grpc.UnaryInvoker , opts ... grpc.CallOption ,
973
+ ) error {
973
974
if i .enabled {
974
975
loader := NewLoader ()
975
976
loader .Start ()
@@ -981,7 +982,8 @@ func (i *LoaderInterceptor) UnaryInterceptor(ctx context.Context, method string,
981
982
}
982
983
983
984
func (i * LoaderInterceptor ) StreamInterceptor (ctx context.Context , desc * grpc.StreamDesc , cc * grpc.ClientConn , method string ,
984
- streamer grpc.Streamer , opts ... grpc.CallOption ) (grpc.ClientStream , error ) {
985
+ streamer grpc.Streamer , opts ... grpc.CallOption ,
986
+ ) (grpc.ClientStream , error ) {
985
987
stream , err := streamer (ctx , desc , cc , method , opts ... )
986
988
return loaderStream {ClientStream : stream , loaderEnabled : i .enabled }, err
987
989
}
@@ -1137,6 +1139,8 @@ func serviceErrorCodeToError(code meshpb.ServiceErrorCode) error {
1137
1139
switch code {
1138
1140
case meshpb .ServiceErrorCode_NOT_LOGGED_IN :
1139
1141
return internal .ErrNotLoggedIn
1142
+ case meshpb .ServiceErrorCode_MONITOR_FAILURE :
1143
+ return internal .ErrMonitorFailed
1140
1144
case meshpb .ServiceErrorCode_API_FAILURE , meshpb .ServiceErrorCode_CONFIG_FAILURE :
1141
1145
fallthrough
1142
1146
default :
0 commit comments