testutil

package
v1.0.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseMockStorage 

type BaseMockStorage struct {
	storage.Storage
}

func (*BaseMockStorage) AcquireWorkflowLease 

func (m *BaseMockStorage) AcquireWorkflowLease(ctx context.Context, workflowID, ownerID string, ttlSeconds int) (bool, error)

func (*BaseMockStorage) CreateAuditLog 

func (m *BaseMockStorage) CreateAuditLog(ctx context.Context, log storage.AuditLog) error

func (*BaseMockStorage) CreateFormSubmission 

func (m *BaseMockStorage) CreateFormSubmission(ctx context.Context, sub storage.FormSubmission) error

func (*BaseMockStorage) CreateLog 

func (m *BaseMockStorage) CreateLog(ctx context.Context, log storage.Log) error

func (*BaseMockStorage) CreateLogs 

func (m *BaseMockStorage) CreateLogs(ctx context.Context, logs []storage.Log) error

func (*BaseMockStorage) CreateOutboxItem 

func (m *BaseMockStorage) CreateOutboxItem(ctx context.Context, item storage.OutboxItem) error

func (*BaseMockStorage) CreateSchema 

func (m *BaseMockStorage) CreateSchema(ctx context.Context, schema storage.Schema) error

func (*BaseMockStorage) CreateSink 

func (m *BaseMockStorage) CreateSink(ctx context.Context, snk storage.Sink) error

func (*BaseMockStorage) CreateSource 

func (m *BaseMockStorage) CreateSource(ctx context.Context, src storage.Source) error

func (*BaseMockStorage) CreateUser 

func (m *BaseMockStorage) CreateUser(ctx context.Context, user storage.User) error

func (*BaseMockStorage) CreateVHost 

func (m *BaseMockStorage) CreateVHost(ctx context.Context, vhost storage.VHost) error

func (*BaseMockStorage) CreateWebhookRequest 

func (m *BaseMockStorage) CreateWebhookRequest(ctx context.Context, req storage.WebhookRequest) error

func (*BaseMockStorage) CreateWorker 

func (m *BaseMockStorage) CreateWorker(ctx context.Context, worker storage.Worker) error

func (*BaseMockStorage) CreateWorkflow 

func (m *BaseMockStorage) CreateWorkflow(ctx context.Context, wf storage.Workflow) error

func (*BaseMockStorage) CreateWorkflowVersion 

func (m *BaseMockStorage) CreateWorkflowVersion(ctx context.Context, version storage.WorkflowVersion) error

func (*BaseMockStorage) CreateWorkspace 

func (m *BaseMockStorage) CreateWorkspace(ctx context.Context, ws storage.Workspace) error

func (*BaseMockStorage) DeleteApproval 

