api

type API struct {
	// contains filtered or unexported fields
}

type Catalog interface {
	Save(ctx context.Context, definition *models.EventDefinition) error
	Get(ctx context.Context, key string) (*models.EventDefinition, error)
	List(ctx context.Context) ([]*models.EventDefinition, error)
}

type Executions interface {
	GetExecutionContext(ctx context.Context, executionID string) (*models.ExecutionContext, error)
	GetExecutionsByWorkflow(ctx context.Context, workflowID string, limit int) ([]*models.ExecutionContext, error)
}

type NodeTypes interface {
	Save(ctx context.Context, nodeType *models.RemoteNodeType) error
	Get(ctx context.Context, id string) (*models.RemoteNodeType, error)
}

type Publisher interface {
	PublishWorkflow(ctx context.Context, workflowID string) (*models.Workflow, error)
	UnpublishWorkflow(ctx context.Context, workflowID string) (*models.Workflow, error)
}

type Resumer interface {
	Resume(ctx context.Context, executionID, nodeID string, data map[string]any) error
}

type Workflows interface {
	FetchAll(ctx context.Context, tenantID string) ([]*models.Workflow, error)
	FetchByID(ctx context.Context, id string) (*models.Workflow, error)
	Create(ctx context.Context, workflow *models.Workflow) (*models.Workflow, error)
}