rflowv2

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: 61 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateService 

func CreateService(srv *FlowServiceV2RPC, options []connect.HandlerOption) (*api.Service, error)

Types

type AiEvent 

type AiEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeAi
}

AiEvent describes an AI node change for sync streaming.

type AiProviderEvent 

type AiProviderEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeAiProvider
}

AiProviderEvent describes an AI Provider node change for sync streaming.

type AiProviderTopic 

type AiProviderTopic struct {
	FlowID idwrap.IDWrap
}

AiProviderTopic identifies the flow whose AI Provider nodes are being published.

type AiTopic 

type AiTopic struct {
	FlowID idwrap.IDWrap
}

AiTopic identifies the flow whose AI nodes are being published.

type ConditionEvent 

type ConditionEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeCondition
}

ConditionEvent describes a Condition node change for sync streaming.

type ConditionTopic 

type ConditionTopic struct {
	FlowID idwrap.IDWrap
}

ConditionTopic identifies the flow whose condition nodes are being published.

type EdgeEvent 

type EdgeEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Edge   *flowv1.Edge
}

EdgeEvent describes an edge change for sync streaming.

type EdgeTopic 

type EdgeTopic struct {
	FlowID idwrap.IDWrap
}

EdgeTopic identifies the flow whose edges are being published.

type ExecutionEvent 

type ExecutionEvent struct {
	Type      string
	FlowID    idwrap.IDWrap
	Execution *flowv1.NodeExecution
}

ExecutionEvent describes a node execution change for sync streaming.

type ExecutionTopic 

type ExecutionTopic struct {
	FlowID idwrap.IDWrap
}

ExecutionTopic identifies the flow whose node executions are being published.

type FlowEvent 

type FlowEvent struct {
	Type string
	Flow *flowv1.Flow
}

FlowEvent describes a flow change for sync streaming.

type FlowServiceV2Deps 

type FlowServiceV2Deps struct {
	DB              *sql.DB
	Readers         FlowServiceV2Readers
	Services        FlowServiceV2Services
	Streamers       FlowServiceV2Streamers
	Resolver        resolver.RequestResolver
	GraphQLResolver gqlresolver.GraphQLResolver
	Logger          *slog.Logger
	JsClient        node_js_executorv1connect.NodeJsExecutorServiceClient
}

func (*FlowServiceV2Deps) Validate 

func (d *FlowServiceV2Deps) Validate() error

type FlowServiceV2RPC 

type FlowServiceV2RPC struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

func New 

func New(deps FlowServiceV2Deps) *FlowServiceV2RPC

func (*FlowServiceV2RPC) DetectFlowFormat 

func (s *FlowServiceV2RPC) DetectFlowFormat(ctx context.Context, data []byte) (string, error)

DetectFlowFormat detects the format of flow data (YAML, JSON, curl, etc.)

func (*FlowServiceV2RPC) EdgeCollection 

func (s *FlowServiceV2RPC) EdgeCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.EdgeCollectionResponse], error)

func (*FlowServiceV2RPC) EdgeDelete 

func (s *FlowServiceV2RPC) EdgeDelete(ctx context.Context, req *connect.Request[flowv1.EdgeDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) EdgeInsert 

func (s *FlowServiceV2RPC) EdgeInsert(ctx context.Context, req *connect.Request[flowv1.EdgeInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) EdgeSync 

func (s *FlowServiceV2RPC) EdgeSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.EdgeSyncResponse],
) error

func (*FlowServiceV2RPC) EdgeUpdate 

func (s *FlowServiceV2RPC) EdgeUpdate(ctx context.Context, req *connect.Request[flowv1.EdgeUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowCollection 

func (s *FlowServiceV2RPC) FlowCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.FlowCollectionResponse], error)

func (*FlowServiceV2RPC) FlowDelete 

