Skip to content

Commit

Permalink
move to use ProtoBuf 0.10
Browse files Browse the repository at this point in the history 
Moved to ProtoBuf 0.10.
Added regenerated code with new code generator.
  • Loading branch information
@tanmaykm
tanmaykm committed Dec 1, 2020
1 parent 9f043f7 commit 09db30f
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 09db30f

Please sign in to comment.