alluxio.grpc

Class GrpcUtils

java.lang.Object

alluxio.grpc.GrpcUtils

@ThreadSafe
public final class GrpcUtils
extends Object

Utility methods for conversion between wire types and grpc types.

Method Summary

Modifier and Type	Method and Description
static Scope	combine(Scope scope1, Scope scope2)
static boolean	contains(Scope source, Scope target)
static MountPOptions	fromMountEntry(File.AddMountPointEntry mountEntryPoint) Creates mount proto options from File.AddMountPointEntry.
static BlockInfo	fromProto(BlockInfo blockPInfo) Converts a proto type to a wire type.
static BlockLocation	fromProto(BlockLocation blockPLocation) Converts a proto type to a wire type.
static FileBlockInfo	fromProto(FileBlockInfo fileBlockPInfo) Converts a proto type to a wire type.
static FileInfo	fromProto(FileInfo pInfo) Converts a proto type to a wire type.
static DescendantType	fromProto(LoadDescendantPType pDescendantType) Converts a proto type to a wire type.
static MountPointInfo	fromProto(MountPointInfo mountPointPInfo) Converts a proto type to a wire type.
static AccessControlList	fromProto(PAcl pAcl)
static AclAction	fromProto(PAclAction pAction)
static AclEntry	fromProto(PAclEntry pAclEntry)
static AclEntryType	fromProto(PAclEntryType pAclEntryType)
static WorkerInfo	fromProto(WorkerInfo workerInfo) Converts a proto type to a wire type.
static WorkerNetAddress	fromProto(WorkerNetAddress workerNetPAddress) Converts a proto type to a wire type.
static InetSocketAddress[]	netAddressToSocketAddress(List<NetAddress> request) Convert a list of NetAddress to InetSocketAddress.
static GetStatusPOptions	toGetStatusOptions(ExistsPOptions existsOptions) Converts from proto type to options.
static PAcl	toProto(AccessControlList acl)
static PAclAction	toProto(AclAction action)
static PAclEntry	toProto(AclEntry aclEntry)
static PAclEntryType	toProto(AclEntryType aclEntryType)
static BlockInfo	toProto(BlockInfo blockInfo) Converts wire type to proto type.
static BlockLocation	toProto(BlockLocation blockLocation) Converts wire type to proto type.
static CommandType	toProto(CommandType commandType)
static PAcl	toProto(DefaultAccessControlList defaultAcl)
static LoadDescendantPType	toProto(DescendantType loadDescendantType) Converts options to proto type.
static FileBlockInfo	toProto(FileBlockInfo fileBlockInfo) Converts wire type to proto type.
static FileInfo	toProto(FileInfo fileInfo) Converts a wire type to a proto type.
static FileSystemCommand	toProto(FileSystemCommand fsCommand)
static LoadMetadataPType	toProto(LoadMetadataType loadMetadataType) Converts options to proto type.
static GetRegisterLeasePResponse	toProto(long workerId, Optional<RegisterLease> lease)
static MountPointInfo	toProto(MountPointInfo info) Converts wire type to proto type.
static PersistFile	toProto(PersistFile persistFile)
static UfsInfo	toProto(UfsInfo ufsInfo)
static WorkerInfo	toProto(WorkerInfo workerInfo) Converts wire type to proto type.
static WorkerNetAddress	toProto(WorkerNetAddress workerNetAddress) Converts wire type to proto type.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toGetStatusOptions

public static GetStatusPOptions toGetStatusOptions(ExistsPOptions existsOptions)

Converts from proto type to options.

Parameters:

existsOptions - the proto options to convert

Returns:

the converted proto options

fromMountEntry

public static MountPOptions fromMountEntry(File.AddMountPointEntry mountEntryPoint)

Creates mount proto options from File.AddMountPointEntry.

Parameters:

mountEntryPoint - mount point entry

Returns:

created mount proto options

fromProto

public static AccessControlList fromProto(PAcl pAcl)

Parameters:

pAcl - the proto representation

Returns:

the AccessControlList instance created from the proto representation

fromProto

public static AclEntry fromProto(PAclEntry pAclEntry)

Parameters:

pAclEntry - the proto representation

Returns:

the AclEntry instance created from the proto representation

fromProto

public static AclAction fromProto(PAclAction pAction)

Parameters:

pAction - the proto representation

Returns:

the AclAction created from the proto representation

fromProto

public static AclEntryType fromProto(PAclEntryType pAclEntryType)

Parameters:

pAclEntryType - the proto representation

Returns:

the AclEntryType created from the proto representation

fromProto

public static BlockLocation fromProto(BlockLocation blockPLocation)

Converts a proto type to a wire type.

Parameters:

blockPLocation - the proto type to convert

Returns:

the converted wire type

fromProto

public static BlockInfo fromProto(BlockInfo blockPInfo)

Converts a proto type to a wire type.

Parameters:

blockPInfo - the proto type to convert

Returns:

the converted wire type

fromProto

public static DescendantType fromProto(LoadDescendantPType pDescendantType)

Converts a proto type to a wire type.

Parameters:

pDescendantType - the proto representation of a descendant type