func (s *FlowServiceV2RPC) FlowDelete(ctx context.Context, req *connect.Request[flowv1.FlowDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowDuplicate 

func (s *FlowServiceV2RPC) FlowDuplicate(ctx context.Context, req *connect.Request[flowv1.FlowDuplicateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowInsert 

func (s *FlowServiceV2RPC) FlowInsert(ctx context.Context, req *connect.Request[flowv1.FlowInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowNodesCopy 

func (s *FlowServiceV2RPC) FlowNodesCopy(
	ctx context.Context,
	req *connect.Request[flowv1.FlowNodesCopyRequest],
) (*connect.Response[flowv1.FlowNodesCopyResponse], error)

FlowNodesCopy serializes selected nodes to YAML for clipboard copy.

func (*FlowServiceV2RPC) FlowNodesPaste 

func (s *FlowServiceV2RPC) FlowNodesPaste(
	ctx context.Context,
	req *connect.Request[flowv1.FlowNodesPasteRequest],
) (*connect.Response[flowv1.FlowNodesPasteResponse], error)

FlowNodesPaste parses YAML from clipboard and creates nodes in the target flow.

func (*FlowServiceV2RPC) FlowNodesPastePreview 

func (s *FlowServiceV2RPC) FlowNodesPastePreview(
	ctx context.Context,
	req *connect.Request[flowv1.FlowNodesPastePreviewRequest],
) (*connect.Response[flowv1.FlowNodesPastePreviewResponse], error)

FlowNodesPastePreview checks which HTTP requests from clipboard YAML already exist in the target workspace.

func (*FlowServiceV2RPC) FlowRun 

func (s *FlowServiceV2RPC) FlowRun(ctx context.Context, req *connect.Request[flowv1.FlowRunRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowStop 

func (s *FlowServiceV2RPC) FlowStop(ctx context.Context, req *connect.Request[flowv1.FlowStopRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowSync 

func (s *FlowServiceV2RPC) FlowSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.FlowSyncResponse],
) error

func (*FlowServiceV2RPC) FlowUpdate 

func (s *FlowServiceV2RPC) FlowUpdate(ctx context.Context, req *connect.Request[flowv1.FlowUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowVariableCollection 

func (s *FlowServiceV2RPC) FlowVariableCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[flowv1.FlowVariableCollectionResponse], error)

func (*FlowServiceV2RPC) FlowVariableDelete 

func (s *FlowServiceV2RPC) FlowVariableDelete(ctx context.Context, req *connect.Request[flowv1.FlowVariableDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowVariableInsert 

func (s *FlowServiceV2RPC) FlowVariableInsert(ctx context.Context, req *connect.Request[flowv1.FlowVariableInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowVariableSync 

func (s *FlowServiceV2RPC) FlowVariableSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.FlowVariableSyncResponse],
) error

func (*FlowServiceV2RPC) FlowVariableUpdate 

func (s *FlowServiceV2RPC) FlowVariableUpdate(ctx context.Context, req *connect.Request[flowv1.FlowVariableUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) FlowVersionCollection 

func (s *FlowServiceV2RPC) FlowVersionCollection(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[flowv1.FlowVersionCollectionResponse], error)

func (*FlowServiceV2RPC) FlowVersionSync 

func (s *FlowServiceV2RPC) FlowVersionSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.FlowVersionSyncResponse],
) error

func (*FlowServiceV2RPC) ImportCurlCommand 

func (s *FlowServiceV2RPC) ImportCurlCommand(ctx context.Context, curlData []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)

ImportCurlCommand imports a curl command into the workspace

func (*FlowServiceV2RPC) ImportYAMLFlow 

func (s *FlowServiceV2RPC) ImportYAMLFlow(ctx context.Context, data []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)

ImportYAMLFlow imports a YAML flow definition into the workspace

func (*FlowServiceV2RPC) ImportYAMLFlowSimple 

func (s *FlowServiceV2RPC) ImportYAMLFlowSimple(
	ctx context.Context,
	data []byte,
	workspaceID idwrap.IDWrap,
) (*ImportResults, error)

ImportYAMLFlowSimple imports a YAML flow with simple options

func (*FlowServiceV2RPC) MutationPublisher 

func (s *FlowServiceV2RPC) MutationPublisher() mutation.Publisher

MutationPublisher returns a unified publisher for flow-related mutation events. Exported so other services (e.g. the workspace importer) can dispatch flow node/edge sync events through the same machinery.

func (*FlowServiceV2RPC) NodeAiCollection 

func (s *FlowServiceV2RPC) NodeAiCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeAiCollectionResponse], error)

func (*FlowServiceV2RPC) NodeAiDelete 

func (s *FlowServiceV2RPC) NodeAiDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiInsert 

func (s *FlowServiceV2RPC) NodeAiInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiMemoryCollection 

func (s *FlowServiceV2RPC) NodeAiMemoryCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeAiMemoryCollectionResponse], error)

func (*FlowServiceV2RPC) NodeAiMemoryDelete 

func (s *FlowServiceV2RPC) NodeAiMemoryDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiMemoryDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiMemoryInsert 

func (s *FlowServiceV2RPC) NodeAiMemoryInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiMemoryInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiMemorySync 

func (s *FlowServiceV2RPC) NodeAiMemorySync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeAiMemorySyncResponse],
) error

func (*FlowServiceV2RPC) NodeAiMemoryUpdate 

func (s *FlowServiceV2RPC) NodeAiMemoryUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiMemoryUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiProviderCollection 

func (s *FlowServiceV2RPC) NodeAiProviderCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeAiProviderCollectionResponse], error)

func (*FlowServiceV2RPC) NodeAiProviderDelete 

func (s *FlowServiceV2RPC) NodeAiProviderDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiProviderDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiProviderInsert 

func (s *FlowServiceV2RPC) NodeAiProviderInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiProviderInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiProviderSync 

func (s *FlowServiceV2RPC) NodeAiProviderSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeAiProviderSyncResponse],
) error

