Documentation
¶
Index ¶
- Variables
- type Auth
- func (*Auth) Descriptor() ([]byte, []int)
- func (m *Auth) GetToken() string
- func (*Auth) ProtoMessage()
- func (m *Auth) Reset()
- func (m *Auth) String() string
- func (m *Auth) XXX_DiscardUnknown()
- func (m *Auth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Auth) XXX_Merge(src proto.Message)
- func (m *Auth) XXX_Size() int
- func (m *Auth) XXX_Unmarshal(b []byte) error
- type BackendType
- type Code
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) GetCode() Code
- func (m *Status) GetMessage() string
- func (m *Status) GetRequestId() string
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) String() string
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var BackendType_name = map[int32]string{
0: "BACKEND_TYPE_UNSET",
1: "BACKEND_TYPE_KAFKA",
2: "BACKEND_TYPE_RABBIT",
3: "BACKEND_TYPE_RABBIT_STREAMS",
4: "BACKEND_TYPE_NSQ",
5: "BACKEND_TYPE_NATS",
6: "BACKEND_TYPE_NATS_STREAMING",
7: "BACKEND_TYPE_GCP_PUBSUB",
8: "BACKEND_TYPE_AZURE_SERVICE_BUS",
9: "BACKEND_TYPE_AZURE_EVENT_HUB",
10: "BACKEND_TYPE_AWS_SQS",
11: "BACKEND_TYPE_AWS_SNS",
12: "BACKEND_TYPE_REDIS_PUBSUB",
13: "BACKEND_TYPE_REDIS_STREAMS",
14: "BACKEND_TYPE_ACTIVEMQ",
15: "BACKEND_TYPE_PULSAR",
16: "BACKEND_TYPE_MQTT",
17: "BACKEND_TYPE_POSTGRES_CDC",
18: "BACKEND_TYPE_MONGODB_CDC",
19: "BACKEND_TYPE_KUBE_MQ",
}
View Source
var BackendType_value = map[string]int32{
"BACKEND_TYPE_UNSET": 0,
"BACKEND_TYPE_KAFKA": 1,
"BACKEND_TYPE_RABBIT": 2,
"BACKEND_TYPE_RABBIT_STREAMS": 3,
"BACKEND_TYPE_NSQ": 4,
"BACKEND_TYPE_NATS": 5,
"BACKEND_TYPE_NATS_STREAMING": 6,
"BACKEND_TYPE_GCP_PUBSUB": 7,
"BACKEND_TYPE_AZURE_SERVICE_BUS": 8,
"BACKEND_TYPE_AZURE_EVENT_HUB": 9,
"BACKEND_TYPE_AWS_SQS": 10,
"BACKEND_TYPE_AWS_SNS": 11,
"BACKEND_TYPE_REDIS_PUBSUB": 12,
"BACKEND_TYPE_REDIS_STREAMS": 13,
"BACKEND_TYPE_ACTIVEMQ": 14,
"BACKEND_TYPE_PULSAR": 15,
"BACKEND_TYPE_MQTT": 16,
"BACKEND_TYPE_POSTGRES_CDC": 17,
"BACKEND_TYPE_MONGODB_CDC": 18,
"BACKEND_TYPE_KUBE_MQ": 19,
}
View Source
var Code_name = map[int32]string{
0: "OK",
1: "CANCELLED",
2: "UNKNOWN",
3: "INVALID_ARGUMENT",
4: "DEADLINE_EXCEEDED",
5: "NOT_FOUND",
6: "ALREADY_EXISTS",
7: "PERMISSION_DENIED",
16: "UNAUTHENTICATED",
8: "RESOURCE_EXHAUSTED",
9: "FAILED_PRECONDITION",
10: "ABORTED",
11: "OUT_OF_RANGE",
12: "UNIMPLEMENTED",
13: "INTERNAL",
14: "UNAVAILABLE",
15: "DATA_LOSS",
}
View Source
var Code_value = map[string]int32{
"OK": 0,
"CANCELLED": 1,
"UNKNOWN": 2,
"INVALID_ARGUMENT": 3,
"DEADLINE_EXCEEDED": 4,
"NOT_FOUND": 5,
"ALREADY_EXISTS": 6,
"PERMISSION_DENIED": 7,
"UNAUTHENTICATED": 16,
"RESOURCE_EXHAUSTED": 8,
"FAILED_PRECONDITION": 9,
"ABORTED": 10,
"OUT_OF_RANGE": 11,
"UNIMPLEMENTED": 12,
"INTERNAL": 13,
"UNAVAILABLE": 14,
"DATA_LOSS": 15,
}
Functions ¶
This section is empty.
Types ¶
type Auth ¶
type Auth struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Auth) Descriptor ¶
func (*Auth) ProtoMessage ¶
func (*Auth) ProtoMessage()
func (*Auth) XXX_DiscardUnknown ¶
func (m *Auth) XXX_DiscardUnknown()
func (*Auth) XXX_Unmarshal ¶
type BackendType ¶ added in v0.0.48
type BackendType int32
const ( BackendType_BACKEND_TYPE_UNSET BackendType = 0 BackendType_BACKEND_TYPE_KAFKA BackendType = 1 BackendType_BACKEND_TYPE_RABBIT BackendType = 2 BackendType_BACKEND_TYPE_RABBIT_STREAMS BackendType = 3 BackendType_BACKEND_TYPE_NSQ BackendType = 4 BackendType_BACKEND_TYPE_NATS BackendType = 5 BackendType_BACKEND_TYPE_NATS_STREAMING BackendType = 6 BackendType_BACKEND_TYPE_GCP_PUBSUB BackendType = 7 BackendType_BACKEND_TYPE_AZURE_SERVICE_BUS BackendType = 8 BackendType_BACKEND_TYPE_AZURE_EVENT_HUB BackendType = 9 BackendType_BACKEND_TYPE_AWS_SQS BackendType = 10 BackendType_BACKEND_TYPE_AWS_SNS BackendType = 11 BackendType_BACKEND_TYPE_REDIS_PUBSUB BackendType = 12 BackendType_BACKEND_TYPE_REDIS_STREAMS BackendType = 13 BackendType_BACKEND_TYPE_ACTIVEMQ BackendType = 14 BackendType_BACKEND_TYPE_PULSAR BackendType = 15 BackendType_BACKEND_TYPE_MQTT BackendType = 16 BackendType_BACKEND_TYPE_POSTGRES_CDC BackendType = 17 BackendType_BACKEND_TYPE_MONGODB_CDC BackendType = 18 BackendType_BACKEND_TYPE_KUBE_MQ BackendType = 19 )
func (BackendType) EnumDescriptor ¶ added in v0.0.48
func (BackendType) EnumDescriptor() ([]byte, []int)
func (BackendType) String ¶ added in v0.0.48
func (x BackendType) String() string
type Code ¶
type Code int32
https://github.com/googleapis/googleapis/blob/master/google/rpc/code.proto
The canonical error codes for gRPC APIs.
Sometimes multiple error codes may apply. Services should return the most specific error code that applies. For example, prefer `OUT_OF_RANGE` over `FAILED_PRECONDITION` if both codes apply. Similarly prefer `NOT_FOUND` or `ALREADY_EXISTS` over `FAILED_PRECONDITION`.
const ( // Not an error; returned on success // // HTTP Mapping: 200 OK Code_OK Code = 0 // The operation was cancelled, typically by the caller. // // HTTP Mapping: 499 Client Closed Request Code_CANCELLED Code = 1 // Unknown error. For example, this error may be returned when // a `Status` value received from another address space belongs to // an error space that is not known in this address space. Also // errors raised by APIs that do not return enough error information // may be converted to this error. // // HTTP Mapping: 500 Internal Server Error Code_UNKNOWN Code = 2 // The client specified an invalid argument. Note that this differs // from `FAILED_PRECONDITION`. `INVALID_ARGUMENT` indicates arguments // that are problematic regardless of the state of the system // (e.g., a malformed file name). // // HTTP Mapping: 400 Bad Request Code_INVALID_ARGUMENT Code = 3 // The deadline expired before the operation could complete. For operations // that change the state of the system, this error may be returned // even if the operation has completed successfully. For example, a // successful response from a server could have been delayed long // enough for the deadline to expire. // // HTTP Mapping: 504 Gateway Timeout Code_DEADLINE_EXCEEDED Code = 4 // Some requested entity (e.g., file or directory) was not found. // // Note to server developers: if a request is denied for an entire class // of users, such as gradual feature rollout or undocumented whitelist, // `NOT_FOUND` may be used. If a request is denied for some users within // a class of users, such as user-based access control, `PERMISSION_DENIED` // must be used. // // HTTP Mapping: 404 Not Found Code_NOT_FOUND Code = 5 // The entity that a client attempted to create (e.g., file or directory) // already exists. // // HTTP Mapping: 409 Conflict Code_ALREADY_EXISTS Code = 6 // The caller does not have permission to execute the specified // operation. `PERMISSION_DENIED` must not be used for rejections // caused by exhausting some resource (use `RESOURCE_EXHAUSTED` // instead for those errors). `PERMISSION_DENIED` must not be // used if the caller can not be identified (use `UNAUTHENTICATED` // instead for those errors). This error code does not imply the // request is valid or the requested entity exists or satisfies // other pre-conditions. // // HTTP Mapping: 403 Forbidden Code_PERMISSION_DENIED Code = 7 // The request does not have valid authentication credentials for the // operation. // // HTTP Mapping: 401 Unauthorized Code_UNAUTHENTICATED Code = 16 // Some resource has been exhausted, perhaps a per-user quota, or // perhaps the entire file system is out of space. // // HTTP Mapping: 429 Too Many Requests Code_RESOURCE_EXHAUSTED Code = 8 // The operation was rejected because the system is not in a state // required for the operation's execution. For example, the directory // to be deleted is non-empty, an rmdir operation is applied to // a non-directory, etc. // // Service implementors can use the following guidelines to decide // between `FAILED_PRECONDITION`, `ABORTED`, and `UNAVAILABLE`: // (a) Use `UNAVAILABLE` if the client can retry just the failing call. // (b) Use `ABORTED` if the client should retry at a higher level // (e.g., when a client-specified test-and-set fails, indicating the // client should restart a read-modify-write sequence). // (c) Use `FAILED_PRECONDITION` if the client should not retry until // the system state has been explicitly fixed. E.g., if an "rmdir" // fails because the directory is non-empty, `FAILED_PRECONDITION` // should be returned since the client should not retry unless // the files are deleted from the directory. // // HTTP Mapping: 400 Bad Request Code_FAILED_PRECONDITION Code = 9 // The operation was aborted, typically due to a concurrency issue such as // a sequencer check failure or transaction abort. // // See the guidelines above for deciding between `FAILED_PRECONDITION`, // `ABORTED`, and `UNAVAILABLE`. // // HTTP Mapping: 409 Conflict Code_ABORTED Code = 10 // The operation was attempted past the valid range. E.g., seeking or // reading past end-of-file. // // Unlike `INVALID_ARGUMENT`, this error indicates a problem that may // be fixed if the system state changes. For example, a 32-bit file // system will generate `INVALID_ARGUMENT` if asked to read at an // offset that is not in the range [0,2^32-1], but it will generate // `OUT_OF_RANGE` if asked to read from an offset past the current // file size. // // There is a fair bit of overlap between `FAILED_PRECONDITION` and // `OUT_OF_RANGE`. We recommend using `OUT_OF_RANGE` (the more specific // error) when it applies so that callers who are iterating through // a space can easily look for an `OUT_OF_RANGE` error to detect when // they are done. // // HTTP Mapping: 400 Bad Request Code_OUT_OF_RANGE Code = 11 // The operation is not implemented or is not supported/enabled in this // service. // // HTTP Mapping: 501 Not Implemented Code_UNIMPLEMENTED Code = 12 // Internal errors. This means that some invariants expected by the // underlying system have been broken. This error code is reserved // for serious errors. // // HTTP Mapping: 500 Internal Server Error Code_INTERNAL Code = 13 // The service is currently unavailable. This is most likely a // transient condition, which can be corrected by retrying with // a backoff. Note that it is not always safe to retry // non-idempotent operations. // // See the guidelines above for deciding between `FAILED_PRECONDITION`, // `ABORTED`, and `UNAVAILABLE`. // // HTTP Mapping: 503 Service Unavailable Code_UNAVAILABLE Code = 14 // Unrecoverable data loss or corruption. // // HTTP Mapping: 500 Internal Server Error Code_DATA_LOSS Code = 15 )
func (Code) EnumDescriptor ¶
type Status ¶
type Status struct {
Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=protos.common.Code" json:"code,omitempty"`
// Message containing status details
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// Set by the backend (to enable troubleshooting)
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Status) Descriptor ¶
func (*Status) GetMessage ¶
func (*Status) GetRequestId ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
Source Files
Click to show internal directories.
Click to hide internal directories.