Package com.illumon.iris.controller.utils

Class ControllerGrpcHelper

java.lang.Object

com.illumon.iris.controller.utils.ControllerGrpcHelper

public final class ControllerGrpcHelper
extends Object

This class contains utilities for packing and unpacking objects for gRPC communication.

Field Summary

Fields

Modifier and Type	Field	Description
static final io.deephaven.shadow.core.io.grpc.Metadata.Key<io.deephaven.proto.controller.ErrorResponse>	ERROR_KEY

Method Summary

Modifier and Type	Method	Description
static io.deephaven.proto.controller.ControllerConfigurationMessage	makeControllerConfigMessage(PersistentQueryControllerConfiguration serverConfiguration)	Serialize a PersistentQueryControllerConfiguration for gRPC
static PersistentQueryDbServerConfig	makeDbServerConfig(io.deephaven.proto.controller.PQDBServerConfigMessage configMessage)	Deserialize a PersistentQueryDbServerConfig from gRPC.
static ExportedObjectInfo	makeExportedObjectInfo(io.deephaven.proto.controller.ExportedObjectInfoMessage eo)	Deserialize an ExportedObjectInfo from gRPC.
static io.deephaven.proto.controller.ExportedObjectInfoMessage	makeExportedObjectInfoMessage(String name, ExportedObjectInfo type)	Make an ExportedObjectInfoMessage from a name and ExportedObjectInfo
static io.deephaven.proto.controller.NamedStringList	makeNamedStringList(String name, String[] list)	Create a NamedStringList object from a string array and name.
static io.deephaven.proto.controller.NamedStringList	makeNamedStringList(String name, Collection<String> list)	Create a NamedStringList object from a collection of strings and name.
static PersistentQueryControllerConfiguration	makePersistentQueryControllerConfiguration(io.deephaven.proto.controller.ControllerConfigurationMessage response)	Deserialize a PersistentQueryControllerConfiguration from gRPC
static io.deephaven.proto.controller.PQDBServerConfigMessage	makePQDBServerConfigMessage(PersistentQueryDbServerConfig config)	Serialize a PersistentQueryDbServerConfig object for gRPC
static PersistentQueryConfiguration	makeQueryConfig(io.deephaven.proto.controller.PersistentQueryConfigMessage configMessage)	Deserialize a PersistentQueryConfiguration from gRPC.
static io.deephaven.proto.controller.PersistentQueryConfigMessage	makeQueryConfigMessage(PersistentQueryConfiguration config)	Serialize a PersistentQueryConfiguration object for gRPC.
static PersistentQueryInfo	makeQueryInfo(io.deephaven.proto.controller.PersistentQueryInfoMessage infoMessage)	Deserialize a PersistentQueryInfo from gRPC.
static io.deephaven.proto.controller.PersistentQueryInfoMessage	makeQueryInfoMessage(PersistentQueryInfo info, WorkerUrlBuilder workerUrlBuilder)	Serialize a PersistentQueryInfo object for gRPC.
static PersistentQueryState.Status	makeStatus(io.deephaven.proto.controller.PersistentQueryStatusEnum grpcStatus)	Deserialize a PersistentQueryState.Status from gRPC.
static TableDefinition	makeTableDefinition(io.deephaven.proto.common.TableDefinitionMessage message)	Deserialize a TableDefinition from gRPC.
static io.deephaven.enterprise.dispatcher.client.WorkerProtocol	makeWorkerProtocol(io.deephaven.proto.controller.WorkerProtocolMessage protocolMessage)	Deserialize a WorkerProtocol from gRPC.

Methods inherited from class java.lang.Object

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

Field Details

ERROR_KEY

public static final io.deephaven.shadow.core.io.grpc.Metadata.Key<io.deephaven.proto.controller.ErrorResponse> ERROR_KEY

Method Details

makeQueryInfoMessage

public static io.deephaven.proto.controller.PersistentQueryInfoMessage makeQueryInfoMessage(@NotNull
 PersistentQueryInfo info,
 @NotNull
 WorkerUrlBuilder workerUrlBuilder)
                                                                                     throws ControllerSerializationException

Serialize a PersistentQueryInfo object for gRPC.

Parameters:

info - the object to serialize

Returns:

the serialized PersistentQueryInfoMessage

Throws:

ControllerSerializationException - if a problem occurred converting the message to gRPC

makeQueryConfigMessage

public static io.deephaven.proto.controller.PersistentQueryConfigMessage makeQueryConfigMessage(@NotNull
 PersistentQueryConfiguration config)
                                                                                         throws ControllerSerializationException

Serialize a PersistentQueryConfiguration object for gRPC.

Parameters:

config - the object to serialize

Returns:

the serialized PersistentQueryConfigMessage

Throws:

ControllerSerializationException - if a problem occurred converting the message to gRPC

makeNamedStringList

public static io.deephaven.proto.controller.NamedStringList makeNamedStringList(@NotNull
 String name,
 @Nullable
 String[] list)

Create a NamedStringList object from a string array and name.