func (*FlowServiceV2RPC) NodeAiProviderUpdate 

func (s *FlowServiceV2RPC) NodeAiProviderUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiProviderUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeAiSync 

func (s *FlowServiceV2RPC) NodeAiSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeAiSyncResponse],
) error

func (*FlowServiceV2RPC) NodeAiUpdate 

func (s *FlowServiceV2RPC) NodeAiUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeAiUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeCollection 

func (s *FlowServiceV2RPC) NodeCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeCollectionResponse], error)

func (*FlowServiceV2RPC) NodeConditionCollection 

func (s *FlowServiceV2RPC) NodeConditionCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeConditionCollectionResponse], error)

func (*FlowServiceV2RPC) NodeConditionDelete 

func (s *FlowServiceV2RPC) NodeConditionDelete(ctx context.Context, req *connect.Request[flowv1.NodeConditionDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeConditionInsert 

func (s *FlowServiceV2RPC) NodeConditionInsert(ctx context.Context, req *connect.Request[flowv1.NodeConditionInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeConditionSync 

func (s *FlowServiceV2RPC) NodeConditionSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeConditionSyncResponse],
) error

func (*FlowServiceV2RPC) NodeConditionUpdate 

func (s *FlowServiceV2RPC) NodeConditionUpdate(ctx context.Context, req *connect.Request[flowv1.NodeConditionUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeDelete 

func (s *FlowServiceV2RPC) NodeDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeExecutionCollection 

func (s *FlowServiceV2RPC) NodeExecutionCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeExecutionCollectionResponse], error)

func (*FlowServiceV2RPC) NodeExecutionSync 

func (s *FlowServiceV2RPC) NodeExecutionSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeExecutionSyncResponse],
) error

func (*FlowServiceV2RPC) NodeForCollection 

func (s *FlowServiceV2RPC) NodeForCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeForCollectionResponse], error)

func (*FlowServiceV2RPC) NodeForDelete 

func (s *FlowServiceV2RPC) NodeForDelete(ctx context.Context, req *connect.Request[flowv1.NodeForDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeForEachCollection 

func (s *FlowServiceV2RPC) NodeForEachCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeForEachCollectionResponse], error)

