Skip to content

Commit

Permalink
Merge pull request #36 from JuliaParallel/tanmaykm
Browse files Browse the repository at this point in the history 
use the updated ProtoBuf.jl code generator
  • Loading branch information
@tanmaykm
tanmaykm authored Jul 26, 2018
2 parents d1103f2 + 40677b5 commit 1b911e8
Show file tree
Hide file tree
Showing 17 changed files with 497 additions and 1,660 deletions.
962 changes: 266 additions & 696 deletions src/hadoop/ClientNamenodeProtocol_pb.jl
View file

Large diffs are not rendered by default.

7 changes: 0 additions & 7 deletions src/hadoop/IpcConnectionContext_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,12 @@
using Compat
using ProtoBuf
import ProtoBuf.meta
import Base: hash, isequal, ==

mutable struct UserInformationProto <: ProtoType
effectiveUser::AbstractString
realUser::AbstractString
UserInformationProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct UserInformationProto
hash(v::UserInformationProto) = ProtoBuf.protohash(v)
isequal(v1::UserInformationProto, v2::UserInformationProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::UserInformationProto, v2::UserInformationProto) = ProtoBuf.protoeq(v1, v2)

mutable struct IpcConnectionContextProto <: ProtoType
userInfo::UserInformationProto
Expand All @@ -20,8 +16,5 @@ mutable struct IpcConnectionContextProto <: ProtoType
end #mutable struct IpcConnectionContextProto
const __fnum_IpcConnectionContextProto = Int[2,3]
meta(t::Type{IpcConnectionContextProto}) = meta(t, ProtoBuf.DEF_REQ, __fnum_IpcConnectionContextProto, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::IpcConnectionContextProto) = ProtoBuf.protohash(v)
isequal(v1::IpcConnectionContextProto, v2::IpcConnectionContextProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::IpcConnectionContextProto, v2::IpcConnectionContextProto) = ProtoBuf.protoeq(v1, v2)

export UserInformationProto, IpcConnectionContextProto
4 changes: 0 additions & 4 deletions src/hadoop/ProtobufRpcEngine_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
using Compat
using ProtoBuf
import ProtoBuf.meta
import Base: hash, isequal, ==

mutable struct RequestHeaderProto <: ProtoType
methodName::AbstractString
Expand All @@ -12,8 +11,5 @@ mutable struct RequestHeaderProto <: ProtoType
end #mutable struct RequestHeaderProto
const __req_RequestHeaderProto = Symbol[:methodName,:declaringClassProtocolName,:clientProtocolVersion]
meta(t::Type{RequestHeaderProto}) = meta(t, __req_RequestHeaderProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RequestHeaderProto) = ProtoBuf.protohash(v)
isequal(v1::RequestHeaderProto, v2::RequestHeaderProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RequestHeaderProto, v2::RequestHeaderProto) = ProtoBuf.protoeq(v1, v2)

export RequestHeaderProto
18 changes: 1 addition & 17 deletions src/hadoop/RpcHeader_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
using Compat
using ProtoBuf
import ProtoBuf.meta
import Base: hash, isequal, ==

struct __enum_RpcKindProto <: ProtoEnum
RPC_BUILTIN::Int32
Expand All @@ -17,9 +16,6 @@ mutable struct RPCTraceInfoProto <: ProtoType
parentId::Int64
RPCTraceInfoProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct RPCTraceInfoProto
hash(v::RPCTraceInfoProto) = ProtoBuf.protohash(v)
isequal(v1::RPCTraceInfoProto, v2::RPCTraceInfoProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RPCTraceInfoProto, v2::RPCTraceInfoProto) = ProtoBuf.protoeq(v1, v2)

struct __enum_RpcRequestHeaderProto_OperationProto <: ProtoEnum
RPC_FINAL_PACKET::Int32
Expand All @@ -42,9 +38,6 @@ const __req_RpcRequestHeaderProto = Symbol[:callId,:clientId]
const __val_RpcRequestHeaderProto = Dict(:retryCount => -1)
const __wtype_RpcRequestHeaderProto = Dict(:callId => :sint32, :retryCount => :sint32)
meta(t::Type{RpcRequestHeaderProto}) = meta(t, __req_RpcRequestHeaderProto, ProtoBuf.DEF_FNUM, __val_RpcRequestHeaderProto, true, ProtoBuf.DEF_PACK, __wtype_RpcRequestHeaderProto, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RpcRequestHeaderProto) = ProtoBuf.protohash(v)
isequal(v1::RpcRequestHeaderProto, v2::RpcRequestHeaderProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RpcRequestHeaderProto, v2::RpcRequestHeaderProto) = ProtoBuf.protoeq(v1, v2)

