mdk

Class SessionImpl

java.lang.Object

mdk.SessionImpl

All Implemented Interfaces:

io.datawire.quark.runtime.QObject, Session

public class SessionImpl
extends java.lang.Object
implements Session, io.datawire.quark.runtime.QObject

Field Summary

Fields

Modifier and Type	Field and Description
mdk_protocol.SharedContext	_context
java.lang.Boolean	_experimental
static io.datawire.quark.runtime.TLS<java.lang.Boolean>	_inLogging
java.util.ArrayList<mdk_metrics.InteractionEvent>	_interactionReports
static java.util.HashMap<java.lang.String,java.lang.Integer>	_levels
MDKImpl	_mdk
java.util.ArrayList<java.util.ArrayList<mdk_discovery.Node>>	_resolved
static quark.reflect.Class	mdk_SessionImpl_ref
static quark.reflect.Class	quark_List_mdk_discovery_Node__ref
static quark.reflect.Class	quark_List_mdk_metrics_InteractionEvent__ref
static quark.reflect.Class	quark_List_quark_List_mdk_discovery_Node___ref
static quark.reflect.Class	quark_List_quark_Map_quark_String_quark_String___ref
static quark.reflect.Class	quark_List_quark_String__ref
static quark.reflect.Class	quark_Map_quark_String_quark_int__ref
static quark.reflect.Class	quark_Map_quark_String_quark_List_quark_Map_quark_String_quark_String____ref
static quark.reflect.Class	quark_Map_quark_String_quark_String__ref

Fields inherited from interface mdk.Session

mdk_Session_ref

Constructor Summary

Constructors

Constructor and Description
SessionImpl(MDKImpl mdk, java.lang.String encodedContext, mdk_protocol.OperationalEnvironment localEnvironment)

Method Summary

Modifier and Type	Method and Description
java.util.ArrayList<mdk_discovery.Node>	_current_interaction()
java.lang.Boolean	_enabled(java.lang.String level)
java.lang.String	_getClass()
java.lang.Object	_getField(java.lang.String name)
static java.lang.Integer	_level(java.lang.String level)
LoggedMessageId	_log(java.lang.String level, java.lang.String category, java.lang.String text)
mdk_runtime.promise.Promise	_resolve(java.lang.String service, java.lang.String version)
mdk_discovery.Node	_resolvedCallback(mdk_discovery.Node result)
void	_setField(java.lang.String name, java.lang.Object value)
mdk_metrics.InteractionEvent	_start_interaction()
LoggedMessageId	critical(java.lang.String category, java.lang.String text) Record a log entry at the CRITICAL logging level.
LoggedMessageId	debug(java.lang.String category, java.lang.String text) Record a log entry at the DEBUG logging level.
LoggedMessageId	error(java.lang.String category, java.lang.String text) Record a log entry at the ERROR logging level.
java.lang.String	externalize() Returns an externalized representation of the distributed session.
void	fail_interaction(java.lang.String message) Record an interaction as failed.
void	finish_interaction() Finish an interaction.
mdk_protocol.OperationalEnvironment	getEnvironment() Return the session's Environment.
java.lang.Object	getProperty(java.lang.String property) Return the value of a property from the distributed session.
java.lang.Double	getRemainingTime() Return how many seconds until the session ought to end.
java.lang.Boolean	hasProperty(java.lang.String property) Return whether the distributed session has a property.
LoggedMessageId	info(java.lang.String category, java.lang.String text) Record a log entry at the INFO logging level.
java.lang.String	inject() Grabs the encoded context.
void	interact(quark.UnaryCallable cmd) This is a convenience API that will perform start_interaction() followed by callable(ssn) followed by finish_interaction().
java.lang.Object	resolve_async(java.lang.String service, java.lang.String version) Locate a compatible service instance asynchronously.
mdk_discovery.Node	resolve_until(java.lang.String service, java.lang.String version, java.lang.Double timeout) Locate a compatible service instance with a non-default timeout.
mdk_discovery.Node	resolve(java.lang.String service, java.lang.String version) Locate a compatible service instance.
void	route(java.lang.String service, java.lang.String version, java.lang.String target, java.lang.String targetVersion) EXPERIMENTAL; requires MDK_EXPERIMENTAL=1 environment variable to function.
void	setDeadline(java.lang.Double timeout) Set how many seconds the session is expected to live from this point.
void	setProperty(java.lang.String property, java.lang.Object value) Set a property on the distributed session.
void	setTimeout(java.lang.Double timeout) DEPRECATED, use setDeadline().
void	start_interaction() Start an interaction with a remote service.
void	trace(java.lang.String level) EXPERIMENTAL: Set the logging level for the session.
LoggedMessageId	warn(java.lang.String category, java.lang.String text) Record a log entry at the WARN logging level.