func (m *BaseMockStorage) DeleteApproval(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteFormSubmissions 

func (m *BaseMockStorage) DeleteFormSubmissions(ctx context.Context, filter storage.FormSubmissionFilter) error

func (*BaseMockStorage) DeleteLogs 

func (m *BaseMockStorage) DeleteLogs(ctx context.Context, filter storage.LogFilter) error

func (*BaseMockStorage) DeleteOutboxItem 

func (m *BaseMockStorage) DeleteOutboxItem(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteSink 

func (m *BaseMockStorage) DeleteSink(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteSource 

func (m *BaseMockStorage) DeleteSource(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteSuspendedMessage 

func (m *BaseMockStorage) DeleteSuspendedMessage(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteUser 

func (m *BaseMockStorage) DeleteUser(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteVHost 

func (m *BaseMockStorage) DeleteVHost(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteWebhookRequests 

func (m *BaseMockStorage) DeleteWebhookRequests(ctx context.Context, filter storage.WebhookRequestFilter) error

func (*BaseMockStorage) DeleteWorker 

func (m *BaseMockStorage) DeleteWorker(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteWorkflow 

func (m *BaseMockStorage) DeleteWorkflow(ctx context.Context, id string) error

func (*BaseMockStorage) DeleteWorkspace 

func (m *BaseMockStorage) DeleteWorkspace(ctx context.Context, id string) error

func (*BaseMockStorage) GetDashboardStats 

func (m *BaseMockStorage) GetDashboardStats(ctx context.Context, vhost string) (storage.DashboardStats, error)

func (*BaseMockStorage) GetFormSubmission 

func (m *BaseMockStorage) GetFormSubmission(ctx context.Context, id string) (storage.FormSubmission, error)

func (*BaseMockStorage) GetLatestSchema 

func (m *BaseMockStorage) GetLatestSchema(ctx context.Context, name string) (storage.Schema, error)

func (*BaseMockStorage) GetLineage 

func (m *BaseMockStorage) GetLineage(ctx context.Context) ([]storage.LineageEdge, error)

func (*BaseMockStorage) GetMessageTrace 

func (m *BaseMockStorage) GetMessageTrace(ctx context.Context, workflowID, messageID string) (storage.MessageTrace, error)

func (*BaseMockStorage) GetNodeStates 

func (m *BaseMockStorage) GetNodeStates(ctx context.Context, workflowID string) (map[string]any, error)

func (*BaseMockStorage) GetPlugin 

func (m *BaseMockStorage) GetPlugin(ctx context.Context, id string) (storage.Plugin, error)

func (*BaseMockStorage) GetSchema 

func (m *BaseMockStorage) GetSchema(ctx context.Context, name string, version int) (storage.Schema, error)

func (*BaseMockStorage) GetSetting 

func (m *BaseMockStorage) GetSetting(ctx context.Context, key string) (string, error)

func (*BaseMockStorage) GetSink 

func (m *BaseMockStorage) GetSink(ctx context.Context, id string) (storage.Sink, error)

func (*BaseMockStorage) GetSource 

func (m *BaseMockStorage) GetSource(ctx context.Context, id string) (storage.Source, error)

func (*BaseMockStorage) GetUser 

func (m *BaseMockStorage) GetUser(ctx context.Context, id string) (storage.User, error)

func (*BaseMockStorage) GetUserByEmail 

func (m *BaseMockStorage) GetUserByEmail(ctx context.Context, email string) (storage.User, error)

func (*BaseMockStorage) GetUserByUsername 

func (m *BaseMockStorage) GetUserByUsername(ctx context.Context, username string) (storage.User, error)

func (*BaseMockStorage) GetVHost 

func (m *BaseMockStorage) GetVHost(ctx context.Context, id string) (storage.VHost, error)

func (*BaseMockStorage) GetWebhookRequest 

func (m *BaseMockStorage) GetWebhookRequest(ctx context.Context, id string) (storage.WebhookRequest, error)

func (*BaseMockStorage) GetWorker 

func (m *BaseMockStorage) GetWorker(ctx context.Context, id string) (storage.Worker, error)

func (*BaseMockStorage) GetWorkflow 

func (m *BaseMockStorage) GetWorkflow(ctx context.Context, id string) (storage.Workflow, error)

func (*BaseMockStorage) GetWorkflowVersion 

func (m *BaseMockStorage) GetWorkflowVersion(ctx context.Context, workflowID string, version int) (storage.WorkflowVersion, error)

func (*BaseMockStorage) GetWorkspace 

func (m *BaseMockStorage) GetWorkspace(ctx context.Context, id string) (storage.Workspace, error)

func (*BaseMockStorage) Init 

func (m *BaseMockStorage) Init(ctx context.Context) error

func (*BaseMockStorage) InstallPlugin 

func (m *BaseMockStorage) InstallPlugin(ctx context.Context, id string) error

func (*BaseMockStorage) ListAllSchemas 

func (m *BaseMockStorage) ListAllSchemas(ctx context.Context) ([]storage.Schema, error)

func (*BaseMockStorage) ListApprovals 

func (m *BaseMockStorage) ListApprovals(ctx context.Context, filter storage.ApprovalFilter) ([]storage.Approval, int, error)

func (*BaseMockStorage) ListAuditLogs 

func (m *BaseMockStorage) ListAuditLogs(ctx context.Context, filter storage.AuditFilter) ([]storage.AuditLog, int, error)

func (*BaseMockStorage) ListFormSubmissions 

func (m *BaseMockStorage) ListFormSubmissions(ctx context.Context, filter storage.FormSubmissionFilter) ([]storage.FormSubmission, int, error)

func (*BaseMockStorage) ListLogs 

func (m *BaseMockStorage) ListLogs(ctx context.Context, filter storage.LogFilter) ([]storage.Log, int, error)

func (*BaseMockStorage) ListMessageTraces 

func (m *BaseMockStorage) ListMessageTraces(ctx context.Context, workflowID string, limit, offset int) ([]storage.MessageTrace, error)

func (*BaseMockStorage) ListOutboxItems 

func (m *BaseMockStorage) ListOutboxItems(ctx context.Context, status string, limit int) ([]storage.OutboxItem, error)

func (*BaseMockStorage) ListPlugins 

func (m *BaseMockStorage) ListPlugins(ctx context.Context) ([]storage.Plugin, error)

func (*BaseMockStorage) ListSchemas 

func (m *BaseMockStorage) ListSchemas(ctx context.Context, name string) ([]storage.Schema, error)

func (*BaseMockStorage) ListSinks 

func (m *BaseMockStorage) ListSinks(ctx context.Context, filter storage.CommonFilter) ([]storage.Sink, int, error)

func (*BaseMockStorage) ListSources 

func (m *BaseMockStorage) ListSources(ctx context.Context, filter storage.CommonFilter) ([]storage.Source, int, error)

func (*BaseMockStorage) ListSuspendedMessages 

func (m *BaseMockStorage) ListSuspendedMessages(ctx context.Context, workflowID string, before time.Time) ([]storage.SuspendedMessage, error)

func (*BaseMockStorage) ListUsers 

func (m *BaseMockStorage) ListUsers(ctx context.Context, filter storage.CommonFilter) ([]storage.User, int, error)

func (*BaseMockStorage) ListVHosts 

func (m *BaseMockStorage) ListVHosts(ctx context.Context, filter storage.CommonFilter) ([]storage.VHost, int, error)

func (*BaseMockStorage) ListWebhookRequests 

func (m *BaseMockStorage) ListWebhookRequests(ctx context.Context, filter storage.WebhookRequestFilter) ([]storage.WebhookRequest, int, error)

func (*BaseMockStorage) ListWorkers 

func (m *BaseMockStorage) ListWorkers(ctx context.Context, filter storage.CommonFilter) ([]storage.Worker, int, error)

func (*BaseMockStorage) ListWorkflowVersions 

func (m *BaseMockStorage) ListWorkflowVersions(ctx context.Context, workflowID string) ([]storage.WorkflowVersion, error)

func (*BaseMockStorage) ListWorkflows 

func (m *BaseMockStorage) ListWorkflows(ctx context.Context, filter storage.CommonFilter) ([]storage.Workflow, int, error)

func (*BaseMockStorage) ListWorkspaces 

func (m *BaseMockStorage) ListWorkspaces(ctx context.Context) ([]storage.Workspace, error)

func (*BaseMockStorage) PurgeAuditLogs 

func (m *BaseMockStorage) PurgeAuditLogs(ctx context.Context, before time.Time) error

func (*BaseMockStorage) PurgeLogs 

func (m *BaseMockStorage) PurgeLogs(ctx context.Context, before time.Time) error

func (*BaseMockStorage) PurgeMessageTraces 

func (m *BaseMockStorage) PurgeMessageTraces(ctx context.Context, before time.Time) error

func (*BaseMockStorage) RecordTraceStep 

func (m *BaseMockStorage) RecordTraceStep(ctx context.Context, workflowID, messageID string, step hermod.TraceStep) error

func (*BaseMockStorage) ReleaseWorkflowLease 

func (m *BaseMockStorage) ReleaseWorkflowLease(ctx context.Context, workflowID, ownerID string) error

func (*BaseMockStorage) RenewWorkflowLease 

func (m *BaseMockStorage) RenewWorkflowLease(ctx context.Context, workflowID, ownerID string, ttlSeconds int) (bool, error)

func (*BaseMockStorage) SaveSetting 

func (m *BaseMockStorage) SaveSetting(ctx context.Context, key string, value string) error

func (*BaseMockStorage) UninstallPlugin 

func (m *BaseMockStorage) UninstallPlugin(ctx context.Context, id string) error

func (*BaseMockStorage) UpdateFormSubmissionStatus 

func (m *BaseMockStorage) UpdateFormSubmissionStatus(ctx context.Context, id string, status string) error

func (*BaseMockStorage) UpdateNodeState 

func (m *BaseMockStorage) UpdateNodeState(ctx context.Context, workflowID, nodeID string, state any) error

func (*BaseMockStorage) UpdateOutboxItem 

func (m *BaseMockStorage) UpdateOutboxItem(ctx context.Context, item storage.OutboxItem) error

func (*BaseMockStorage) UpdateSink 

func (m *BaseMockStorage) UpdateSink(ctx context.Context, snk storage.Sink) error

func (*BaseMockStorage) UpdateSinkStatus 

func (m *BaseMockStorage) UpdateSinkStatus(ctx context.Context, id string, status string) error

func (*BaseMockStorage) UpdateSource 

func (m *BaseMockStorage) UpdateSource(ctx context.Context, src storage.Source) error

func (*BaseMockStorage) UpdateSourceState 

func (m *BaseMockStorage) UpdateSourceState(ctx context.Context, id string, state map[string]string) error

func (*BaseMockStorage) UpdateSourceStatus 

func (m *BaseMockStorage) UpdateSourceStatus(ctx context.Context, id string, status string) error

func (*BaseMockStorage) UpdateUser 

func (m *BaseMockStorage) UpdateUser(ctx context.Context, user storage.User) error

func (*BaseMockStorage) UpdateVHost 

func (m *BaseMockStorage) UpdateVHost(ctx context.Context, vhost storage.VHost) error

func (*BaseMockStorage) UpdateWorker 

func (m *BaseMockStorage) UpdateWorker(ctx context.Context, worker storage.Worker) error

func (*BaseMockStorage) UpdateWorkerHeartbeat 

func (m *BaseMockStorage) UpdateWorkerHeartbeat(ctx context.Context, id string, cpu, mem float64) error

func (*BaseMockStorage) UpdateWorkflow 

func (m *BaseMockStorage) UpdateWorkflow(ctx context.Context, wf storage.Workflow) error

func (*BaseMockStorage) UpdateWorkflowStats 

func (m *BaseMockStorage) UpdateWorkflowStats(ctx context.Context, id string, processed, errors, lag uint64) error

func (*BaseMockStorage) UpdateWorkflowStatus 

func (m *BaseMockStorage) UpdateWorkflowStatus(ctx context.Context, id string, status string) 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.