struct __enum_RpcResponseHeaderProto_RpcStatusProto <: ProtoEnum
SUCCESS::Int32
Expand Down Expand Up @@ -86,9 +79,6 @@ const __req_RpcResponseHeaderProto = Symbol[:callId,:status]
const __val_RpcResponseHeaderProto = Dict(:retryCount => -1)
const __wtype_RpcResponseHeaderProto = Dict(:retryCount => :sint32)
meta(t::Type{RpcResponseHeaderProto}) = meta(t, __req_RpcResponseHeaderProto, ProtoBuf.DEF_FNUM, __val_RpcResponseHeaderProto, true, ProtoBuf.DEF_PACK, __wtype_RpcResponseHeaderProto, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RpcResponseHeaderProto) = ProtoBuf.protohash(v)
isequal(v1::RpcResponseHeaderProto, v2::RpcResponseHeaderProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RpcResponseHeaderProto, v2::RpcResponseHeaderProto) = ProtoBuf.protoeq(v1, v2)

struct __enum_RpcSaslProto_SaslState <: ProtoEnum
SUCCESS::Int32
Expand All @@ -111,21 +101,15 @@ mutable struct RpcSaslProto_SaslAuth <: ProtoType
end #mutable struct RpcSaslProto_SaslAuth
const __req_RpcSaslProto_SaslAuth = Symbol[:method,:mechanism]
meta(t::Type{RpcSaslProto_SaslAuth}) = meta(t, __req_RpcSaslProto_SaslAuth, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RpcSaslProto_SaslAuth) = ProtoBuf.protohash(v)
isequal(v1::RpcSaslProto_SaslAuth, v2::RpcSaslProto_SaslAuth) = ProtoBuf.protoisequal(v1, v2)
==(v1::RpcSaslProto_SaslAuth, v2::RpcSaslProto_SaslAuth) = ProtoBuf.protoeq(v1, v2)

mutable struct RpcSaslProto <: ProtoType
version::UInt32
state::Int32
token::Array{UInt8,1}
auths::Vector{RpcSaslProto_SaslAuth}
auths::Base.Vector{RpcSaslProto_SaslAuth}
RpcSaslProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct RpcSaslProto
const __req_RpcSaslProto = Symbol[:state]
meta(t::Type{RpcSaslProto}) = meta(t, __req_RpcSaslProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RpcSaslProto) = ProtoBuf.protohash(v)
isequal(v1::RpcSaslProto, v2::RpcSaslProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RpcSaslProto, v2::RpcSaslProto) = ProtoBuf.protoeq(v1, v2)

export RpcKindProto, RPCTraceInfoProto, RpcRequestHeaderProto_OperationProto, RpcRequestHeaderProto, RpcResponseHeaderProto_RpcStatusProto, RpcResponseHeaderProto_RpcErrorCodeProto, RpcResponseHeaderProto, RpcSaslProto_SaslState, RpcSaslProto_SaslAuth, RpcSaslProto
22 changes: 0 additions & 22 deletions src/hadoop/Security_pb.jl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
using Compat
using ProtoBuf
import ProtoBuf.meta
import Base: hash, isequal, ==

mutable struct TokenProto <: ProtoType
identifier::Array{UInt8,1}
Expand All @@ -13,63 +12,42 @@ mutable struct TokenProto <: ProtoType
end #mutable struct TokenProto
const __req_TokenProto = Symbol[:identifier,:password,:kind,:service]
meta(t::Type{TokenProto}) = meta(t, __req_TokenProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::TokenProto) = ProtoBuf.protohash(v)
isequal(v1::TokenProto, v2::TokenProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::TokenProto, v2::TokenProto) = ProtoBuf.protoeq(v1, v2)

