LogoLogo
Home
Core Platform
Core Platform
  • Introduction
    • Overview
    • Use Cases
    • Architecture
    • Built with ML & AI
    • Quick Start
  • Examples
    • Training Examples
      • API Flow Examples
      • Microservice Examples
      • UI Example
      • Exercise: Hello World API
      • Exercise: Test State
      • Exercise: Test UI
    • Exercise: To-do List
      • To-do List Runner
      • To-do List Gateway
      • To-do List UI
      • To-do List Query
  • Troubleshooting
    • Rierino Packages
    • Release Notes
    • Useful Checks
    • Error Codes
  • Devops
    • Overview
    • API Flows
      • Using the Saga Screen
      • Defining a Saga
      • Configuring Saga Steps
        • Event Step
        • Transform Step
          • Transform Classes
        • Condition Step
          • Condition Classes
        • Step Link
      • Injecting Variables
    • Microservices
      • Runners
        • Using the Runner Screen
        • Defining a Runner
        • Managing Runner Settings
        • Adding Runner Elements
        • Deploying Runners
          • Spring Runners
          • Samza Runners
          • Camel Runners
      • Elements
        • Systems
        • State Managers
          • Typical Use Cases
          • State Data Structure
          • Local States
            • In-Memory Map
            • Caffeine Cache
            • Samza Based
            • Lucene Based
            • Single File
            • Multiple Files
            • Selected IDs Map
            • Indexed Map
          • Shared States
            • MongoDB Collection
            • Jooq (SQL) Table
            • Redis Map
            • Couchbase Collection
            • Elasticsearch Index
            • Elasticsearch Joined
            • Etcd Namespace
          • Specialized States
            • CRUD Service
            • Odata Service
          • State Coordinators
            • Lazy Cache Coordinator
            • Event Store Coordinator
            • Write thru Coordinator
          • Loading Strategies
          • ID Generators
        • Listeners
        • Query Managers
          • MongoDB
          • Elasticsearch
          • Lucene
          • SQL Based
          • Odata Service
        • Handlers
          • Core Handlers
            • Write Data
            • Read Data
            • Query Data
            • Apply Rules
            • Call Rest API
            • Generate Text/Html
            • Parse Html
            • Generate Secrets
            • Orchestrate User Task
            • Perform File Operation
            • Run Shell Command
            • Send/Receive Emails
          • Custom Code Handlers
            • Run Scripts
            • Run Java Code
            • Run Java Package
          • Flow Handlers
            • Orchestrate Saga
            • Loop Each Entry
            • Run Multiple Steps
            • Buffer Payloads
            • Merge Parallel Steps
            • Log Event
            • Send Event
            • Validate Event
            • Transform Event
            • Perform DB Transaction
            • Trigger Runner Command
            • Do Nothing
            • Modify Role Data
            • Enrich Role Data
            • Convert Pulse to Journal
          • Gateway Handlers
            • Authenticate
              • No Authentication
              • State Based
              • Keycloak Based
            • Sessionize
          • Specialized Handlers
            • Apply Advanced Rules
            • Calculate Real-time Metrics
            • Score ML Models
            • Score LangChain Models
            • Service MCP Requests
            • Service A2A Requests
            • Consume Web of Things
            • Perform Text Embedding
            • Run Python Procedure
            • Generate Excel
            • Generate PDF
            • Call SOAP API
            • Integrate with Camel
        • Actions
        • Streams
          • Kafka Topic
          • CDC Feed
          • Camel Component
        • Roles
        • Generic Settings
        • Global Settings
      • Deployments
        • Defining a Deployment
        • Alternative Loaders
    • Gateway & Security
      • Gateway Servers
        • Gateway Systems
        • Gateway Channels
        • Gateway Services
        • Gateway Tokens
      • APIs
        • OpenAPI Specification
        • Response Formats
    • Administration
      • Managing Deployments
      • Sending Commands
      • Streaming Messages
      • Migrating Assets
    • Batch Tasks
      • Python Processes
      • Python Iterators
      • Python Processors
    • Pro-Code
      • Custom Handlers
      • Custom State Managers
      • Custom Query Managers
      • Custom CDC Managers
  • Design
    • Overview
    • User Interface
      • Apps
      • UIs
        • Listers
        • Widgets
          • Value Widgets
          • Array Widgets
          • Object Widgets
          • Indirect Widgets
          • Atom Widgets
        • Menus
          • Lister Menu Actions
          • Selection Menu Actions
          • Editor Menu Actions
          • Widget Menu Actions
          • Custom Menu Actions
          • RAI Menu Actions
        • Extended Scope
          • Conditional Display
          • Data Context
          • Extra Data
          • Default Item
          • Extra Events
      • Options
      • Translations
      • Icons
      • Styles
      • Components
    • API Mapping
    • Data Schema
      • Common Data
  • Configuration
    • Overview
    • Queries
      • Query Types
      • Query Platforms
        • MongoDB Queries
        • Odata Queries
        • SQL Queries
        • Elasticsearch Queries
        • Lucene Queries
        • Siddhi Queries
    • Business Rules
      • Drools Rules
    • Dynamic Handlers
  • Data Science
    • Overview
    • ML Models
      • Scheduler Platforms
        • Airflow Scheduler
    • GenAI Models
    • MCP Servers
    • Complex Event Processing
      • Siddhi Data Flows
    • Data Visualizations
    • Customizations
  • EXTENSIONS
    • JMESPath
    • Handlebars
