sflow

package
v0.0.0-...-36d6306 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNoFlowFound = sql.ErrNoRows
View Source 
var ErrNoFlowTag error = sql.ErrNoRows
View Source 
var ErrNoFlowVariableFound = errors.New("no flow variable find")
View Source 
var ErrNoNodeAIFound = sql.ErrNoRows
View Source 
var ErrNoNodeAiProviderFound = sql.ErrNoRows
View Source 
var ErrNoNodeForEachFound = errors.New("node foreach not found")
View Source 
var ErrNoNodeForFound = sql.ErrNoRows
View Source 
var ErrNoNodeFound error = sql.ErrNoRows
View Source 
var ErrNoNodeJsFound = sql.ErrNoRows
View Source 
var ErrNoNodeMemoryFound = sql.ErrNoRows
View Source 
var ErrNoNodeRunSubFlowFound = sql.ErrNoRows
View Source 
var ErrNoNodeSubFlowReturnFound = sql.ErrNoRows
View Source 
var ErrNoNodeSubFlowTriggerFound = sql.ErrNoRows
View Source 
var ErrNoNodeWaitFound = sql.ErrNoRows

Functions

func ConvertDBToFlow 

func ConvertDBToFlow(item gen.Flow) mflow.Flow

func ConvertDBToFlowTag 

func ConvertDBToFlowTag(item gen.FlowTag) mflow.FlowTag

func ConvertDBToFlowVariable 

func ConvertDBToFlowVariable(item gen.FlowVariable) mflow.FlowVariable

func ConvertDBToNodeAi 

func ConvertDBToNodeAi(nf gen.FlowNodeAi) *mflow.NodeAI

func ConvertDBToNodeAiProvider 

func ConvertDBToNodeAiProvider(nf gen.FlowNodeAiProvider) *mflow.NodeAiProvider

func ConvertDBToNodeFor 

func ConvertDBToNodeFor(nf gen.FlowNodeFor) *mflow.NodeFor

func ConvertDBToNodeForEach 

func ConvertDBToNodeForEach(nf gen.FlowNodeForEach) *mflow.NodeForEach

func ConvertDBToNodeJs 

func ConvertDBToNodeJs(nf gen.FlowNodeJ) *mflow.NodeJS

INFO: for some reason sqlc generate `Js` as `J`, will check later why it is not working

func ConvertDBToNodeMemory 

func ConvertDBToNodeMemory(nf gen.FlowNodeMemory) *mflow.NodeMemory

func ConvertDBToNodeRunSubFlow 

func ConvertDBToNodeRunSubFlow(row gen.FlowNodeRunSubFlow) *mflow.NodeRunSubFlow

func ConvertDBToNodeSubFlowReturn 

func ConvertDBToNodeSubFlowReturn(row gen.FlowNodeSubFlowReturn) *mflow.NodeSubFlowReturn

func ConvertDBToNodeSubFlowTrigger 

func ConvertDBToNodeSubFlowTrigger(row gen.FlowNodeSubFlowTrigger) *mflow.NodeSubFlowTrigger

func ConvertDBToNodeWait 

func ConvertDBToNodeWait(nw gen.FlowNodeWait) *mflow.NodeWait

func ConvertFlowTagToDB 

func ConvertFlowTagToDB(item mflow.FlowTag) gen.FlowTag

func ConvertFlowToDB 

func ConvertFlowToDB(item mflow.Flow) gen.Flow

func ConvertFlowVariableToDB 

func ConvertFlowVariableToDB(item mflow.FlowVariable) gen.FlowVariable

func ConvertNodeAiProviderToDB 

func ConvertNodeAiProviderToDB(mn mflow.NodeAiProvider) gen.FlowNodeAiProvider

func ConvertNodeAiToDB 

func ConvertNodeAiToDB(mn mflow.NodeAI) gen.FlowNodeAi

func ConvertNodeExecutionToDB 

func ConvertNodeExecutionToDB(ne mflow.NodeExecution) *gen.NodeExecution

func ConvertNodeExecutionToModel 

func ConvertNodeExecutionToModel(ne gen.NodeExecution) *mflow.NodeExecution

func ConvertNodeForEachToDB 

func ConvertNodeForEachToDB(nf mflow.NodeForEach) gen.FlowNodeForEach

func ConvertNodeForToDB 

func ConvertNodeForToDB(nf mflow.NodeFor) gen.FlowNodeFor

func ConvertNodeJsToDB 

func ConvertNodeJsToDB(mn mflow.NodeJS) gen.FlowNodeJ

func ConvertNodeMemoryToDB 

func ConvertNodeMemoryToDB(mn mflow.NodeMemory) gen.FlowNodeMemory

func ConvertNodeRunSubFlowToDB 

func ConvertNodeRunSubFlowToDB(m mflow.NodeRunSubFlow) gen.FlowNodeRunSubFlow

func ConvertNodeSubFlowReturnToDB 

func ConvertNodeSubFlowReturnToDB(m mflow.NodeSubFlowReturn) gen.FlowNodeSubFlowReturn

func ConvertNodeSubFlowTriggerToDB 

func ConvertNodeSubFlowTriggerToDB(m mflow.NodeSubFlowTrigger) gen.FlowNodeSubFlowTrigger

func ConvertNodeToDB 

func ConvertNodeToDB(n mflow.Node) *gen.FlowNode

func ConvertNodeToModel 

func ConvertNodeToModel(n gen.FlowNode) *mflow.Node

func ConvertNodeWaitToDB 

func ConvertNodeWaitToDB(mn mflow.NodeWait) gen.FlowNodeWait

func ConvertToDBEdge 

func ConvertToDBEdge(e mflow.Edge) gen.FlowEdge

func ConvertToDBNodeGraphQL 

func ConvertToDBNodeGraphQL(ng mflow.NodeGraphQL) (gen.FlowNodeGraphql, bool)

func ConvertToDBNodeHTTP 

func ConvertToDBNodeHTTP(nr mflow.NodeRequest) (gen.FlowNodeHttp, bool)

func ConvertToDBNodeIf 

func ConvertToDBNodeIf(ni mflow.NodeIf) gen.FlowNodeCondition

func ConvertToDBNodeWsConnection 

func ConvertToDBNodeWsConnection(n mflow.NodeWsConnection) (gen.FlowNodeWsConnection, bool)

func ConvertToDBNodeWsSend 

func ConvertToDBNodeWsSend(n mflow.NodeWsSend) gen.FlowNodeWsSend

func ConvertToModelEdge 

func ConvertToModelEdge(e gen.FlowEdge) *mflow.Edge

func ConvertToModelNodeGraphQL 

func ConvertToModelNodeGraphQL(ng gen.FlowNodeGraphql) *mflow.NodeGraphQL

func ConvertToModelNodeHTTP 

func ConvertToModelNodeHTTP(nr gen.FlowNodeHttp) *mflow.NodeRequest

func ConvertToModelNodeIf 

func ConvertToModelNodeIf(ni gen.FlowNodeCondition) *mflow.NodeIf

func ConvertToModelNodeWsConnection 

func ConvertToModelNodeWsConnection(n gen.FlowNodeWsConnection) *mflow.NodeWsConnection

func ConvertToModelNodeWsSend 

func ConvertToModelNodeWsSend(n gen.FlowNodeWsSend) *mflow.NodeWsSend

Types

type EdgeReader 

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

func NewEdgeReader 

func NewEdgeReader(db *sql.DB) *EdgeReader

func NewEdgeReaderFromQueries 

func NewEdgeReaderFromQueries(queries *gen.Queries) *EdgeReader

func (*EdgeReader) GetEdge 

func (r *EdgeReader) GetEdge(ctx context.Context, id idwrap.IDWrap) (*mflow.Edge, error)

func (*EdgeReader) GetEdgesByFlowID 

func (r *EdgeReader) GetEdgesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.Edge, error)

func (*EdgeReader) GetEdgesByNodeIDs 

func (r *EdgeReader) GetEdgesByNodeIDs(ctx context.Context, nodeIDs []idwrap.IDWrap) ([]mflow.Edge, error)

type EdgeService 

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

func NewEdgeService 

func NewEdgeService(queries *gen.Queries) EdgeService

func NewEdgeServiceTX 

func NewEdgeServiceTX(ctx context.Context, tx gen.DBTX) (*EdgeService, error)

func (EdgeService) CreateEdge 

func (es EdgeService) CreateEdge(ctx context.Context, e mflow.Edge) error

func (EdgeService) CreateEdgeBulk 

func (es EdgeService) CreateEdgeBulk(ctx context.Context, edges []mflow.Edge) error

func (EdgeService) DeleteEdge 

func (es EdgeService) DeleteEdge(ctx context.Context, id idwrap.IDWrap) error

func (EdgeService) GetEdge 

func (es EdgeService) GetEdge(ctx context.Context, id idwrap.IDWrap) (*mflow.Edge, error)

func (EdgeService) GetEdgesByFlowID 

func (es EdgeService) GetEdgesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.Edge, error)

func (EdgeService) Reader 

func (s EdgeService) Reader() *EdgeReader

func (EdgeService) TX 

func (es EdgeService) TX(tx *sql.Tx) EdgeService

func (EdgeService) UpdateEdge 

func (es EdgeService) UpdateEdge(ctx context.Context, e mflow.Edge) error

