errors.h

Go to the documentation of this file.

#pragma once

 
#include "fwd.h"
 
#include <library/cpp/yson/node/node.h>
 
#include <util/generic/yexception.h>
#include <util/generic/guid.h>
#include <util/generic/string.h>
#include <util/generic/vector.h>
#include <util/generic/yexception.h>
 
namespace NJson {
    class TJsonValue;
} // namespace NJson
 
namespace NYT {


class TApiUsageError
    : public TWithBackTrace<yexception>
{ };

class TRequestRetriesTimeout
    : public yexception
{ };


class TYtError
{
public:
    TYtError();

    explicit TYtError(const TString& message);

    TYtError(int code, TString message, TVector<TYtError> inner = {}, TNode::TMapType attributes = {});

    TYtError(const ::NJson::TJsonValue& value);

    TYtError(const TNode& value);

    bool ContainsErrorCode(int code) const;

    TString ShortDescription() const;

    TString FullDescription() const;

    int GetCode() const;

    const TString& GetMessage() const;

    bool ContainsText(const TStringBuf& text) const;

    const TVector<TYtError>& InnerErrors() const;

    void ParseFrom(TStringBuf jsonError);

    TSet<int> GetAllErrorCodes() const;

    bool HasAttributes() const;

    const TNode::TMapType& GetAttributes() const;

    TString GetYsonText() const;
 
private:
    int Code_;
    TString Message_;
    TVector<TYtError> InnerErrors_;
    TNode::TMapType Attributes_;
};


class TErrorResponse
    : public yexception
{
public:
    TErrorResponse(TYtError error, const TString& requestId);

    const TYtError& GetError() const;

    TString GetRequestId() const;

    bool IsFromTrailers() const;

    bool IsTransportError() const;

    bool IsResolveError() const;

    bool IsAccessDenied() const;

    bool IsUnauthorized() const;

    bool IsConcurrentTransactionLockConflict() const;

    bool IsRequestRateLimitExceeded() const;
 
    // YT can't serve request because it is overloaded.
    bool IsRequestQueueSizeLimitExceeded() const;

    bool IsChunkUnavailable() const;

    bool IsRequestTimedOut() const;

    bool IsNoSuchTransaction() const;
 
    // User reached their limit of concurrently running operations.
    bool IsConcurrentOperationsLimitReached() const;

    bool IsOk() const;
 
    void SetRawError(const TString& message);
    void SetError(TYtError error);
    void ParseFromJsonError(const TString& jsonError);
    void SetIsFromTrailers(bool isFromTrailers);
 
private:
    void Setup();
 
private:
    TString RequestId_;
    TYtError Error_;
    bool IsFromTrailers_ = false;
};


struct TFailedJobInfo
{
    TJobId JobId;

    TYtError Error;

    TString Stderr;
};


class TOperationFailedError
    : public yexception
{
public:
    enum EState {
        Failed,
        Aborted,
    };
 
public:
    TOperationFailedError(EState state, TOperationId id, TYtError ytError, TVector<TFailedJobInfo> failedJobInfo);

    EState GetState() const;

    TOperationId GetOperationId() const;

    const TYtError& GetError() const;

    const TVector<TFailedJobInfo>& GetFailedJobInfo() const;
 
private:
    EState State_;
    TOperationId OperationId_;
    TYtError Error_;
    TVector<TFailedJobInfo> FailedJobInfo_;
};

class TInputStreamAbortedError
    : public yexception
{ };

 
} // namespace NYT