Powered by GitBook

© Rierino Software Inc. 2025. All rights reserved.

On this page
  • Runners
  • Train CRUD
  • Train RPC
  • Train CDC
  • Deployments
  • Training Core
  1. Examples
  2. Training Examples

Microservice Examples

These examples can be viewed from Runner and Deployment screens in Devops app

PreviousAPI Flow ExamplesNextUI Example

Last updated 6 months ago

Runners

Train CRUD

This CRUD event runner provides read/write access to a single MongoDB collection named 'dummy' on 'master' database, through /dummy GET, POST, PUT, PATCH, DELETE endpoints. Full list of operations and parameters that can be used with this runner can be found .

This runner is mapped to "CRUD Train" gateway system and "Train CRUD" gateway channel, accessible through [API_SERVER]/api/request/train_crud/[PATH].

A standard CRUD event runner includes three handlers: read, write, and condition. These handlers enable operations on states added to the runner. Advanced settings are available, such as restricting read/write access to specific states or using saga flows for custom logic in CRUD operations. More details are provided in the subsequent DevOps sections.

Train RPC

This runner is mapped to "RPC Train" gateway system and "Train RPC" gateway channel, accessible through [API_SERVER]/api/request/train_rpc/[PATH] URL.

A typical RPC event runner requires an input stream (request_train in training example) and a saga handler at a minimum to grant the runner rights to execute saga flows. All other elements are added based on the intended capabilities and access rights for the runner.

The train RPC runner includes the following elements as an example:

  • read, write handlers to perform basic CRUD operations in saga flows on 'dummy' collection on 'master' MongoDB database

  • query handler to run queries on 'master' MongoDB database

  • rest handler to perform API calls on 'datausa' external system, with predefined 'action' definitions as well

  • script, template_hb and openhft handlers to execute custom scripts and code, which is stored in 'handler_code' collection on 'devops' MongoDB database and cached locally on an in-memory Map for fast access

  • rule handler to perform rule calculations, which is stored in 'rule_training' collection on 'config' MongoDB database and used directly without a cache

Train CDC

This CDC event runner listens to changes on the 'dummy' collection of 'master' database in MongoDB and triggers /On_dummy saga flow to process these changes.

This runner is not accessible through APIs and only uses CDC triggers as requests.

A typical CDC event runner includes one or more CDC streams (such as the 'dummy' collection change stream on 'master' MongoDB database in training example), as well as a mechanism for storing and retrieving offsets to allow continuation of CDC flows on service restart. For Spring based runners, a state manager is typically used, whereas Samza based runners have their own checkpointing configurations. A CDC stream can be linked to various roles, such as triggering any saga flow as in the training example, or publishing enriched CDC records on a Kafka topic.

Deployments

Training Core

This deployment includes all event runners and is configured for deployment in admin-backend namespace.

The training core deployment is typically installed automatically with the core platform, so it does not require additional deployment actions.

This RPC event runner provides read, write, query, secret and rest handlers as well as dynamic code execution capabilities while orchestating sagas listed in .

API flow examples
here
CRUD Runner
RPC Runner
CDC Runner
Deployment Runner List