func (*FlowServiceV2RPC) NodeForEachDelete 

func (s *FlowServiceV2RPC) NodeForEachDelete(ctx context.Context, req *connect.Request[flowv1.NodeForEachDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeForEachInsert 

func (s *FlowServiceV2RPC) NodeForEachInsert(ctx context.Context, req *connect.Request[flowv1.NodeForEachInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeForEachSync 

func (s *FlowServiceV2RPC) NodeForEachSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeForEachSyncResponse],
) error

func (*FlowServiceV2RPC) NodeForEachUpdate 

func (s *FlowServiceV2RPC) NodeForEachUpdate(ctx context.Context, req *connect.Request[flowv1.NodeForEachUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeForInsert 

func (s *FlowServiceV2RPC) NodeForInsert(ctx context.Context, req *connect.Request[flowv1.NodeForInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeForSync 

func (s *FlowServiceV2RPC) NodeForSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeForSyncResponse],
) error

func (*FlowServiceV2RPC) NodeForUpdate 

func (s *FlowServiceV2RPC) NodeForUpdate(ctx context.Context, req *connect.Request[flowv1.NodeForUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeGraphQLCollection 

func (s *FlowServiceV2RPC) NodeGraphQLCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeGraphQLCollectionResponse], error)

func (*FlowServiceV2RPC) NodeGraphQLDelete 

func (s *FlowServiceV2RPC) NodeGraphQLDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeGraphQLDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeGraphQLInsert 

func (s *FlowServiceV2RPC) NodeGraphQLInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeGraphQLInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeGraphQLSync 

func (s *FlowServiceV2RPC) NodeGraphQLSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeGraphQLSyncResponse],
) error

func (*FlowServiceV2RPC) NodeGraphQLUpdate 

func (s *FlowServiceV2RPC) NodeGraphQLUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeGraphQLUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeHttpCollection 

func (s *FlowServiceV2RPC) NodeHttpCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeHttpCollectionResponse], error)

func (*FlowServiceV2RPC) NodeHttpDelete 

func (s *FlowServiceV2RPC) NodeHttpDelete(ctx context.Context, req *connect.Request[flowv1.NodeHttpDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeHttpInsert 

func (s *FlowServiceV2RPC) NodeHttpInsert(ctx context.Context, req *connect.Request[flowv1.NodeHttpInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeHttpSync 

func (s *FlowServiceV2RPC) NodeHttpSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeHttpSyncResponse],
) error

func (*FlowServiceV2RPC) NodeHttpUpdate 

func (s *FlowServiceV2RPC) NodeHttpUpdate(ctx context.Context, req *connect.Request[flowv1.NodeHttpUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeInsert 

func (s *FlowServiceV2RPC) NodeInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeJsCollection 

func (s *FlowServiceV2RPC) NodeJsCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeJsCollectionResponse], error)

func (*FlowServiceV2RPC) NodeJsDelete 

func (s *FlowServiceV2RPC) NodeJsDelete(ctx context.Context, req *connect.Request[flowv1.NodeJsDeleteRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeJsInsert 

func (s *FlowServiceV2RPC) NodeJsInsert(ctx context.Context, req *connect.Request[flowv1.NodeJsInsertRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeJsSync 

func (s *FlowServiceV2RPC) NodeJsSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeJsSyncResponse],
) error

func (*FlowServiceV2RPC) NodeJsUpdate 

func (s *FlowServiceV2RPC) NodeJsUpdate(ctx context.Context, req *connect.Request[flowv1.NodeJsUpdateRequest]) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeRunSubFlowCollection 

func (s *FlowServiceV2RPC) NodeRunSubFlowCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeRunSubFlowCollectionResponse], error)

func (*FlowServiceV2RPC) NodeRunSubFlowDelete 

func (s *FlowServiceV2RPC) NodeRunSubFlowDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeRunSubFlowDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeRunSubFlowInsert 

func (s *FlowServiceV2RPC) NodeRunSubFlowInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeRunSubFlowInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeRunSubFlowSync 

func (s *FlowServiceV2RPC) NodeRunSubFlowSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeRunSubFlowSyncResponse],
) error