func (EdgeService) UpdateEdgeState 

func (es EdgeService) UpdateEdgeState(ctx context.Context, id idwrap.IDWrap, state mflow.NodeState) error

type EdgeWriter 

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

func NewEdgeWriter 

func NewEdgeWriter(tx gen.DBTX) *EdgeWriter

func NewEdgeWriterFromQueries 

func NewEdgeWriterFromQueries(queries *gen.Queries) *EdgeWriter

func (*EdgeWriter) CreateEdge 

func (w *EdgeWriter) CreateEdge(ctx context.Context, e mflow.Edge) error

func (*EdgeWriter) CreateEdgeBulk 

func (w *EdgeWriter) CreateEdgeBulk(ctx context.Context, edges []mflow.Edge) error

func (*EdgeWriter) DeleteEdge 

func (w *EdgeWriter) DeleteEdge(ctx context.Context, id idwrap.IDWrap) error

func (*EdgeWriter) UpdateEdge 

func (w *EdgeWriter) UpdateEdge(ctx context.Context, e mflow.Edge) error

func (*EdgeWriter) UpdateEdgeState 

func (w *EdgeWriter) UpdateEdgeState(ctx context.Context, id idwrap.IDWrap, state mflow.NodeState) error

type FlowReader 

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

func NewFlowReader 

func NewFlowReader(db *sql.DB) *FlowReader

func NewFlowReaderFromQueries 

func NewFlowReaderFromQueries(queries *gen.Queries) *FlowReader

func (*FlowReader) GetAllFlowsByWorkspaceID 

func (r *FlowReader) GetAllFlowsByWorkspaceID(ctx context.Context, workspaceID idwrap.IDWrap) ([]mflow.Flow, error)

GetAllFlowsByWorkspaceID returns all flows including versions for TanStack DB sync

func (*FlowReader) GetFlow 

func (r *FlowReader) GetFlow(ctx context.Context, id idwrap.IDWrap) (mflow.Flow, error)

func (*FlowReader) GetFlowsByVersionParentID 

func (r *FlowReader) GetFlowsByVersionParentID(ctx context.Context, versionParentID idwrap.IDWrap) ([]mflow.Flow, error)

func (*FlowReader) GetFlowsByWorkspaceID 

func (r *FlowReader) GetFlowsByWorkspaceID(ctx context.Context, workspaceID idwrap.IDWrap) ([]mflow.Flow, error)

func (*FlowReader) GetLatestVersionByParentID 

func (r *FlowReader) GetLatestVersionByParentID(ctx context.Context, parentID idwrap.IDWrap) (*mflow.Flow, error)

GetLatestVersionByParentID returns the most recent version of a flow

type FlowService 

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

func NewFlowService 

func NewFlowService(queries *gen.Queries) FlowService

func NewFlowServiceTX 

func NewFlowServiceTX(ctx context.Context, tx *sql.Tx) (*FlowService, error)

func (*FlowService) CreateFlow 

func (s *FlowService) CreateFlow(ctx context.Context, item mflow.Flow) error

func (*FlowService) CreateFlowBulk 

func (s *FlowService) CreateFlowBulk(ctx context.Context, flows []mflow.Flow) error

func (*FlowService) CreateFlowVersion 

func (s *FlowService) CreateFlowVersion(ctx context.Context, parentFlow mflow.Flow) (mflow.Flow, error)

CreateFlowVersion creates a new flow version (a flow with VersionParentID set) This is used to snapshot a flow when it's run

func (*FlowService) DeleteFlow 

func (s *FlowService) DeleteFlow(ctx context.Context, id idwrap.IDWrap) error

func (*FlowService) GetAllFlowsByWorkspaceID 

func (s *FlowService) GetAllFlowsByWorkspaceID(ctx context.Context, workspaceID idwrap.IDWrap) ([]mflow.Flow, error)

GetAllFlowsByWorkspaceID returns all flows including versions for TanStack DB sync

func (*FlowService) GetFlow 

func (s *FlowService) GetFlow(ctx context.Context, id idwrap.IDWrap) (mflow.Flow, error)

func (*FlowService) GetFlowsByVersionParentID 

func (s *FlowService) GetFlowsByVersionParentID(ctx context.Context, versionParentID idwrap.IDWrap) ([]mflow.Flow, error)

func (*FlowService) GetFlowsByWorkspaceID 

func (s *FlowService) GetFlowsByWorkspaceID(ctx context.Context, workspaceID idwrap.IDWrap) ([]mflow.Flow, error)

func (*FlowService) GetLatestVersionByParentID 

func (s *FlowService) GetLatestVersionByParentID(ctx context.Context, parentID idwrap.IDWrap) (*mflow.Flow, error)

GetLatestVersionByParentID returns the most recent version of a flow

func (FlowService) Reader 

func (s FlowService) Reader() *FlowReader

func (FlowService) TX 

func (s FlowService) TX(tx *sql.Tx) FlowService

func (*FlowService) UpdateFlow 

func (s *FlowService) UpdateFlow(ctx context.Context, flow mflow.Flow) error

func (*FlowService) UpdateFlowNodeIDMapping 

func (s *FlowService) UpdateFlowNodeIDMapping(ctx context.Context, flowID idwrap.IDWrap, mapping []byte) error

UpdateFlowNodeIDMapping updates the node ID mapping for a flow version

type FlowTagReader 

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

func NewFlowTagReader 

func NewFlowTagReader(db *sql.DB) *FlowTagReader

func NewFlowTagReaderFromQueries 

func NewFlowTagReaderFromQueries(queries *gen.Queries) *FlowTagReader

func (*FlowTagReader) GetFlowTag 

func (r *FlowTagReader) GetFlowTag(ctx context.Context, id idwrap.IDWrap) (mflow.FlowTag, error)

func (*FlowTagReader) GetFlowTagsByTagID 

func (r *FlowTagReader) GetFlowTagsByTagID(ctx context.Context, tagID idwrap.IDWrap) ([]mflow.FlowTag, error)

type FlowTagService 

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

func NewFlowTagService 

func NewFlowTagService(queries *gen.Queries) FlowTagService

func NewFlowTagServiceTX 

func NewFlowTagServiceTX(ctx context.Context, tx *sql.Tx) (*FlowTagService, error)

func (*FlowTagService) CreateFlowTag 

func (s *FlowTagService) CreateFlowTag(ctx context.Context, ftag mflow.FlowTag) error

func (*FlowTagService) DeleteFlowTag 

func (s *FlowTagService) DeleteFlowTag(ctx context.Context, id idwrap.IDWrap) error

func (*FlowTagService) GetFlowTag 

func (s *FlowTagService) GetFlowTag(ctx context.Context, id idwrap.IDWrap) (mflow.FlowTag, error)

func (*FlowTagService) GetFlowTagsByTagID 

func (s *FlowTagService) GetFlowTagsByTagID(ctx context.Context, tagID idwrap.IDWrap) ([]mflow.FlowTag, error)

func (FlowTagService) Reader 

func (s FlowTagService) Reader() *FlowTagReader

type FlowTagWriter 

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

func NewFlowTagWriter 

func NewFlowTagWriter(tx gen.DBTX) *FlowTagWriter

func NewFlowTagWriterFromQueries 

func NewFlowTagWriterFromQueries(queries *gen.Queries) *FlowTagWriter

func (*FlowTagWriter) CreateFlowTag 

func (w *FlowTagWriter) CreateFlowTag(ctx context.Context, ftag mflow.FlowTag) error

func (*FlowTagWriter) DeleteFlowTag 

func (w *FlowTagWriter) DeleteFlowTag(ctx context.Context, id idwrap.IDWrap) error

type FlowVariableReader 

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

func NewFlowVariableReader 

func NewFlowVariableReader(db *sql.DB) *FlowVariableReader

func NewFlowVariableReaderFromQueries 

func NewFlowVariableReaderFromQueries(queries *gen.Queries) *FlowVariableReader

func (*FlowVariableReader) GetFlowVariable 

func (r *FlowVariableReader) GetFlowVariable(ctx context.Context, id idwrap.IDWrap) (mflow.FlowVariable, error)

func (*FlowVariableReader) GetFlowVariablesByFlowID 

func (r *FlowVariableReader) GetFlowVariablesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.FlowVariable, error)

func (*FlowVariableReader) GetFlowVariablesByFlowIDOrdered 

func (r *FlowVariableReader) GetFlowVariablesByFlowIDOrdered(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.FlowVariable, error)

GetFlowVariablesByFlowIDOrdered returns flow variables in the flow ordered by display_order

type FlowVariableService 

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

func NewFlowVariableService 

func NewFlowVariableService(queries *gen.Queries) FlowVariableService

func NewFlowVariableServiceTX 

func NewFlowVariableServiceTX(ctx context.Context, tx *sql.Tx) (*FlowVariableService, error)

func (*FlowVariableService) CreateFlowVariable 

func (s *FlowVariableService) CreateFlowVariable(ctx context.Context, item mflow.FlowVariable) error

func (*FlowVariableService) CreateFlowVariableBulk 

func (s *FlowVariableService) CreateFlowVariableBulk(ctx context.Context, variables []mflow.FlowVariable) error

func (*FlowVariableService) DeleteFlowVariable 

func (s *FlowVariableService) DeleteFlowVariable(ctx context.Context, id idwrap.IDWrap) error

