Skip to content

Commit f906ac5

Browse files
tanmaykmtanmaykm
authored
Merge pull request #52 from JuliaParallel/tan/protoupgrade
move to use ProtoBuf 0.10
2 parents 9f043f7 + 09db30f commit f906ac5

15 files changed

+879
-441
lines changed

‎Project.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ uuid = "0bb624de-12df-571d-ad84-47aef8b93290"
33
keywords = ["hadoop", "hdfs", "yarn", "client"]
44
license = "MIT"
55
desc = "Hadoop HDFS and Yarn client"
6-
version = "0.5.0"
6+
version = "0.5.1"
77

88
[deps]
99
Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"
@@ -22,7 +22,7 @@ UUIDs = "cf7118a7-6976-5b1a-9a39-7adc72f591a4"
2222
[compat]
2323
julia = "1"
2424
MbedTLS = "0.6.8, 0.7, 1"
25-
ProtoBuf = "0.9"
25+
ProtoBuf = "0.10"
2626
URIParser = "0.4"
2727

2828
[extras]

‎src/hadoop/ClientNamenodeProtocol_pb.jl

Lines changed: 312 additions & 156 deletions
Large diffs are not rendered by default.

‎src/hadoop/HAServiceProtocol_pb.jl

Lines changed: 23 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,10 @@ const HARequestSource = (;[
2020
mutable struct HAStateChangeRequestInfoProto <: ProtoType
2121
__protobuf_jl_internal_meta::ProtoMeta
2222
__protobuf_jl_internal_values::Dict{Symbol,Any}
23+
__protobuf_jl_internal_defaultset::Set{Symbol}
2324

2425
function HAStateChangeRequestInfoProto(; kwargs...)
25-
obj = new(meta(HAStateChangeRequestInfoProto), Dict{Symbol,Any}())
26+
obj = new(meta(HAStateChangeRequestInfoProto), Dict{Symbol,Any}(), Set{Symbol}())
2627
values = obj.__protobuf_jl_internal_values
2728
symdict = obj.__protobuf_jl_internal_meta.symdict
2829
for nv in kwargs
@@ -57,9 +58,10 @@ end
5758
mutable struct MonitorHealthRequestProto <: ProtoType
5859
__protobuf_jl_internal_meta::ProtoMeta
5960
__protobuf_jl_internal_values::Dict{Symbol,Any}
61+
__protobuf_jl_internal_defaultset::Set{Symbol}
6062

6163
function MonitorHealthRequestProto(; kwargs...)
62-
obj = new(meta(MonitorHealthRequestProto), Dict{Symbol,Any}())
64+
obj = new(meta(MonitorHealthRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
6365
values = obj.__protobuf_jl_internal_values
6466
symdict = obj.__protobuf_jl_internal_meta.symdict
6567
for nv in kwargs
@@ -86,9 +88,10 @@ end
8688
mutable struct MonitorHealthResponseProto <: ProtoType
8789
__protobuf_jl_internal_meta::ProtoMeta
8890
__protobuf_jl_internal_values::Dict{Symbol,Any}
91+
__protobuf_jl_internal_defaultset::Set{Symbol}
8992

9093
function MonitorHealthResponseProto(; kwargs...)
91-
obj = new(meta(MonitorHealthResponseProto), Dict{Symbol,Any}())
94+
obj = new(meta(MonitorHealthResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
9295
values = obj.__protobuf_jl_internal_values
9396
symdict = obj.__protobuf_jl_internal_meta.symdict
9497
for nv in kwargs
@@ -115,9 +118,10 @@ end
115118
mutable struct TransitionToActiveRequestProto <: ProtoType
116119
__protobuf_jl_internal_meta::ProtoMeta
117120
__protobuf_jl_internal_values::Dict{Symbol,Any}
121+
__protobuf_jl_internal_defaultset::Set{Symbol}
118122

119123
function TransitionToActiveRequestProto(; kwargs...)
120-
obj = new(meta(TransitionToActiveRequestProto), Dict{Symbol,Any}())
124+
obj = new(meta(TransitionToActiveRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
121125
values = obj.__protobuf_jl_internal_values
122126
symdict = obj.__protobuf_jl_internal_meta.symdict
123127
for nv in kwargs
@@ -152,9 +156,10 @@ end
152156
mutable struct TransitionToActiveResponseProto <: ProtoType
153157
__protobuf_jl_internal_meta::ProtoMeta
154158
__protobuf_jl_internal_values::Dict{Symbol,Any}
159+
__protobuf_jl_internal_defaultset::Set{Symbol}
155160

156161
function TransitionToActiveResponseProto(; kwargs...)
157-
obj = new(meta(TransitionToActiveResponseProto), Dict{Symbol,Any}())
162+
obj = new(meta(TransitionToActiveResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
158163
values = obj.__protobuf_jl_internal_values
159164
symdict = obj.__protobuf_jl_internal_meta.symdict
160165
for nv in kwargs
@@ -181,9 +186,10 @@ end
181186
mutable struct TransitionToStandbyRequestProto <: ProtoType
182187
__protobuf_jl_internal_meta::ProtoMeta
183188
__protobuf_jl_internal_values::Dict{Symbol,Any}
189+
__protobuf_jl_internal_defaultset::Set{Symbol}
184190

185191
function TransitionToStandbyRequestProto(; kwargs...)
186-
obj = new(meta(TransitionToStandbyRequestProto), Dict{Symbol,Any}())
192+
obj = new(meta(TransitionToStandbyRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
187193
values = obj.__protobuf_jl_internal_values
188194
symdict = obj.__protobuf_jl_internal_meta.symdict
189195
for nv in kwargs
@@ -218,9 +224,10 @@ end
218224
mutable struct TransitionToStandbyResponseProto <: ProtoType
219225
__protobuf_jl_internal_meta::ProtoMeta
220226
__protobuf_jl_internal_values::Dict{Symbol,Any}
227+
__protobuf_jl_internal_defaultset::Set{Symbol}
221228

222229
function TransitionToStandbyResponseProto(; kwargs...)
223-
obj = new(meta(TransitionToStandbyResponseProto), Dict{Symbol,Any}())
230+
obj = new(meta(TransitionToStandbyResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
224231
values = obj.__protobuf_jl_internal_values
225232
symdict = obj.__protobuf_jl_internal_meta.symdict
226233
for nv in kwargs
@@ -247,9 +254,10 @@ end
247254
mutable struct TransitionToObserverRequestProto <: ProtoType
248255
__protobuf_jl_internal_meta::ProtoMeta
249256
__protobuf_jl_internal_values::Dict{Symbol,Any}
257+
__protobuf_jl_internal_defaultset::Set{Symbol}
250258

251259
function TransitionToObserverRequestProto(; kwargs...)
252-
obj = new(meta(TransitionToObserverRequestProto), Dict{Symbol,Any}())
260+
obj = new(meta(TransitionToObserverRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
253261
values = obj.__protobuf_jl_internal_values
254262
symdict = obj.__protobuf_jl_internal_meta.symdict
255263
for nv in kwargs
@@ -284,9 +292,10 @@ end
284292
mutable struct TransitionToObserverResponseProto <: ProtoType
285293
__protobuf_jl_internal_meta::ProtoMeta
286294
__protobuf_jl_internal_values::Dict{Symbol,Any}
295+
__protobuf_jl_internal_defaultset::Set{Symbol}
287296

288297
function TransitionToObserverResponseProto(; kwargs...)
289-
obj = new(meta(TransitionToObserverResponseProto), Dict{Symbol,Any}())
298+
obj = new(meta(TransitionToObserverResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
290299
values = obj.__protobuf_jl_internal_values
291300
symdict = obj.__protobuf_jl_internal_meta.symdict
292301
for nv in kwargs
@@ -313,9 +322,10 @@ end
313322
mutable struct GetServiceStatusRequestProto <: ProtoType
314323
__protobuf_jl_internal_meta::ProtoMeta
315324
__protobuf_jl_internal_values::Dict{Symbol,Any}
325+
__protobuf_jl_internal_defaultset::Set{Symbol}
316326

317327
function GetServiceStatusRequestProto(; kwargs...)
318-
obj = new(meta(GetServiceStatusRequestProto), Dict{Symbol,Any}())
328+
obj = new(meta(GetServiceStatusRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
319329
values = obj.__protobuf_jl_internal_values
320330
symdict = obj.__protobuf_jl_internal_meta.symdict
321331
for nv in kwargs
@@ -342,9 +352,10 @@ end
342352
mutable struct GetServiceStatusResponseProto <: ProtoType
343353
__protobuf_jl_internal_meta::ProtoMeta
344354
__protobuf_jl_internal_values::Dict{Symbol,Any}
355+
__protobuf_jl_internal_defaultset::Set{Symbol}
345356

346357
function GetServiceStatusResponseProto(; kwargs...)
347-
obj = new(meta(GetServiceStatusResponseProto), Dict{Symbol,Any}())
358+
obj = new(meta(GetServiceStatusResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
348359
values = obj.__protobuf_jl_internal_values
349360
symdict = obj.__protobuf_jl_internal_meta.symdict
350361
for nv in kwargs
@@ -418,4 +429,4 @@ getServiceStatus(stub::HAServiceProtocolServiceStub, controller::ProtoRpcControl
418429
getServiceStatus(stub::HAServiceProtocolServiceBlockingStub, controller::ProtoRpcController, inp::hadoop.common.GetServiceStatusRequestProto) = call_method(stub.impl, _HAServiceProtocolService_methods[5], controller, inp)
419430

420431
export HAServiceStateProto, HARequestSource, HAStateChangeRequestInfoProto, MonitorHealthRequestProto, MonitorHealthResponseProto, TransitionToActiveRequestProto, TransitionToActiveResponseProto, TransitionToStandbyRequestProto, TransitionToStandbyResponseProto, TransitionToObserverRequestProto, TransitionToObserverResponseProto, GetServiceStatusRequestProto, GetServiceStatusResponseProto, HAServiceProtocolService, HAServiceProtocolServiceStub, HAServiceProtocolServiceBlockingStub, monitorHealth, transitionToActive, transitionToStandby, transitionToObserver, getServiceStatus
421-
# COV_EXCL_STOP
432+
# COV_EXCL_STOP

‎src/hadoop/IpcConnectionContext_pb.jl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,10 @@ import ProtoBuf.meta
66
mutable struct UserInformationProto <: ProtoType
77
__protobuf_jl_internal_meta::ProtoMeta
88
__protobuf_jl_internal_values::Dict{Symbol,Any}
9+
__protobuf_jl_internal_defaultset::Set{Symbol}
910

1011
function UserInformationProto(; kwargs...)
11-
obj = new(meta(UserInformationProto), Dict{Symbol,Any}())
12+
obj = new(meta(UserInformationProto), Dict{Symbol,Any}(), Set{Symbol}())
1213
values = obj.__protobuf_jl_internal_values
1314
symdict = obj.__protobuf_jl_internal_meta.symdict
1415
for nv in kwargs
@@ -44,9 +45,10 @@ end
4445
mutable struct IpcConnectionContextProto <: ProtoType
4546
__protobuf_jl_internal_meta::ProtoMeta
4647
__protobuf_jl_internal_values::Dict{Symbol,Any}
48+
__protobuf_jl_internal_defaultset::Set{Symbol}
4749

4850
function IpcConnectionContextProto(; kwargs...)
49-
obj = new(meta(IpcConnectionContextProto), Dict{Symbol,Any}())
51+
obj = new(meta(IpcConnectionContextProto), Dict{Symbol,Any}(), Set{Symbol}())
5052
values = obj.__protobuf_jl_internal_values
5153
symdict = obj.__protobuf_jl_internal_meta.symdict
5254
for nv in kwargs

‎src/hadoop/ProtobufRpcEngine_pb.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,10 @@ import ProtoBuf.meta
66
mutable struct RequestHeaderProto <: ProtoType
77
__protobuf_jl_internal_meta::ProtoMeta
88
__protobuf_jl_internal_values::Dict{Symbol,Any}
9+
__protobuf_jl_internal_defaultset::Set{Symbol}
910

1011
function RequestHeaderProto(; kwargs...)
11-
obj = new(meta(RequestHeaderProto), Dict{Symbol,Any}())
12+
obj = new(meta(RequestHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
1213
values = obj.__protobuf_jl_internal_values
1314
symdict = obj.__protobuf_jl_internal_meta.symdict
1415
for nv in kwargs

‎src/hadoop/RpcHeader_pb.jl

Lines changed: 12 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,10 @@ const RpcKindProto = (;[
1212
mutable struct RPCTraceInfoProto <: ProtoType
1313
__protobuf_jl_internal_meta::ProtoMeta
1414
__protobuf_jl_internal_values::Dict{Symbol,Any}
15+
__protobuf_jl_internal_defaultset::Set{Symbol}
1516

1617
function RPCTraceInfoProto(; kwargs...)
17-
obj = new(meta(RPCTraceInfoProto), Dict{Symbol,Any}())
18+
obj = new(meta(RPCTraceInfoProto), Dict{Symbol,Any}(), Set{Symbol}())
1819
values = obj.__protobuf_jl_internal_values
1920
symdict = obj.__protobuf_jl_internal_meta.symdict
2021
for nv in kwargs
@@ -50,9 +51,10 @@ end
5051
mutable struct RPCCallerContextProto <: ProtoType
5152
__protobuf_jl_internal_meta::ProtoMeta
5253
__protobuf_jl_internal_values::Dict{Symbol,Any}
54+
__protobuf_jl_internal_defaultset::Set{Symbol}
5355

5456
function RPCCallerContextProto(; kwargs...)
55-
obj = new(meta(RPCCallerContextProto), Dict{Symbol,Any}())
57+
obj = new(meta(RPCCallerContextProto), Dict{Symbol,Any}(), Set{Symbol}())
5658
values = obj.__protobuf_jl_internal_values
5759
symdict = obj.__protobuf_jl_internal_meta.symdict
5860
for nv in kwargs
@@ -95,9 +97,10 @@ const RpcRequestHeaderProto_OperationProto = (;[
9597
mutable struct RpcRequestHeaderProto <: ProtoType
9698
__protobuf_jl_internal_meta::ProtoMeta
9799
__protobuf_jl_internal_values::Dict{Symbol,Any}
100+
__protobuf_jl_internal_defaultset::Set{Symbol}
98101

99102
function RpcRequestHeaderProto(; kwargs...)
100-
obj = new(meta(RpcRequestHeaderProto), Dict{Symbol,Any}())
103+
obj = new(meta(RpcRequestHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
101104
values = obj.__protobuf_jl_internal_values
102105
symdict = obj.__protobuf_jl_internal_meta.symdict
103106
for nv in kwargs
@@ -169,9 +172,10 @@ const RpcResponseHeaderProto_RpcErrorCodeProto = (;[
169172
mutable struct RpcResponseHeaderProto <: ProtoType
170173
__protobuf_jl_internal_meta::ProtoMeta
171174
__protobuf_jl_internal_values::Dict{Symbol,Any}
175+
__protobuf_jl_internal_defaultset::Set{Symbol}
172176

173177
function RpcResponseHeaderProto(; kwargs...)
174-
obj = new(meta(RpcResponseHeaderProto), Dict{Symbol,Any}())
178+
obj = new(meta(RpcResponseHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
175179
values = obj.__protobuf_jl_internal_values
176180
symdict = obj.__protobuf_jl_internal_meta.symdict
177181
for nv in kwargs
@@ -233,9 +237,10 @@ const RpcSaslProto_SaslState = (;[
233237
mutable struct RpcSaslProto_SaslAuth <: ProtoType
234238
__protobuf_jl_internal_meta::ProtoMeta
235239
__protobuf_jl_internal_values::Dict{Symbol,Any}
240+
__protobuf_jl_internal_defaultset::Set{Symbol}
236241

237242
function RpcSaslProto_SaslAuth(; kwargs...)
238-
obj = new(meta(RpcSaslProto_SaslAuth), Dict{Symbol,Any}())
243+
obj = new(meta(RpcSaslProto_SaslAuth), Dict{Symbol,Any}(), Set{Symbol}())
239244
values = obj.__protobuf_jl_internal_values
240245
symdict = obj.__protobuf_jl_internal_meta.symdict
241246
for nv in kwargs
@@ -278,9 +283,10 @@ end
278283
mutable struct RpcSaslProto <: ProtoType
279284
__protobuf_jl_internal_meta::ProtoMeta
280285
__protobuf_jl_internal_values::Dict{Symbol,Any}
286+
__protobuf_jl_internal_defaultset::Set{Symbol}
281287

282288
function RpcSaslProto(; kwargs...)
283-
obj = new(meta(RpcSaslProto), Dict{Symbol,Any}())
289+
obj = new(meta(RpcSaslProto), Dict{Symbol,Any}(), Set{Symbol}())
284290
values = obj.__protobuf_jl_internal_values
285291
symdict = obj.__protobuf_jl_internal_meta.symdict
286292
for nv in kwargs

‎src/hadoop/Security_pb.jl

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,10 @@ import ProtoBuf.meta
66
mutable struct TokenProto <: ProtoType
77
__protobuf_jl_internal_meta::ProtoMeta
88
__protobuf_jl_internal_values::Dict{Symbol,Any}
9+
__protobuf_jl_internal_defaultset::Set{Symbol}
910

1011
function TokenProto(; kwargs...)
11-
obj = new(meta(TokenProto), Dict{Symbol,Any}())
12+
obj = new(meta(TokenProto), Dict{Symbol,Any}(), Set{Symbol}())
1213
values = obj.__protobuf_jl_internal_values
1314
symdict = obj.__protobuf_jl_internal_meta.symdict
1415
for nv in kwargs
@@ -49,9 +50,10 @@ end
4950
mutable struct GetDelegationTokenRequestProto <: ProtoType
5051
__protobuf_jl_internal_meta::ProtoMeta
5152
__protobuf_jl_internal_values::Dict{Symbol,Any}
53+
__protobuf_jl_internal_defaultset::Set{Symbol}
5254

5355
function GetDelegationTokenRequestProto(; kwargs...)
54-
obj = new(meta(GetDelegationTokenRequestProto), Dict{Symbol,Any}())
56+
obj = new(meta(GetDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
5557
values = obj.__protobuf_jl_internal_values
5658
symdict = obj.__protobuf_jl_internal_meta.symdict
5759
for nv in kwargs
@@ -86,9 +88,10 @@ end
8688
mutable struct GetDelegationTokenResponseProto <: ProtoType
8789
__protobuf_jl_internal_meta::ProtoMeta
8890
__protobuf_jl_internal_values::Dict{Symbol,Any}
91+
__protobuf_jl_internal_defaultset::Set{Symbol}
8992

9093
function GetDelegationTokenResponseProto(; kwargs...)
91-
obj = new(meta(GetDelegationTokenResponseProto), Dict{Symbol,Any}())
94+
obj = new(meta(GetDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
9295
values = obj.__protobuf_jl_internal_values
9396
symdict = obj.__protobuf_jl_internal_meta.symdict
9497
for nv in kwargs
@@ -122,9 +125,10 @@ end
122125
mutable struct RenewDelegationTokenRequestProto <: ProtoType
123126
__protobuf_jl_internal_meta::ProtoMeta
124127
__protobuf_jl_internal_values::Dict{Symbol,Any}
128+
__protobuf_jl_internal_defaultset::Set{Symbol}
125129

126130
function RenewDelegationTokenRequestProto(; kwargs...)
127-
obj = new(meta(RenewDelegationTokenRequestProto), Dict{Symbol,Any}())
131+
obj = new(meta(RenewDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
128132
values = obj.__protobuf_jl_internal_values
129133
symdict = obj.__protobuf_jl_internal_meta.symdict
130134
for nv in kwargs
@@ -159,9 +163,10 @@ end
159163
mutable struct RenewDelegationTokenResponseProto <: ProtoType
160164
__protobuf_jl_internal_meta::ProtoMeta
161165
__protobuf_jl_internal_values::Dict{Symbol,Any}
166+
__protobuf_jl_internal_defaultset::Set{Symbol}
162167

163168
function RenewDelegationTokenResponseProto(; kwargs...)
164-
obj = new(meta(RenewDelegationTokenResponseProto), Dict{Symbol,Any}())
169+
obj = new(meta(RenewDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
165170
values = obj.__protobuf_jl_internal_values
166171
symdict = obj.__protobuf_jl_internal_meta.symdict
167172
for nv in kwargs
@@ -196,9 +201,10 @@ end
196201
mutable struct CancelDelegationTokenRequestProto <: ProtoType
197202
__protobuf_jl_internal_meta::ProtoMeta
198203
__protobuf_jl_internal_values::Dict{Symbol,Any}
204+
__protobuf_jl_internal_defaultset::Set{Symbol}
199205

200206
function CancelDelegationTokenRequestProto(; kwargs...)
201-
obj = new(meta(CancelDelegationTokenRequestProto), Dict{Symbol,Any}())
207+
obj = new(meta(CancelDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
202208
values = obj.__protobuf_jl_internal_values
203209
symdict = obj.__protobuf_jl_internal_meta.symdict
204210
for nv in kwargs
@@ -233,9 +239,10 @@ end
233239
mutable struct CancelDelegationTokenResponseProto <: ProtoType
234240
__protobuf_jl_internal_meta::ProtoMeta
235241
__protobuf_jl_internal_values::Dict{Symbol,Any}
242+
__protobuf_jl_internal_defaultset::Set{Symbol}
236243

237244
function CancelDelegationTokenResponseProto(; kwargs...)
238-
obj = new(meta(CancelDelegationTokenResponseProto), Dict{Symbol,Any}())
245+
obj = new(meta(CancelDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
239246
values = obj.__protobuf_jl_internal_values
240247
symdict = obj.__protobuf_jl_internal_meta.symdict
241248
for nv in kwargs

0 commit comments

Comments
 (0)