func (*FlowServiceV2RPC) NodeRunSubFlowUpdate 

func (s *FlowServiceV2RPC) NodeRunSubFlowUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeRunSubFlowUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowReturnCollection 

func (s *FlowServiceV2RPC) NodeSubFlowReturnCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeSubFlowReturnCollectionResponse], error)

func (*FlowServiceV2RPC) NodeSubFlowReturnDelete 

func (s *FlowServiceV2RPC) NodeSubFlowReturnDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowReturnDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowReturnInsert 

func (s *FlowServiceV2RPC) NodeSubFlowReturnInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowReturnInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowReturnSync 

func (s *FlowServiceV2RPC) NodeSubFlowReturnSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeSubFlowReturnSyncResponse],
) error

func (*FlowServiceV2RPC) NodeSubFlowReturnUpdate 

func (s *FlowServiceV2RPC) NodeSubFlowReturnUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowReturnUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowTriggerCollection 

func (s *FlowServiceV2RPC) NodeSubFlowTriggerCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeSubFlowTriggerCollectionResponse], error)

func (*FlowServiceV2RPC) NodeSubFlowTriggerDelete 

func (s *FlowServiceV2RPC) NodeSubFlowTriggerDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowTriggerDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowTriggerInsert 

func (s *FlowServiceV2RPC) NodeSubFlowTriggerInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowTriggerInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSubFlowTriggerSync 

func (s *FlowServiceV2RPC) NodeSubFlowTriggerSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeSubFlowTriggerSyncResponse],
) error

func (*FlowServiceV2RPC) NodeSubFlowTriggerUpdate 

func (s *FlowServiceV2RPC) NodeSubFlowTriggerUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeSubFlowTriggerUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeSync 

func (s *FlowServiceV2RPC) NodeSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeSyncResponse],
) error

func (*FlowServiceV2RPC) NodeUpdate 

func (s *FlowServiceV2RPC) NodeUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWaitCollection 

func (s *FlowServiceV2RPC) NodeWaitCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeWaitCollectionResponse], error)

func (*FlowServiceV2RPC) NodeWaitDelete 

func (s *FlowServiceV2RPC) NodeWaitDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWaitDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWaitInsert 

func (s *FlowServiceV2RPC) NodeWaitInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWaitInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWaitSync 

func (s *FlowServiceV2RPC) NodeWaitSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeWaitSyncResponse],
) error

func (*FlowServiceV2RPC) NodeWaitUpdate 

func (s *FlowServiceV2RPC) NodeWaitUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWaitUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsConnectionCollection 

func (s *FlowServiceV2RPC) NodeWsConnectionCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeWsConnectionCollectionResponse], error)

func (*FlowServiceV2RPC) NodeWsConnectionDelete 

func (s *FlowServiceV2RPC) NodeWsConnectionDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsConnectionDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsConnectionInsert 

func (s *FlowServiceV2RPC) NodeWsConnectionInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsConnectionInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsConnectionSync 

func (s *FlowServiceV2RPC) NodeWsConnectionSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeWsConnectionSyncResponse],
) error

func (*FlowServiceV2RPC) NodeWsConnectionUpdate 

func (s *FlowServiceV2RPC) NodeWsConnectionUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsConnectionUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsSendCollection 

func (s *FlowServiceV2RPC) NodeWsSendCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[flowv1.NodeWsSendCollectionResponse], error)

func (*FlowServiceV2RPC) NodeWsSendDelete 

func (s *FlowServiceV2RPC) NodeWsSendDelete(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsSendDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsSendInsert 

func (s *FlowServiceV2RPC) NodeWsSendInsert(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsSendInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) NodeWsSendSync 

func (s *FlowServiceV2RPC) NodeWsSendSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[flowv1.NodeWsSendSyncResponse],
) error

func (*FlowServiceV2RPC) NodeWsSendUpdate 

