mdk

Class MDKImpl

java.lang.Object

mdk.MDKImpl

All Implemented Interfaces:

io.datawire.quark.runtime.QObject, MDK

public class MDKImpl
extends java.lang.Object
implements MDK, io.datawire.quark.runtime.QObject

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.Double	_defaultTimeout
mdk_discovery.Discovery	_disco
mdk_discovery.DiscoverySource	_discoSource
mdk_protocol.OperationalEnvironment	_environment
mdk_metrics.MetricsClient	_metrics
mdk_protocol.OpenCloseSubscriber	_openclose
java.util.HashMap<java.lang.String,java.lang.Object>	_reflection_hack
java.lang.Boolean	_running
mdk_runtime.MDKRuntime	_runtime
mdk_tracing.Tracer	_tracer
mdk_protocol.WSClient	_wsclient
static java.lang.String	CONTEXT_HEADER This header is used to propogate shared context for distributed traces.
io.datawire.quark.runtime.Logger	logger
static quark.reflect.Class	mdk_MDKImpl_ref
java.lang.String	procUUID
static quark.reflect.Class	quark_Map_quark_String_quark_Object__ref

Fields inherited from interface mdk.MDK

mdk_MDK_ref

Constructor Summary

Constructors

Constructor and Description
MDKImpl(mdk_runtime.MDKRuntime runtime)

Method Summary

Modifier and Type	Method and Description
java.lang.String	_getClass()
java.lang.Object	_getField(java.lang.String name)
void	_setField(java.lang.String name, java.lang.Object value)
java.lang.Double	_timeout()
Session	derive(java.lang.String encodedContext) Create a new Session.
mdk_discovery.DiscoverySourceFactory	getDiscoveryFactory(mdk_runtime.EnvironmentVariables env) Choose DiscoverySource based on environment variables.
mdk_discovery.FailurePolicyFactory	getFailurePolicy(mdk_runtime.MDKRuntime runtime) Choose FailurePolicy based on environment variables.
mdk_protocol.WSClient	getWSClient(mdk_runtime.MDKRuntime runtime) Get a WSClient, unless env variables suggest the user doesn't want one.
Session	join(java.lang.String encodedContext) Create a new Session and join it to an existing distributed sesion.
void	register(java.lang.String service, java.lang.String version, java.lang.String address) Registers a service endpoint with the discovery system.
Session	session() Creates a new Session.
void	setDefaultDeadline(java.lang.Double seconds) Set the default timeout for MDK sessions.
void	setDefaultTimeout(java.lang.Double seconds) DEPRECATED, use setDefaultDeadline().
void	start() Start the MDK.
void	stop() Stop the MDK.

Methods inherited from class java.lang.Object

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

Field Detail

mdk_MDKImpl_ref

public static quark.reflect.Class mdk_MDKImpl_ref

quark_Map_quark_String_quark_Object__ref

public static quark.reflect.Class quark_Map_quark_String_quark_Object__ref

CONTEXT_HEADER

public static java.lang.String CONTEXT_HEADER

This header is used to propogate shared context for distributed traces.

logger

public io.datawire.quark.runtime.Logger logger

_reflection_hack

public java.util.HashMap<java.lang.String,java.lang.Object> _reflection_hack

_runtime

public mdk_runtime.MDKRuntime _runtime

_wsclient

public mdk_protocol.WSClient _wsclient

_openclose

public mdk_protocol.OpenCloseSubscriber _openclose

_disco

public mdk_discovery.Discovery _disco

_discoSource

public mdk_discovery.DiscoverySource _discoSource

_tracer

public mdk_tracing.Tracer _tracer

_metrics

public mdk_metrics.MetricsClient _metrics

procUUID

public java.lang.String procUUID

_running

public java.lang.Boolean _running

_defaultTimeout

public java.lang.Double _defaultTimeout

_environment

public mdk_protocol.OperationalEnvironment _environment

Constructor Detail

MDKImpl

public MDKImpl(mdk_runtime.MDKRuntime runtime)

Method Detail

getDiscoveryFactory

public mdk_discovery.DiscoverySourceFactory getDiscoveryFactory(mdk_runtime.EnvironmentVariables env)

Choose DiscoverySource based on environment variables.

getFailurePolicy

public mdk_discovery.FailurePolicyFactory getFailurePolicy(mdk_runtime.MDKRuntime runtime)

Choose FailurePolicy based on environment variables.

getWSClient

public mdk_protocol.WSClient getWSClient(mdk_runtime.MDKRuntime runtime)

Get a WSClient, unless env variables suggest the user doesn't want one.

_timeout

public java.lang.Double _timeout()

start

public void start()

Description copied from interface: MDK

Start the MDK. An MDK instance will not communicate with foundational services unless it is started.

Specified by:

start in interface MDK

stop

public void stop()

Description copied from interface: MDK

Stop the MDK. When the MDK stops unregisters any service endpoints from the discovery system. This should always be done prior to process exit in order to propogate node shutdowns in realtime rather than waiting for heartbeats to detect node departures.

Specified by:

stop in interface MDK

register

public void register(java.lang.String service,
                     java.lang.String version,
                     java.lang.String address)

Description copied from interface: MDK

Registers a service endpoint with the discovery system. This can be called at any point, however registered endpoints will not be advertised to the discovery system until the MDK is started.

Specified by:

register in interface MDK

setDefaultDeadline

public void setDefaultDeadline(java.lang.Double seconds)

Description copied from interface: MDK

Set the default timeout for MDK sessions. This is the maximum timeout; if a joined session has a lower timeout that will be used.

Specified by:

setDefaultDeadline in interface MDK

setDefaultTimeout

public void setDefaultTimeout(java.lang.Double seconds)

Description copied from interface: MDK

DEPRECATED, use setDefaultDeadline().

Specified by:

setDefaultTimeout in interface MDK

session

public Session session()

Description copied from interface: MDK

Creates a new Session. A Session created in this way will result in a new distributed trace. This should therefore be used primarily by edge services. Intermediary and foundational services should make use of join(encodedContext) in order to preserve distributed traces.

Specified by:

session in interface MDK

derive

public Session derive(java.lang.String encodedContext)

Description copied from interface: MDK

Create a new Session. The given encoded distributed session's properties will be used to configure the new Session, e.g. overrides will be preserved. However, because this is a new Session the timeout will not be copied from the encoded session. This is intended for use for encoded context received via a broadcast medium (pub/sub, message queues with multiple readers, etc.). If you know only you received the encoded context, e.g. you're coding a server that receives the context from a HTTP request, you should join() instead.

Specified by:

derive in interface MDK

join

public Session join(java.lang.String encodedContext)

Description copied from interface: MDK

Create a new Session and join it to an existing distributed sesion. This should only ever be done once per an encoded context. That means you should only use it for RPC or similar one-off calls. If you received the encoded context via a broadcast medium (pub/sub, message queues with multiple readers, etc.) you should use childSession() instead.

Specified by:

join in interface MDK

_getClass

public java.lang.String _getClass()

Specified by:

_getClass in interface io.datawire.quark.runtime.QObject

_getField

public java.lang.Object _getField(java.lang.String name)

Specified by:

_getField in interface io.datawire.quark.runtime.QObject

_setField

public void _setField(java.lang.String name,
                      java.lang.Object value)

Specified by:

_setField in interface io.datawire.quark.runtime.QObject