Methods inherited from class java.lang.Object

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

Field Detail

_levels

public static java.util.HashMap<java.lang.String,java.lang.Integer> _levels

_inLogging

public static io.datawire.quark.runtime.TLS<java.lang.Boolean> _inLogging

mdk_SessionImpl_ref

public static quark.reflect.Class mdk_SessionImpl_ref

quark_Map_quark_String_quark_int__ref

public static quark.reflect.Class quark_Map_quark_String_quark_int__ref

quark_Map_quark_String_quark_List_quark_Map_quark_String_quark_String____ref

public static quark.reflect.Class quark_Map_quark_String_quark_List_quark_Map_quark_String_quark_String____ref

quark_Map_quark_String_quark_String__ref

public static quark.reflect.Class quark_Map_quark_String_quark_String__ref

quark_List_quark_List_mdk_discovery_Node___ref

public static quark.reflect.Class quark_List_quark_List_mdk_discovery_Node___ref

quark_List_mdk_discovery_Node__ref

public static quark.reflect.Class quark_List_mdk_discovery_Node__ref

quark_List_mdk_metrics_InteractionEvent__ref

public static quark.reflect.Class quark_List_mdk_metrics_InteractionEvent__ref

quark_List_quark_Map_quark_String_quark_String___ref

public static quark.reflect.Class quark_List_quark_Map_quark_String_quark_String___ref

quark_List_quark_String__ref

public static quark.reflect.Class quark_List_quark_String__ref

_mdk

public MDKImpl _mdk

_resolved

public java.util.ArrayList<java.util.ArrayList<mdk_discovery.Node>> _resolved

_interactionReports

public java.util.ArrayList<mdk_metrics.InteractionEvent> _interactionReports

_context

public mdk_protocol.SharedContext _context

_experimental

public java.lang.Boolean _experimental

Constructor Detail

SessionImpl

public SessionImpl(MDKImpl mdk,
                   java.lang.String encodedContext,
                   mdk_protocol.OperationalEnvironment localEnvironment)

Method Detail

getEnvironment

public mdk_protocol.OperationalEnvironment getEnvironment()

Description copied from interface: Session

Return the session's Environment.

Specified by:

getEnvironment in interface Session

getProperty

public java.lang.Object getProperty(java.lang.String property)

Description copied from interface: Session

Return the value of a property from the distributed session.

Specified by:

getProperty in interface Session

setProperty

public void setProperty(java.lang.String property,
                        java.lang.Object value)

Description copied from interface: Session

Set a property on the distributed session. The key should be prefixed with a namespace so that it doesn't conflict with built-in properties, e.g. 'examplenamespace:myproperty' instead of 'myproperty'. The value should be JSON serializable.

Specified by:

setProperty in interface Session

hasProperty

public java.lang.Boolean hasProperty(java.lang.String property)

Description copied from interface: Session

Return whether the distributed session has a property.

Specified by:

hasProperty in interface Session

setTimeout

public void setTimeout(java.lang.Double timeout)

Description copied from interface: Session

DEPRECATED, use setDeadline().

Specified by:

setTimeout in interface Session

setDeadline

public void setDeadline(java.lang.Double timeout)

Description copied from interface: Session

Set how many seconds the session is expected to live from this point. If a timeout has previously been set the new timeout will only be used if it is lower than the existing timeout. The MDK will not enforce the timeout. Rather, it provides the information to any process or server in the same session (even if they are on different machines). By passing this timeout to blocking APIs you can ensure timeouts are enforced across a whole distributed session.

Specified by:

setDeadline in interface Session

getRemainingTime

public java.lang.Double getRemainingTime()

Description copied from interface: Session

Return how many seconds until the session ought to end. This will only be accurate across multiple servers insofar as their clocks are in sync. If a timeout has not been set the result will be null.

Specified by:

getRemainingTime in interface Session

route

public void route(java.lang.String service,
                  java.lang.String version,
                  java.lang.String target,
                  java.lang.String targetVersion)

