FTN6: FutoIn Invoker Concept
Version: 1.1
Date: 2014-09-30
Copyright: 2014 FutoIn Project (http://futoin.org)
Authors: Andrey Galkin
CHANGES
- v1.1
- Added FTN14 Cache support
- Clarified "credentials" parameter
- Clarified "self://" scheme
- Added AdvancedCCM-specific startup optimization extensions
Warning
This specification IS NOT mandatory. It is just a reference model.
Any implementation IS ALLOWED to provide own architecture with
drawback of breaking easy migration from one to another.
1. Concept
There must be a centralized connection and credentials manager (CCM) object.
It should be possible to create multiple independent instances of such type.
Each connection end-point should have a unique associative name in scope of
single CCM object. Connection end-points can be statically and/or dynamically
registered/configured. More advanced implementation may use centralized service to
resolve/retrieve connection end-points and related credentials on demand.
Invoker code retrieves FutoIn interface references from CCM object and invokes
FutoIn interface function through special "call" method, passing function name
and associative parameter map. Invocation result is returned as a map of result
values.
There should be a common FutoIn exception type from which Expected and Unexpected
FutoIn exception types must inherit as defined in FTN3.
By design, most Executor implementation also implement Invoker design as it is required
for separation of concerns on Service/RPC level, but not single project level.
1.1. Reserved interface names
Some of interface names can be reserved for internal semantics, like runtime
resolving service interface.
All names starting with hash "#" symbol are reserved for internal purpose in
Invoker implementation concept.
1.1.2. Pre-defined interfaces names:
- "#resolver" - Runtime Iface Resolver v1.x
- "#auth" - AuthService v1.x
- "#defense" - Defense system v1.x
- "#acl" - Access Control system v1.x
- "#log" - Audit Logging v1.x
- "#cachel1" - cache v1.x (fast local, but small)
- "#cachel2" - cache v1.x (slower local, but large)
- "#cachel3" - cache v1.x (much slower and much larger)
1.2. Type and identifier safety
There should be a Simple CCM, which is lightweight and designed for small memory
footprint and/or high performance cases. Advanced CCM interface should inherit
from the Simple one.
Advanced CCM implementation must implement a special native dummy interface,
even if there is no difference with Simple one, so native link/resolve error is generated,
if Simple CCM implementation is provided to Client code, which expects Advanced CCM.
Advanced CCM implementation can retrieve FutoIn interface definitions and enforce
additional checks, including compile and/or run-time specialized native interface
building.
In such process, FutoIn interface functions must become native interface members with
every function parameter becoming native member's formal parameter. If multiple
values can be returned natively, result values are mapped to those. Otherwise,
map of result values is returned. If there are no
result values then native member returns nothing and should complete as soon
as request message is scheduled to be sent without waiting for reply.
Note: Simple CCM is not expected to parse interfaces. Therefore, all request
messages must have "forcersp" flag and Simple CCM must expect response for every call.
1.2. Invoker calls to Executor in scope of the same process
FutoIn implementations are allowed to optimize calls within single process in
implementation-defined way, keeping the same behavior between remote and local calls.
Local calls must never execute if there are Invoker frames on execution stack. It means, Invoker
function must return before Executor runs or Executor must run in a different thread. Yes, it may have performance
issues.
2. Invoker interfaces
Reference Invoker concept is built around FTN12 Async API
2.1. Connection and Credentials Manager
Simple CCM:
- void register( AsyncSteps as, name, ifacever, endpoint [, $credentials] )
- register standard MasterService end-point (adds steps to as)
- as - AsyncSteps instance as registration may be blocking on external resources
- name - unique identifier in scope of CCM instance
- ifacever - iface identifier and its version separated by colon, see note below
- endpoint - URI or any other resource identifier of iface implementing peer, accepted by CCM implementation
- $credentials - optional, authentication credentials (string)
- 'master' - enable MasterService authentication logic (Advanced CCM only)
- '{user}:{clear-text-password}' - send as is in the 'sec' section
- NOTE: some more reserved words and/or patterns can appear in the future
- NativeIface iface( name )
- Get native interface wrapper for invocation of iface methods
- name - see register()
- Note: it can have template/generic counterpart like iface() for strict type languages
- void unRegister( name )
- unregister previously registered interface (should not be used, unless really needed)
- name - see register()
- NativeDefenseIface defense() - shortcut to iface( "#defense" )
- NativeLogIface log() - returns extended API interface as defined in FTN9 IF AuditLogService
- NativeBurstIface burst() - returns extended API interface as defined in FTN10 Burst Calls
- NativeCacheIface cache_l1() - returns extended API interface as defined in FTN14 Cache
- NativeCacheIface cache_l2() - returns extended API interface as defined in FTN14 Cache
- NativeCacheIface cache_l3() - returns extended API interface as defined in FTN14 Cache
- void assertIface( name, ifacever )
- Assert that interface registered by name matches major version and minor is not less than required.
- This function must generate fatal error and forbid any further execution
- name - see register()
- ifacever - required interface and its version
- void alias( name, alias )
- Alias interface name with another name
- name - as provided in register()
- alias - register alias for name
Advanced CCM extensions:
- boolean initRegFromCache( AsyncSteps as, cache_l1_endpoint )
- cache_l1_endpoint - end-point URL for Cache L1
- returns true, if successfully initialized from cache (no need to register interfaces)
- Note: Cache L1 needs to be registered first
- void cacheReg( AsyncSteps as )
- call after all registrations are done to cache them
2.1.1. Unique interface name in CCM instance (name)
The idea behind is that each component/library/etc. assumes that end product registers interfaces,
their endpoints and possibly provides other information during initialization phase or
prior to using the specific component.
Example:
// Init
AsyncSteps as;
ccm.register( as, "some_id', "some.iface:1.3", "https://..." )
ccm.alias( "some_id', "componentA.ifaceA" )
ccm.alias( "some_id', "componentB.ifaceB" )
as.add( ComponentA.init )
as.add( ComponentB.init )
as.add( startService )
// start actual execution
as.execute();
// in Component A (note minor version less than registered)
ComponentA.init()
{
ccm.assertIface( "componentA.iface", "some.iface:1.0" )
iface = ccm.iface( "componentA.iface" )
iface.someFunc()
}
// in Component B (note different minor version)
ComponentB.init()
{
ccm.assertIface( "componentB.iface", "some.iface:1.1" )
iface = ccm.iface( "componentB.iface" )
iface.someFunc()
}
2.1.2. Interface and version
ifacever must be represented as FutoIn interface identifier and version, separated by colon ":"
Example: "futoin.master.service:1.0", "futoin.master.service:2.1".
Invoker implementation must ensure that major versions match and registered minor version is not less
than requested minor version.
2.1.3. End point URL
The following URL schemes should be supported:
- http://
- https://
- ws:// - with automatic fallback to http://, if not supported by Invoker implementation
- wss// - with automatic fallback to https://, if not supported by Invoker implementation
- self:// - implemented in scope of the same Executor, when used as CCM for Executor
- The rest is implementation-defined name/pointer to implementation
2.2. Native FutoIn interface interface
- void call( AsyncSteps as, name, params [, upload_data [, download_stream]] )
- generic FutoIn function call interface
- result is passed through AsyncSteps.success() as a map
- upload_data - either raw data or input stream, if provided
- download_stream - output stream, if provided
- Note: data transfer requests must not interleave with non-data calls, if parallel processing is possible
- InterfaceInfo iface() - return interface to introspect interface information:
- NativeBurstIface burst() - returns extended API interfaces defined in FTN10 Burst Calls
- void bindDerivedKey( AsyncSteps as )
- results with DerivedKeyAccessor through as.success()
Advanced CCM:
- void member_call_intercept( AsyncSteps as, param1, param2, param3 )
- Platform/Language-specific interception of undefined method calls, converting to
NativeInterface.call()
2.3. Derived Key accessing wrapper
The same interface can be used in parallel. This feature generates and
binds specific DerivedKey for the following call.
- derivedKey()
- *() - any function, calls underlying iface function, ensuring the right derived key in use
2.4. Derived Key
See FTN6 Interface Executor Concept
2.5. AsyncSteps interface
See FTN12 Async API
2.5. InterfaceInfo
- name() - get FutoIn interface type
- version() - get FutoIn interface version
- inherits() - get list of inherited interfaces starting from the most derived, may be null
- funcs() - get list of available functions, may be null
- constraints() - get list of interface constraints, may be null
3. Language/Platform-specific notes
3.1. native JVM (Java, Groovy, etc.)
3.2. Python
3.3. PHP
3.4. C++
=END OF SPEC=