Skip to content

Commit

Permalink
Merge pull request JuliaParallel#52 from JuliaParallel/tan/protoupgrade
Browse files Browse the repository at this point in the history 
move to use ProtoBuf 0.10
  • Loading branch information
@tanmaykm
tanmaykm authored Dec 1, 2020
2 parents 9f043f7 + 09db30f commit f906ac5
Show file tree
Hide file tree
Showing 15 changed files with 879 additions and 441 deletions.
4 changes: 2 additions & 2 deletions Project.toml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ uuid = "0bb624de-12df-571d-ad84-47aef8b93290"
keywords = ["hadoop", "hdfs", "yarn", "client"]
license = "MIT"
desc = "Hadoop HDFS and Yarn client"
version = "0.5.0"
version = "0.5.1"

[deps]
Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"
Expand All @@ -22,7 +22,7 @@ UUIDs = "cf7118a7-6976-5b1a-9a39-7adc72f591a4"
[compat]
julia = "1"
MbedTLS = "0.6.8, 0.7, 1"
ProtoBuf = "0.9"
ProtoBuf = "0.10"
URIParser = "0.4"

[extras]
Expand Down
468 changes: 312 additions & 156 deletions src/hadoop/ClientNamenodeProtocol_pb.jl
View file

Large diffs are not rendered by default.