Description copied from interface: Session

EXPERIMENTAL; requires MDK_EXPERIMENTAL=1 environment variable to function. Override service resolution for the current distributed session. All attempts to resolve *service*, *version* will be replaced with an attempt to resolve *target*, *targetVersion*. This effect will be propogated to any downstream services involved in the distributed session.

Specified by:

route in interface Session

trace

public void trace(java.lang.String level)

Description copied from interface: Session

EXPERIMENTAL: Set the logging level for the session.

Specified by:

trace in interface Session

_level

public static java.lang.Integer _level(java.lang.String level)

_enabled

public java.lang.Boolean _enabled(java.lang.String level)

_log

public LoggedMessageId _log(java.lang.String level,
                            java.lang.String category,
                            java.lang.String text)

critical

public LoggedMessageId critical(java.lang.String category,
                                java.lang.String text)

Description copied from interface: Session

Record a log entry at the CRITICAL logging level.

Specified by:

critical in interface Session

error

public LoggedMessageId error(java.lang.String category,
                             java.lang.String text)

Description copied from interface: Session

Record a log entry at the ERROR logging level.

Specified by:

error in interface Session

warn

public LoggedMessageId warn(java.lang.String category,
                            java.lang.String text)

Description copied from interface: Session

Record a log entry at the WARN logging level.

Specified by:

warn in interface Session

info

public LoggedMessageId info(java.lang.String category,
                            java.lang.String text)

Description copied from interface: Session

Record a log entry at the INFO logging level.

Specified by:

info in interface Session

debug

public LoggedMessageId debug(java.lang.String category,
                             java.lang.String text)

Description copied from interface: Session

Record a log entry at the DEBUG logging level.

Specified by:

debug in interface Session

_resolve

public mdk_runtime.promise.Promise _resolve(java.lang.String service,
                                            java.lang.String version)

resolve_async

public java.lang.Object resolve_async(java.lang.String service,
                                      java.lang.String version)

Description copied from interface: Session

Locate a compatible service instance asynchronously. The result is returned as a promise.

Specified by:

resolve_async in interface Session

resolve

public mdk_discovery.Node resolve(java.lang.String service,
                                  java.lang.String version)

Description copied from interface: Session

Locate a compatible service instance. Uses a minimum of 10 seconds and the timeout set on the session.

Specified by:

resolve in interface Session

resolve_until

public mdk_discovery.Node resolve_until(java.lang.String service,
                                        java.lang.String version,
                                        java.lang.Double timeout)

Description copied from interface: Session

Locate a compatible service instance with a non-default timeout.

Specified by:

resolve_until in interface Session

_resolvedCallback

public mdk_discovery.Node _resolvedCallback(mdk_discovery.Node result)

_current_interaction

public java.util.ArrayList<mdk_discovery.Node> _current_interaction()

start_interaction

public void start_interaction()

Description copied from interface: Session

Start an interaction with a remote service. The session tracks any nodes resolved during an interactin with a remote service. The service resolution API permits a compatible instance of the service to be located. In addition, it tracks which exact instances are in use during any interaction. Should the interaction fail, circuit breaker state is updated for those nodes, and all involved instances involved are reported to the tracing services. This permits realtime reporting of integration issues when services are updated, and also allows circuit breakers to mitigate the impact of any such issues.

Specified by:

start_interaction in interface Session

_start_interaction

public mdk_metrics.InteractionEvent _start_interaction()

inject

public java.lang.String inject()

Description copied from interface: Session

Grabs the encoded context.

Specified by:

inject in interface Session

externalize

public java.lang.String externalize()

Description copied from interface: Session

Returns an externalized representation of the distributed session.

Specified by:

externalize in interface Session

fail_interaction

public void fail_interaction(java.lang.String message)

Description copied from interface: Session

Record an interaction as failed. This will update circuit breaker state for the remote nodes, as well as reporting all nodes involved to the tracing system.

Specified by:

fail_interaction in interface Session

finish_interaction

public void finish_interaction()

Description copied from interface: Session

Finish an interaction. This marks an interaction as completed.

Specified by:

finish_interaction in interface Session

interact

public void interact(quark.UnaryCallable cmd)

Description copied from interface: Session

This is a convenience API that will perform start_interaction() followed by callable(ssn) followed by finish_interaction().

Specified by:

interact in interface Session

_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