Skip to content

Commit

Permalink
Merge pull request #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 committed 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

2 comments on commit f906ac5

@tanmaykm
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@JuliaRegistrator register

@JuliaRegistrator
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Registration pull request created: JuliaRegistries/General/25624

After the above pull request is merged, it is recommended that a tag is created on this repository for the registered package version.

This will be done automatically if the Julia TagBot GitHub Action is installed, or can be done manually through the github interface, or via:

git tag -a v0.5.1 -m "<description of version>" f906ac53b35ff42f51857a18d21f7336fe579816
git push origin v0.5.1

Please sign in to comment.