Extensions

Kronos enables custom implementations of its pluggable components.

Out of the box extensions

• Task Definition Reader
  • File Reader
• Task Handler
  • Shell Command Handler
• Message Bus
  • Kafka Message Bus
• Task Store
  • SQLite Task store

Building a custom extension

The user needs to download the release package and add it to development environment (IDE) during the custom implementation. The following components are available for user implementation.

Task Definition Reader

A task definition reader is used to provide a custom source of task definitions.

Implementing a custom task definition reader is as simple as implementing TaskDefinitionReader interface. To configure a custom task definition reader check this link.

Task Handler

A handler is used to execute the submitted task.

Implementing a custom task handler is as simple as implementing TaskHandler interface. To configure a custom task handler check this link.

Message Bus

A message bus is used to exchange message between the scheduler and executor.

Implementing a custom message require used to implement Producer.java and Consumer.java interface for the task and task status queue. To configure a custom message bus check this link.

Task Store

A task store is used to keep the current state of the tasks.

Implementing a custom task store is as simple as implementing TaskStore interface. To configure a custom task store check this link.

Timeout Policy

Custom policies can be defined to apply to the task in case of timeout.

Implementing a custom timeout policy is as simple as implementing TimeoutPolicy interface. To configure a custom timeout policy check this link.