func (s *FlowServiceV2RPC) NodeWsSendUpdate(
	ctx context.Context,
	req *connect.Request[flowv1.NodeWsSendUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*FlowServiceV2RPC) ParseCurlCommand 

func (s *FlowServiceV2RPC) ParseCurlCommand(ctx context.Context, curlData []byte, workspaceID idwrap.IDWrap) (*tcurlv2.CurlResolvedV2, error)

ParseCurlCommand parses a curl command without importing it

func (*FlowServiceV2RPC) ParseFlowData 

func (s *FlowServiceV2RPC) ParseFlowData(ctx context.Context, data []byte, workspaceID idwrap.IDWrap) (interface{}, error)

ParseFlowData parses flow data without importing it (supports YAML, JSON, curl)

func (*FlowServiceV2RPC) ParseYAMLFlow 

func (s *FlowServiceV2RPC) ParseYAMLFlow(ctx context.Context, data []byte, workspaceID idwrap.IDWrap) (*ioworkspace.WorkspaceBundle, error)

ParseYAMLFlow parses YAML flow data without importing it

func (*FlowServiceV2RPC) ValidateYAMLFlow 

func (s *FlowServiceV2RPC) ValidateYAMLFlow(ctx context.Context, data []byte) error

ValidateYAMLFlow validates YAML flow data without importing

type FlowServiceV2Readers 

type FlowServiceV2Readers struct {
	Workspace     *sworkspace.WorkspaceReader
	Flow          *sflow.FlowReader
	Node          *sflow.NodeReader
	Env           *senv.EnvReader
	Http          *shttp.Reader
	Edge          *sflow.EdgeReader
	NodeRequest   *sflow.NodeRequestReader
	FlowVariable  *sflow.FlowVariableReader
	NodeExecution *sflow.NodeExecutionReader
	HttpResponse  *shttp.HttpResponseReader
}

func (*FlowServiceV2Readers) Validate 

func (r *FlowServiceV2Readers) Validate() error

type FlowServiceV2Services 

type FlowServiceV2Services struct {
	Workspace          *sworkspace.WorkspaceService
	Flow               *sflow.FlowService
	Edge               *sflow.EdgeService
	Node               *sflow.NodeService
	NodeRequest        *sflow.NodeRequestService
	NodeFor            *sflow.NodeForService
	NodeForEach        *sflow.NodeForEachService
	NodeIf             *sflow.NodeIfService
	NodeJs             *sflow.NodeJsService
	NodeAI             *sflow.NodeAIService
	NodeAiProvider     *sflow.NodeAiProviderService
	NodeMemory         *sflow.NodeMemoryService
	NodeGraphQL        *sflow.NodeGraphQLService
	NodeWsConnection   *sflow.NodeWsConnectionService
	NodeWsSend         *sflow.NodeWsSendService
	NodeWait           *sflow.NodeWaitService
	NodeSubFlowTrigger *sflow.NodeSubFlowTriggerService
	NodeSubFlowReturn  *sflow.NodeSubFlowReturnService
	NodeRunSubFlow     *sflow.NodeRunSubFlowService
	WebSocket          *swebsocket.WebSocketService
	WebSocketHeader    *swebsocket.WebSocketHeaderService
	NodeExecution      *sflow.NodeExecutionService
	FlowVariable       *sflow.FlowVariableService
	Env                *senv.EnvironmentService
	Var                *senv.VariableService
	Http               *shttp.HTTPService
	HttpBodyRaw        *shttp.HttpBodyRawService
	HttpResponse       shttp.HttpResponseService
	GraphQLResponse    sgraphql.GraphQLResponseService
	GraphQL            *sgraphql.GraphQLService
	GraphQLHeader      *sgraphql.GraphQLHeaderService
	GraphQLAssert      *sgraphql.GraphQLAssertService
	File               *sfile.FileService
	Importer           WorkspaceImporter
	Credential         scredential.CredentialService
}

func (*FlowServiceV2Services) Validate 

func (s *FlowServiceV2Services) Validate() error

type FlowServiceV2Streamers 

type FlowServiceV2Streamers struct {
	Flow                  eventstream.SyncStreamer[FlowTopic, FlowEvent]
	Node                  eventstream.SyncStreamer[NodeTopic, NodeEvent]
	Edge                  eventstream.SyncStreamer[EdgeTopic, EdgeEvent]
	Var                   eventstream.SyncStreamer[FlowVariableTopic, FlowVariableEvent]
	Version               eventstream.SyncStreamer[FlowVersionTopic, FlowVersionEvent]
	For                   eventstream.SyncStreamer[ForTopic, ForEvent]
	Condition             eventstream.SyncStreamer[ConditionTopic, ConditionEvent]
	ForEach               eventstream.SyncStreamer[ForEachTopic, ForEachEvent]
	Js                    eventstream.SyncStreamer[JsTopic, JsEvent]
	Ai                    eventstream.SyncStreamer[AiTopic, AiEvent]
	AiProvider            eventstream.SyncStreamer[AiProviderTopic, AiProviderEvent]
	Memory                eventstream.SyncStreamer[MemoryTopic, MemoryEvent]
	NodeGraphQL           eventstream.SyncStreamer[NodeGraphQLTopic, NodeGraphQLEvent]
	GraphQL               eventstream.SyncStreamer[rgraphql.GraphQLTopic, rgraphql.GraphQLEvent]
	WebSocket             eventstream.SyncStreamer[rwebsocket.WebSocketTopic, rwebsocket.WebSocketEvent]
	Execution             eventstream.SyncStreamer[ExecutionTopic, ExecutionEvent]
	Http                  eventstream.SyncStreamer[rhttp.HttpTopic, rhttp.HttpEvent]
	HttpResponse          eventstream.SyncStreamer[rhttp.HttpResponseTopic, rhttp.HttpResponseEvent]
	HttpResponseHeader    eventstream.SyncStreamer[rhttp.HttpResponseHeaderTopic, rhttp.HttpResponseHeaderEvent]
	HttpResponseAssert    eventstream.SyncStreamer[rhttp.HttpResponseAssertTopic, rhttp.HttpResponseAssertEvent]
	GraphQLResponse       eventstream.SyncStreamer[rgraphql.GraphQLResponseTopic, rgraphql.GraphQLResponseEvent]
	GraphQLResponseHeader eventstream.SyncStreamer[rgraphql.GraphQLResponseHeaderTopic, rgraphql.GraphQLResponseHeaderEvent]
	GraphQLResponseAssert eventstream.SyncStreamer[rgraphql.GraphQLResponseAssertTopic, rgraphql.GraphQLResponseAssertEvent]
	Log                   eventstream.SyncStreamer[rlog.LogTopic, rlog.LogEvent]
	File                  eventstream.SyncStreamer[rfile.FileTopic, rfile.FileEvent]
}

type FlowTopic 

type FlowTopic struct {
	WorkspaceID idwrap.IDWrap
}

FlowTopic identifies the workspace whose flows are being published.

type FlowVariableEvent 

type FlowVariableEvent struct {
	Type     string
	FlowID   idwrap.IDWrap
	Variable mflow.FlowVariable
}

FlowVariableEvent describes a flow variable change for sync streaming.

type FlowVariableTopic 

type FlowVariableTopic struct {
	FlowID idwrap.IDWrap
}

FlowVariableTopic identifies the flow whose variables are being published.

type FlowVersionEvent 

type FlowVersionEvent struct {
	Type      string
	FlowID    idwrap.IDWrap
	VersionID idwrap.IDWrap
}

FlowVersionEvent describes a flow version change for sync streaming.

type FlowVersionTopic 

type FlowVersionTopic struct {
	FlowID idwrap.IDWrap
}

FlowVersionTopic identifies the flow whose versions are being published.

type ForEachEvent 

type ForEachEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeForEach
}

