gRPC: DEADLINE_EXCEEDED

1
2
3
4
5
6
7
8
9

ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()

resp, err := client.SomeMethod(ctx, &pb.Request{})
if err != nil {
    if status.Code(err) == codes.DeadlineExceeded {
        log.Println("Timeout exceeded")
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

import grpc

channel = grpc.insecure_channel('localhost:50051')
stub = service_pb2_grpc.MyServiceStub(channel)

try:
    response = stub.SomeMethod(request, timeout=30)
except grpc.RpcError as e:
    if e.code() == grpc.StatusCode.DEADLINE_EXCEEDED:
        print("Timeout exceeded")

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

retryPolicy := `{
    "methodConfig": [{
        "name": [{"service": "myservice.MyService"}],
        "retryPolicy": {
            "maxAttempts": 3,
            "initialBackoff": "0.1s",
            "maxBackoff": "1s",
            "backoffMultiplier": 2
        }
    }]
}`