forked from vitessio/vitess
-
Notifications
You must be signed in to change notification settings - Fork 1
/
vtrpc.pb.go
216 lines (200 loc) · 10.5 KB
/
vtrpc.pb.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
// Code generated by protoc-gen-go.
// source: vtrpc.proto
// DO NOT EDIT!
/*
Package vtrpc is a generated protocol buffer package.
It is generated from these files:
vtrpc.proto
It has these top-level messages:
CallerID
RPCError
*/
package vtrpc
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
const _ = proto.ProtoPackageIsVersion1
// ErrorCode is the enum values for Errors. Internally, errors should
// be created with one of these codes. These will then be translated over the wire
// by various RPC frameworks.
type ErrorCode int32
const (
// SUCCESS is returned from a successful call
ErrorCode_SUCCESS ErrorCode = 0
// CANCELLED means that the context was cancelled (and noticed in the app layer,
// as opposed to the RPC layer)
ErrorCode_CANCELLED ErrorCode = 1
// UNKNOWN_ERROR includes:
// 1. MySQL error codes that we don't explicitly handle.
// 2. MySQL response that wasn't as expected. For example, we might expect a MySQL
// timestamp to be returned in a particular way, but it wasn't.
// 3. Anything else that doesn't fall into a different bucket.
ErrorCode_UNKNOWN_ERROR ErrorCode = 2
// BAD_INPUT is returned when an end-user either sends SQL that couldn't be parsed correctly,
// or tries a query that isn't supported by Vitess.
ErrorCode_BAD_INPUT ErrorCode = 3
// DEADLINE_EXCEEDED is returned when an action is taking longer than a given timeout.
ErrorCode_DEADLINE_EXCEEDED ErrorCode = 4
// INTEGRITY_ERROR is returned on integrity error from MySQL, usually due to
// duplicate primary keys
ErrorCode_INTEGRITY_ERROR ErrorCode = 5
// PERMISSION_DENIED errors are returned when a user requests access to something
// that they don't have permissions for.
ErrorCode_PERMISSION_DENIED ErrorCode = 6
// RESOURCE_EXHAUSTED is returned when a query exceeds its quota in some dimension
// and can't be completed due to that. Queries that return RESOURCE_EXHAUSTED
// should not be retried, as it could be detrimental to the server's health.
// Examples of errors that will cause the RESOURCE_EXHAUSTED code:
// 1. TxPoolFull: this is retried server-side, and is only returned as an error
// if the server-side retries failed.
// 2. Query is killed due to it taking too long.
ErrorCode_RESOURCE_EXHAUSTED ErrorCode = 7
// QUERY_NOT_SERVED means that a query could not be served right now.
// Client can interpret it as: "the tablet that you sent this query to cannot
// serve the query right now, try a different tablet or try again later."
// This could be due to various reasons: QueryService is not serving, should
// not be serving, wrong shard, wrong tablet type, blacklisted table, etc.
// Clients that receive this error should usually retry the query, but after taking
// the appropriate steps to make sure that the query will get sent to the correct
// tablet.
ErrorCode_QUERY_NOT_SERVED ErrorCode = 8
// NOT_IN_TX means that we're not currently in a transaction, but we should be.
ErrorCode_NOT_IN_TX ErrorCode = 9
// INTERNAL_ERRORs are problems that only the server can fix, not the client.
// These errors are not due to a query itself, but rather due to the state of
// the system.
// Generally, we don't expect the errors to go away by themselves, but they
// may go away after human intervention.
// Examples of scenarios where INTERNAL_ERROR is returned:
// 1. Something is not configured correctly internally.
// 2. A necessary resource is not available, and we don't expect it to become available by itself.
// 3. A sanity check fails
// 4. Some other internal error occurs
// Clients should not retry immediately, as there is little chance of success.
// However, it's acceptable for retries to happen internally, for example to
// multiple backends, in case only a subset of backend are not functional.
ErrorCode_INTERNAL_ERROR ErrorCode = 10
// TRANSIENT_ERROR is used for when there is some error that we expect we can
// recover from automatically - often due to a resource limit temporarily being
// reached. Retrying this error, with an exponential backoff, should succeed.
// Clients should be able to successfully retry the query on the same backends.
// Examples of things that can trigger this error:
// 1. Query has been throttled
// 2. VtGate could have request backlog
ErrorCode_TRANSIENT_ERROR ErrorCode = 11
// UNAUTHENTICATED errors are returned when a user requests access to something,
// and we're unable to verify the user's authentication.
ErrorCode_UNAUTHENTICATED ErrorCode = 12
)
var ErrorCode_name = map[int32]string{
0: "SUCCESS",
1: "CANCELLED",
2: "UNKNOWN_ERROR",
3: "BAD_INPUT",
4: "DEADLINE_EXCEEDED",
5: "INTEGRITY_ERROR",
6: "PERMISSION_DENIED",
7: "RESOURCE_EXHAUSTED",
8: "QUERY_NOT_SERVED",
9: "NOT_IN_TX",
10: "INTERNAL_ERROR",
11: "TRANSIENT_ERROR",
12: "UNAUTHENTICATED",
}
var ErrorCode_value = map[string]int32{
"SUCCESS": 0,
"CANCELLED": 1,
"UNKNOWN_ERROR": 2,
"BAD_INPUT": 3,
"DEADLINE_EXCEEDED": 4,
"INTEGRITY_ERROR": 5,
"PERMISSION_DENIED": 6,
"RESOURCE_EXHAUSTED": 7,
"QUERY_NOT_SERVED": 8,
"NOT_IN_TX": 9,
"INTERNAL_ERROR": 10,
"TRANSIENT_ERROR": 11,
"UNAUTHENTICATED": 12,
}
func (x ErrorCode) String() string {
return proto.EnumName(ErrorCode_name, int32(x))
}
func (ErrorCode) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
// CallerID is passed along RPCs to identify the originating client
// for a request. It is not meant to be secure, but only
// informational. The client can put whatever info they want in these
// fields, and they will be trusted by the servers. The fields will
// just be used for logging purposes, and to easily find a client.
// VtGate propagates it to VtTablet, and VtTablet may use this
// information for monitoring purposes, to display on dashboards, or
// for blacklisting purposes.
type CallerID struct {
// principal is the effective user identifier. It is usually filled in
// with whoever made the request to the appserver, if the request
// came from an automated job or another system component.
// If the request comes directly from the Internet, or if the Vitess client
// takes action on its own accord, it is okay for this field to be absent.
Principal string `protobuf:"bytes,1,opt,name=principal" json:"principal,omitempty"`
// component describes the running process of the effective caller.
// It can for instance be the hostname:port of the servlet initiating the
// database call, or the container engine ID used by the servlet.
Component string `protobuf:"bytes,2,opt,name=component" json:"component,omitempty"`
// subcomponent describes a component inisde the immediate caller which
// is responsible for generating is request. Suggested values are a
// servlet name or an API endpoint name.
Subcomponent string `protobuf:"bytes,3,opt,name=subcomponent" json:"subcomponent,omitempty"`
}
func (m *CallerID) Reset() { *m = CallerID{} }
func (m *CallerID) String() string { return proto.CompactTextString(m) }
func (*CallerID) ProtoMessage() {}
func (*CallerID) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
// RPCError is an application-level error structure returned by
// VtTablet (and passed along by VtGate if appropriate).
// We use this so the clients don't have to parse the error messages,
// but instead can depend on the value of the code.
type RPCError struct {
Code ErrorCode `protobuf:"varint,1,opt,name=code,enum=vtrpc.ErrorCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}
func (m *RPCError) Reset() { *m = RPCError{} }
func (m *RPCError) String() string { return proto.CompactTextString(m) }
func (*RPCError) ProtoMessage() {}
func (*RPCError) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
func init() {
proto.RegisterType((*CallerID)(nil), "vtrpc.CallerID")
proto.RegisterType((*RPCError)(nil), "vtrpc.RPCError")
proto.RegisterEnum("vtrpc.ErrorCode", ErrorCode_name, ErrorCode_value)
}
var fileDescriptor0 = []byte{
// 372 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x54, 0x91, 0xcd, 0xce, 0xd2, 0x40,
0x14, 0x86, 0x85, 0xef, 0x07, 0x7a, 0xf8, 0xc0, 0x32, 0xfe, 0xa4, 0x31, 0x2e, 0x0c, 0x71, 0x61,
0x5c, 0x74, 0xa1, 0x57, 0x30, 0x4c, 0x4f, 0x64, 0xb4, 0x4e, 0x71, 0x7e, 0x14, 0x56, 0x0d, 0xd4,
0xc6, 0x60, 0x80, 0x36, 0xa5, 0x90, 0x78, 0x05, 0xde, 0xb6, 0x33, 0xa5, 0x42, 0xbe, 0x55, 0x73,
0x9e, 0xf7, 0x3d, 0x7d, 0x9a, 0x53, 0x18, 0x9c, 0xea, 0xaa, 0xcc, 0xc2, 0xb2, 0x2a, 0xea, 0x82,
0xdc, 0x35, 0xc3, 0xe4, 0x37, 0xf4, 0xd9, 0x6a, 0xbb, 0xcd, 0x2b, 0x1e, 0x91, 0xd7, 0xe0, 0x95,
0xd5, 0x66, 0x9f, 0x6d, 0xca, 0xd5, 0x36, 0xe8, 0xbc, 0xe9, 0xbc, 0xf3, 0xe4, 0x15, 0xb8, 0x34,
0x2b, 0x76, 0x65, 0xb1, 0xcf, 0xf7, 0x75, 0xd0, 0x3d, 0xa7, 0x17, 0x40, 0x26, 0xf0, 0x70, 0x38,
0xae, 0xaf, 0x85, 0x9b, 0xa6, 0xf0, 0x88, 0x4d, 0x3e, 0x43, 0x5f, 0xce, 0x19, 0x56, 0x55, 0x51,
0x91, 0xb7, 0x70, 0x9b, 0x15, 0x3f, 0xf3, 0x46, 0x33, 0xfa, 0xe0, 0x87, 0xe7, 0x4f, 0x6b, 0x32,
0x66, 0xb9, 0x6c, 0x52, 0x12, 0x40, 0x6f, 0x97, 0x1f, 0x0e, 0xab, 0x5f, 0x79, 0x6b, 0xfc, 0x3f,
0xbe, 0xff, 0xdb, 0x05, 0xef, 0xd2, 0x26, 0x03, 0xe8, 0x29, 0xc3, 0x18, 0x2a, 0xe5, 0x3f, 0x21,
0x43, 0xf0, 0x18, 0x15, 0x0c, 0xe3, 0x18, 0x23, 0xbf, 0x43, 0xc6, 0x30, 0x34, 0xe2, 0x8b, 0x48,
0x7e, 0x88, 0x14, 0xa5, 0x4c, 0xa4, 0xdf, 0x75, 0x8d, 0x29, 0x8d, 0x52, 0x2e, 0xe6, 0x46, 0xfb,
0x37, 0xe4, 0x05, 0x8c, 0x23, 0xa4, 0x51, 0xcc, 0x05, 0xa6, 0xb8, 0x60, 0x88, 0x91, 0x5d, 0xbc,
0x25, 0xcf, 0xe0, 0x29, 0x17, 0x1a, 0x3f, 0x49, 0xae, 0x97, 0xed, 0xea, 0x9d, 0xeb, 0xce, 0x51,
0x7e, 0xe5, 0x4a, 0xf1, 0x44, 0xa4, 0x11, 0x0a, 0x6e, 0xbb, 0xf7, 0xe4, 0x25, 0x10, 0x89, 0x2a,
0x31, 0x92, 0xb9, 0x57, 0xcc, 0xa8, 0x51, 0xda, 0xf2, 0x1e, 0x79, 0x0e, 0xfe, 0x37, 0x83, 0x72,
0x99, 0x8a, 0x44, 0xa7, 0x0a, 0xe5, 0x77, 0x4b, 0xfb, 0xce, 0xef, 0x66, 0x2e, 0x52, 0xbd, 0xf0,
0x3d, 0x42, 0x60, 0xe4, 0x44, 0x52, 0xd0, 0xb8, 0xf5, 0x80, 0x93, 0x6b, 0x49, 0x85, 0xe2, 0x28,
0x74, 0x0b, 0x07, 0x0e, 0x1a, 0x41, 0x8d, 0x9e, 0x59, 0xc8, 0x19, 0x75, 0x8a, 0x87, 0xe9, 0x2b,
0x08, 0xec, 0x89, 0xc3, 0x3f, 0xc5, 0xb1, 0x3e, 0xae, 0xf3, 0xf0, 0xb4, 0xa9, 0xed, 0x89, 0xce,
0x3f, 0x79, 0x7d, 0xdf, 0x3c, 0x3e, 0xfe, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x7c, 0x77, 0xfd, 0x16,
0xfa, 0x01, 0x00, 0x00,
}