spider

Dec 8, 2025

Changes in this version

type AddActionRequest

+ NodeName string

type MDWorkflowAction

+ NodeName string

type UpdateActionRequest

+ NodeName string

Dec 7, 2025

Changes in this version

type WorkflowAction

+ NodeName string

Dec 2, 2025

Changes in this version

type NatsInputMessage

+ ActionLabel string

+ NodeID string

+ NodeName string

Dec 2, 2025

Changes in this version

type InputMessage

+ ActionLabel string

+ NodeID string

+ NodeName string

Dec 1, 2025

Changes in this version

type EventPublisher

+ PublishWorkflowCompleted func(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

Nov 25, 2025

Changes in this version

+ type EventPublisher interface

+ Close func() error

+ PublishEntered func(ctx context.Context, ...) error

+ PublishExitedFailed func(ctx context.Context, ...) error

+ PublishExitedSuccess func(ctx context.Context, ...) error

+ PublishWorkflowStarted func(ctx context.Context, tenantID, workflowID, workflowName, sessionID string, ...) error

type Workflow

+ func InitWorkflowWithPublisher(messenger WorkflowMessengerAdapter, storage WorkflowStorageAdapter, ...) *Workflow

Nov 24, 2025

Changes in this version

type WorkerConfig

+ WorkflowName string

Nov 21, 2025

Changes in this version

type MongodDBWorkerStorageAdapter

+ func (w *MongodDBWorkerStorageAdapter) GetExecutionHistory(ctx context.Context, tenantID, workflowID, actionKey, userID string) (*WorkflowExecutionHistory, error)

+ func (w *MongodDBWorkerStorageAdapter) UpsertExecutionHistory(ctx context.Context, record *WorkflowExecutionHistory) error

type Worker

+ func (w *Worker) GetExecutionHistory(ctx context.Context, tenantID, workflowID, actionKey, userID string) (*WorkflowExecutionHistory, error)

+ func (w *Worker) UpsertExecutionHistory(ctx context.Context, record *WorkflowExecutionHistory) error

+ type WorkflowExecutionHistory struct

+ ActionID string

+ ActionKey string

+ ExecutedAt time.Time

+ RetryCount int

+ Status string

+ TenantID string

+ UserID string

+ WorkflowID string

Oct 31, 2025

Changes in this version

type Worker

+ ActionID string

+ Messenger WorkerMessengerAdapter

+ Storage WorkerStorageAdapter

Oct 6, 2025

Changes in this version

type MongodDBWorkflowStorageAdapter

+ func (w *MongodDBWorkflowStorageAdapter) GetWorkflowPeers(ctx context.Context, tenantID, workflowID string) ([]WorkflowPeer, error)

+ type WorkflowPeer struct

+ ChildKey string

+ MetaOutput string

+ ParentKey string

type WorkflowStorageAdapter

+ GetWorkflowPeers func(ctx context.Context, tenantID, workflowID string) ([]WorkflowPeer, error)

Oct 5, 2025

Changes in this version

+ func LazyBootstrapWorker(actionID string, h func(c InputMessageContext, m InputMessage) error) error

+ type AddActionRequest struct

+ ActionID string

+ Config map[string]string

+ Key string

+ Map map[string]Mapper

+ Meta map[string]string

+ TenantID string

+ WorkflowID string

+ type CreateFlowRequest struct

+ ID string

+ Meta map[string]string

+ Name string

+ TenantID string

+ TriggerType FlowTriggerType

+ type Flow struct

+ ID string

+ Meta map[string]string

+ Name string

+ Status FlowStatus

+ TenantID string

+ TriggerType FlowTriggerType

+ Version uint64

+ type FlowListResponse struct

+ Flows []WorkflowInfo

+ Page int

+ PageSize int

+ Total int64

+ type FlowStatus string

+ var FlowStatusActive FlowStatus = "active"

+ var FlowStatusDraft FlowStatus = "draft"

+ type FlowTriggerType string

+ var FlowTriggerTypeEvent FlowTriggerType = "event"

+ var FlowTriggerTypeSchedule FlowTriggerType = "schedule"

+ type InitMongodDBWorkflowStorageAdapterOpt struct

+ BetaAutoSetupSchema bool

+ type InitNATSWorkerMessengerAdapterOpt struct

+ BetaAutoSetupNATS bool

+ type InitNATSWorkflowMessengerAdapterOpt struct

+ BetaAutoSetupNATS bool

+ type InputMessage struct

+ ActionID string

+ Key string

+ SessionID string

+ TaskID string

+ TenantID string

+ Values string

+ WorkflowID string

+ func (m *InputMessage) ToOutputMessage(metaOutput, values string) OutputMessage

+ type InputMessageContext struct

+ Context context.Context

+ SendOutput func(metaOutput string, values string) error

+ Timestamp time.Time

+ type MDFlow struct

+ ID string

+ Meta map[string]string

+ Name string

+ Status FlowStatus

+ TenantID string

+ TriggerType FlowTriggerType

+ Version uint64

+ type MDWorkflowAction struct

+ ActionID string

+ Config map[string]string

+ Disabled bool

+ ID string

+ Key string

+ Map map[string]Mapper

+ Meta map[string]string

+ TenantID string

+ WorkflowID string

+ type MDWorkflowActionDep struct

+ DepKey string

+ ID string

+ Key string

+ MetaOutput string

+ WorkflowID string

+ type MDWorkflowSessionContext struct

+ ID string

+ SessionID string

+ TaskID string

+ Value map[string]map[string]interface{}

+ WorkflowID string

+ type Mapper struct

+ Mode MapperMode

+ Value string

+ type MapperMode string

+ var MapperModeExpression MapperMode = "expression"

+ var MapperModeFixed MapperMode = "fixed"

+ var MapperModeKey MapperMode = "key"

+ type MongodDBWorkerStorageAdapter struct

+ func InitMongodDBWorkerStorageAdapter(ctx context.Context) (*MongodDBWorkerStorageAdapter, error)

+ func NewMongodDBWorkerStorageAdapter(client *mongo.Client, db *mongo.Database) *MongodDBWorkerStorageAdapter

+ func (w *MongodDBWorkerStorageAdapter) Close(ctx context.Context) error

+ func (w *MongodDBWorkerStorageAdapter) GetAllConfigs(ctx context.Context, actionID string) ([]WorkerConfig, error)

+ type MongodDBWorkflowStorageAdapter struct

+ func InitMongodDBWorkflowStorageAdapter(ctx context.Context, opt InitMongodDBWorkflowStorageAdapterOpt) (*MongodDBWorkflowStorageAdapter, error)

+ func NewMongodDBWorkflowStorageAdapter(client *mongo.Client, db *mongo.Database) *MongodDBWorkflowStorageAdapter

+ func (w *MongodDBWorkflowStorageAdapter) AddAction(ctx context.Context, req *AddActionRequest) (*WorkflowAction, error)

+ func (w *MongodDBWorkflowStorageAdapter) AddDep(ctx context.Context, tenantID, workflowID, key, metaOutput, depKey string) error

+ func (w *MongodDBWorkflowStorageAdapter) Close(ctx context.Context) error

+ func (w *MongodDBWorkflowStorageAdapter) CreateFlow(ctx context.Context, req *CreateFlowRequest) (*Flow, error)

+ func (w *MongodDBWorkflowStorageAdapter) CreateSessionContext(ctx context.Context, workflowID, sessionID, taskID string, ...) error

+ func (w *MongodDBWorkflowStorageAdapter) DeleteAction(ctx context.Context, tenantID, workflowID, key string) error

+ func (w *MongodDBWorkflowStorageAdapter) DeleteAllActions(ctx context.Context, tenantID, workflowID string) error

+ func (w *MongodDBWorkflowStorageAdapter) DeleteAllDeps(ctx context.Context, tenantID, workflowID string) error

+ func (w *MongodDBWorkflowStorageAdapter) DeleteFlow(ctx context.Context, tenantID, flowID string) error

+ func (w *MongodDBWorkflowStorageAdapter) DeleteSessionContext(ctx context.Context, workflowID, sessionID, taskID string) error

+ func (w *MongodDBWorkflowStorageAdapter) DisableWorkflowAction(ctx context.Context, tenantID, workflowID, key string) error

+ func (w *MongodDBWorkflowStorageAdapter) GetFlow(ctx context.Context, tenantID, flowID string) (*Flow, error)

+ func (w *MongodDBWorkflowStorageAdapter) GetSessionContext(ctx context.Context, workflowID, sessionID, taskID string) (map[string]map[string]interface{}, error)

+ func (w *MongodDBWorkflowStorageAdapter) GetWorkflowActions(ctx context.Context, tenantID, workflowID string) ([]WorkflowAction, error)

+ func (w *MongodDBWorkflowStorageAdapter) ListFlows(ctx context.Context, tenantID string, page, pageSize int) (*FlowListResponse, error)

+ func (w *MongodDBWorkflowStorageAdapter) QueryWorkflowAction(ctx context.Context, tenantID, workflowID, key string) (*WorkflowAction, error)

+ func (w *MongodDBWorkflowStorageAdapter) QueryWorkflowActionDependencies(ctx context.Context, tenantID, workflowID, key, metaOutput string) ([]WorkflowAction, error)

+ func (w *MongodDBWorkflowStorageAdapter) UpdateAction(ctx context.Context, req *UpdateActionRequest) (*WorkflowAction, error)

+ func (w *MongodDBWorkflowStorageAdapter) UpdateFlow(ctx context.Context, req *UpdateFlowRequest) (*Flow, error)

+ type NATSWorkerMessengerAdapter struct

+ func InitNATSWorkerMessengerAdapter(ctx context.Context, actionID string, opt InitNATSWorkerMessengerAdapterOpt) (*NATSWorkerMessengerAdapter, error)

+ func (m *NATSWorkerMessengerAdapter) Close(ctx context.Context) error

+ func (m *NATSWorkerMessengerAdapter) ListenInputMessages(ctx context.Context, h func(c InputMessageContext, message InputMessage) error) error

+ func (m *NATSWorkerMessengerAdapter) SendOutputMessage(ctx context.Context, message OutputMessage) error

+ func (m *NATSWorkerMessengerAdapter) SendTriggerMessage(ctx context.Context, message TriggerMessage) error

+ type NATSWorkflowMessengerAdapter struct

+ func InitNATSWorkflowMessengerAdapter(ctx context.Context, opt InitNATSWorkflowMessengerAdapterOpt) (*NATSWorkflowMessengerAdapter, error)

+ func (m *NATSWorkflowMessengerAdapter) Close(ctx context.Context) error

+ func (m *NATSWorkflowMessengerAdapter) ListenOutputMessages(ctx context.Context, ...) error

+ func (m *NATSWorkflowMessengerAdapter) ListenTriggerMessages(ctx context.Context, ...) error

+ func (m *NATSWorkflowMessengerAdapter) SendInputMessage(ctx context.Context, message InputMessage) error

+ type NatsInputMessage struct

+ ActionID string

+ Key string

+ SessionID string

+ TaskID string

+ TenantID string

+ Values string

+ WorkflowID string

+ func (n *NatsInputMessage) ToInputMessage() InputMessage

+ type NatsOutputMessage struct

+ ActionID string

+ Key string

+ MetaOutput string

+ SessionID string

+ TaskID string

+ TenantID string

+ Values string

+ WorkflowID string

+ func (n *NatsOutputMessage) ToOutputMessage() OutputMessage

+ func (n NatsOutputMessage) FromOutputMessage(message OutputMessage) NatsOutputMessage

+ type NatsTriggerMessage struct

+ ActionID string

+ Key string

+ MetaOutput string

+ TenantID string

+ Values string

+ WorkflowID string

+ func (n *NatsTriggerMessage) ToTriggerMessage() TriggerMessage

+ func (n NatsTriggerMessage) FromTriggerMessage(message TriggerMessage) NatsTriggerMessage

+ type OutputMessage struct

+ ActionID string

+ Key string

+ MetaOutput string

+ SessionID string

+ TaskID string

+ TenantID string

+ Values string

+ WorkflowID string

+ type OutputMessageContext struct

+ Context context.Context

+ Timestamp time.Time

+ type TriggerMessage struct

+ ActionID string

+ Key string

+ MetaOutput string

+ TenantID string

+ Values string

+ WorkflowID string

+ type TriggerMessageContext struct

+ Context context.Context

+ Timestamp time.Time

+ type UpdateActionRequest struct

+ Config map[string]string

+ Key string

+ Map map[string]Mapper

+ Meta map[string]string

+ TenantID string

+ WorkflowID string

+ type UpdateFlowRequest struct

+ FlowID string

+ Meta map[string]string

+ Name string

+ Status FlowStatus

+ TenantID string

+ TriggerType FlowTriggerType

+ type Worker struct

+ func InitDefaultWorker(ctx context.Context, actionID string) (*Worker, error)

+ func (w *Worker) Close(ctx context.Context) error

+ func (w *Worker) GetAllConfigs(ctx context.Context) ([]WorkerConfig, error)

+ func (w *Worker) Run(ctx context.Context, h func(c InputMessageContext, m InputMessage) error) error

+ func (w *Worker) SendTriggerMessage(ctx context.Context, m TriggerMessage) error

+ type WorkerConfig struct

+ Config map[string]string

+ Key string

+ Meta map[string]string

+ TenantID string

+ WorkflowActionID string

+ WorkflowID string

+ type WorkerMessengerAdapter interface

+ Close func(ctx context.Context) error

+ ListenInputMessages func(ctx context.Context, h func(c InputMessageContext, message InputMessage) error) error

+ SendOutputMessage func(ctx context.Context, message OutputMessage) error

+ SendTriggerMessage func(ctx context.Context, message TriggerMessage) error

+ type WorkerStorageAdapter interface

+ Close func(ctx context.Context) error

+ GetAllConfigs func(ctx context.Context, actionID string) ([]WorkerConfig, error)

+ type Workflow struct

+ func InitDefaultWorkflow(ctx context.Context) (*Workflow, error)

+ func InitWorkflow(messenger WorkflowMessengerAdapter, storage WorkflowStorageAdapter) *Workflow

+ func (w *Workflow) Close(ctx context.Context) error

+ func (w *Workflow) Messenger() WorkflowMessengerAdapter

+ func (w *Workflow) Run(ctx context.Context) error

+ func (w *Workflow) Storage() WorkflowStorageAdapter

+ type WorkflowAction struct

+ ActionID string

+ Config map[string]string

+ Disabled bool

+ ID string

+ Key string

+ Map map[string]Mapper

+ Meta map[string]string

+ TenantID string

+ WorkflowID string

+ type WorkflowInfo struct

+ ID string

+ Meta map[string]string

+ Name string

+ Status FlowStatus

+ TenantID string

+ TriggerType FlowTriggerType

+ Version uint64

+ type WorkflowMessengerAdapter interface

+ Close func(ctx context.Context) error

+ ListenOutputMessages func(ctx context.Context, ...) error

+ ListenTriggerMessages func(ctx context.Context, ...) error

+ SendInputMessage func(ctx context.Context, message InputMessage) error

+ type WorkflowStorageAdapter interface

+ AddAction func(ctx context.Context, req *AddActionRequest) (*WorkflowAction, error)

+ AddDep func(ctx context.Context, tenantID, workflowID, key, metaOutput, key2 string) error

+ Close func(ctx context.Context) error

+ CreateFlow func(ctx context.Context, req *CreateFlowRequest) (*Flow, error)

+ CreateSessionContext func(ctx context.Context, workflowID, sessionID, taskID string, ...) error

+ DeleteAction func(ctx context.Context, tenantID, workflowID, key string) error

+ DeleteAllActions func(ctx context.Context, tenantID, workflowID string) error

+ DeleteAllDeps func(ctx context.Context, tenantID, workflowID string) error

+ DeleteFlow func(ctx context.Context, tenantID, flowID string) error

+ DeleteSessionContext func(ctx context.Context, workflowID, sessionID, taskID string) error

+ DisableWorkflowAction func(ctx context.Context, tenantID, workflowID, key string) error

+ GetFlow func(ctx context.Context, tenantID, flowID string) (*Flow, error)

+ GetSessionContext func(ctx context.Context, workflowID, sessionID, taskID string) (map[string]map[string]interface{}, error)

+ GetWorkflowActions func(ctx context.Context, tenantID, workflowID string) ([]WorkflowAction, error)

+ ListFlows func(ctx context.Context, tenantID string, page, pageSize int) (*FlowListResponse, error)

+ QueryWorkflowAction func(ctx context.Context, tenantID, workflowID, key string) (*WorkflowAction, error)

+ QueryWorkflowActionDependencies func(ctx context.Context, tenantID, workflowID, key, metaOutput string) ([]WorkflowAction, error)

+ UpdateAction func(ctx context.Context, req *UpdateActionRequest) (*WorkflowAction, error)

+ UpdateFlow func(ctx context.Context, req *UpdateFlowRequest) (*Flow, error)