Returns:

the wire representation of the descendant type

fromProto

public static FileInfo fromProto(FileInfo pInfo)

Converts a proto type to a wire type.

Parameters:

pInfo - the proto representation of a file information

Returns:

wire representation of the file information

fromProto

public static FileBlockInfo fromProto(FileBlockInfo fileBlockPInfo)

Converts a proto type to a wire type.

Parameters:

fileBlockPInfo - the proto type to convert

Returns:

the converted wire type

fromProto

public static MountPointInfo fromProto(MountPointInfo mountPointPInfo)

Converts a proto type to a wire type.

Parameters:

mountPointPInfo - the proto type to convert

Returns:

the converted wire type

fromProto

public static WorkerInfo fromProto(WorkerInfo workerInfo)

Converts a proto type to a wire type.

Parameters:

workerInfo - the proto type to convert

Returns:

the converted wire type

fromProto

public static WorkerNetAddress fromProto(WorkerNetAddress workerNetPAddress)

Converts a proto type to a wire type.

Parameters:

workerNetPAddress - the proto type to convert

Returns:

the converted wire type

toProto

public static PAcl toProto(AccessControlList acl)

Parameters:

acl - the access control list to convert

Returns:

the proto representation of this object

toProto

public static PAcl toProto(DefaultAccessControlList defaultAcl)

Parameters:

defaultAcl - the default access control list to convert

Returns:

the proto representation of default acl object

toProto

public static PAclAction toProto(AclAction action)

Parameters:

action - the acl action to convert

Returns:

the proto representation of this enum

toProto

public static PAclEntry toProto(AclEntry aclEntry)

Parameters:

aclEntry - the acl entry to convert

Returns:

the proto representation of AclEntry instance

toProto

public static PAclEntryType toProto(AclEntryType aclEntryType)

Parameters:

aclEntryType - the acl entry type to convert

Returns:

the proto representation of this enum

toProto

public static BlockInfo toProto(BlockInfo blockInfo)

Converts wire type to proto type.

Parameters:

blockInfo - the wire type to convert

Returns:

the converted proto type

toProto

public static BlockLocation toProto(BlockLocation blockLocation)

Converts wire type to proto type.

Parameters:

blockLocation - the wire type to convert

Returns:

the converted proto type

toProto

public static FileInfo toProto(FileInfo fileInfo)

Converts a wire type to a proto type.

Parameters:

fileInfo - the wire representation of a file information

Returns:

proto representation of the file information

toProto

public static FileBlockInfo toProto(FileBlockInfo fileBlockInfo)

Converts wire type to proto type.

Parameters:

fileBlockInfo - the wire representation to convert

Returns:

converted proto representation

toProto

public static LoadMetadataPType toProto(LoadMetadataType loadMetadataType)

Converts options to proto type.

Parameters:

loadMetadataType - the LoadMetadataType

Returns:

the proto representation of this enum

toProto

public static LoadDescendantPType toProto(DescendantType loadDescendantType)

Converts options to proto type.

Parameters:

loadDescendantType - the DescendantType

Returns:

the proto representation of this enum

toProto

public static MountPointInfo toProto(MountPointInfo info)

Converts wire type to proto type.

Parameters:

info - the wire representation to convert

Returns:

converted proto representation

toProto

public static WorkerInfo toProto(WorkerInfo workerInfo)

Converts wire type to proto type.

Parameters:

workerInfo - the wire representation to convert

Returns:

the converted proto representation

toProto

public static WorkerNetAddress toProto(WorkerNetAddress workerNetAddress)

Converts wire type to proto type.

Parameters:

workerNetAddress - the wire representation to convert

Returns:

the converted proto representation

toProto

public static CommandType toProto(CommandType commandType)

Parameters:

commandType - wire type

Returns:

proto representation of given wire type

toProto

public static PersistFile toProto(PersistFile persistFile)

Parameters:

persistFile - wire type

Returns:

proto representation of given wire type

toProto

public static FileSystemCommand toProto(FileSystemCommand fsCommand)

Parameters:

fsCommand - wire type

Returns:

proto representation of given wire type

toProto

public static UfsInfo toProto(UfsInfo ufsInfo)

Parameters:

ufsInfo - wire type

Returns:

proto representation of given wire type

toProto

public static GetRegisterLeasePResponse toProto(long workerId,
                                                Optional<RegisterLease> lease)

Parameters:

workerId - the worker that requests a lease

lease - the lease decision from the master

Returns:

a GetRegisterLeasePResponse

contains

public static boolean contains(Scope source,
                               Scope target)

Parameters:

source - source enum

target - target enum

Returns:

true if target enum is contained within the source

combine

public static Scope combine(Scope scope1,
                            Scope scope2)

Parameters:

scope1 - source1

scope2 - source2

Returns:

combined enum of given enums

netAddressToSocketAddress

public static InetSocketAddress[] netAddressToSocketAddress(List<NetAddress> request)
                                                     throws UnknownHostException

Convert a list of NetAddress to InetSocketAddress.

Parameters:

request - the net addresses

Returns:

the list of InetSocketAddresses

Throws:

UnknownHostException