ForEachEvent describes a ForEach node change for sync streaming.

type ForEachTopic 

type ForEachTopic struct {
	FlowID idwrap.IDWrap
}

ForEachTopic identifies the flow whose ForEach nodes are being published.

type ForEvent 

type ForEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeFor
}

ForEvent describes a For node change for sync streaming.

type ForTopic 

type ForTopic struct {
	FlowID idwrap.IDWrap
}

ForTopic identifies the flow whose For nodes are being published.

type ImportResults 

type ImportResults struct {
	WorkspaceID     idwrap.IDWrap
	HTTPReqsCreated int
	HTTPReqsUpdated int
	HTTPReqsSkipped int
	HTTPReqsFailed  int
	FilesCreated    int
	FilesUpdated    int
	FilesSkipped    int
	FilesFailed     int
	FlowsCreated    int
	FlowsUpdated    int
	FlowsSkipped    int
	FlowsFailed     int
	NodesCreated    int
	NodesUpdated    int
	NodesSkipped    int
	NodesFailed     int
	Duration        int64
}

ImportResults represents the results of a workspace import operation

type JsEvent 

type JsEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeJs
}

JsEvent describes a JavaScript node change for sync streaming.

type JsTopic 

type JsTopic struct {
	FlowID idwrap.IDWrap
}