func (*FlowVariableService) GetFlowVariable 

func (s *FlowVariableService) GetFlowVariable(ctx context.Context, id idwrap.IDWrap) (mflow.FlowVariable, error)

func (*FlowVariableService) GetFlowVariablesByFlowID 

func (s *FlowVariableService) GetFlowVariablesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.FlowVariable, error)

func (*FlowVariableService) GetFlowVariablesByFlowIDOrdered 

func (s *FlowVariableService) GetFlowVariablesByFlowIDOrdered(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.FlowVariable, error)

GetFlowVariablesByFlowIDOrdered returns flow variables in the flow ordered by display_order

func (*FlowVariableService) MoveFlowVariableAfter 

func (s *FlowVariableService) MoveFlowVariableAfter(ctx context.Context, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableAfter moves a flow variable to be positioned after the target variable

func (*FlowVariableService) MoveFlowVariableAfterTX 

func (s *FlowVariableService) MoveFlowVariableAfterTX(ctx context.Context, tx *sql.Tx, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableAfterTX moves a flow variable to be positioned after the target variable within a transaction

func (*FlowVariableService) MoveFlowVariableBefore 

func (s *FlowVariableService) MoveFlowVariableBefore(ctx context.Context, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableBefore moves a flow variable to be positioned before the target variable

func (*FlowVariableService) MoveFlowVariableBeforeTX 

func (s *FlowVariableService) MoveFlowVariableBeforeTX(ctx context.Context, tx *sql.Tx, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableBeforeTX moves a flow variable to be positioned before the target variable within a transaction

func (FlowVariableService) Reader 

func (s FlowVariableService) Reader() *FlowVariableReader

func (*FlowVariableService) ReorderFlowVariables 

func (s *FlowVariableService) ReorderFlowVariables(ctx context.Context, orderedIDs []idwrap.IDWrap) error

ReorderFlowVariables performs a bulk reorder of flow variables by updating their display_order

func (*FlowVariableService) ReorderFlowVariablesTX 

func (s *FlowVariableService) ReorderFlowVariablesTX(ctx context.Context, tx *sql.Tx, orderedIDs []idwrap.IDWrap) error

ReorderFlowVariablesTX performs a bulk reorder of flow variables within a transaction

func (FlowVariableService) TX 

func (s FlowVariableService) TX(tx *sql.Tx) FlowVariableService

func (*FlowVariableService) UpdateFlowVariable 

func (s *FlowVariableService) UpdateFlowVariable(ctx context.Context, item mflow.FlowVariable) error

func (*FlowVariableService) UpdateFlowVariableOrder 

func (s *FlowVariableService) UpdateFlowVariableOrder(ctx context.Context, id idwrap.IDWrap, order float64) error

UpdateFlowVariableOrder updates the display_order for a single flow variable

type FlowVariableWriter 

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

func NewFlowVariableWriter 

func NewFlowVariableWriter(tx gen.DBTX) *FlowVariableWriter

func NewFlowVariableWriterFromQueries 

func NewFlowVariableWriterFromQueries(queries *gen.Queries) *FlowVariableWriter

func (*FlowVariableWriter) CreateFlowVariable 

func (w *FlowVariableWriter) CreateFlowVariable(ctx context.Context, item mflow.FlowVariable) error

func (*FlowVariableWriter) CreateFlowVariableBulk 

func (w *FlowVariableWriter) CreateFlowVariableBulk(ctx context.Context, variables []mflow.FlowVariable) error

func (*FlowVariableWriter) DeleteFlowVariable 

func (w *FlowVariableWriter) DeleteFlowVariable(ctx context.Context, id idwrap.IDWrap) error

func (*FlowVariableWriter) MoveFlowVariableAfter 

func (w *FlowVariableWriter) MoveFlowVariableAfter(ctx context.Context, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableAfter moves a flow variable to be positioned after the target variable

func (*FlowVariableWriter) MoveFlowVariableBefore 

func (w *FlowVariableWriter) MoveFlowVariableBefore(ctx context.Context, variableID, targetVariableID idwrap.IDWrap) error

MoveFlowVariableBefore moves a flow variable to be positioned before the target variable

func (*FlowVariableWriter) ReorderFlowVariables 

func (w *FlowVariableWriter) ReorderFlowVariables(ctx context.Context, orderedIDs []idwrap.IDWrap) error

ReorderFlowVariables performs a bulk reorder of flow variables by updating their display_order

func (*FlowVariableWriter) UpdateFlowVariable 

func (w *FlowVariableWriter) UpdateFlowVariable(ctx context.Context, item mflow.FlowVariable) error

func (*FlowVariableWriter) UpdateFlowVariableOrder 

func (w *FlowVariableWriter) UpdateFlowVariableOrder(ctx context.Context, id idwrap.IDWrap, order float64) error

UpdateFlowVariableOrder updates the display_order for a single flow variable

type FlowWriter 

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

func NewFlowWriter 

func NewFlowWriter(tx gen.DBTX) *FlowWriter

func NewFlowWriterFromQueries 

func NewFlowWriterFromQueries(queries *gen.Queries) *FlowWriter

func (*FlowWriter) CreateFlow 

func (w *FlowWriter) CreateFlow(ctx context.Context, item mflow.Flow) error

func (*FlowWriter) CreateFlowBulk 

func (w *FlowWriter) CreateFlowBulk(ctx context.Context, flows []mflow.Flow) error

func (*FlowWriter) CreateFlowVersion 

func (w *FlowWriter) CreateFlowVersion(ctx context.Context, parentFlow mflow.Flow) (mflow.Flow, error)

CreateFlowVersion creates a new flow version (a flow with VersionParentID set) This is used to snapshot a flow when it's run

func (*FlowWriter) DeleteFlow 

func (w *FlowWriter) DeleteFlow(ctx context.Context, id idwrap.IDWrap) error

func (*FlowWriter) UpdateFlow 

func (w *FlowWriter) UpdateFlow(ctx context.Context, flow mflow.Flow) error

func (*FlowWriter) UpdateFlowNodeIDMapping 

func (w *FlowWriter) UpdateFlowNodeIDMapping(ctx context.Context, flowID idwrap.IDWrap, mapping []byte) error

UpdateFlowNodeIDMapping updates the node ID mapping for a flow version

type NodeAIReader 

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

NodeAIReader reads AI nodes from the database.

func NewNodeAIReader 

func NewNodeAIReader(db *sql.DB) *NodeAIReader

NewNodeAIReader creates a new reader with db connection.

func NewNodeAIReaderFromQueries 

func NewNodeAIReaderFromQueries(queries *gen.Queries) *NodeAIReader

NewNodeAIReaderFromQueries creates a reader from existing queries.

func (*NodeAIReader) GetNodeAI 

func (r *NodeAIReader) GetNodeAI(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeAI, error)

GetNodeAI returns an AI node by its flow node ID.

type NodeAIService 

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

NodeAIService provides CRUD operations for AI nodes.

func NewNodeAIService 

func NewNodeAIService(queries *gen.Queries) NodeAIService

NewNodeAIService creates a new service with queries.

func (NodeAIService) CreateNodeAI 

func (s NodeAIService) CreateNodeAI(ctx context.Context, n mflow.NodeAI) error

CreateNodeAI creates a new AI node.

func (NodeAIService) DeleteNodeAI 

func (s NodeAIService) DeleteNodeAI(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeAI deletes an AI node by its flow node ID.

func (NodeAIService) GetNodeAI 

func (s NodeAIService) GetNodeAI(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeAI, error)

GetNodeAI returns an AI node by its flow node ID.

func (NodeAIService) Reader 

func (s NodeAIService) Reader() *NodeAIReader

Reader returns the underlying reader.

func (NodeAIService) TX 

func (s NodeAIService) TX(tx *sql.Tx) NodeAIService

TX returns a new service scoped to the transaction.

func (NodeAIService) UpdateNodeAI 

func (s NodeAIService) UpdateNodeAI(ctx context.Context, n mflow.NodeAI) error

UpdateNodeAI updates an existing AI node.

type NodeAIWriter 

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

NodeAIWriter writes AI nodes to the database.

func NewNodeAIWriter 

func NewNodeAIWriter(tx gen.DBTX) *NodeAIWriter

NewNodeAIWriter creates a writer from a transaction.

func NewNodeAIWriterFromQueries 

func NewNodeAIWriterFromQueries(queries *gen.Queries) *NodeAIWriter

NewNodeAIWriterFromQueries creates a writer from existing queries.

func (*NodeAIWriter) CreateNodeAI 

func (w *NodeAIWriter) CreateNodeAI(ctx context.Context, n mflow.NodeAI) error

CreateNodeAI creates a new AI node.

func (*NodeAIWriter) DeleteNodeAI 

func (w *NodeAIWriter) DeleteNodeAI(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeAI deletes an AI node by its flow node ID.

func (*NodeAIWriter) UpdateNodeAI 

func (w *NodeAIWriter) UpdateNodeAI(ctx context.Context, n mflow.NodeAI) error

UpdateNodeAI updates an existing AI node.

type NodeAiProviderReader 

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

NodeAiProviderReader reads AI Provider nodes from the database.

func NewNodeAiProviderReader 

func NewNodeAiProviderReader(db *sql.DB) *NodeAiProviderReader

NewNodeAiProviderReader creates a new reader with db connection.

func NewNodeAiProviderReaderFromQueries 

func NewNodeAiProviderReaderFromQueries(queries *gen.Queries) *NodeAiProviderReader

NewNodeAiProviderReaderFromQueries creates a reader from existing queries.

func (*NodeAiProviderReader) GetNodeAiProvider 

func (r *NodeAiProviderReader) GetNodeAiProvider(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeAiProvider, error)

GetNodeAiProvider returns an AI Provider node by its flow node ID.

type NodeAiProviderService 

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

NodeAiProviderService provides CRUD operations for AI Provider nodes.

func NewNodeAiProviderService 

func NewNodeAiProviderService(queries *gen.Queries) NodeAiProviderService

NewNodeAiProviderService creates a new service with queries.

func (NodeAiProviderService) CreateNodeAiProvider 

func (s NodeAiProviderService) CreateNodeAiProvider(ctx context.Context, n mflow.NodeAiProvider) error

CreateNodeAiProvider creates a new AI Provider node.

func (NodeAiProviderService) DeleteNodeAiProvider 

func (s NodeAiProviderService) DeleteNodeAiProvider(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeAiProvider deletes an AI Provider node by its flow node ID.

func (NodeAiProviderService) GetNodeAiProvider 

func (s NodeAiProviderService) GetNodeAiProvider(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeAiProvider, error)

GetNodeAiProvider returns an AI Provider node by its flow node ID.

func (NodeAiProviderService) Reader 

func (s NodeAiProviderService) Reader() *NodeAiProviderReader

Reader returns the underlying reader.

func (NodeAiProviderService) TX 

func (s NodeAiProviderService) TX(tx *sql.Tx) NodeAiProviderService

TX returns a new service scoped to the transaction.

func (NodeAiProviderService) UpdateNodeAiProvider 

func (s NodeAiProviderService) UpdateNodeAiProvider(ctx context.Context, n mflow.NodeAiProvider) error

UpdateNodeAiProvider updates an existing AI Provider node.

type NodeAiProviderWriter 

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

NodeAiProviderWriter writes AI Provider nodes to the database.

func NewNodeAiProviderWriterFromQueries 

func NewNodeAiProviderWriterFromQueries(queries *gen.Queries) *NodeAiProviderWriter

NewNodeAiProviderWriterFromQueries creates a writer from existing queries.

func (*NodeAiProviderWriter) CreateNodeAiProvider 

func (w *NodeAiProviderWriter) CreateNodeAiProvider(ctx context.Context, n mflow.NodeAiProvider) error

CreateNodeAiProvider creates a new AI Provider node.

func (*NodeAiProviderWriter) DeleteNodeAiProvider 

func (w *NodeAiProviderWriter) DeleteNodeAiProvider(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeAiProvider deletes an AI Provider node by its flow node ID.

func (*NodeAiProviderWriter) UpdateNodeAiProvider 

func (w *NodeAiProviderWriter) UpdateNodeAiProvider(ctx context.Context, n mflow.NodeAiProvider) error

UpdateNodeAiProvider updates an existing AI Provider node.

type NodeExecutionReader 

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

func NewNodeExecutionReader 

func NewNodeExecutionReader(db *sql.DB) *NodeExecutionReader

func NewNodeExecutionReaderFromQueries 

func NewNodeExecutionReaderFromQueries(queries *gen.Queries) *NodeExecutionReader

func (*NodeExecutionReader) GetLatestNodeExecutionByNodeID 

func (r *NodeExecutionReader) GetLatestNodeExecutionByNodeID(ctx context.Context, nodeID idwrap.IDWrap) (*mflow.NodeExecution, error)

func (*NodeExecutionReader) GetNodeExecution 

func (r *NodeExecutionReader) GetNodeExecution(ctx context.Context, executionID idwrap.IDWrap) (*mflow.NodeExecution, error)

func (*NodeExecutionReader) GetNodeExecutionsByNodeID 

func (r *NodeExecutionReader) GetNodeExecutionsByNodeID(ctx context.Context, nodeID idwrap.IDWrap) ([]mflow.NodeExecution, error)

type NodeExecutionService 

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

func NewNodeExecutionService 

func NewNodeExecutionService(queries *gen.Queries) NodeExecutionService

func NewNodeExecutionServiceTX 

func NewNodeExecutionServiceTX(ctx context.Context, tx *sql.Tx) (*NodeExecutionService, error)

func (NodeExecutionService) CreateNodeExecution 

func (s NodeExecutionService) CreateNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

func (NodeExecutionService) DeleteNodeExecutionsByNodeID 

func (s NodeExecutionService) DeleteNodeExecutionsByNodeID(ctx context.Context, nodeID idwrap.IDWrap) error

func (NodeExecutionService) DeleteNodeExecutionsByNodeIDs 

func (s NodeExecutionService) DeleteNodeExecutionsByNodeIDs(ctx context.Context, nodeIDs []idwrap.IDWrap) error

func (NodeExecutionService) GetLatestNodeExecutionByNodeID 

func (s NodeExecutionService) GetLatestNodeExecutionByNodeID(ctx context.Context, nodeID idwrap.IDWrap) (*mflow.NodeExecution, error)

func (NodeExecutionService) GetNodeExecution 

func (s NodeExecutionService) GetNodeExecution(ctx context.Context, executionID idwrap.IDWrap) (*mflow.NodeExecution, error)

func (NodeExecutionService) GetNodeExecutionsByNodeID 

func (s NodeExecutionService) GetNodeExecutionsByNodeID(ctx context.Context, nodeID idwrap.IDWrap) ([]mflow.NodeExecution, error)

func (NodeExecutionService) ListNodeExecutionsByNodeID 

func (s NodeExecutionService) ListNodeExecutionsByNodeID(ctx context.Context, nodeID idwrap.IDWrap) ([]mflow.NodeExecution, error)

func (NodeExecutionService) Reader 

func (s NodeExecutionService) Reader() *NodeExecutionReader

func (NodeExecutionService) TX 

func (s NodeExecutionService) TX(tx *sql.Tx) NodeExecutionService

func (NodeExecutionService) UpdateNodeExecution 

func (s NodeExecutionService) UpdateNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

func (NodeExecutionService) UpdateNodeExecutionNodeID 

func (s NodeExecutionService) UpdateNodeExecutionNodeID(ctx context.Context, execID, newNodeID idwrap.IDWrap) error

func (NodeExecutionService) UpsertNodeExecution 

func (s NodeExecutionService) UpsertNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

type NodeExecutionWriter 

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

func NewNodeExecutionWriter 

func NewNodeExecutionWriter(tx gen.DBTX) *NodeExecutionWriter

func NewNodeExecutionWriterFromQueries 

func NewNodeExecutionWriterFromQueries(queries *gen.Queries) *NodeExecutionWriter

func (*NodeExecutionWriter) CreateNodeExecution 

func (w *NodeExecutionWriter) CreateNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

func (*NodeExecutionWriter) DeleteNodeExecutionsByNodeID 

func (w *NodeExecutionWriter) DeleteNodeExecutionsByNodeID(ctx context.Context, nodeID idwrap.IDWrap) error

func (*NodeExecutionWriter) DeleteNodeExecutionsByNodeIDs 

func (w *NodeExecutionWriter) DeleteNodeExecutionsByNodeIDs(ctx context.Context, nodeIDs []idwrap.IDWrap) error

func (*NodeExecutionWriter) UpdateNodeExecution 

func (w *NodeExecutionWriter) UpdateNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

func (*NodeExecutionWriter) UpdateNodeExecutionNodeID 

func (w *NodeExecutionWriter) UpdateNodeExecutionNodeID(ctx context.Context, execID, newNodeID idwrap.IDWrap) error

UpdateNodeExecutionNodeID updates the node_id of a node execution This is used to move executions from parent nodes to version nodes

func (*NodeExecutionWriter) UpsertNodeExecution 

func (w *NodeExecutionWriter) UpsertNodeExecution(ctx context.Context, ne mflow.NodeExecution) error

type NodeForEachReader 

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

func NewNodeForEachReader 

func NewNodeForEachReader(db *sql.DB) *NodeForEachReader

func NewNodeForEachReaderFromQueries 

func NewNodeForEachReaderFromQueries(queries *gen.Queries) *NodeForEachReader

func (*NodeForEachReader) GetNodeForEach 

func (r *NodeForEachReader) GetNodeForEach(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeForEach, error)

type NodeForEachService 

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

func NewNodeForEachService 

func NewNodeForEachService(queries *gen.Queries) NodeForEachService

func NewNodeForEachServiceTX 

func NewNodeForEachServiceTX(ctx context.Context, tx *sql.Tx) (*NodeForEachService, error)

func (NodeForEachService) CreateNodeForEach 

func (nfs NodeForEachService) CreateNodeForEach(ctx context.Context, nf mflow.NodeForEach) error

func (NodeForEachService) CreateNodeForEachBulk 

func (nfs NodeForEachService) CreateNodeForEachBulk(ctx context.Context, forEachNodes []mflow.NodeForEach) error

func (NodeForEachService) DeleteNodeForEach 

func (nfs NodeForEachService) DeleteNodeForEach(ctx context.Context, id idwrap.IDWrap) error

func (NodeForEachService) GetNodeForEach 

func (nfs NodeForEachService) GetNodeForEach(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeForEach, error)

func (NodeForEachService) Reader 

func (s NodeForEachService) Reader() *NodeForEachReader

func (NodeForEachService) TX 

func (nfs NodeForEachService) TX(tx *sql.Tx) NodeForEachService

func (NodeForEachService) UpdateNodeForEach 

func (nfs NodeForEachService) UpdateNodeForEach(ctx context.Context, nf mflow.NodeForEach) error

type NodeForEachWriter 

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

func NewNodeForEachWriter 

func NewNodeForEachWriter(tx gen.DBTX) *NodeForEachWriter

func NewNodeForEachWriterFromQueries 

func NewNodeForEachWriterFromQueries(queries *gen.Queries) *NodeForEachWriter

func (*NodeForEachWriter) CreateNodeForEach 

func (w *NodeForEachWriter) CreateNodeForEach(ctx context.Context, nf mflow.NodeForEach) error

func (*NodeForEachWriter) CreateNodeForEachBulk 

func (w *NodeForEachWriter) CreateNodeForEachBulk(ctx context.Context, forEachNodes []mflow.NodeForEach) error

func (*NodeForEachWriter) DeleteNodeForEach 

func (w *NodeForEachWriter) DeleteNodeForEach(ctx context.Context, id idwrap.IDWrap) error

func (*NodeForEachWriter) UpdateNodeForEach 

func (w *NodeForEachWriter) UpdateNodeForEach(ctx context.Context, nf mflow.NodeForEach) error

type NodeForReader 

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

func NewNodeForReader 

func NewNodeForReader(db *sql.DB) *NodeForReader

func NewNodeForReaderFromQueries 

func NewNodeForReaderFromQueries(queries *gen.Queries) *NodeForReader

func (*NodeForReader) GetNodeFor 

func (r *NodeForReader) GetNodeFor(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeFor, error)

type NodeForService 

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

func NewNodeForService 

func NewNodeForService(queries *gen.Queries) NodeForService

func NewNodeForServiceTX 

func NewNodeForServiceTX(ctx context.Context, tx *sql.Tx) (*NodeForService, error)

func (NodeForService) CreateNodeFor 

func (nfs NodeForService) CreateNodeFor(ctx context.Context, nf mflow.NodeFor) error

func (NodeForService) CreateNodeForBulk 

func (nfs NodeForService) CreateNodeForBulk(ctx context.Context, nf []mflow.NodeFor) error

func (NodeForService) DeleteNodeFor 

func (nfs NodeForService) DeleteNodeFor(ctx context.Context, id idwrap.IDWrap) error

func (NodeForService) GetNodeFor 

func (nfs NodeForService) GetNodeFor(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeFor, error)

func (NodeForService) Reader 

func (s NodeForService) Reader() *NodeForReader

func (NodeForService) TX 

func (nfs NodeForService) TX(tx *sql.Tx) NodeForService

func (NodeForService) UpdateNodeFor 

func (nfs NodeForService) UpdateNodeFor(ctx context.Context, nf mflow.NodeFor) error

type NodeForWriter 

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

func NewNodeForWriter 

func NewNodeForWriter(tx gen.DBTX) *NodeForWriter

func NewNodeForWriterFromQueries 

func NewNodeForWriterFromQueries(queries *gen.Queries) *NodeForWriter

func (*NodeForWriter) CreateNodeFor 

func (w *NodeForWriter) CreateNodeFor(ctx context.Context, nf mflow.NodeFor) error

func (*NodeForWriter) CreateNodeForBulk 

func (w *NodeForWriter) CreateNodeForBulk(ctx context.Context, nf []mflow.NodeFor) error

func (*NodeForWriter) DeleteNodeFor 

func (w *NodeForWriter) DeleteNodeFor(ctx context.Context, id idwrap.IDWrap) error

func (*NodeForWriter) UpdateNodeFor 

func (w *NodeForWriter) UpdateNodeFor(ctx context.Context, nf mflow.NodeFor) error

type NodeGraphQLReader 

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

func NewNodeGraphQLReader 

func NewNodeGraphQLReader(db *sql.DB) *NodeGraphQLReader

func NewNodeGraphQLReaderFromQueries 

func NewNodeGraphQLReaderFromQueries(queries *gen.Queries) *NodeGraphQLReader

func (*NodeGraphQLReader) GetNodeGraphQL 

func (r *NodeGraphQLReader) GetNodeGraphQL(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeGraphQL, error)

type NodeGraphQLService 

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

func NewNodeGraphQLService 

func NewNodeGraphQLService(queries *gen.Queries) NodeGraphQLService

func NewNodeGraphQLServiceTX 

func NewNodeGraphQLServiceTX(ctx context.Context, tx *sql.Tx) (*NodeGraphQLService, error)

func (NodeGraphQLService) CreateNodeGraphQL 

func (ngs NodeGraphQLService) CreateNodeGraphQL(ctx context.Context, ng mflow.NodeGraphQL) error

func (NodeGraphQLService) DeleteNodeGraphQL 

func (ngs NodeGraphQLService) DeleteNodeGraphQL(ctx context.Context, id idwrap.IDWrap) error

func (NodeGraphQLService) GetNodeGraphQL 

func (ngs NodeGraphQLService) GetNodeGraphQL(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeGraphQL, error)

func (NodeGraphQLService) Reader 

func (ngs NodeGraphQLService) Reader() *NodeGraphQLReader

func (NodeGraphQLService) TX 

func (ngs NodeGraphQLService) TX(tx *sql.Tx) NodeGraphQLService

func (NodeGraphQLService) UpdateNodeGraphQL 

func (ngs NodeGraphQLService) UpdateNodeGraphQL(ctx context.Context, ng mflow.NodeGraphQL) error

type NodeGraphQLWriter 

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

func NewNodeGraphQLWriter 

func NewNodeGraphQLWriter(tx gen.DBTX) *NodeGraphQLWriter

func NewNodeGraphQLWriterFromQueries 

func NewNodeGraphQLWriterFromQueries(queries *gen.Queries) *NodeGraphQLWriter

func (*NodeGraphQLWriter) CreateNodeGraphQL 

func (w *NodeGraphQLWriter) CreateNodeGraphQL(ctx context.Context, ng mflow.NodeGraphQL) error

func (*NodeGraphQLWriter) DeleteNodeGraphQL 

func (w *NodeGraphQLWriter) DeleteNodeGraphQL(ctx context.Context, id idwrap.IDWrap) error

func (*NodeGraphQLWriter) UpdateNodeGraphQL 

func (w *NodeGraphQLWriter) UpdateNodeGraphQL(ctx context.Context, ng mflow.NodeGraphQL) error

type NodeIfReader 

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

func NewNodeIfReader 

func NewNodeIfReader(db *sql.DB) *NodeIfReader

func NewNodeIfReaderFromQueries 

func NewNodeIfReaderFromQueries(queries *gen.Queries) *NodeIfReader

func (*NodeIfReader) GetNodeIf 

func (r *NodeIfReader) GetNodeIf(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeIf, error)

type NodeIfService 

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

func NewNodeIfService 

func NewNodeIfService(queries *gen.Queries) *NodeIfService

func NewNodeIfServiceTX 

func NewNodeIfServiceTX(ctx context.Context, tx *sql.Tx) (*NodeIfService, error)

func (NodeIfService) CreateNodeIf 

func (nifs NodeIfService) CreateNodeIf(ctx context.Context, ni mflow.NodeIf) error

func (NodeIfService) CreateNodeIfBulk 

func (nifs NodeIfService) CreateNodeIfBulk(ctx context.Context, conditionNodes []mflow.NodeIf) error

func (NodeIfService) DeleteNodeIf 

func (nifs NodeIfService) DeleteNodeIf(ctx context.Context, id idwrap.IDWrap) error

func (NodeIfService) GetNodeIf 

func (nifs NodeIfService) GetNodeIf(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeIf, error)

func (NodeIfService) Reader 

func (s NodeIfService) Reader() *NodeIfReader

func (NodeIfService) TX 

func (nifs NodeIfService) TX(tx *sql.Tx) *NodeIfService

func (NodeIfService) UpdateNodeIf 

func (nifs NodeIfService) UpdateNodeIf(ctx context.Context, ni mflow.NodeIf) error

type NodeIfWriter 

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

func NewNodeIfWriter 

func NewNodeIfWriter(tx gen.DBTX) *NodeIfWriter

func NewNodeIfWriterFromQueries 

func NewNodeIfWriterFromQueries(queries *gen.Queries) *NodeIfWriter

func (*NodeIfWriter) CreateNodeIf 

func (w *NodeIfWriter) CreateNodeIf(ctx context.Context, ni mflow.NodeIf) error

func (*NodeIfWriter) CreateNodeIfBulk 

func (w *NodeIfWriter) CreateNodeIfBulk(ctx context.Context, conditionNodes []mflow.NodeIf) error

func (*NodeIfWriter) DeleteNodeIf 

func (w *NodeIfWriter) DeleteNodeIf(ctx context.Context, id idwrap.IDWrap) error

func (*NodeIfWriter) UpdateNodeIf 

func (w *NodeIfWriter) UpdateNodeIf(ctx context.Context, ni mflow.NodeIf) error

type NodeJsReader 

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

func NewNodeJsReader 

func NewNodeJsReader(db *sql.DB) *NodeJsReader

func NewNodeJsReaderFromQueries 

func NewNodeJsReaderFromQueries(queries *gen.Queries) *NodeJsReader

func (*NodeJsReader) GetNodeJS 

func (r *NodeJsReader) GetNodeJS(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeJS, error)

type NodeJsService 

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

func NewNodeJsService 

func NewNodeJsService(queries *gen.Queries) NodeJsService

func NewNodeJsServiceTX 

func NewNodeJsServiceTX(ctx context.Context, tx *sql.Tx) (*NodeJsService, error)

func (NodeJsService) CreateNodeJS 

func (nfs NodeJsService) CreateNodeJS(ctx context.Context, mn mflow.NodeJS) error

func (NodeJsService) CreateNodeJSBulk 

func (nfs NodeJsService) CreateNodeJSBulk(ctx context.Context, jsNodes []mflow.NodeJS) error

func (NodeJsService) DeleteNodeJS 

func (nfs NodeJsService) DeleteNodeJS(ctx context.Context, id idwrap.IDWrap) error

func (NodeJsService) GetNodeJS 

func (nfs NodeJsService) GetNodeJS(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeJS, error)

func (NodeJsService) Reader 

func (s NodeJsService) Reader() *NodeJsReader

func (NodeJsService) TX 

func (nfs NodeJsService) TX(tx *sql.Tx) NodeJsService

func (NodeJsService) UpdateNodeJS 

func (nfs NodeJsService) UpdateNodeJS(ctx context.Context, mn mflow.NodeJS) error

type NodeJsWriter 

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

func NewNodeJsWriter 

func NewNodeJsWriter(tx gen.DBTX) *NodeJsWriter

func NewNodeJsWriterFromQueries 

func NewNodeJsWriterFromQueries(queries *gen.Queries) *NodeJsWriter

func (*NodeJsWriter) CreateNodeJS 

func (w *NodeJsWriter) CreateNodeJS(ctx context.Context, mn mflow.NodeJS) error

func (*NodeJsWriter) CreateNodeJSBulk 

func (w *NodeJsWriter) CreateNodeJSBulk(ctx context.Context, jsNodes []mflow.NodeJS) error

func (*NodeJsWriter) DeleteNodeJS 

func (w *NodeJsWriter) DeleteNodeJS(ctx context.Context, id idwrap.IDWrap) error

func (*NodeJsWriter) UpdateNodeJS 

func (w *NodeJsWriter) UpdateNodeJS(ctx context.Context, mn mflow.NodeJS) error

type NodeMemoryReader 

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

NodeMemoryReader reads Memory nodes from the database.

func NewNodeMemoryReader 

func NewNodeMemoryReader(db *sql.DB) *NodeMemoryReader

NewNodeMemoryReader creates a new reader with db connection.

func NewNodeMemoryReaderFromQueries 

func NewNodeMemoryReaderFromQueries(queries *gen.Queries) *NodeMemoryReader

NewNodeMemoryReaderFromQueries creates a reader from existing queries.

func (*NodeMemoryReader) GetNodeMemory 

func (r *NodeMemoryReader) GetNodeMemory(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeMemory, error)

GetNodeMemory returns a Memory node by its flow node ID.

type NodeMemoryService 

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

NodeMemoryService provides CRUD operations for Memory nodes.

func NewNodeMemoryService 

func NewNodeMemoryService(queries *gen.Queries) NodeMemoryService

NewNodeMemoryService creates a new service with queries.

func (NodeMemoryService) CreateNodeMemory 

func (s NodeMemoryService) CreateNodeMemory(ctx context.Context, n mflow.NodeMemory) error

CreateNodeMemory creates a new Memory node.

func (NodeMemoryService) DeleteNodeMemory 

func (s NodeMemoryService) DeleteNodeMemory(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeMemory deletes a Memory node by its flow node ID.

func (NodeMemoryService) GetNodeMemory 

func (s NodeMemoryService) GetNodeMemory(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeMemory, error)

GetNodeMemory returns a Memory node by its flow node ID.

func (NodeMemoryService) Reader 

func (s NodeMemoryService) Reader() *NodeMemoryReader

Reader returns the underlying reader.

func (NodeMemoryService) TX 

func (s NodeMemoryService) TX(tx *sql.Tx) NodeMemoryService

TX returns a new service scoped to the transaction.

func (NodeMemoryService) UpdateNodeMemory 

func (s NodeMemoryService) UpdateNodeMemory(ctx context.Context, n mflow.NodeMemory) error

UpdateNodeMemory updates an existing Memory node.

type NodeMemoryWriter 

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

NodeMemoryWriter writes Memory nodes to the database.

func NewNodeMemoryWriterFromQueries 

func NewNodeMemoryWriterFromQueries(queries *gen.Queries) *NodeMemoryWriter

NewNodeMemoryWriterFromQueries creates a writer from existing queries.

func (*NodeMemoryWriter) CreateNodeMemory 

func (w *NodeMemoryWriter) CreateNodeMemory(ctx context.Context, n mflow.NodeMemory) error

CreateNodeMemory creates a new Memory node.

func (*NodeMemoryWriter) DeleteNodeMemory 

func (w *NodeMemoryWriter) DeleteNodeMemory(ctx context.Context, id idwrap.IDWrap) error

DeleteNodeMemory deletes a Memory node by its flow node ID.

func (*NodeMemoryWriter) UpdateNodeMemory 

func (w *NodeMemoryWriter) UpdateNodeMemory(ctx context.Context, n mflow.NodeMemory) error

UpdateNodeMemory updates an existing Memory node.

type NodeReader 

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

func NewNodeReader 

func NewNodeReader(db *sql.DB) *NodeReader

func NewNodeReaderFromQueries 

func NewNodeReaderFromQueries(queries *gen.Queries) *NodeReader

func (*NodeReader) GetNode 

func (r *NodeReader) GetNode(ctx context.Context, id idwrap.IDWrap) (*mflow.Node, error)

func (*NodeReader) GetNodesByFlowID 

func (r *NodeReader) GetNodesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.Node, error)

type NodeReaders 

type NodeReaders struct {
	JS      *NodeJsReader
	If      *NodeIfReader
	For     *NodeForReader
	ForEach *NodeForEachReader
	AI      *NodeAIReader
}

NodeReaders bundles all node implementation readers for convenient access. Use this when you need to read multiple node types (e.g., in import/export, flow execution, or tests).

func NewNodeReaders 

func NewNodeReaders(q *gen.Queries) NodeReaders

NewNodeReaders creates all node readers from a queries instance.

type NodeRequestReader 

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

func NewNodeRequestReader 

func NewNodeRequestReader(db *sql.DB) *NodeRequestReader

func NewNodeRequestReaderFromQueries 

func NewNodeRequestReaderFromQueries(queries *gen.Queries) *NodeRequestReader

func (*NodeRequestReader) GetNodeRequest 

func (r *NodeRequestReader) GetNodeRequest(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeRequest, error)

type NodeRequestService 

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

func NewNodeRequestService 

func NewNodeRequestService(queries *gen.Queries) NodeRequestService

func NewNodeRequestServiceTX 

func NewNodeRequestServiceTX(ctx context.Context, tx *sql.Tx) (*NodeRequestService, error)

func (NodeRequestService) CreateNodeRequest 

func (nrs NodeRequestService) CreateNodeRequest(ctx context.Context, nr mflow.NodeRequest) error

func (NodeRequestService) CreateNodeRequestBulk 

func (nrs NodeRequestService) CreateNodeRequestBulk(ctx context.Context, nodes []mflow.NodeRequest) error

func (NodeRequestService) DeleteNodeRequest 

func (nrs NodeRequestService) DeleteNodeRequest(ctx context.Context, id idwrap.IDWrap) error

func (NodeRequestService) GetNodeRequest 

func (nrs NodeRequestService) GetNodeRequest(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeRequest, error)

func (NodeRequestService) Reader 

func (s NodeRequestService) Reader() *NodeRequestReader

func (NodeRequestService) TX 

func (nrs NodeRequestService) TX(tx *sql.Tx) NodeRequestService

func (NodeRequestService) UpdateNodeRequest 

func (nrs NodeRequestService) UpdateNodeRequest(ctx context.Context, nr mflow.NodeRequest) error

type NodeRequestWriter 

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

func NewNodeRequestWriter 

func NewNodeRequestWriter(tx gen.DBTX) *NodeRequestWriter

func NewNodeRequestWriterFromQueries 

func NewNodeRequestWriterFromQueries(queries *gen.Queries) *NodeRequestWriter

func (*NodeRequestWriter) CreateNodeRequest 

func (w *NodeRequestWriter) CreateNodeRequest(ctx context.Context, nr mflow.NodeRequest) error

func (*NodeRequestWriter) CreateNodeRequestBulk 

func (w *NodeRequestWriter) CreateNodeRequestBulk(ctx context.Context, nodes []mflow.NodeRequest) error

func (*NodeRequestWriter) DeleteNodeRequest 

func (w *NodeRequestWriter) DeleteNodeRequest(ctx context.Context, id idwrap.IDWrap) error

func (*NodeRequestWriter) UpdateNodeRequest 

func (w *NodeRequestWriter) UpdateNodeRequest(ctx context.Context, nr mflow.NodeRequest) error

type NodeRunSubFlowReader 

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

func NewNodeRunSubFlowReader 

func NewNodeRunSubFlowReader(db *sql.DB) *NodeRunSubFlowReader

func NewNodeRunSubFlowReaderFromQueries 

func NewNodeRunSubFlowReaderFromQueries(queries *gen.Queries) *NodeRunSubFlowReader

func (*NodeRunSubFlowReader) GetNodeRunSubFlow 

func (r *NodeRunSubFlowReader) GetNodeRunSubFlow(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeRunSubFlow, error)

type NodeRunSubFlowService 

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

func NewNodeRunSubFlowService 

func NewNodeRunSubFlowService(queries *gen.Queries) NodeRunSubFlowService

func (NodeRunSubFlowService) CreateNodeRunSubFlow 

func (s NodeRunSubFlowService) CreateNodeRunSubFlow(ctx context.Context, m mflow.NodeRunSubFlow) error

func (NodeRunSubFlowService) DeleteNodeRunSubFlow 

func (s NodeRunSubFlowService) DeleteNodeRunSubFlow(ctx context.Context, id idwrap.IDWrap) error

func (NodeRunSubFlowService) GetNodeRunSubFlow 

func (s NodeRunSubFlowService) GetNodeRunSubFlow(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeRunSubFlow, error)

func (NodeRunSubFlowService) Reader 

func (s NodeRunSubFlowService) Reader() *NodeRunSubFlowReader

func (NodeRunSubFlowService) TX 

func (s NodeRunSubFlowService) TX(tx *sql.Tx) NodeRunSubFlowService

func (NodeRunSubFlowService) UpdateNodeRunSubFlow 

func (s NodeRunSubFlowService) UpdateNodeRunSubFlow(ctx context.Context, m mflow.NodeRunSubFlow) error

type NodeRunSubFlowWriter 

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

func NewNodeRunSubFlowWriter 

func NewNodeRunSubFlowWriter(tx gen.DBTX) *NodeRunSubFlowWriter

func NewNodeRunSubFlowWriterFromQueries 

func NewNodeRunSubFlowWriterFromQueries(queries *gen.Queries) *NodeRunSubFlowWriter

func (*NodeRunSubFlowWriter) CreateNodeRunSubFlow 

func (w *NodeRunSubFlowWriter) CreateNodeRunSubFlow(ctx context.Context, m mflow.NodeRunSubFlow) error

func (*NodeRunSubFlowWriter) DeleteNodeRunSubFlow 

func (w *NodeRunSubFlowWriter) DeleteNodeRunSubFlow(ctx context.Context, id idwrap.IDWrap) error

func (*NodeRunSubFlowWriter) UpdateNodeRunSubFlow 

func (w *NodeRunSubFlowWriter) UpdateNodeRunSubFlow(ctx context.Context, m mflow.NodeRunSubFlow) error

type NodeService 

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

func NewNodeService 

func NewNodeService(queries *gen.Queries) NodeService

func NewNodeServiceTX 

func NewNodeServiceTX(ctx context.Context, tx *sql.Tx) (*NodeService, error)

func (NodeService) CreateNode 

func (ns NodeService) CreateNode(ctx context.Context, n mflow.Node) error

func (NodeService) CreateNodeBulk 

func (ns NodeService) CreateNodeBulk(ctx context.Context, nodes []mflow.Node) error

func (NodeService) CreateNodeWithState 

func (ns NodeService) CreateNodeWithState(ctx context.Context, n mflow.Node) error

CreateNodeWithState creates a node with a specific state value. Used for version flow snapshots where the execution state should be preserved.

func (NodeService) DeleteNode 

func (ns NodeService) DeleteNode(ctx context.Context, id idwrap.IDWrap) error

func (NodeService) GetNode 

func (ns NodeService) GetNode(ctx context.Context, id idwrap.IDWrap) (*mflow.Node, error)

func (NodeService) GetNodesByFlowID 

func (ns NodeService) GetNodesByFlowID(ctx context.Context, flowID idwrap.IDWrap) ([]mflow.Node, error)

func (NodeService) Reader 

func (s NodeService) Reader() *NodeReader

func (NodeService) TX 

func (s NodeService) TX(tx *sql.Tx) NodeService

func (NodeService) UpdateNode 

func (ns NodeService) UpdateNode(ctx context.Context, n mflow.Node) error

func (NodeService) UpdateNodeState 

func (ns NodeService) UpdateNodeState(ctx context.Context, id idwrap.IDWrap, state mflow.NodeState) error

type NodeSubFlowReturnReader 

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

func NewNodeSubFlowReturnReader 

func NewNodeSubFlowReturnReader(db *sql.DB) *NodeSubFlowReturnReader

func NewNodeSubFlowReturnReaderFromQueries 

func NewNodeSubFlowReturnReaderFromQueries(queries *gen.Queries) *NodeSubFlowReturnReader

func (*NodeSubFlowReturnReader) GetNodeSubFlowReturn 

func (r *NodeSubFlowReturnReader) GetNodeSubFlowReturn(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeSubFlowReturn, error)

type NodeSubFlowReturnService 

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

func NewNodeSubFlowReturnService 

func NewNodeSubFlowReturnService(queries *gen.Queries) NodeSubFlowReturnService

func (NodeSubFlowReturnService) CreateNodeSubFlowReturn 

func (s NodeSubFlowReturnService) CreateNodeSubFlowReturn(ctx context.Context, m mflow.NodeSubFlowReturn) error

func (NodeSubFlowReturnService) DeleteNodeSubFlowReturn 

func (s NodeSubFlowReturnService) DeleteNodeSubFlowReturn(ctx context.Context, id idwrap.IDWrap) error

func (NodeSubFlowReturnService) GetNodeSubFlowReturn 

func (s NodeSubFlowReturnService) GetNodeSubFlowReturn(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeSubFlowReturn, error)

func (NodeSubFlowReturnService) Reader 

func (s NodeSubFlowReturnService) Reader() *NodeSubFlowReturnReader

func (NodeSubFlowReturnService) TX 

func (s NodeSubFlowReturnService) TX(tx *sql.Tx) NodeSubFlowReturnService

func (NodeSubFlowReturnService) UpdateNodeSubFlowReturn 

func (s NodeSubFlowReturnService) UpdateNodeSubFlowReturn(ctx context.Context, m mflow.NodeSubFlowReturn) error

type NodeSubFlowReturnWriter 

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

func NewNodeSubFlowReturnWriter 

func NewNodeSubFlowReturnWriter(tx gen.DBTX) *NodeSubFlowReturnWriter

func NewNodeSubFlowReturnWriterFromQueries 

func NewNodeSubFlowReturnWriterFromQueries(queries *gen.Queries) *NodeSubFlowReturnWriter

func (*NodeSubFlowReturnWriter) CreateNodeSubFlowReturn 

func (w *NodeSubFlowReturnWriter) CreateNodeSubFlowReturn(ctx context.Context, m mflow.NodeSubFlowReturn) error

func (*NodeSubFlowReturnWriter) DeleteNodeSubFlowReturn 

func (w *NodeSubFlowReturnWriter) DeleteNodeSubFlowReturn(ctx context.Context, id idwrap.IDWrap) error

func (*NodeSubFlowReturnWriter) UpdateNodeSubFlowReturn 

func (w *NodeSubFlowReturnWriter) UpdateNodeSubFlowReturn(ctx context.Context, m mflow.NodeSubFlowReturn) error

type NodeSubFlowTriggerReader 

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

func NewNodeSubFlowTriggerReader 

func NewNodeSubFlowTriggerReader(db *sql.DB) *NodeSubFlowTriggerReader

func NewNodeSubFlowTriggerReaderFromQueries 

func NewNodeSubFlowTriggerReaderFromQueries(queries *gen.Queries) *NodeSubFlowTriggerReader

func (*NodeSubFlowTriggerReader) GetNodeSubFlowTrigger 

func (r *NodeSubFlowTriggerReader) GetNodeSubFlowTrigger(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeSubFlowTrigger, error)

type NodeSubFlowTriggerService 

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

func NewNodeSubFlowTriggerService 

func NewNodeSubFlowTriggerService(queries *gen.Queries) NodeSubFlowTriggerService

func (NodeSubFlowTriggerService) CreateNodeSubFlowTrigger 

func (s NodeSubFlowTriggerService) CreateNodeSubFlowTrigger(ctx context.Context, m mflow.NodeSubFlowTrigger) error

func (NodeSubFlowTriggerService) DeleteNodeSubFlowTrigger 

func (s NodeSubFlowTriggerService) DeleteNodeSubFlowTrigger(ctx context.Context, id idwrap.IDWrap) error

func (NodeSubFlowTriggerService) GetNodeSubFlowTrigger 

func (s NodeSubFlowTriggerService) GetNodeSubFlowTrigger(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeSubFlowTrigger, error)

func (NodeSubFlowTriggerService) Reader 

func (s NodeSubFlowTriggerService) Reader() *NodeSubFlowTriggerReader

func (NodeSubFlowTriggerService) TX 

func (s NodeSubFlowTriggerService) TX(tx *sql.Tx) NodeSubFlowTriggerService

func (NodeSubFlowTriggerService) UpdateNodeSubFlowTrigger 

func (s NodeSubFlowTriggerService) UpdateNodeSubFlowTrigger(ctx context.Context, m mflow.NodeSubFlowTrigger) error

type NodeSubFlowTriggerWriter 

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

func NewNodeSubFlowTriggerWriter 

func NewNodeSubFlowTriggerWriter(tx gen.DBTX) *NodeSubFlowTriggerWriter

func NewNodeSubFlowTriggerWriterFromQueries 

func NewNodeSubFlowTriggerWriterFromQueries(queries *gen.Queries) *NodeSubFlowTriggerWriter

func (*NodeSubFlowTriggerWriter) CreateNodeSubFlowTrigger 

func (w *NodeSubFlowTriggerWriter) CreateNodeSubFlowTrigger(ctx context.Context, m mflow.NodeSubFlowTrigger) error

func (*NodeSubFlowTriggerWriter) DeleteNodeSubFlowTrigger 

func (w *NodeSubFlowTriggerWriter) DeleteNodeSubFlowTrigger(ctx context.Context, id idwrap.IDWrap) error

func (*NodeSubFlowTriggerWriter) UpdateNodeSubFlowTrigger 

func (w *NodeSubFlowTriggerWriter) UpdateNodeSubFlowTrigger(ctx context.Context, m mflow.NodeSubFlowTrigger) error

type NodeWaitReader 

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

func NewNodeWaitReader 

func NewNodeWaitReader(db *sql.DB) *NodeWaitReader

func NewNodeWaitReaderFromQueries 

func NewNodeWaitReaderFromQueries(queries *gen.Queries) *NodeWaitReader

func (*NodeWaitReader) GetNodeWait 

func (r *NodeWaitReader) GetNodeWait(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWait, error)

type NodeWaitService 

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

func NewNodeWaitService 

func NewNodeWaitService(queries *gen.Queries) NodeWaitService

func (NodeWaitService) CreateNodeWait 

func (s NodeWaitService) CreateNodeWait(ctx context.Context, mn mflow.NodeWait) error

func (NodeWaitService) DeleteNodeWait 

func (s NodeWaitService) DeleteNodeWait(ctx context.Context, id idwrap.IDWrap) error

func (NodeWaitService) GetNodeWait 

func (s NodeWaitService) GetNodeWait(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWait, error)

func (NodeWaitService) Reader 

func (s NodeWaitService) Reader() *NodeWaitReader

func (NodeWaitService) TX 

func (s NodeWaitService) TX(tx *sql.Tx) NodeWaitService

func (NodeWaitService) UpdateNodeWait 

func (s NodeWaitService) UpdateNodeWait(ctx context.Context, mn mflow.NodeWait) error

type NodeWaitWriter 

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

func NewNodeWaitWriter 

func NewNodeWaitWriter(tx gen.DBTX) *NodeWaitWriter

func NewNodeWaitWriterFromQueries 

func NewNodeWaitWriterFromQueries(queries *gen.Queries) *NodeWaitWriter

func (*NodeWaitWriter) CreateNodeWait 

func (w *NodeWaitWriter) CreateNodeWait(ctx context.Context, mn mflow.NodeWait) error

func (*NodeWaitWriter) DeleteNodeWait 

func (w *NodeWaitWriter) DeleteNodeWait(ctx context.Context, id idwrap.IDWrap) error

func (*NodeWaitWriter) UpdateNodeWait 

func (w *NodeWaitWriter) UpdateNodeWait(ctx context.Context, mn mflow.NodeWait) error

type NodeWriter 

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

func NewNodeWriter 

func NewNodeWriter(tx gen.DBTX) *NodeWriter

func NewNodeWriterFromQueries 

func NewNodeWriterFromQueries(queries *gen.Queries) *NodeWriter

func (*NodeWriter) CreateNode 

func (w *NodeWriter) CreateNode(ctx context.Context, n mflow.Node) error

func (*NodeWriter) CreateNodeBulk 

func (w *NodeWriter) CreateNodeBulk(ctx context.Context, nodes []mflow.Node) error

func (*NodeWriter) CreateNodeWithState 

func (w *NodeWriter) CreateNodeWithState(ctx context.Context, n mflow.Node) error

CreateNodeWithState creates a node with a specific state value. Used for version flow snapshots where the execution state should be preserved.

func (*NodeWriter) DeleteNode 

func (w *NodeWriter) DeleteNode(ctx context.Context, id idwrap.IDWrap) error

func (*NodeWriter) UpdateNode 

func (w *NodeWriter) UpdateNode(ctx context.Context, n mflow.Node) error

func (*NodeWriter) UpdateNodeState 

func (w *NodeWriter) UpdateNodeState(ctx context.Context, id idwrap.IDWrap, state mflow.NodeState) error

type NodeWsConnectionReader 

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

func NewNodeWsConnectionReaderFromQueries 

func NewNodeWsConnectionReaderFromQueries(queries *gen.Queries) *NodeWsConnectionReader

func (*NodeWsConnectionReader) GetNodeWsConnection 

func (r *NodeWsConnectionReader) GetNodeWsConnection(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWsConnection, error)

type NodeWsConnectionService 

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

func NewNodeWsConnectionService 

func NewNodeWsConnectionService(queries *gen.Queries) NodeWsConnectionService

func (NodeWsConnectionService) CreateNodeWsConnection 

func (s NodeWsConnectionService) CreateNodeWsConnection(ctx context.Context, n mflow.NodeWsConnection) error

func (NodeWsConnectionService) DeleteNodeWsConnection 

func (s NodeWsConnectionService) DeleteNodeWsConnection(ctx context.Context, id idwrap.IDWrap) error

func (NodeWsConnectionService) GetNodeWsConnection 

func (s NodeWsConnectionService) GetNodeWsConnection(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWsConnection, error)

func (NodeWsConnectionService) Reader 

func (s NodeWsConnectionService) Reader() *NodeWsConnectionReader

func (NodeWsConnectionService) TX 

func (s NodeWsConnectionService) TX(tx *sql.Tx) NodeWsConnectionService

func (NodeWsConnectionService) UpdateNodeWsConnection 

func (s NodeWsConnectionService) UpdateNodeWsConnection(ctx context.Context, n mflow.NodeWsConnection) error

type NodeWsConnectionWriter 

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

func NewNodeWsConnectionWriter 

func NewNodeWsConnectionWriter(tx gen.DBTX) *NodeWsConnectionWriter

func NewNodeWsConnectionWriterFromQueries 

func NewNodeWsConnectionWriterFromQueries(queries *gen.Queries) *NodeWsConnectionWriter

func (*NodeWsConnectionWriter) CreateNodeWsConnection 

func (w *NodeWsConnectionWriter) CreateNodeWsConnection(ctx context.Context, n mflow.NodeWsConnection) error

func (*NodeWsConnectionWriter) DeleteNodeWsConnection 

func (w *NodeWsConnectionWriter) DeleteNodeWsConnection(ctx context.Context, id idwrap.IDWrap) error

func (*NodeWsConnectionWriter) UpdateNodeWsConnection 

func (w *NodeWsConnectionWriter) UpdateNodeWsConnection(ctx context.Context, n mflow.NodeWsConnection) error

type NodeWsSendReader 

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

func NewNodeWsSendReaderFromQueries 

func NewNodeWsSendReaderFromQueries(queries *gen.Queries) *NodeWsSendReader

func (*NodeWsSendReader) GetNodeWsSend 

func (r *NodeWsSendReader) GetNodeWsSend(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWsSend, error)

type NodeWsSendService 

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

func NewNodeWsSendService 

func NewNodeWsSendService(queries *gen.Queries) NodeWsSendService

func (NodeWsSendService) CreateNodeWsSend 

func (s NodeWsSendService) CreateNodeWsSend(ctx context.Context, n mflow.NodeWsSend) error

func (NodeWsSendService) DeleteNodeWsSend 

func (s NodeWsSendService) DeleteNodeWsSend(ctx context.Context, id idwrap.IDWrap) error

func (NodeWsSendService) GetNodeWsSend 

func (s NodeWsSendService) GetNodeWsSend(ctx context.Context, id idwrap.IDWrap) (*mflow.NodeWsSend, error)

func (NodeWsSendService) Reader 

func (s NodeWsSendService) Reader() *NodeWsSendReader

func (NodeWsSendService) TX 

func (s NodeWsSendService) TX(tx *sql.Tx) NodeWsSendService

func (NodeWsSendService) UpdateNodeWsSend 

func (s NodeWsSendService) UpdateNodeWsSend(ctx context.Context, n mflow.NodeWsSend) error

type NodeWsSendWriter 

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

func NewNodeWsSendWriter 

func NewNodeWsSendWriter(tx gen.DBTX) *NodeWsSendWriter

func NewNodeWsSendWriterFromQueries 

func NewNodeWsSendWriterFromQueries(queries *gen.Queries) *NodeWsSendWriter

func (*NodeWsSendWriter) CreateNodeWsSend 

func (w *NodeWsSendWriter) CreateNodeWsSend(ctx context.Context, n mflow.NodeWsSend) error

func (*NodeWsSendWriter) DeleteNodeWsSend 

func (w *NodeWsSendWriter) DeleteNodeWsSend(ctx context.Context, id idwrap.IDWrap) error

func (*NodeWsSendWriter) UpdateNodeWsSend 

func (w *NodeWsSendWriter) UpdateNodeWsSend(ctx context.Context, n mflow.NodeWsSend) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.