mutable struct GetDelegationTokenRequestProto <: ProtoType
renewer::AbstractString
GetDelegationTokenRequestProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct GetDelegationTokenRequestProto
const __req_GetDelegationTokenRequestProto = Symbol[:renewer]
meta(t::Type{GetDelegationTokenRequestProto}) = meta(t, __req_GetDelegationTokenRequestProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::GetDelegationTokenRequestProto) = ProtoBuf.protohash(v)
isequal(v1::GetDelegationTokenRequestProto, v2::GetDelegationTokenRequestProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::GetDelegationTokenRequestProto, v2::GetDelegationTokenRequestProto) = ProtoBuf.protoeq(v1, v2)

mutable struct GetDelegationTokenResponseProto <: ProtoType
token::TokenProto
GetDelegationTokenResponseProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct GetDelegationTokenResponseProto
hash(v::GetDelegationTokenResponseProto) = ProtoBuf.protohash(v)
isequal(v1::GetDelegationTokenResponseProto, v2::GetDelegationTokenResponseProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::GetDelegationTokenResponseProto, v2::GetDelegationTokenResponseProto) = ProtoBuf.protoeq(v1, v2)

mutable struct RenewDelegationTokenRequestProto <: ProtoType
token::TokenProto
RenewDelegationTokenRequestProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct RenewDelegationTokenRequestProto
const __req_RenewDelegationTokenRequestProto = Symbol[:token]
meta(t::Type{RenewDelegationTokenRequestProto}) = meta(t, __req_RenewDelegationTokenRequestProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RenewDelegationTokenRequestProto) = ProtoBuf.protohash(v)
isequal(v1::RenewDelegationTokenRequestProto, v2::RenewDelegationTokenRequestProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RenewDelegationTokenRequestProto, v2::RenewDelegationTokenRequestProto) = ProtoBuf.protoeq(v1, v2)

mutable struct RenewDelegationTokenResponseProto <: ProtoType
newExpiryTime::UInt64
RenewDelegationTokenResponseProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct RenewDelegationTokenResponseProto
const __req_RenewDelegationTokenResponseProto = Symbol[:newExpiryTime]
meta(t::Type{RenewDelegationTokenResponseProto}) = meta(t, __req_RenewDelegationTokenResponseProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::RenewDelegationTokenResponseProto) = ProtoBuf.protohash(v)
isequal(v1::RenewDelegationTokenResponseProto, v2::RenewDelegationTokenResponseProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::RenewDelegationTokenResponseProto, v2::RenewDelegationTokenResponseProto) = ProtoBuf.protoeq(v1, v2)

mutable struct CancelDelegationTokenRequestProto <: ProtoType
token::TokenProto
CancelDelegationTokenRequestProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct CancelDelegationTokenRequestProto
const __req_CancelDelegationTokenRequestProto = Symbol[:token]
meta(t::Type{CancelDelegationTokenRequestProto}) = meta(t, __req_CancelDelegationTokenRequestProto, ProtoBuf.DEF_FNUM, ProtoBuf.DEF_VAL, true, ProtoBuf.DEF_PACK, ProtoBuf.DEF_WTYPES, ProtoBuf.DEF_ONEOFS, ProtoBuf.DEF_ONEOF_NAMES, ProtoBuf.DEF_FIELD_TYPES)
hash(v::CancelDelegationTokenRequestProto) = ProtoBuf.protohash(v)
isequal(v1::CancelDelegationTokenRequestProto, v2::CancelDelegationTokenRequestProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::CancelDelegationTokenRequestProto, v2::CancelDelegationTokenRequestProto) = ProtoBuf.protoeq(v1, v2)

mutable struct CancelDelegationTokenResponseProto <: ProtoType
CancelDelegationTokenResponseProto(; kwargs...) = (o=new(); fillunset(o); isempty(kwargs) || ProtoBuf._protobuild(o, kwargs); o)
end #mutable struct CancelDelegationTokenResponseProto
hash(v::CancelDelegationTokenResponseProto) = ProtoBuf.protohash(v)
isequal(v1::CancelDelegationTokenResponseProto, v2::CancelDelegationTokenResponseProto) = ProtoBuf.protoisequal(v1, v2)
==(v1::CancelDelegationTokenResponseProto, v2::CancelDelegationTokenResponseProto) = ProtoBuf.protoeq(v1, v2)

export TokenProto, GetDelegationTokenRequestProto, GetDelegationTokenResponseProto, RenewDelegationTokenRequestProto, RenewDelegationTokenResponseProto, CancelDelegationTokenRequestProto, CancelDelegationTokenResponseProto
Loading

0 comments on commit 1b911e8

Please sign in to comment.