JsTopic identifies the flow whose JavaScript nodes are being published.

type MemoryEvent 

type MemoryEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeAiMemory
}

MemoryEvent describes a Memory node change for sync streaming.

type MemoryTopic 

type MemoryTopic struct {
	FlowID idwrap.IDWrap
}

MemoryTopic identifies the flow whose Memory nodes are being published.

type MockWorkspaceImporter 

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

MockWorkspaceImporter provides a mock implementation for testing

func NewMockWorkspaceImporter 

func NewMockWorkspaceImporter(results *ImportResults, err error) *MockWorkspaceImporter

NewMockWorkspaceImporter creates a new mock importer

func (*MockWorkspaceImporter) ImportWorkspaceFromCurl 

func (m *MockWorkspaceImporter) ImportWorkspaceFromCurl(ctx context.Context, curlData []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)

func (*MockWorkspaceImporter) ImportWorkspaceFromYAML 

func (m *MockWorkspaceImporter) ImportWorkspaceFromYAML(ctx context.Context, data []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)

type NodeEvent 

type NodeEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.Node
}

NodeEvent describes a node change for sync streaming.

type NodeGraphQLEvent 

type NodeGraphQLEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeGraphQL
}

NodeGraphQLEvent describes a GraphQL node change for sync streaming.

type NodeGraphQLTopic 

type NodeGraphQLTopic struct {
	FlowID idwrap.IDWrap
}

NodeGraphQLTopic identifies the flow whose GraphQL nodes are being published.

type NodeTopic 

type NodeTopic struct {
	FlowID idwrap.IDWrap
}

NodeTopic identifies the flow whose nodes are being published.

type NodeWsConnectionEvent 

type NodeWsConnectionEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeWsConnection
}

NodeWsConnectionEvent describes a WS Connection node change for sync streaming.

type NodeWsConnectionTopic 

type NodeWsConnectionTopic struct {
	FlowID idwrap.IDWrap
}

NodeWsConnectionTopic identifies the flow whose WS Connection nodes are being published.

type NodeWsSendEvent 

type NodeWsSendEvent struct {
	Type   string
	FlowID idwrap.IDWrap
	Node   *flowv1.NodeWsSend
}

NodeWsSendEvent describes a WS Send node change for sync streaming.

type NodeWsSendTopic 

type NodeWsSendTopic struct {
	FlowID idwrap.IDWrap
}

NodeWsSendTopic identifies the flow whose WS Send nodes are being published.

type WorkspaceImporter 

type WorkspaceImporter interface {
	ImportWorkspaceFromYAML(ctx context.Context, data []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)
	ImportWorkspaceFromCurl(ctx context.Context, curlData []byte, workspaceID idwrap.IDWrap) (*ImportResults, error)
}

WorkspaceImporter defines the interface for importing workspace data

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.