if errors.As(err, &cqlRequestErr) {
if cqlRequestErr.Code() == gocql.ErrCodeOverloaded {
Cause: enumspb.RESOURCE_EXHAUSTED_CAUSE_SYSTEM_OVERLOADED,
Scope: enumspb.RESOURCE_EXHAUSTED_SCOPE_SYSTEM,
Message: fmt.Sprintf("operation %v encountered %v", operation, cqlRequestErr.Error()),
}
}
if cqlRequestErr.Code() == gocql.ErrCodeInvalid {