March Docs

Modules

TConduitError TSchema TBackoff TUniqueScope TUniqueConstraint TUniqueConflict TPerKeyRateLimit TRateLimiterBackend TRateLimit TJobConfig TJobInfo TRetentionConfig TConfig TCronOverlap TCronConfig TCronSchedule TJobRow TDeadLetter TNodeInfo TWorkflowError TExecutionMode TWorkflowConfig TWorkflowHandle TWorkflowRow TWorkflowCheckpoint TWorkflowSignal TWorkflowContext TWorkflowEvent TAuth IStorage Fcancel_cron Fcancel_workflow Fcluster_leader Fenqueue_all Fpause_cron Fpause_queue Fresume_cron Fresume_queue

Fcancel_cron Fcancel_workflow Fcluster_leader Fcluster_nodes Fenqueue Fenqueue_all Fenqueue_in Fenqueue_in_with Fenqueue_with Fis_cluster_leader Fpause_cron Fpause_queue Fregister Fregister_cron Fregister_default Fregister_workflow Freplay_workflow Freplay_workflow_to Fresume_cron Fresume_queue Fschedule_cron Fsignal_workflow Fstart Fstart_workflow Fstop Fworkflow_events Fworkflow_status

▸Conduit.Backoff

Fcustom Fdelay Fexponential Ffibonacci Flinear_strat Fname

▸Conduit.Config

▸Conduit.CronConfig

▸Conduit.CronParser

TField TCronExpr Fmatches Fnext_run Fparse

▸Conduit.CronRegistry

TEntry Fall Ffire Flookup Foverlap_from_string Foverlap_to_string Fregister

▸Conduit.CronScheduler

Fstart Ftimezone_offset_s Fupsert_static

▸Conduit.Dashboard

TQueueSummary Fget_summary Fstart_standalone Fsubscribe_to_summary

▸Conduit.Dashboard.Actions

Fcancel_job Fcancel_workflow Fdelete_all_dead_letters Fdelete_cron Fdelete_dead_letter Fdelete_job Fpause_cron Fresume_cron Fretry_all_dead_letters Fretry_dead_letter Fretry_job Ftrigger_cron_now

▸Conduit.Dashboard.Auth

▸Conduit.Dashboard.Html

Faction_btn Fflash Fflash_from_query Fpage Fpage_with_nav Fpagination Frelative_time Frelative_time_opt Fstatus_badge Ftable Ftable_with_empty

▸Conduit.Dashboard.Pages.Crons

▸Conduit.Dashboard.Pages.DeadLetters

▸Conduit.Dashboard.Pages.Jobs

▸Conduit.Dashboard.Pages.Nodes

▸Conduit.Dashboard.Pages.Overview

▸Conduit.Dashboard.Pages.Queues

Frender_detail Frender_list

▸Conduit.Dashboard.Pages.Workflows

Frender_detail Frender_list

▸Conduit.Dashboard.Queries

Fcrons Fdead_letters Fjob_by_id Fjobs_list Fnodes Fqueue_summary Fworkflow_by_id Fworkflow_checkpoints Fworkflows

▸Conduit.Dashboard.Router

▸Conduit.DeadLetter

Ffrom_job Fto_job_info

▸Conduit.EventStore

Fappend Fcheckpoint_payload Fcount Fextract_value Fload_all Fload_up_to Freplay_key Fwarm_replay Fwarm_replay_to

▸Conduit.JobConfig

▸Conduit.Middleware.Chain

▸Conduit.Node

Fis_leader Fleader_node_id Fstart Fstop

▸Conduit.Pruner

▸Conduit.Queue

Fdispatch Fenqueue Fenqueue_all Fenqueue_in Flookup_config Fregister_performer

▸Conduit.QueueControl

Fis_paused Fpause Fresume

▸Conduit.RateLimiter

Facquire Fsnooze_duration

▸Conduit.RetentionConfig

▸Conduit.Schema

Fbuild Fnone Fvalidate

▸Conduit.Shutdown

Fclear_draining Fis_draining Fset_draining

▸Conduit.Storage.Postgres

TStore Flocal Fnew

▸Conduit.Telemetry

TConduitTelemetryEvent Fattach Fattach_logger Fdetach Fdispatch

▸Conduit.Time

▸Conduit.Unique

Fconflicts Ffingerprint Frelease

▸Conduit.Worker

▸Conduit.WorkflowConfig

▸Conduit.WorkflowContext

Fcheckpoint Fchild Fnew Fparallel Fwait_for_signal Fwarm_cache

▸Conduit.WorkflowRegistry

TWorkflowEntry Flookup Flookup_config Fregister Frun

▸Conduit.WorkflowRunner

Fenqueue Fexecute Fjob_type

▸Forge.CmdConduit

Fgen_migrations

March Docs›Conduit.Schema

Conduit.Schema

Functions

fnbuildbuild(f : a -> Result((), String)) : Conduit.Schema(a)#

fnnonenone() : Conduit.Schema(a)#

fnvalidatevalidate(schema : Conduit.Schema(a), args : a) : Result((), String)#