Parameters:

name - the name to use

list - the array of values

Returns:

a new NamedStringList

makeNamedStringList

@NotNull
public static io.deephaven.proto.controller.NamedStringList makeNamedStringList(@NotNull
 String name,
 @Nullable
 Collection<String> list)

Create a NamedStringList object from a collection of strings and name.

Parameters:

name - the name to use

list - the collection of values

Returns:

a new NamedStringList

makeExportedObjectInfoMessage

public static io.deephaven.proto.controller.ExportedObjectInfoMessage makeExportedObjectInfoMessage(@NotNull
 String name,
 @NotNull
 ExportedObjectInfo type)
                                                                                             throws ControllerSerializationException

Make an ExportedObjectInfoMessage from a name and ExportedObjectInfo

Parameters:

name - the name of the object

type - the ExportedObjectInfo

Returns:

a new ExportedObjectInfoMessage

Throws:

ControllerSerializationException - if a problem occurred converting the message to gRPC

makePQDBServerConfigMessage

public static io.deephaven.proto.controller.PQDBServerConfigMessage makePQDBServerConfigMessage(@NotNull
 PersistentQueryDbServerConfig config)
                                                                                         throws ControllerSerializationException

Serialize a PersistentQueryDbServerConfig object for gRPC

Parameters:

config - the configuration to serialize

Returns:

a new PersistentQueryDbServerConfig

Throws:

ControllerSerializationException - if a problem occurred converting the message to gRPC

makeControllerConfigMessage

public static io.deephaven.proto.controller.ControllerConfigurationMessage makeControllerConfigMessage(@NotNull
 PersistentQueryControllerConfiguration serverConfiguration)
                                                                                                throws ControllerSerializationException

Serialize a PersistentQueryControllerConfiguration for gRPC

Parameters:

serverConfiguration - the configuration to serialize

Returns:

a new ControllerConfigurationMessage

Throws:

ControllerSerializationException - if a problem occurred converting the message to gRPC

makeQueryInfo

public static PersistentQueryInfo makeQueryInfo(@NotNull
 io.deephaven.proto.controller.PersistentQueryInfoMessage infoMessage)
                                         throws ControllerSerializationException

Deserialize a PersistentQueryInfo from gRPC.

Parameters:

infoMessage - the message to deserialize

Returns:

a new PersistentQueryInfo

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makeWorkerProtocol

public static io.deephaven.enterprise.dispatcher.client.WorkerProtocol makeWorkerProtocol(@NotNull
 io.deephaven.proto.controller.WorkerProtocolMessage protocolMessage)

Deserialize a WorkerProtocol from gRPC.

Parameters:

protocolMessage - the message to deserialize

Returns:

a new WorkerProtocol

makeQueryConfig

public static PersistentQueryConfiguration makeQueryConfig(io.deephaven.proto.controller.PersistentQueryConfigMessage configMessage)
                                                    throws ControllerSerializationException

Deserialize a PersistentQueryConfiguration from gRPC.

Parameters:

configMessage - the message to deserialize

Returns:

a new PersistentQueryConfiguration

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makeStatus

public static PersistentQueryState.Status makeStatus(@NotNull
 io.deephaven.proto.controller.PersistentQueryStatusEnum grpcStatus)
                                              throws ControllerSerializationException

Deserialize a PersistentQueryState.Status from gRPC.

Parameters:

grpcStatus - the message to deserialize

Returns:

a new PersistentQueryState.Status.

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makeDbServerConfig

public static PersistentQueryDbServerConfig makeDbServerConfig(io.deephaven.proto.controller.PQDBServerConfigMessage configMessage)
                                                        throws ControllerSerializationException

Deserialize a PersistentQueryDbServerConfig from gRPC.

Parameters:

configMessage - the message to deserialize

Returns:

a new PersistentQueryDbServerConfig

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makePersistentQueryControllerConfiguration

public static PersistentQueryControllerConfiguration makePersistentQueryControllerConfiguration(@NotNull
 io.deephaven.proto.controller.ControllerConfigurationMessage response)
                                                                                         throws ControllerSerializationException

Deserialize a PersistentQueryControllerConfiguration from gRPC

Parameters:

response - the message to deserialize

Returns:

a new PersistentQueryControllerConfiguration

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makeExportedObjectInfo

public static ExportedObjectInfo makeExportedObjectInfo(io.deephaven.proto.controller.ExportedObjectInfoMessage eo)
                                                 throws ControllerSerializationException

Deserialize an ExportedObjectInfo from gRPC.

Parameters:

eo - the message to deserialize

Returns:

a new ExportedObjectInfo

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message

makeTableDefinition

public static TableDefinition makeTableDefinition(@NotNull
 io.deephaven.proto.common.TableDefinitionMessage message)
                                           throws ControllerSerializationException

Deserialize a TableDefinition from gRPC.

Parameters:

message - the message to deserialize

Returns:

a new TableDefinition

Throws:

ControllerSerializationException - if a problem occurred deserializing gRPC message