35 changes: 23 additions & 12 deletions src/hadoop/HAServiceProtocol_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,10 @@ const HARequestSource = (;[
mutable struct HAStateChangeRequestInfoProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function HAStateChangeRequestInfoProto(; kwargs...)
obj = new(meta(HAStateChangeRequestInfoProto), Dict{Symbol,Any}())
obj = new(meta(HAStateChangeRequestInfoProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -57,9 +58,10 @@ end
mutable struct MonitorHealthRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function MonitorHealthRequestProto(; kwargs...)
obj = new(meta(MonitorHealthRequestProto), Dict{Symbol,Any}())
obj = new(meta(MonitorHealthRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -86,9 +88,10 @@ end
mutable struct MonitorHealthResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function MonitorHealthResponseProto(; kwargs...)
obj = new(meta(MonitorHealthResponseProto), Dict{Symbol,Any}())
obj = new(meta(MonitorHealthResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -115,9 +118,10 @@ end
mutable struct TransitionToActiveRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToActiveRequestProto(; kwargs...)
obj = new(meta(TransitionToActiveRequestProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToActiveRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -152,9 +156,10 @@ end
mutable struct TransitionToActiveResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToActiveResponseProto(; kwargs...)
obj = new(meta(TransitionToActiveResponseProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToActiveResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -181,9 +186,10 @@ end
mutable struct TransitionToStandbyRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToStandbyRequestProto(; kwargs...)
obj = new(meta(TransitionToStandbyRequestProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToStandbyRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -218,9 +224,10 @@ end
mutable struct TransitionToStandbyResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToStandbyResponseProto(; kwargs...)
obj = new(meta(TransitionToStandbyResponseProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToStandbyResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -247,9 +254,10 @@ end
mutable struct TransitionToObserverRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToObserverRequestProto(; kwargs...)
obj = new(meta(TransitionToObserverRequestProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToObserverRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -284,9 +292,10 @@ end
mutable struct TransitionToObserverResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TransitionToObserverResponseProto(; kwargs...)
obj = new(meta(TransitionToObserverResponseProto), Dict{Symbol,Any}())
obj = new(meta(TransitionToObserverResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -313,9 +322,10 @@ end
mutable struct GetServiceStatusRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function GetServiceStatusRequestProto(; kwargs...)
obj = new(meta(GetServiceStatusRequestProto), Dict{Symbol,Any}())
obj = new(meta(GetServiceStatusRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand All @@ -342,9 +352,10 @@ end
mutable struct GetServiceStatusResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

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

export HAServiceStateProto, HARequestSource, HAStateChangeRequestInfoProto, MonitorHealthRequestProto, MonitorHealthResponseProto, TransitionToActiveRequestProto, TransitionToActiveResponseProto, TransitionToStandbyRequestProto, TransitionToStandbyResponseProto, TransitionToObserverRequestProto, TransitionToObserverResponseProto, GetServiceStatusRequestProto, GetServiceStatusResponseProto, HAServiceProtocolService, HAServiceProtocolServiceStub, HAServiceProtocolServiceBlockingStub, monitorHealth, transitionToActive, transitionToStandby, transitionToObserver, getServiceStatus
# COV_EXCL_STOP
# COV_EXCL_STOP
6 changes: 4 additions & 2 deletions src/hadoop/IpcConnectionContext_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,10 @@ import ProtoBuf.meta
mutable struct UserInformationProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function UserInformationProto(; kwargs...)
obj = new(meta(UserInformationProto), Dict{Symbol,Any}())
obj = new(meta(UserInformationProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -44,9 +45,10 @@ end
mutable struct IpcConnectionContextProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function IpcConnectionContextProto(; kwargs...)
obj = new(meta(IpcConnectionContextProto), Dict{Symbol,Any}())
obj = new(meta(IpcConnectionContextProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down
3 changes: 2 additions & 1 deletion src/hadoop/ProtobufRpcEngine_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,10 @@ import ProtoBuf.meta
mutable struct RequestHeaderProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RequestHeaderProto(; kwargs...)
obj = new(meta(RequestHeaderProto), Dict{Symbol,Any}())
obj = new(meta(RequestHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down
18 changes: 12 additions & 6 deletions src/hadoop/RpcHeader_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,10 @@ const RpcKindProto = (;[
mutable struct RPCTraceInfoProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RPCTraceInfoProto(; kwargs...)
obj = new(meta(RPCTraceInfoProto), Dict{Symbol,Any}())
obj = new(meta(RPCTraceInfoProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -50,9 +51,10 @@ end
mutable struct RPCCallerContextProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RPCCallerContextProto(; kwargs...)
obj = new(meta(RPCCallerContextProto), Dict{Symbol,Any}())
obj = new(meta(RPCCallerContextProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -95,9 +97,10 @@ const RpcRequestHeaderProto_OperationProto = (;[
mutable struct RpcRequestHeaderProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RpcRequestHeaderProto(; kwargs...)
obj = new(meta(RpcRequestHeaderProto), Dict{Symbol,Any}())
obj = new(meta(RpcRequestHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -169,9 +172,10 @@ const RpcResponseHeaderProto_RpcErrorCodeProto = (;[
mutable struct RpcResponseHeaderProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RpcResponseHeaderProto(; kwargs...)
obj = new(meta(RpcResponseHeaderProto), Dict{Symbol,Any}())
obj = new(meta(RpcResponseHeaderProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -233,9 +237,10 @@ const RpcSaslProto_SaslState = (;[
mutable struct RpcSaslProto_SaslAuth <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RpcSaslProto_SaslAuth(; kwargs...)
obj = new(meta(RpcSaslProto_SaslAuth), Dict{Symbol,Any}())
obj = new(meta(RpcSaslProto_SaslAuth), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -278,9 +283,10 @@ end
mutable struct RpcSaslProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RpcSaslProto(; kwargs...)
obj = new(meta(RpcSaslProto), Dict{Symbol,Any}())
obj = new(meta(RpcSaslProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down
21 changes: 14 additions & 7 deletions src/hadoop/Security_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,10 @@ import ProtoBuf.meta
mutable struct TokenProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function TokenProto(; kwargs...)
obj = new(meta(TokenProto), Dict{Symbol,Any}())
obj = new(meta(TokenProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -49,9 +50,10 @@ end
mutable struct GetDelegationTokenRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function GetDelegationTokenRequestProto(; kwargs...)
obj = new(meta(GetDelegationTokenRequestProto), Dict{Symbol,Any}())
obj = new(meta(GetDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -86,9 +88,10 @@ end
mutable struct GetDelegationTokenResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function GetDelegationTokenResponseProto(; kwargs...)
obj = new(meta(GetDelegationTokenResponseProto), Dict{Symbol,Any}())
obj = new(meta(GetDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -122,9 +125,10 @@ end
mutable struct RenewDelegationTokenRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RenewDelegationTokenRequestProto(; kwargs...)
obj = new(meta(RenewDelegationTokenRequestProto), Dict{Symbol,Any}())
obj = new(meta(RenewDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -159,9 +163,10 @@ end
mutable struct RenewDelegationTokenResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function RenewDelegationTokenResponseProto(; kwargs...)
obj = new(meta(RenewDelegationTokenResponseProto), Dict{Symbol,Any}())
obj = new(meta(RenewDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -196,9 +201,10 @@ end
mutable struct CancelDelegationTokenRequestProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function CancelDelegationTokenRequestProto(; kwargs...)
obj = new(meta(CancelDelegationTokenRequestProto), Dict{Symbol,Any}())
obj = new(meta(CancelDelegationTokenRequestProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down Expand Up @@ -233,9 +239,10 @@ end
mutable struct CancelDelegationTokenResponseProto <: ProtoType
__protobuf_jl_internal_meta::ProtoMeta
__protobuf_jl_internal_values::Dict{Symbol,Any}
__protobuf_jl_internal_defaultset::Set{Symbol}

function CancelDelegationTokenResponseProto(; kwargs...)
obj = new(meta(CancelDelegationTokenResponseProto), Dict{Symbol,Any}())
obj = new(meta(CancelDelegationTokenResponseProto), Dict{Symbol,Any}(), Set{Symbol}())
values = obj.__protobuf_jl_internal_values
symdict = obj.__protobuf_jl_internal_meta.symdict
for nv in kwargs
Expand Down
Loading

0 comments on commit f906ac5

Please sign in to comment.