pkg/

directory
v0.0.0-...-0f02e2e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2025 License: BSD-2-Clause

Directories

Path Synopsis
channels
kafka
Package kafka provides Apache Kafka integration for event messaging.
Package kafka provides Apache Kafka integration for event messaging.
Package cmd provides common initialization functions for command-line applications.
Package cmd provides common initialization functions for command-line applications.
Package eventbus provides event-driven communication infrastructure for workflow orchestration.
Package eventbus provides event-driven communication infrastructure for workflow orchestration.
kafka
Package kafka provides Apache Kafka integration for event messaging.
Package kafka provides Apache Kafka integration for event messaging.
Package events defines event types and structures for workflow lifecycle notifications.
Package events defines event types and structures for workflow lifecycle notifications.
Package models defines core node-based workflow models for graph execution
Package models defines core node-based workflow models for graph execution
nodes
conditional
Package conditional provides conditional branching node factory for registry integration.
Package conditional provides conditional branching node factory for registry integration.
httprequest
Package httprequest provides HTTP request node factory for the registry system.
Package httprequest provides HTTP request node factory for the registry system.
log
Package log provides logging node factory for registry integration.
Package log provides logging node factory for registry integration.
merge
Package merge provides merge node factory for registry integration.
Package merge provides merge node factory for registry integration.
switch
Package switch provides switch node factory for registry integration.
Package switch provides switch node factory for registry integration.
transform
Package transform provides data transformation node factory for registry integration.
Package transform provides data transformation node factory for registry integration.
trigger
Package trigger provides trigger node implementations for workflow graph execution.
Package trigger provides trigger node implementations for workflow graph execution.
Package persistence provides input coordination state management.
Package persistence provides input coordination state management.
file
Package file provides file-based persistence implementation for workflows and triggers.
Package file provides file-based persistence implementation for workflows and triggers.
postgresql
Package postgresql provides PostgreSQL persistence implementation for workflows and triggers.
Package postgresql provides PostgreSQL persistence implementation for workflows and triggers.
sqlbase
Package sqlbase provides the base functionality for SQL database persistence.
Package sqlbase provides the base functionality for SQL database persistence.
Package protocol defines the interfaces and contracts for pluggable nodes.
Package protocol defines the interfaces and contracts for pluggable nodes.
providers
Package registry provides node factory registration for the registry system.
Package registry provides node factory registration for the registry system.
Package template provides templating functionality for dynamic workflow configuration.
Package template provides templating functionality for dynamic workflow configuration.
Package tracer provides distributed tracing functionality for workflow monitoring.
Package tracer provides distributed tracing functionality for workflow monitoring.
Package web provides HTTP handlers and REST API endpoints for workflow management.
Package web provides HTTP handlers and REST API endpoints for workflow management.
Package workflow provides workflow publishing functionality with simplified versioning.
Package workflow provides workflow publishing functionality with simplified versioning.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL