workflow.h

Go to the documentation of this file.

 
#ifndef CSILK_WORKFLOW_H
#define CSILK_WORKFLOW_H
 
#include "csilk/app/app.h"
#include "csilk/csilk.h"
 
void csilk_wf_serve_ui(csilk_app_t* app, const char* path);
 
typedef struct csilk_wf_s csilk_wf_t;
 
typedef struct csilk_wf_ctx_s csilk_wf_ctx_t;
 
typedef enum {
    CSILK_WF_JOIN_AND, 
    CSILK_WF_JOIN_OR   
} csilk_wf_join_policy_t;
 
typedef struct csilk_data_s {
    char* type;     
    void* value;        
    void (*free_fn)(void*); 
    void* meta;     
} csilk_data_t;
 
typedef struct {
    char* node_id;
    uint64_t start_time; 
    uint64_t end_time;   
    char* input_dump;    
    char* output_dump;   
    char* model;         
    int prompt_tokens;
    int completion_tokens;
    char* error; 
} csilk_wf_trace_node_t;
 
typedef struct {
    char* exec_id; 
    uint64_t start_time;
    uint64_t end_time;
    csilk_wf_trace_node_t** nodes;
    size_t node_count;
} csilk_wf_trace_t;
 
typedef const char* (*csilk_wf_router_t)(csilk_data_t* input);
 
typedef struct {
    const char* model;  
    const char* system_msg; 
    const char* prompt; 
    double temperature;
    int max_tokens;
    int stream;       
    int max_history_messages; 
} csilk_ai_config_t;
 
typedef csilk_data_t* (*csilk_wf_handler_t)(csilk_wf_ctx_t* ctx,
                        csilk_data_t* input,
                        void* user_data);
 
typedef struct csilk_wf_node_s csilk_wf_node_t;
 
/* --- Memory Helpers (Arena-backed) --- */
 
csilk_data_t* csilk_wf_data_new(csilk_wf_ctx_t* ctx, const char* type, void* value);
 
char* csilk_wf_strdup(csilk_wf_ctx_t* ctx, const char* s);
 
void* csilk_wf_alloc(csilk_wf_ctx_t* ctx, size_t size);
 
/* --- Lifecycle --- */
 
csilk_wf_t* csilk_wf_new(const char* name);
 
void csilk_wf_free(csilk_wf_t* wf);
 
csilk_wf_node_t*
csilk_wf_add(csilk_wf_t* wf, const char* id, csilk_wf_handler_t handler, void* user_data);
 
csilk_wf_node_t* csilk_wf_add_ai(csilk_wf_t* wf, const char* id, const csilk_ai_config_t* config);
 
/* --- Tool Calling --- */
 
typedef char* (*csilk_wf_tool_fn)(const char* args_json, void* user_data);
 
void csilk_wf_register_tool(csilk_wf_t* wf,
                const char* name,
                const char* description,
                const char* parameters_json,
                csilk_wf_tool_fn fn,
                void* user_data);
 
csilk_wf_node_t* csilk_wf_get_node(csilk_wf_t* wf, const char* id);
 
void csilk_wf_node_set_entry(csilk_wf_node_t* node, int is_entry);
 
/* --- Connections --- */
 
void csilk_wf_bind(csilk_wf_node_t* from, csilk_wf_node_t* to);
 
void csilk_wf_on(csilk_wf_node_t* from, const char* condition, csilk_wf_node_t* to);
 
void csilk_wf_on_loop(csilk_wf_node_t* from, const char* condition, csilk_wf_node_t* to);
 
void csilk_wf_on_error(csilk_wf_node_t* from, csilk_wf_node_t* target);
 
void csilk_wf_route(csilk_wf_node_t* node, csilk_wf_router_t router);
 
void csilk_wf_node_set_join(csilk_wf_node_t* node, csilk_wf_join_policy_t policy);
 
void csilk_wf_node_set_interactive(csilk_wf_node_t* node, int is_interactive);
 
void csilk_wf_node_set_schema(csilk_wf_node_t* node, const char* schema);
 
void csilk_wf_signal_continue(csilk_wf_t* wf,
                  const char* exec_id,
                  csilk_data_t* input,
                  void (*callback)(csilk_data_t* result));
 
void csilk_wf_node_set_timeout(csilk_wf_node_t* node, int timeout_ms);
 
void csilk_wf_set_ttl(csilk_wf_t* wf, int ttl_sec);
 
void csilk_wf_node_set_retry(csilk_wf_node_t* node, int max_retries, int retry_delay_ms);
 
void csilk_wf_node_set_remote(csilk_wf_node_t* node, int is_remote);
 
void csilk_wf_enable_distributed(csilk_wf_t* wf, csilk_mq_t* mq);
 
/* --- Execution --- */
 
void csilk_wf_set_persistence(csilk_wf_t* wf, const char* wal_dir);
 
const char*
csilk_wf_run(csilk_wf_t* wf, csilk_data_t* input, void (*callback)(csilk_data_t* result));
 
void csilk_wf_resume(csilk_wf_t* wf, const char* exec_id, void (*callback)(csilk_data_t* result));
 
void csilk_wf_run_traced(csilk_wf_t* wf,
             csilk_data_t* input,
             void (*callback)(csilk_data_t* result, csilk_wf_trace_t* trace));
 
char* csilk_wf_trace_to_json(const csilk_wf_trace_t* trace);
 
void csilk_wf_trace_free(csilk_wf_trace_t* trace);
 
/* --- Declarative API --- */
 
void csilk_wf_register_handler(const char* name, csilk_wf_handler_t handler);
 
csilk_wf_t* csilk_wf_load_yaml(const char* path);
 
csilk_wf_t* csilk_wf_from_json(const char* json);
 
/* --- Visualization --- */
 
char* csilk_wf_to_mermaid(csilk_wf_t* wf);
 
/* --- Monitoring --- */
 
void csilk_wf_register_monitor(csilk_wf_t* wf, csilk_ctx_t* c);
 
void csilk_wf_set_budget(csilk_wf_t* wf, int max_tokens);
 
#endif /* CSILK_WORKFLOW_H */