module

package

Go to main page

Versions in this module

v0

v0.2.12

Feb 25, 2026

v0.2.11

Feb 25, 2026

Changes in this version

type JWTAuthModule

+ func (j *JWTAuthModule) SetAllowRegistration(allow bool)

v0.2.10

Feb 25, 2026

v0.2.9

Feb 25, 2026

Changes in this version

+ type GitCheckoutStep struct

+ func (s *GitCheckoutStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GitCheckoutStep) Name() string

+ type GitCloneStep struct

+ func (s *GitCloneStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GitCloneStep) Name() string

+ type GitCommitStep struct

+ func (s *GitCommitStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GitCommitStep) Name() string

+ type GitPushStep struct

+ func (s *GitPushStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GitPushStep) Name() string

+ type GitTagStep struct

+ func (s *GitTagStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GitTagStep) Name() string

type StepFactory

+ func NewGitCheckoutStepFactory() StepFactory

+ func NewGitCloneStepFactory() StepFactory

+ func NewGitCommitStepFactory() StepFactory

+ func NewGitPushStepFactory() StepFactory

+ func NewGitTagStepFactory() StepFactory

v0.2.8

Feb 25, 2026

v0.2.7

Feb 25, 2026

Changes in this version

+ func ExpandEnvString(s string) string

+ type CacheDeleteStep struct

+ func (s *CacheDeleteStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *CacheDeleteStep) Name() string

+ type CacheGetStep struct

+ func (s *CacheGetStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *CacheGetStep) Name() string

+ type CacheModule interface

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (string, error)

+ Set func(ctx context.Context, key, value string, ttl time.Duration) error

+ type CacheSetStep struct

+ func (s *CacheSetStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *CacheSetStep) Name() string

+ type RedisCache struct

+ func NewRedisCache(name string, cfg RedisCacheConfig) *RedisCache

+ func NewRedisCacheWithClient(name string, cfg RedisCacheConfig, client RedisClient) *RedisCache

+ func (r *RedisCache) Delete(ctx context.Context, key string) error

+ func (r *RedisCache) Get(ctx context.Context, key string) (string, error)

+ func (r *RedisCache) Init(app modular.Application) error

+ func (r *RedisCache) Name() string

+ func (r *RedisCache) ProvidesServices() []modular.ServiceProvider

+ func (r *RedisCache) RequiresServices() []modular.ServiceDependency

+ func (r *RedisCache) Set(ctx context.Context, key, value string, ttl time.Duration) error

+ func (r *RedisCache) Start(ctx context.Context) error

+ func (r *RedisCache) Stop(_ context.Context) error

+ type RedisCacheConfig struct

+ Address string

+ DB int

+ DefaultTTL time.Duration

+ Password string

+ Prefix string

+ type RedisClient interface

+ Close func() error

+ Del func(ctx context.Context, keys ...string) *redis.IntCmd

+ Get func(ctx context.Context, key string) *redis.StringCmd

+ Ping func(ctx context.Context) *redis.StatusCmd

+ Set func(ctx context.Context, key string, value any, expiration time.Duration) *redis.StatusCmd

+ type StateMachineGetStep struct

+ func (s *StateMachineGetStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *StateMachineGetStep) Name() string

+ type StateMachineTransitionStep struct

+ func (s *StateMachineTransitionStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *StateMachineTransitionStep) Name() string

type StepFactory

+ func NewCacheDeleteStepFactory() StepFactory

+ func NewCacheGetStepFactory() StepFactory

+ func NewCacheSetStepFactory() StepFactory

+ func NewStateMachineGetStepFactory() StepFactory

+ func NewStateMachineTransitionStepFactory() StepFactory

v0.2.6

Feb 25, 2026

Changes in this version

+ type BuildFromConfigStep struct

+ func (s *BuildFromConfigStep) Execute(ctx context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *BuildFromConfigStep) Name() string

+ type PluginSpec struct

+ Binary string

+ Name string

type StepFactory

+ func NewBuildFromConfigStepFactory() StepFactory

v0.2.5

Feb 25, 2026

v0.2.4

Feb 25, 2026

Changes in this version

type StandardHTTPRouter

+ func (r *StandardHTTPRouter) AddGlobalMiddleware(mw HTTPMiddleware)

v0.2.3

Feb 25, 2026

Changes in this version

+ type ForEachStep struct

+ func (s *ForEachStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ForEachStep) Name() string

+ type OTelMiddleware struct

+ func NewOTelMiddleware(name, serverName string) *OTelMiddleware

+ func (m *OTelMiddleware) Init(_ modular.Application) error

+ func (m *OTelMiddleware) Name() string

+ func (m *OTelMiddleware) Process(next http.Handler) http.Handler

+ func (m *OTelMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *OTelMiddleware) RequiresServices() []modular.ServiceDependency

+ func (m *OTelMiddleware) Start(_ context.Context) error

+ func (m *OTelMiddleware) Stop(_ context.Context) error

type StepFactory

+ func NewForEachStepFactory(registryFn func() *StepRegistry, app modular.Application) StepFactory

+ func NewWebhookVerifyStepFactory() StepFactory

+ type WebhookVerifyStep struct

+ func (s *WebhookVerifyStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *WebhookVerifyStep) Name() string

v0.2.2

Feb 24, 2026

v0.2.1

Feb 24, 2026

Changes in this version

+ var HTTPRequestContextKey = httpReqContextKey

v0.2.0

Feb 24, 2026

Changes in this version

+ var HTTPResponseWriterContextKey = httpRWContextKey

v0.1.9

Feb 24, 2026

v0.1.8

Feb 24, 2026

v0.1.7

Feb 24, 2026

v0.1.6

Feb 24, 2026

Changes in this version

+ var ErrNotImplemented = errors.New("step not implemented: requires sandbox.DockerSandbox (not yet available)")

type APIGateway

+ func (g *APIGateway) SetRateLimit(cfg *RateLimitConfig)

+ type APIGatewayOption func(*APIGateway)

+ func WithRateLimit(cfg *RateLimitConfig) APIGatewayOption

+ type DLQServiceConfig struct

+ MaxRetries int

+ RetentionDays int

+ type DLQServiceModule struct

+ func NewDLQServiceModule(name string, cfg DLQServiceConfig) *DLQServiceModule

+ func (m *DLQServiceModule) DLQMux() http.Handler

+ func (m *DLQServiceModule) Init(_ modular.Application) error

+ func (m *DLQServiceModule) MaxRetries() int

+ func (m *DLQServiceModule) Name() string

+ func (m *DLQServiceModule) ProvidesServices() []modular.ServiceProvider

+ func (m *DLQServiceModule) RequiresServices() []modular.ServiceDependency

+ func (m *DLQServiceModule) RetentionDays() int

+ func (m *DLQServiceModule) Store() *evstore.InMemoryDLQStore

+ type EventStoreServiceConfig struct

+ DBPath string

+ RetentionDays int

+ type EventStoreServiceModule struct

+ func NewEventStoreServiceModule(name string, cfg EventStoreServiceConfig) (*EventStoreServiceModule, error)

+ func (m *EventStoreServiceModule) Init(_ modular.Application) error

+ func (m *EventStoreServiceModule) Name() string

+ func (m *EventStoreServiceModule) ProvidesServices() []modular.ServiceProvider

+ func (m *EventStoreServiceModule) RequiresServices() []modular.ServiceDependency

+ func (m *EventStoreServiceModule) RetentionDays() int

+ func (m *EventStoreServiceModule) Store() *evstore.SQLiteEventStore

type ExecutionTracker

+ func (t *ExecutionTracker) SetEventStoreRecorder(r EventRecorder)

type HTTPIntegrationConnector

+ func (c *HTTPIntegrationConnector) AllowPrivateIPs()

+ func (c *HTTPIntegrationConnector) DisallowPrivateIPs()

+ type OpenAPIConfig struct

+ BasePath string

+ MaxBodyBytes int64

+ RouterName string

+ SpecFile string

+ SwaggerUI OpenAPISwaggerUIConfig

+ Validation OpenAPIValidationConfig

type OpenAPIGenerator

+ func (g *OpenAPIGenerator) RegisterAdminSchemas()

+ type OpenAPIModule struct

+ func NewOpenAPIModule(name string, cfg OpenAPIConfig) *OpenAPIModule

+ func (m *OpenAPIModule) Dependencies() []string

+ func (m *OpenAPIModule) Init(app modular.Application) error

+ func (m *OpenAPIModule) Name() string

+ func (m *OpenAPIModule) ProvidesServices() []modular.ServiceProvider

+ func (m *OpenAPIModule) RegisterRoutes(router HTTPRouter)

+ func (m *OpenAPIModule) RequiresServices() []modular.ServiceDependency

+ func (m *OpenAPIModule) RouterName() string

+ func (m *OpenAPIModule) Start(_ context.Context) error

+ func (m *OpenAPIModule) Stop(_ context.Context) error

+ type OpenAPISwaggerUIConfig struct

+ Enabled bool

+ Path string

+ type OpenAPIValidationConfig struct

+ Request bool

+ Response bool

type Pipeline

+ func (p *Pipeline) Run(ctx context.Context, data map[string]any) (map[string]any, error)

+ func (p *Pipeline) SetEventRecorder(recorder interfaces.EventRecorder)

+ func (p *Pipeline) SetLogger(logger *slog.Logger)

+ type PipelineLookupFn func(name string) (*Pipeline, bool)

type RESTAPIHandlerConfig

+ InitialTransition string

+ SeedFile string

+ SourceResourceName string

+ StateFilter string

type RateLimitMiddleware

+ func NewRateLimitMiddlewareWithHourlyRate(name string, requestsPerHour, burstSize int) *RateLimitMiddleware

+ type StaticFileServerOption func(*StaticFileServer)

+ func WithCacheMaxAge(seconds int) StaticFileServerOption

+ func WithSPAFallback() StaticFileServerOption

type StepFactory

+ func NewValidatePaginationStepFactory() StepFactory

+ func NewValidatePathParamStepFactory() StepFactory

+ func NewValidateRequestBodyStepFactory() StepFactory

+ func NewWorkflowCallStepFactory(lookup PipelineLookupFn) StepFactory

+ type TimelineServiceModule struct

+ func NewTimelineServiceModule(name string, eventStore evstore.EventStore) *TimelineServiceModule

+ func (m *TimelineServiceModule) BackfillMux() http.Handler

+ func (m *TimelineServiceModule) Init(_ modular.Application) error

+ func (m *TimelineServiceModule) Name() string

+ func (m *TimelineServiceModule) ProvidesServices() []modular.ServiceProvider

+ func (m *TimelineServiceModule) ReplayMux() http.Handler

+ func (m *TimelineServiceModule) RequiresServices() []modular.ServiceDependency

+ func (m *TimelineServiceModule) TimelineMux() http.Handler

+ type ValidatePaginationStep struct

+ func (s *ValidatePaginationStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ValidatePaginationStep) Name() string

+ type ValidatePathParamStep struct

+ func (s *ValidatePathParamStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ValidatePathParamStep) Name() string

+ type ValidateRequestBodyStep struct

+ func (s *ValidateRequestBodyStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ValidateRequestBodyStep) Name() string

+ type WorkflowCallMode string

+ const WorkflowCallModeAsync

+ const WorkflowCallModeSync

+ type WorkflowCallStep struct

+ func (s *WorkflowCallStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *WorkflowCallStep) Name() string

+ type WorkflowConfig struct

+ Engine string

+ InitialTransition string

+ InstanceIDField string

+ InstanceIDPrefix string

+ SeedFile string

+ Type string

type WorkflowRegistry

+ func (w *WorkflowRegistry) WorkflowStore() any

v0.1.5

Feb 22, 2026

Changes in this version

+ type ExecutionTrackerProvider interface

+ TrackPipelineExecution func(ctx context.Context, pipeline *Pipeline, triggerData map[string]any, ...) (*PipelineContext, error)

type GCSStorage

+ func (g *GCSStorage) MkdirAll(_ context.Context, _ string) error

+ func (g *GCSStorage) SetBucketHandle(bh gcsBucketHandle)

type JWTAuthModule

+ func (j *JWTAuthModule) CreateOAuthUser(oauthKey, name string, meta map[string]any) (*User, error)

+ type LicenseModule struct

+ func NewLicenseModule(name string, cfg map[string]any) (*LicenseModule, error)

+ func (m *LicenseModule) Init(_ modular.Application) error

+ func (m *LicenseModule) Name() string

+ func (m *LicenseModule) ProvidesServices() []modular.ServiceProvider

+ func (m *LicenseModule) RequiresServices() []modular.ServiceDependency

+ func (m *LicenseModule) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (m *LicenseModule) Start(ctx context.Context) error

+ func (m *LicenseModule) Stop(ctx context.Context) error

+ func (m *LicenseModule) Validator() *licensing.HTTPValidator

+ type LicenseModuleConfig struct

+ CacheTTL string

+ GracePeriod string

+ LicenseKey string

+ RefreshInterval string

+ ServerURL string

+ type OAuth2Module struct

+ func NewOAuth2Module(name string, providerCfgs []OAuth2ProviderConfig, jwtAuth *JWTAuthModule) *OAuth2Module

+ func (m *OAuth2Module) Handle(w http.ResponseWriter, r *http.Request)

+ func (m *OAuth2Module) Init(_ modular.Application) error

+ func (m *OAuth2Module) Name() string

+ func (m *OAuth2Module) ProvidesServices() []modular.ServiceProvider

+ func (m *OAuth2Module) RequiresServices() []modular.ServiceDependency

+ func (m *OAuth2Module) SetJWTAuth(j *JWTAuthModule)

+ type OAuth2ProviderConfig struct

+ AuthURL string

+ ClientID string

+ ClientSecret string

+ Name string

+ RedirectURL string

+ Scopes []string

+ TokenURL string

+ UserInfoURL string

type StandardHTTPServer

+ func (s *StandardHTTPServer) SetTimeouts(read, write, idle time.Duration)

v0.1.1

Feb 22, 2026

v0.1.0

Feb 22, 2026

Changes in this version

+ const EventBusBridgeName

+ const EventBusTriggerName

+ const EventTriggerName

+ const HTTPTriggerName

+ const InMemoryMessageBrokerName

+ const LifecycleCompleted

+ const LifecycleFailed

+ const LifecycleStarted

+ const ReconciliationTriggerName

+ const ScheduleTriggerName

+ const SimpleMessageHandlerName

+ const StateMachineEngineName

+ const StateMachineStateConnectorName

+ const StateTrackerName

+ func BuildDeleteSQL(table string, where string, whereArgs ...any) (string, []any, error)

+ func BuildInsertSQL(table string, data map[string]any) (string, []any, error)

+ func BuildUpdateSQL(table string, data map[string]any, where string, whereArgs ...any) (string, []any, error)

+ func CalculateBackoff(initialBackoff time.Duration, multiplier float64, maxBackoff time.Duration, ...) time.Duration

+ func CreateIsolatedApp(t *testing.T) modular.Application

+ func DefaultSummaryFields() []string

+ func DefaultTransitionMap() map[string]string

+ func GatewayTimeout(route *GatewayRoute, defaultTimeout time.Duration) time.Duration

+ func GetRequestID(ctx context.Context) string

+ func RegisterAdminSchemas(gen *OpenAPIGenerator)

+ func SkipTestWithContext(ctx context.Context, skip bool) context.Context

+ func StepTopic(workflowType, stepName, lifecycle string) string

+ func WorkflowTopic(workflowType, lifecycle string) string

+ type AIClassifyStep struct

+ func (s *AIClassifyStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *AIClassifyStep) Name() string

+ type AICompleteStep struct

+ func (s *AICompleteStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *AICompleteStep) Name() string

+ type AIExtractStep struct

+ func (s *AIExtractStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *AIExtractStep) Name() string

+ type APIGateway struct

+ func NewAPIGateway(name string) *APIGateway

+ func (g *APIGateway) Handle(w http.ResponseWriter, r *http.Request)

+ func (g *APIGateway) Init(_ modular.Application) error

+ func (g *APIGateway) Name() string

+ func (g *APIGateway) ProvidesServices() []modular.ServiceProvider

+ func (g *APIGateway) RequiresServices() []modular.ServiceDependency

+ func (g *APIGateway) Routes() []GatewayRoute

+ func (g *APIGateway) SetAuth(cfg *AuthConfig)

+ func (g *APIGateway) SetCORS(cfg *CORSConfig)

+ func (g *APIGateway) SetGlobalRateLimit(cfg *RateLimitConfig)

+ func (g *APIGateway) SetRoutes(routes []GatewayRoute) error

+ func (g *APIGateway) Start(_ context.Context) error

+ func (g *APIGateway) Stop(_ context.Context) error

+ type AWSAPIGateway struct

+ func NewAWSAPIGateway(name string) *AWSAPIGateway

+ func (a *AWSAPIGateway) APIID() string

+ func (a *AWSAPIGateway) Init(_ modular.Application) error

+ func (a *AWSAPIGateway) Name() string

+ func (a *AWSAPIGateway) ProvidesServices() []modular.ServiceProvider

+ func (a *AWSAPIGateway) Region() string

+ func (a *AWSAPIGateway) RequiresServices() []modular.ServiceDependency

+ func (a *AWSAPIGateway) SetConfig(region, apiID, stage string)

+ func (a *AWSAPIGateway) Stage() string

+ func (a *AWSAPIGateway) Start(_ context.Context) error

+ func (a *AWSAPIGateway) Stop(_ context.Context) error

+ func (a *AWSAPIGateway) SyncRoutes(routes []GatewayRoute) error

+ type ArtifactOutput struct

+ Key string

+ Path string

+ type ArtifactPullStep struct

+ func (s *ArtifactPullStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ArtifactPullStep) Name() string

+ type ArtifactPushStep struct

+ func (s *ArtifactPushStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ArtifactPushStep) Name() string

+ type AuthConfig struct

+ Header string

+ Type string

+ type AuthMiddleware struct

+ func NewAuthMiddleware(name string, authType string) *AuthMiddleware

+ func (m *AuthMiddleware) AddProvider(validTokens map[string]map[string]any)

+ func (m *AuthMiddleware) Init(app modular.Application) error

+ func (m *AuthMiddleware) Name() string

+ func (m *AuthMiddleware) Process(next http.Handler) http.Handler

+ func (m *AuthMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *AuthMiddleware) RegisterProvider(provider AuthProvider)

+ func (m *AuthMiddleware) RequiresServices() []modular.ServiceDependency

+ func (m *AuthMiddleware) Start(ctx context.Context) error

+ func (m *AuthMiddleware) Stop(ctx context.Context) error

+ type AuthProvider interface

+ Authenticate func(token string) (bool, map[string]any, error)

+ type BuildUIStep struct

+ func (s *BuildUIStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *BuildUIStep) Name() string

+ type CORSConfig struct

+ AllowHeaders []string

+ AllowMethods []string

+ AllowOrigins []string

+ MaxAge int

+ type CORSMiddleware struct

+ func NewCORSMiddleware(name string, allowedOrigins, allowedMethods []string) *CORSMiddleware

+ func (m *CORSMiddleware) Init(app modular.Application) error

+ func (m *CORSMiddleware) Name() string

+ func (m *CORSMiddleware) Process(next http.Handler) http.Handler

+ func (m *CORSMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *CORSMiddleware) RequiresServices() []modular.ServiceDependency

+ func (m *CORSMiddleware) Start(ctx context.Context) error

+ func (m *CORSMiddleware) Stop(ctx context.Context) error

+ type CircuitBreakerStep struct

+ func (s *CircuitBreakerStep) Execute(_ context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *CircuitBreakerStep) Name() string

+ func (s *CircuitBreakerStep) RecordFailure()

+ func (s *CircuitBreakerStep) RecordSuccess()

+ func (s *CircuitBreakerStep) State() CircuitState

+ type CircuitState string

+ const CircuitClosed

+ const CircuitHalfOpen

+ const CircuitOpen

+ type CommandFunc func(ctx context.Context, r *http.Request) (any, error)

+ type CommandHandler struct

+ func NewCommandHandler(name string) *CommandHandler

+ func (h *CommandHandler) Handle(w http.ResponseWriter, r *http.Request)

+ func (h *CommandHandler) Init(app modular.Application) error

+ func (h *CommandHandler) Name() string

+ func (h *CommandHandler) ProvidesServices() []modular.ServiceProvider

+ func (h *CommandHandler) RegisterCommand(name string, fn CommandFunc)

+ func (h *CommandHandler) RequiresServices() []modular.ServiceDependency

+ func (h *CommandHandler) ResolveDelegatePostStart()

+ func (h *CommandHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *CommandHandler) SetDelegate(name string)

+ func (h *CommandHandler) SetDelegateHandler(handler http.Handler)

+ func (h *CommandHandler) SetExecutionTracker(t *ExecutionTracker)

+ func (h *CommandHandler) SetRoutePipeline(routePath string, pipeline *Pipeline)

+ type CompositeTransitionHandler struct

+ func NewCompositeTransitionHandler() *CompositeTransitionHandler

+ func (c *CompositeTransitionHandler) AddHandler(handler TransitionHandler)

+ func (c *CompositeTransitionHandler) HandleTransition(ctx context.Context, event TransitionEvent) error

+ type ConditionalStep struct

+ func (s *ConditionalStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ConditionalStep) Name() string

+ type ConstraintCheckStep struct

+ func (s *ConstraintCheckStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ConstraintCheckStep) Name() string

+ type CronScheduler struct

+ func NewCronScheduler(name string, cronExpression string) *CronScheduler

+ func (s *CronScheduler) Init(app modular.Application) error

+ func (s *CronScheduler) Name() string

+ func (s *CronScheduler) Schedule(job Job) error

+ func (s *CronScheduler) Start(ctx context.Context) error

+ func (s *CronScheduler) Stop(ctx context.Context) error

+ type CrossWorkflowRouter struct

+ func NewCrossWorkflowRouter(linkStore store.CrossWorkflowLinkStore, getEngine func(uuid.UUID) (any, bool), ...) *CrossWorkflowRouter

+ func (r *CrossWorkflowRouter) RefreshLinks(ctx context.Context) error

+ func (r *CrossWorkflowRouter) RouteEvent(ctx context.Context, sourceWorkflowID uuid.UUID, eventType string, ...) error

+ type DBExecStep struct

+ func (s *DBExecStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *DBExecStep) Name() string

+ type DBProvider interface

+ DB func() *sql.DB

+ type DBQueryStep struct

+ func (s *DBQueryStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *DBQueryStep) Name() string

+ type DataTransformer struct

+ func NewDataTransformer(name string) *DataTransformer

+ func (dt *DataTransformer) Init(app modular.Application) error

+ func (dt *DataTransformer) Name() string

+ func (dt *DataTransformer) RegisterPipeline(pipeline *TransformPipeline)

+ func (dt *DataTransformer) Transform(ctx context.Context, pipelineName string, data any) (any, error)

+ func (dt *DataTransformer) TransformWithOps(ctx context.Context, ops []TransformOperation, data any) (any, error)

+ type DatabaseConfig struct

+ ConnMaxLifetime time.Duration

+ DSN string

+ Driver string

+ MaxIdleConns int

+ MaxOpenConns int

+ MigrationsDir string

+ type DatabaseIntegrationConnector struct

+ func NewDatabaseIntegrationConnector(name string, db *WorkflowDatabase) *DatabaseIntegrationConnector

+ func (c *DatabaseIntegrationConnector) Connect(ctx context.Context) error

+ func (c *DatabaseIntegrationConnector) Disconnect(ctx context.Context) error

+ func (c *DatabaseIntegrationConnector) Execute(ctx context.Context, action string, params map[string]any) (map[string]any, error)

+ func (c *DatabaseIntegrationConnector) GetName() string

+ func (c *DatabaseIntegrationConnector) IsConnected() bool

+ type DelegateStep struct

+ func (s *DelegateStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *DelegateStep) Name() string

+ type DeployStep struct

+ func (s *DeployStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *DeployStep) Name() string

+ type DockerBuildStep struct

+ func (s *DockerBuildStep) Execute(ctx context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *DockerBuildStep) Name() string

+ type DockerPushStep struct

+ func (s *DockerPushStep) Execute(ctx context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *DockerPushStep) Name() string

+ type DockerRunStep struct

+ func (s *DockerRunStep) Execute(ctx context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *DockerRunStep) Name() string

+ type DriftCheckStep struct

+ func (s *DriftCheckStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *DriftCheckStep) Name() string

+ type DriftReport struct

+ Diffs []platform.DiffEntry

+ Drifted bool

+ Error string

+ ResourceName string

+ ResourceType string

+ type ErrorStrategy string

+ const ErrorStrategyCompensate

+ const ErrorStrategySkip

+ const ErrorStrategyStop

+ type EventBusBridge struct

+ func NewEventBusBridge(name string) *EventBusBridge

+ func (b *EventBusBridge) Consumer() MessageConsumer

+ func (b *EventBusBridge) Init(app modular.Application) error

+ func (b *EventBusBridge) InitFromApp(app modular.Application) error

+ func (b *EventBusBridge) Name() string

+ func (b *EventBusBridge) Producer() MessageProducer

+ func (b *EventBusBridge) SendMessage(topic string, message []byte) error

+ func (b *EventBusBridge) SetEventBus(eb *eventbus.EventBusModule)

+ func (b *EventBusBridge) Start(_ context.Context) error

+ func (b *EventBusBridge) Stop(_ context.Context) error

+ func (b *EventBusBridge) Subscribe(topic string, handler MessageHandler) error

+ func (b *EventBusBridge) Unsubscribe(topic string) error

+ type EventBusTrigger struct

+ func NewEventBusTrigger() *EventBusTrigger

+ func NewEventBusTriggerWithNamespace(namespace ModuleNamespaceProvider) *EventBusTrigger

+ func (t *EventBusTrigger) Configure(app modular.Application, triggerConfig any) error

+ func (t *EventBusTrigger) Init(app modular.Application) error

+ func (t *EventBusTrigger) Name() string

+ func (t *EventBusTrigger) SetEventBusAndEngine(eb *eventbus.EventBusModule, engine WorkflowEngine)

+ func (t *EventBusTrigger) Start(ctx context.Context) error

+ func (t *EventBusTrigger) Stop(_ context.Context) error

+ type EventBusTriggerSubscription struct

+ Action string

+ Async bool

+ Event string

+ Params map[string]any

+ Topic string

+ Workflow string

+ type EventData struct

+ CorrelID string

+ Data map[string]any

+ EventType string

+ RawMessage []byte

+ SourceID string

+ Timestamp time.Time

+ type EventHandler interface

+ HandlePattern func(ctx context.Context, match PatternMatch) error

+ type EventPattern struct

+ Condition string

+ EventTypes []string

+ ExtraParams map[string]any

+ MaxOccurs int

+ MinOccurs int

+ OrderMatters bool

+ PatternID string

+ WindowTime time.Duration

+ type EventProcessor struct

+ func GetProcessor(app modular.Application) (*EventProcessor, error)

+ func NewEventProcessor(name string) *EventProcessor

+ func (p *EventProcessor) AddPattern(pattern *EventPattern)

+ func (p *EventProcessor) Error() string

+ func (p *EventProcessor) GetService(name string, out any) error

+ func (p *EventProcessor) Init(app modular.Application) error

+ func (p *EventProcessor) Name() string

+ func (p *EventProcessor) ProcessEvent(ctx context.Context, event EventData) error

+ func (p *EventProcessor) ProvidesServices() []modular.ServiceProvider

+ func (p *EventProcessor) RegisterHandler(patternID string, handler EventHandler) error

+ func (p *EventProcessor) RequiresServices() []modular.ServiceDependency

+ func (p *EventProcessor) Service(name string) any

+ func (p *EventProcessor) Services() map[string]any

+ func (p *EventProcessor) SetError(err error)

+ func (p *EventProcessor) Start(ctx context.Context) error

+ func (p *EventProcessor) Stop(ctx context.Context) error

+ type EventProcessorLocator struct

+ App modular.Application

+ func NewEventProcessorLocator(app modular.Application) *EventProcessorLocator

+ func (l *EventProcessorLocator) Locate(name string) (*EventProcessor, error)

+ func (l *EventProcessorLocator) LocateDefault() (*EventProcessor, error)

+ type EventRecorder interface

+ RecordEvent func(ctx context.Context, executionID string, eventType string, data map[string]any) error

+ type EventTrigger struct

+ func NewEventTrigger() *EventTrigger

+ func NewEventTriggerWithNamespace(namespace ModuleNamespaceProvider) *EventTrigger

+ func (t *EventTrigger) Configure(app modular.Application, triggerConfig any) error

+ func (t *EventTrigger) Init(app modular.Application) error

+ func (t *EventTrigger) Name() string

+ func (t *EventTrigger) SetBrokerAndEngine(broker MessageBroker, engine WorkflowEngine)

+ func (t *EventTrigger) Start(ctx context.Context) error

+ func (t *EventTrigger) Stop(ctx context.Context) error

+ type EventTriggerConfig struct

+ Subscriptions []EventTriggerSubscription

+ type EventTriggerSubscription struct

+ Action string

+ Event string

+ Params map[string]any

+ Topic string

+ Workflow string

+ type ExecutionTracker struct

+ EventStoreRecorder EventRecorder

+ Store *V1Store

+ Tracer *tracing.WorkflowTracer

+ WorkflowID string

+ func (t *ExecutionTracker) RecordEvent(ctx context.Context, executionID string, eventType string, data map[string]any) error

+ func (t *ExecutionTracker) TrackPipelineExecution(ctx context.Context, pipeline *Pipeline, triggerData map[string]any, ...) (*PipelineContext, error)

+ type Executor interface

+ Execute func(ctx context.Context, params map[string]any) (map[string]any, error)

+ type ExternalOperation struct

+ HasBody bool

+ Method string

+ OperationID string

+ Path string

+ Summary string

+ Tags []string

+ type ExternalStateMachineDefinition struct

+ Description string

+ ID string

+ InitialState string

+ States map[string]StateMachineStateConfig

+ Transitions map[string]StateMachineTransitionConfig

+ type FFGateStep struct

+ func (s *FFGateStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *FFGateStep) Name() string

+ type FeatureFlagAdmin interface

+ CreateFlag func(data json.RawMessage) (any, error)

+ DeleteFlag func(key string) error

+ EvaluateFlag func(key string, user string, group string) (any, error)

+ GetFlag func(key string) (any, error)

+ ListFlags func() ([]any, error)

+ SSEHandler func() http.Handler

+ SetOverrides func(key string, data json.RawMessage) (any, error)

+ UpdateFlag func(key string, data json.RawMessage) (any, error)

+ type FeatureFlagAdminAdapter struct

+ func NewFeatureFlagAdminAdapter(service *featureflag.Service, store *generic.Store) *FeatureFlagAdminAdapter

+ func (a *FeatureFlagAdminAdapter) CreateFlag(data json.RawMessage) (any, error)

+ func (a *FeatureFlagAdminAdapter) DeleteFlag(key string) error

+ func (a *FeatureFlagAdminAdapter) EvaluateFlag(key string, user string, group string) (any, error)

+ func (a *FeatureFlagAdminAdapter) GetFlag(key string) (any, error)

+ func (a *FeatureFlagAdminAdapter) ListFlags() ([]any, error)

+ func (a *FeatureFlagAdminAdapter) SSEHandler() http.Handler

+ func (a *FeatureFlagAdminAdapter) SetOverrides(key string, data json.RawMessage) (any, error)

+ func (a *FeatureFlagAdminAdapter) UpdateFlag(key string, data json.RawMessage) (any, error)

+ type FeatureFlagModule struct

+ func NewFeatureFlagModule(name string, cfg FeatureFlagModuleConfig) (*FeatureFlagModule, error)

+ func (m *FeatureFlagModule) Init(_ modular.Application) error

+ func (m *FeatureFlagModule) Name() string

+ func (m *FeatureFlagModule) ProvidesServices() []modular.ServiceProvider

+ func (m *FeatureFlagModule) RequiresServices() []modular.ServiceDependency

+ func (m *FeatureFlagModule) SSEEnabled() bool

+ func (m *FeatureFlagModule) Service() *featureflag.Service

+ func (m *FeatureFlagModule) Store() *generic.Store

+ type FeatureFlagModuleConfig struct

+ CacheTTL string

+ DBPath string

+ Provider string

+ SSEEnabled bool

+ type FeatureFlagStep struct

+ func (s *FeatureFlagStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *FeatureFlagStep) Name() string

+ type FieldEncryptor struct

+ func NewFieldEncryptor(keyStr string) *FieldEncryptor

+ func NewFieldEncryptorFromEnv() *FieldEncryptor

+ func (e *FieldEncryptor) DecryptJSON(data []byte) ([]byte, error)

+ func (e *FieldEncryptor) DecryptPIIFields(data map[string]any) (map[string]any, error)

+ func (e *FieldEncryptor) DecryptValue(encoded string) (string, error)

+ func (e *FieldEncryptor) Enabled() bool

+ func (e *FieldEncryptor) EncryptJSON(data []byte) ([]byte, error)

+ func (e *FieldEncryptor) EncryptPIIFields(data map[string]any) (map[string]any, error)

+ func (e *FieldEncryptor) EncryptValue(plaintext string) (string, error)

+ type FieldMapping struct

+ func DefaultRESTFieldMapping() *FieldMapping

+ func FieldMappingFromConfig(cfg map[string]any) *FieldMapping

+ func NewFieldMapping() *FieldMapping

+ func (fm *FieldMapping) Clone() *FieldMapping

+ func (fm *FieldMapping) Has(logical string) bool

+ func (fm *FieldMapping) MarshalJSON() ([]byte, error)

+ func (fm *FieldMapping) Merge(other *FieldMapping)

+ func (fm *FieldMapping) Primary(logical string) string

+ func (fm *FieldMapping) Resolve(data map[string]any, logical string) (any, bool)

+ func (fm *FieldMapping) ResolveSlice(data map[string]any, logical string) []any

+ func (fm *FieldMapping) ResolveString(data map[string]any, logical string) string

+ func (fm *FieldMapping) Set(logical string, actual ...string)

+ func (fm *FieldMapping) SetValue(data map[string]any, logical string, value any)

+ func (fm *FieldMapping) String() string

+ func (fm *FieldMapping) UnmarshalJSON(data []byte) error

+ type Finding struct

+ Line int

+ Location string

+ Message string

+ RuleID string

+ Severity string

+ type FunctionHandler struct

+ func NewFunctionHandler(fn func(ctx context.Context, match PatternMatch) error) *FunctionHandler

+ func (h *FunctionHandler) HandlePattern(ctx context.Context, match PatternMatch) error

+ type FunctionJob struct

+ func NewFunctionJob(fn func(context.Context) error) *FunctionJob

+ func (j *FunctionJob) Execute(ctx context.Context) error

+ type FunctionMessageHandler struct

+ func NewFunctionMessageHandler(fn func(message []byte) error) *FunctionMessageHandler

+ func (h *FunctionMessageHandler) HandleMessage(message []byte) error

+ type FunctionTransitionHandler struct

+ func NewFunctionTransitionHandler(fn func(ctx context.Context, event TransitionEvent) error) *FunctionTransitionHandler

+ func (h *FunctionTransitionHandler) HandleTransition(ctx context.Context, event TransitionEvent) error

+ type GCSStorage struct

+ func NewGCSStorage(name string) *GCSStorage

+ func (g *GCSStorage) Delete(_ context.Context, _ string) error

+ func (g *GCSStorage) Get(_ context.Context, _ string) (io.ReadCloser, error)

+ func (g *GCSStorage) Init(app modular.Application) error

+ func (g *GCSStorage) List(_ context.Context, _ string) ([]store.FileInfo, error)

+ func (g *GCSStorage) Name() string

+ func (g *GCSStorage) ProvidesServices() []modular.ServiceProvider

+ func (g *GCSStorage) Put(_ context.Context, _ string, _ io.Reader) error

+ func (g *GCSStorage) RequiresServices() []modular.ServiceDependency

+ func (g *GCSStorage) SetBucket(bucket string)

+ func (g *GCSStorage) SetCredentialsFile(path string)

+ func (g *GCSStorage) SetProject(project string)

+ func (g *GCSStorage) Start(_ context.Context) error

+ func (g *GCSStorage) Stat(_ context.Context, _ string) (store.FileInfo, error)

+ func (g *GCSStorage) Stop(_ context.Context) error

+ type GateStep struct

+ func (s *GateStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *GateStep) Name() string

+ type GatewayRoute struct

+ Auth bool

+ Backend string

+ Methods []string

+ PathPrefix string

+ RateLimit *RateLimitConfig

+ StripPrefix bool

+ Timeout string

+ type HTTPCallStep struct

+ func (s *HTTPCallStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *HTTPCallStep) Name() string

+ type HTTPHandler interface

+ Handle func(w http.ResponseWriter, r *http.Request)

+ type HTTPHandlerAdapter struct

+ func NewHTTPHandlerAdapter(handler http.Handler) *HTTPHandlerAdapter

+ func (a *HTTPHandlerAdapter) Handle(w http.ResponseWriter, r *http.Request)

+ type HTTPIntegrationConnector struct

+ func NewHTTPIntegrationConnector(name, baseURL string) *HTTPIntegrationConnector

+ func (c *HTTPIntegrationConnector) Connect(ctx context.Context) error

+ func (c *HTTPIntegrationConnector) Disconnect(ctx context.Context) error

+ func (c *HTTPIntegrationConnector) Execute(ctx context.Context, action string, params map[string]any) (map[string]any, error)

+ func (c *HTTPIntegrationConnector) GetName() string

+ func (c *HTTPIntegrationConnector) IsConnected() bool

+ func (c *HTTPIntegrationConnector) SetAllowPrivateIPs(allow bool)

+ func (c *HTTPIntegrationConnector) SetBasicAuth(username, password string)

+ func (c *HTTPIntegrationConnector) SetBearerAuth(token string)

+ func (c *HTTPIntegrationConnector) SetDefaultHeader(key, value string)

+ func (c *HTTPIntegrationConnector) SetHeader(key, value string)

+ func (c *HTTPIntegrationConnector) SetRateLimit(requestsPerMinute int)

+ func (c *HTTPIntegrationConnector) SetTimeout(timeout time.Duration)

+ type HTTPMiddleware interface

+ Process func(next http.Handler) http.Handler

+ type HTTPRouter interface

+ AddRoute func(method, path string, handler HTTPHandler)

+ type HTTPServer interface

+ AddRouter func(router HTTPRouter)

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ type HTTPTrigger struct

+ func NewHTTPTrigger() *HTTPTrigger

+ func NewHTTPTriggerWithNamespace(namespace ModuleNamespaceProvider) *HTTPTrigger

+ func (t *HTTPTrigger) Configure(app modular.Application, triggerConfig any) error

+ func (t *HTTPTrigger) Init(app modular.Application) error

+ func (t *HTTPTrigger) Name() string

+ func (t *HTTPTrigger) Start(ctx context.Context) error

+ func (t *HTTPTrigger) Stop(ctx context.Context) error

+ type HTTPTriggerConfig struct

+ Routes []HTTPTriggerRoute

+ type HTTPTriggerRoute struct

+ Action string

+ Method string

+ Params map[string]any

+ Path string

+ Workflow string

+ type HealthCheck func(ctx context.Context) HealthCheckResult

+ type HealthCheckResult struct

+ Message string

+ Status string

+ type HealthCheckable interface

+ HealthStatus func() HealthCheckResult

+ type HealthChecker struct

+ func NewHealthChecker(name string) *HealthChecker

+ func (h *HealthChecker) AutoDiscover() bool

+ func (h *HealthChecker) DiscoverHealthCheckables()

+ func (h *HealthChecker) HealthHandler() http.HandlerFunc

+ func (h *HealthChecker) HealthPath() string

+ func (h *HealthChecker) Init(app modular.Application) error

+ func (h *HealthChecker) LiveHandler() http.HandlerFunc

+ func (h *HealthChecker) LivePath() string

+ func (h *HealthChecker) Name() string

+ func (h *HealthChecker) ProvidesServices() []modular.ServiceProvider

+ func (h *HealthChecker) ReadyHandler() http.HandlerFunc

+ func (h *HealthChecker) ReadyPath() string

+ func (h *HealthChecker) RegisterCheck(name string, check HealthCheck)

+ func (h *HealthChecker) RequiresServices() []modular.ServiceDependency

+ func (h *HealthChecker) SetConfig(cfg HealthCheckerConfig)

+ func (h *HealthChecker) SetStarted(started bool)

+ type HealthCheckerConfig struct

+ AutoDiscover bool

+ CheckTimeout time.Duration

+ HealthPath string

+ LivePath string

+ ReadyPath string

+ func DefaultHealthCheckerConfig() HealthCheckerConfig

+ type HealthHTTPHandler struct

+ Handler http.HandlerFunc

+ func (h *HealthHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ type InMemoryMessageBroker struct

+ func NewInMemoryMessageBroker(name string) *InMemoryMessageBroker

+ func NewInMemoryMessageBrokerWithNamespace(name string, namespace ModuleNamespaceProvider) *InMemoryMessageBroker

+ func NewStandardInMemoryMessageBroker(namespace ModuleNamespaceProvider) *InMemoryMessageBroker

+ func (b *InMemoryMessageBroker) Consumer() MessageConsumer

+ func (b *InMemoryMessageBroker) DeliveryTimeout() time.Duration

+ func (b *InMemoryMessageBroker) Init(app modular.Application) error

+ func (b *InMemoryMessageBroker) MaxQueueSize() int

+ func (b *InMemoryMessageBroker) Name() string

+ func (b *InMemoryMessageBroker) Producer() MessageProducer

+ func (b *InMemoryMessageBroker) ProvidesServices() []modular.ServiceProvider

+ func (b *InMemoryMessageBroker) RequiresServices() []modular.ServiceDependency

+ func (b *InMemoryMessageBroker) SendMessage(topic string, message []byte) error

+ func (b *InMemoryMessageBroker) SetDeliveryTimeout(d time.Duration)

+ func (b *InMemoryMessageBroker) SetMaxQueueSize(n int)

+ func (b *InMemoryMessageBroker) Start(ctx context.Context) error

+ func (b *InMemoryMessageBroker) Stop(ctx context.Context) error

+ func (b *InMemoryMessageBroker) Subscribe(topic string, handler MessageHandler) error

+ type IntegrationConnector interface

+ Connect func(ctx context.Context) error

+ Disconnect func(ctx context.Context) error

+ Execute func(ctx context.Context, action string, params map[string]any) (map[string]any, error)

+ GetName func() string

+ IsConnected func() bool

+ type IntegrationRegistry interface

+ GetConnector func(name string) (IntegrationConnector, error)

+ Init func(app modular.Application) error

+ ListConnectors func() []string

+ Name func() string

+ RegisterConnector func(connector IntegrationConnector)

+ Start func() error

+ Stop func() error

+ type JQStep struct

+ func (s *JQStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *JQStep) Name() string

+ type JSONResponseStep struct

+ func (s *JSONResponseStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *JSONResponseStep) Name() string

+ type JWTAuthModule struct

+ func NewJWTAuthModule(name, secret string, tokenExpiry time.Duration, issuer string) *JWTAuthModule

+ func (j *JWTAuthModule) Authenticate(tokenStr string) (bool, map[string]any, error)

+ func (j *JWTAuthModule) Handle(w http.ResponseWriter, r *http.Request)

+ func (j *JWTAuthModule) Init(app modular.Application) error

+ func (j *JWTAuthModule) Name() string

+ func (j *JWTAuthModule) ProvidesServices() []modular.ServiceProvider

+ func (j *JWTAuthModule) RequiresServices() []modular.ServiceDependency

+ func (j *JWTAuthModule) SetResponseFormat(format string)

+ func (j *JWTAuthModule) SetSeedFile(path string)

+ func (j *JWTAuthModule) Start(ctx context.Context) error

+ func (j *JWTAuthModule) Stop(ctx context.Context) error

+ type Job interface

+ Execute func(ctx context.Context) error

+ type KafkaBroker struct

+ func NewKafkaBroker(name string) *KafkaBroker

+ func (b *KafkaBroker) Consumer() MessageConsumer

+ func (b *KafkaBroker) HealthStatus() HealthCheckResult

+ func (b *KafkaBroker) Init(app modular.Application) error

+ func (b *KafkaBroker) Name() string

+ func (b *KafkaBroker) Producer() MessageProducer

+ func (b *KafkaBroker) ProvidesServices() []modular.ServiceProvider

+ func (b *KafkaBroker) RequiresServices() []modular.ServiceDependency

+ func (b *KafkaBroker) SetBrokers(brokers []string)

+ func (b *KafkaBroker) SetGroupID(groupID string)

+ func (b *KafkaBroker) Start(ctx context.Context) error

+ func (b *KafkaBroker) Stop(_ context.Context) error

+ func (b *KafkaBroker) Subscribe(topic string, handler MessageHandler) error

+ type ListenerAdapter struct

+ func NewListenerAdapter(listener TransitionListener) *ListenerAdapter

+ func (a *ListenerAdapter) HandleTransition(ctx context.Context, event TransitionEvent) error

+ type LocalStorageModule struct

+ func NewLocalStorageModule(name, rootDir string) *LocalStorageModule

+ func (m *LocalStorageModule) Delete(ctx context.Context, path string) error

+ func (m *LocalStorageModule) Get(ctx context.Context, path string) (io.ReadCloser, error)

+ func (m *LocalStorageModule) Init(app modular.Application) error

+ func (m *LocalStorageModule) List(ctx context.Context, prefix string) ([]store.FileInfo, error)

+ func (m *LocalStorageModule) Name() string

+ func (m *LocalStorageModule) ProvidesServices() []modular.ServiceProvider

+ func (m *LocalStorageModule) Put(ctx context.Context, path string, reader io.Reader) error

+ func (m *LocalStorageModule) RequiresServices() []modular.ServiceDependency

+ func (m *LocalStorageModule) Start(_ context.Context) error

+ func (m *LocalStorageModule) Stat(ctx context.Context, path string) (store.FileInfo, error)

+ func (m *LocalStorageModule) Stop(_ context.Context) error

+ func (m *LocalStorageModule) Storage() store.StorageProvider

+ type LogCollector struct

+ func NewLogCollector(name string, cfg LogCollectorConfig) *LogCollector

+ func (lc *LogCollector) AddEntry(entry LogEntry)

+ func (lc *LogCollector) CollectFromEmitters()

+ func (lc *LogCollector) Entries() []LogEntry

+ func (lc *LogCollector) Init(app modular.Application) error

+ func (lc *LogCollector) LogHandler() http.HandlerFunc

+ func (lc *LogCollector) Name() string

+ func (lc *LogCollector) ProvidesServices() []modular.ServiceProvider

+ func (lc *LogCollector) RequiresServices() []modular.ServiceDependency

+ func (lc *LogCollector) StartCollectionLoop(ctx context.Context, interval time.Duration) context.CancelFunc

+ type LogCollectorConfig struct

+ LogLevel string

+ OutputFormat string

+ RetentionDays int

+ type LogEmitter interface

+ DrainLogs func() []LogEntry

+ type LogEntry struct

+ Level string

+ Message string

+ Module string

+ Timestamp time.Time

+ type LogHTTPHandler struct

+ Handler http.HandlerFunc

+ func (h *LogHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ type LogStep struct

+ func (s *LogStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *LogStep) Name() string

+ type LoggingMiddleware struct

+ func NewLoggingMiddleware(name string, logLevel string) *LoggingMiddleware

+ func (m *LoggingMiddleware) Init(app modular.Application) error

+ func (m *LoggingMiddleware) Name() string

+ func (m *LoggingMiddleware) Process(next http.Handler) http.Handler

+ func (m *LoggingMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *LoggingMiddleware) RequiresServices() []modular.ServiceDependency

+ type MessageBroker interface

+ Consumer func() MessageConsumer

+ Producer func() MessageProducer

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ Subscribe func(topic string, handler MessageHandler) error

+ type MessageConsumer interface

+ Subscribe func(topic string, handler MessageHandler) error

+ Unsubscribe func(topic string) error

+ type MessageHandler interface

+ HandleMessage func(message []byte) error

+ type MessageHandlerAdapter struct

+ func (a *MessageHandlerAdapter) HandleMessage(msg []byte) error

+ type MessageHandlerJobAdapter struct

+ func NewMessageHandlerJobAdapter(handler MessageHandler) *MessageHandlerJobAdapter

+ func (a *MessageHandlerJobAdapter) Execute(ctx context.Context) error

+ type MessageProducer interface

+ SendMessage func(topic string, message []byte) error

+ type MetricsCollector struct

+ ActiveWorkflows *prometheus.GaugeVec

+ HTTPRequestDuration *prometheus.HistogramVec

+ HTTPRequestsTotal *prometheus.CounterVec

+ ModuleOperations *prometheus.CounterVec

+ WorkflowDuration *prometheus.HistogramVec

+ WorkflowExecutions *prometheus.CounterVec

+ func NewMetricsCollector(name string) *MetricsCollector

+ func NewMetricsCollectorWithConfig(name string, cfg MetricsCollectorConfig) *MetricsCollector

+ func (m *MetricsCollector) Handler() http.Handler

+ func (m *MetricsCollector) Init(app modular.Application) error

+ func (m *MetricsCollector) MetricsPath() string

+ func (m *MetricsCollector) Name() string

+ func (m *MetricsCollector) ProvidesServices() []modular.ServiceProvider

+ func (m *MetricsCollector) RecordHTTPRequest(method, path string, statusCode int, duration time.Duration)

+ func (m *MetricsCollector) RecordModuleOperation(module, operation, status string)

+ func (m *MetricsCollector) RecordWorkflowDuration(workflowType, action string, duration time.Duration)

+ func (m *MetricsCollector) RecordWorkflowExecution(workflowType, action, status string)

+ func (m *MetricsCollector) RequiresServices() []modular.ServiceDependency

+ func (m *MetricsCollector) SetActiveWorkflows(workflowType string, count float64)

+ type MetricsCollectorConfig struct

+ EnabledMetrics []string

+ MetricsPath string

+ Namespace string

+ Subsystem string

+ func DefaultMetricsCollectorConfig() MetricsCollectorConfig

+ type MetricsHTTPHandler struct

+ Handler http.Handler

+ func (h *MetricsHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ type MockApplication struct

+ Config map[string]any

+ ConfigSectionMap map[string]modular.ConfigProvider

+ MockLogger *MockLogger

+ Modules map[string]modular.Module

+ Services map[string]any

+ func NewMockApplication() *MockApplication

+ func (a *MockApplication) ConfigProvider() modular.ConfigProvider

+ func (a *MockApplication) ConfigSections() map[string]modular.ConfigProvider

+ func (a *MockApplication) GetAllModules() map[string]modular.Module

+ func (a *MockApplication) GetConfig() map[string]any

+ func (a *MockApplication) GetConfigSection(section string) (modular.ConfigProvider, error)

+ func (a *MockApplication) GetModule(name string) modular.Module

+ func (a *MockApplication) GetService(name string, out any) error

+ func (a *MockApplication) GetServiceEntry(serviceName string) (*modular.ServiceRegistryEntry, bool)

+ func (a *MockApplication) GetServicesByInterface(interfaceType reflect.Type) []*modular.ServiceRegistryEntry

+ func (a *MockApplication) GetServicesByModule(moduleName string) []string

+ func (a *MockApplication) Init() error

+ func (a *MockApplication) IsVerboseConfig() bool

+ func (a *MockApplication) Logger() modular.Logger

+ func (a *MockApplication) OnConfigLoaded(hook func(modular.Application) error)

+ func (a *MockApplication) RegisterConfigSection(name string, config modular.ConfigProvider)

+ func (a *MockApplication) RegisterModule(module modular.Module)

+ func (a *MockApplication) RegisterService(name string, service any) error

+ func (a *MockApplication) Run() error

+ func (a *MockApplication) SetLogger(logger modular.Logger)

+ func (a *MockApplication) SetVerboseConfig(enabled bool)

+ func (a *MockApplication) Start() error

+ func (a *MockApplication) StartTime() time.Time

+ func (a *MockApplication) Stop() error

+ func (a *MockApplication) SvcRegistry() modular.ServiceRegistry

+ type MockConfigProvider struct

+ Config map[string]any

+ func (p *MockConfigProvider) GetConfig() any

+ type MockLogger struct

+ Messages []string

+ func (l *MockLogger) Debug(format string, args ...any)

+ func (l *MockLogger) Error(format string, args ...any)

+ func (l *MockLogger) Fatal(format string, args ...any)

+ func (l *MockLogger) Info(format string, args ...any)

+ func (l *MockLogger) Warn(format string, args ...any)

+ type MockScheduler struct

+ func NewMockScheduler() *MockScheduler

+ func (s *MockScheduler) Init(registry modular.ServiceRegistry) error

+ func (s *MockScheduler) Name() string

+ func (s *MockScheduler) Schedule(job Job) error

+ func (s *MockScheduler) SetCronExpression(index int, cronExpression string)

+ func (s *MockScheduler) Start(ctx context.Context) error

+ func (s *MockScheduler) Stop(ctx context.Context) error

+ type MockWorkflowEngine struct

+ func NewMockWorkflowEngine() *MockWorkflowEngine

+ func (e *MockWorkflowEngine) TriggerWorkflow(ctx context.Context, workflowType string, action string, data map[string]any) error

+ type ModuleNamespace struct

+ func NewModuleNamespace(prefix string, suffix string) *ModuleNamespace

+ func (ns *ModuleNamespace) FormatName(baseName string) string

+ func (ns *ModuleNamespace) ResolveDependency(dependencyName string) string

+ func (ns *ModuleNamespace) ResolveServiceName(serviceName string) string

+ type ModuleNamespaceProvider interface

+ FormatName func(baseName string) string

+ ResolveDependency func(dependencyName string) string

+ ResolveServiceName func(serviceName string) string

+ ValidateModuleName func(moduleName string) error

+ type ModuleNamespaceProviderFunc struct

+ FormatNameFunc func(baseName string) string

+ ResolveDependencyFunc func(dependencyName string) string

+ ResolveServiceNameFunc func(serviceName string) string

+ ValidateModuleNameFunc func(moduleName string) error

+ func (m ModuleNamespaceProviderFunc) FormatName(baseName string) string

+ func (m ModuleNamespaceProviderFunc) ResolveDependency(dependencyName string) string

+ func (m ModuleNamespaceProviderFunc) ResolveServiceName(serviceName string) string

+ func (m ModuleNamespaceProviderFunc) ValidateModuleName(moduleName string) error

+ type NATSBroker struct

+ func NewNATSBroker(name string) *NATSBroker

+ func (b *NATSBroker) Consumer() MessageConsumer

+ func (b *NATSBroker) Init(app modular.Application) error

+ func (b *NATSBroker) Name() string

+ func (b *NATSBroker) Producer() MessageProducer

+ func (b *NATSBroker) ProvidesServices() []modular.ServiceProvider

+ func (b *NATSBroker) RequiresServices() []modular.ServiceDependency

+ func (b *NATSBroker) SetURL(url string)

+ func (b *NATSBroker) Start(ctx context.Context) error

+ func (b *NATSBroker) Stop(_ context.Context) error

+ func (b *NATSBroker) Subscribe(topic string, handler MessageHandler) error

+ type OTelTracing struct

+ func NewOTelTracing(name string) *OTelTracing

+ func (o *OTelTracing) Init(app modular.Application) error

+ func (o *OTelTracing) Name() string

+ func (o *OTelTracing) ProvidesServices() []modular.ServiceProvider

+ func (o *OTelTracing) RequiresServices() []modular.ServiceDependency

+ func (o *OTelTracing) SetEndpoint(endpoint string)

+ func (o *OTelTracing) SetServiceName(serviceName string)

+ func (o *OTelTracing) Start(ctx context.Context) error

+ func (o *OTelTracing) Stop(ctx context.Context) error

+ type OpenAPIComponents struct

+ Schemas map[string]*OpenAPISchema

+ type OpenAPIConsumer struct

+ func NewOpenAPIConsumer(name string, config OpenAPIConsumerConfig) *OpenAPIConsumer

+ func (c *OpenAPIConsumer) CallOperation(ctx context.Context, operationID string, data map[string]any) (map[string]any, error)

+ func (c *OpenAPIConsumer) GetFieldMapping() *FieldMapping

+ func (c *OpenAPIConsumer) GetSpec() *OpenAPISpec

+ func (c *OpenAPIConsumer) Init(app modular.Application) error

+ func (c *OpenAPIConsumer) ListOperations() []ExternalOperation

+ func (c *OpenAPIConsumer) Name() string

+ func (c *OpenAPIConsumer) ProvidesServices() []modular.ServiceProvider

+ func (c *OpenAPIConsumer) RequiresServices() []modular.ServiceDependency

+ func (c *OpenAPIConsumer) ServeOperations(w http.ResponseWriter, _ *http.Request)

+ func (c *OpenAPIConsumer) ServeSpec(w http.ResponseWriter, _ *http.Request)

+ func (c *OpenAPIConsumer) SetClient(client *http.Client)

+ func (c *OpenAPIConsumer) SetFieldMapping(fm *FieldMapping)

+ type OpenAPIConsumerConfig struct

+ SpecFile string

+ SpecURL string

+ type OpenAPIGenerator struct

+ func NewOpenAPIGenerator(name string, config OpenAPIGeneratorConfig) *OpenAPIGenerator

+ func (g *OpenAPIGenerator) ApplySchemas()

+ func (g *OpenAPIGenerator) BuildSpec(workflows map[string]any)

+ func (g *OpenAPIGenerator) BuildSpecFromRoutes(routes []RouteDefinition)

+ func (g *OpenAPIGenerator) GetSpec() *OpenAPISpec

+ func (g *OpenAPIGenerator) Handle(w http.ResponseWriter, r *http.Request)

+ func (g *OpenAPIGenerator) Init(app modular.Application) error

+ func (g *OpenAPIGenerator) Name() string

+ func (g *OpenAPIGenerator) ProvidesServices() []modular.ServiceProvider

+ func (g *OpenAPIGenerator) RegisterComponentSchema(name string, schema *OpenAPISchema)

+ func (g *OpenAPIGenerator) RequiresServices() []modular.ServiceDependency

+ func (g *OpenAPIGenerator) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (g *OpenAPIGenerator) ServeJSON(w http.ResponseWriter, _ *http.Request)

+ func (g *OpenAPIGenerator) ServeYAML(w http.ResponseWriter, _ *http.Request)

+ func (g *OpenAPIGenerator) SetOperationSchema(method, path string, req, resp *OpenAPISchema)

+ func (g *OpenAPIGenerator) SortedPaths() []string

+ type OpenAPIGeneratorConfig struct

+ Description string

+ Servers []string

+ Title string

+ Version string

+ type OpenAPIHTTPHandler struct

+ Handler http.HandlerFunc

+ func (h *OpenAPIHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ type OpenAPIInfo struct

+ Description string

+ Title string

+ Version string

+ type OpenAPIMediaType struct

+ Schema *OpenAPISchema

+ type OpenAPIOperation struct

+ OperationID string

+ Parameters []OpenAPIParameter

+ RequestBody *OpenAPIRequestBody

+ Responses map[string]*OpenAPIResponse

+ Summary string

+ Tags []string

+ type OpenAPIParameter struct

+ Description string

+ In string

+ Name string

+ Required bool

+ Schema *OpenAPISchema

+ type OpenAPIPath struct

+ Delete *OpenAPIOperation

+ Get *OpenAPIOperation

+ Options *OpenAPIOperation

+ Patch *OpenAPIOperation

+ Post *OpenAPIOperation

+ Put *OpenAPIOperation

+ type OpenAPIRequestBody struct

+ Content map[string]*OpenAPIMediaType

+ Description string

+ Required bool

+ type OpenAPIResponse struct

+ Content map[string]*OpenAPIMediaType

+ Description string

+ type OpenAPISchema struct

+ AdditionalProperties *OpenAPISchema

+ Description string

+ Enum []string

+ Example any

+ Format string

+ Items *OpenAPISchema

+ Nullable bool

+ Properties map[string]*OpenAPISchema

+ Ref string

+ Required []string

+ Type string

+ func SchemaArray(items *OpenAPISchema) *OpenAPISchema

+ func SchemaRef(name string) *OpenAPISchema

+ type OpenAPIServer struct

+ Description string

+ URL string

+ type OpenAPISpec struct

+ Components *OpenAPIComponents

+ Info OpenAPIInfo

+ OpenAPI string

+ Paths map[string]*OpenAPIPath

+ Servers []OpenAPIServer

+ type PatternMatch struct

+ Events []EventData

+ MatchedTime time.Time

+ PatternID string

+ type PersistenceStore struct

+ func NewPersistenceStore(name, dbServiceName string) *PersistenceStore

+ func (p *PersistenceStore) DeleteResource(resourceType, id string) error

+ func (p *PersistenceStore) Init(app modular.Application) error

+ func (p *PersistenceStore) LoadResource(resourceType, id string) (map[string]any, error)

+ func (p *PersistenceStore) LoadResources(resourceType string) (map[string]map[string]any, error)

+ func (p *PersistenceStore) LoadUsers() ([]UserRecord, error)

+ func (p *PersistenceStore) LoadWorkflowInstances(workflowType string) ([]*WorkflowInstance, error)

+ func (p *PersistenceStore) Name() string

+ func (p *PersistenceStore) Ping(ctx context.Context) error

+ func (p *PersistenceStore) ProvidesServices() []modular.ServiceProvider

+ func (p *PersistenceStore) RequiresServices() []modular.ServiceDependency

+ func (p *PersistenceStore) SaveResource(resourceType, id string, data map[string]any) error

+ func (p *PersistenceStore) SaveUser(user UserRecord) error

+ func (p *PersistenceStore) SaveWorkflowInstance(instance *WorkflowInstance) error

+ func (p *PersistenceStore) SetDB(db *sql.DB)

+ func (p *PersistenceStore) SetEncryptor(enc *FieldEncryptor)

+ func (p *PersistenceStore) Start(ctx context.Context) error

+ func (p *PersistenceStore) Stop(ctx context.Context) error

+ type Pipeline struct

+ Compensation []PipelineStep

+ EventRecorder EventRecorder

+ ExecutionID string

+ Logger *slog.Logger

+ Metadata map[string]any

+ Name string

+ OnError ErrorStrategy

+ RoutePattern string

+ Steps []PipelineStep

+ Timeout time.Duration

+ func (p *Pipeline) Execute(ctx context.Context, triggerData map[string]any) (*PipelineContext, error)

+ type PipelineContext struct

+ Current map[string]any

+ Metadata map[string]any

+ StepOutputs map[string]map[string]any

+ TriggerData map[string]any

+ func NewPipelineContext(triggerData map[string]any, metadata map[string]any) *PipelineContext

+ func (pc *PipelineContext) MergeStepOutput(stepName string, output map[string]any)

+ type PipelineStep interface

+ Execute func(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ Name func() string

+ type PlatformApplyStep struct

+ func (s *PlatformApplyStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *PlatformApplyStep) Name() string

+ type PlatformDestroyStep struct

+ func (s *PlatformDestroyStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *PlatformDestroyStep) Name() string

+ type PlatformPlanStep struct

+ func (s *PlatformPlanStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *PlatformPlanStep) Name() string

+ type PlatformTemplateStep struct

+ func (s *PlatformTemplateStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *PlatformTemplateStep) Name() string

+ type PortAllocator struct

+ func NewPortAllocator(basePort int) *PortAllocator

+ func (p *PortAllocator) Allocate(name string) (int, error)

+ func (p *PortAllocator) AllocatedPorts() map[int]string

+ func (p *PortAllocator) ExcludePort(port int, name string)

+ func (p *PortAllocator) Release(name string)

+ type ProcessingStep struct

+ func NewProcessingStep(name string, config ProcessingStepConfig) *ProcessingStep

+ func (ps *ProcessingStep) HandleTransition(ctx context.Context, event TransitionEvent) error

+ func (ps *ProcessingStep) Init(app modular.Application) error

+ func (ps *ProcessingStep) Name() string

+ func (ps *ProcessingStep) ProvidesServices() []modular.ServiceProvider

+ func (ps *ProcessingStep) RequiresServices() []modular.ServiceDependency

+ func (ps *ProcessingStep) Start(_ context.Context) error

+ func (ps *ProcessingStep) Stop(_ context.Context) error

+ type ProcessingStepConfig struct

+ CompensateTransition string

+ ComponentID string

+ MaxRetries int

+ RetryBackoffMs int

+ SuccessTransition string

+ TimeoutSeconds int

+ type PublishStep struct

+ func (s *PublishStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *PublishStep) Name() string

+ type QueryFunc func(ctx context.Context, r *http.Request) (any, error)

+ type QueryHandler struct

+ func NewQueryHandler(name string) *QueryHandler

+ func (h *QueryHandler) Handle(w http.ResponseWriter, r *http.Request)

+ func (h *QueryHandler) Init(app modular.Application) error

+ func (h *QueryHandler) Name() string

+ func (h *QueryHandler) ProvidesServices() []modular.ServiceProvider

+ func (h *QueryHandler) RegisterQuery(name string, fn QueryFunc)

+ func (h *QueryHandler) RequiresServices() []modular.ServiceDependency

+ func (h *QueryHandler) ResolveDelegatePostStart()

+ func (h *QueryHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *QueryHandler) SetDelegate(name string)

+ func (h *QueryHandler) SetDelegateHandler(handler http.Handler)

+ func (h *QueryHandler) SetExecutionTracker(t *ExecutionTracker)

+ func (h *QueryHandler) SetRoutePipeline(routePath string, pipeline *Pipeline)

+ type QueryResult struct

+ Columns []string

+ Count int

+ Rows []map[string]any

+ type RESTAPIHandler struct

+ func NewRESTAPIHandler(name, resourceName string) *RESTAPIHandler

+ func (h *RESTAPIHandler) Constructor() modular.ModuleConstructor

+ func (h *RESTAPIHandler) Handle(w http.ResponseWriter, r *http.Request)

+ func (h *RESTAPIHandler) Init(app modular.Application) error

+ func (h *RESTAPIHandler) Name() string

+ func (h *RESTAPIHandler) ProvidesServices() []modular.ServiceProvider

+ func (h *RESTAPIHandler) RequiresServices() []modular.ServiceDependency

+ func (h *RESTAPIHandler) SetFieldMapping(fm *FieldMapping)

+ func (h *RESTAPIHandler) SetInitialTransition(t string)

+ func (h *RESTAPIHandler) SetInstanceIDPrefix(prefix string)

+ func (h *RESTAPIHandler) SetSeedFile(path string)

+ func (h *RESTAPIHandler) SetSourceResourceName(name string)

+ func (h *RESTAPIHandler) SetStateFilter(state string)

+ func (h *RESTAPIHandler) SetSummaryFields(fields []string)

+ func (h *RESTAPIHandler) SetTransitionMap(tm map[string]string)

+ func (h *RESTAPIHandler) SetWorkflowEngine(we string)

+ func (h *RESTAPIHandler) SetWorkflowType(wt string)

+ func (h *RESTAPIHandler) Start(ctx context.Context) error

+ func (h *RESTAPIHandler) Stop(ctx context.Context) error

+ type RESTAPIHandlerConfig struct

+ InstanceIDField string

+ InstanceIDPrefix string

+ PublishEvents bool

+ ResourceName string

+ WorkflowEngine string

+ WorkflowType string

+ type RESTResource struct

+ Data map[string]any

+ ID string

+ LastUpdate string

+ State string

+ type RateLimitConfig struct

+ BurstSize int

+ RequestsPerMinute int

+ type RateLimitMiddleware struct

+ func NewRateLimitMiddleware(name string, requestsPerMinute, burstSize int) *RateLimitMiddleware

+ func NewRateLimitMiddlewareWithStrategy(name string, requestsPerMinute, burstSize int, strategy RateLimitStrategy) *RateLimitMiddleware

+ func (m *RateLimitMiddleware) Init(app modular.Application) error

+ func (m *RateLimitMiddleware) Name() string

+ func (m *RateLimitMiddleware) Process(next http.Handler) http.Handler

+ func (m *RateLimitMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *RateLimitMiddleware) RequiresServices() []modular.ServiceDependency

+ func (m *RateLimitMiddleware) SetTokenHeader(header string)

+ func (m *RateLimitMiddleware) Start(_ context.Context) error

+ func (m *RateLimitMiddleware) Stop(_ context.Context) error

+ func (m *RateLimitMiddleware) Strategy() RateLimitStrategy

+ type RateLimitStep struct

+ func (s *RateLimitStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *RateLimitStep) Name() string

+ type RateLimitStrategy string

+ const RateLimitByIP

+ const RateLimitByIPAndToken

+ const RateLimitByToken

+ type ReconciliationTrigger struct

+ func NewReconciliationTrigger() *ReconciliationTrigger

+ func (t *ReconciliationTrigger) Configure(app modular.Application, triggerConfig any) error

+ func (t *ReconciliationTrigger) Dependencies() []string

+ func (t *ReconciliationTrigger) Init(app modular.Application) error

+ func (t *ReconciliationTrigger) Name() string

+ func (t *ReconciliationTrigger) Start(ctx context.Context) error

+ func (t *ReconciliationTrigger) Stop(_ context.Context) error

+ type RequestIDMiddleware struct

+ func NewRequestIDMiddleware(name string) *RequestIDMiddleware

+ func (m *RequestIDMiddleware) Init(app modular.Application) error

+ func (m *RequestIDMiddleware) Middleware() func(http.Handler) http.Handler

+ func (m *RequestIDMiddleware) Name() string

+ func (m *RequestIDMiddleware) Process(next http.Handler) http.Handler

+ func (m *RequestIDMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *RequestIDMiddleware) RequiresServices() []modular.ServiceDependency

+ type RequestParseStep struct

+ func (s *RequestParseStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *RequestParseStep) Name() string

+ type ResourceStateMapping struct

+ InstanceIDKey string

+ ResourceType string

+ StateMachine string

+ type Route struct

+ Handler HTTPHandler

+ Method string

+ Middlewares []HTTPMiddleware

+ Path string

+ type RouteDefinition struct

+ Handler string

+ Method string

+ Middlewares []string

+ Path string

+ Summary string

+ Tags []string

+ type RuntimeEngineBuilder func(cfg *config.WorkflowConfig, logger *slog.Logger) (stopFunc func(context.Context) error, err error)

+ type RuntimeHandler struct

+ func NewRuntimeHandler(manager *RuntimeManager) *RuntimeHandler

+ func (h *RuntimeHandler) RegisterRoutes(mux *http.ServeMux)

+ func (h *RuntimeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type RuntimeInstance struct

+ Config *config.WorkflowConfig

+ ConfigPath string

+ Error string

+ ID string

+ Name string

+ Ports map[string]int

+ StartedAt time.Time

+ Status string

+ WorkDir string

+ type RuntimeManager struct

+ func NewRuntimeManager(store *V1Store, builder RuntimeEngineBuilder, logger *slog.Logger) *RuntimeManager

+ func (rm *RuntimeManager) AnnounceServices(instance *RuntimeInstance)

+ func (rm *RuntimeManager) GetInstance(id string) (*RuntimeInstance, bool)

+ func (rm *RuntimeManager) LaunchFromPath(ctx context.Context, path string) (*RuntimeInstance, error)

+ func (rm *RuntimeManager) LaunchFromWorkspace(ctx context.Context, id, name, yamlContent, workspaceDir string) error

+ func (rm *RuntimeManager) LaunchFromYAML(ctx context.Context, id, name, yamlContent string) error

+ func (rm *RuntimeManager) ListInstances() []RuntimeInstance

+ func (rm *RuntimeManager) LoadFromPaths(ctx context.Context, paths []string) error

+ func (rm *RuntimeManager) SetPortAllocator(pa *PortAllocator)

+ func (rm *RuntimeManager) StopAll(ctx context.Context) error

+ func (rm *RuntimeManager) StopWorkflow(ctx context.Context, id string) error

+ type S3Storage struct

+ func NewS3Storage(name string) *S3Storage

+ func (s *S3Storage) DeleteObject(ctx context.Context, key string) error

+ func (s *S3Storage) GetObject(ctx context.Context, key string) (io.ReadCloser, error)

+ func (s *S3Storage) Init(app modular.Application) error

+ func (s *S3Storage) Name() string

+ func (s *S3Storage) ProvidesServices() []modular.ServiceProvider

+ func (s *S3Storage) PutObject(ctx context.Context, key string, body io.Reader) error

+ func (s *S3Storage) RequiresServices() []modular.ServiceDependency

+ func (s *S3Storage) SetBucket(bucket string)

+ func (s *S3Storage) SetClient(client *s3.Client)

+ func (s *S3Storage) SetEndpoint(endpoint string)

+ func (s *S3Storage) SetRegion(region string)

+ func (s *S3Storage) Start(ctx context.Context) error

+ func (s *S3Storage) Stop(_ context.Context) error

+ type SQLiteStorage struct

+ func NewSQLiteStorage(name, dbPath string) *SQLiteStorage

+ func (s *SQLiteStorage) DB() *sql.DB

+ func (s *SQLiteStorage) Init(app modular.Application) error

+ func (s *SQLiteStorage) Name() string

+ func (s *SQLiteStorage) ProvidesServices() []modular.ServiceProvider

+ func (s *SQLiteStorage) RequiresServices() []modular.ServiceDependency

+ func (s *SQLiteStorage) SetMaxConnections(n int)

+ func (s *SQLiteStorage) SetWALMode(enabled bool)

+ func (s *SQLiteStorage) Start(_ context.Context) error

+ func (s *SQLiteStorage) Stop(_ context.Context) error

+ type SSEEvent struct

+ Data string

+ Event string

+ ID string

+ type SSETracer struct

+ func NewSSETracer(logger *slog.Logger) *SSETracer

+ func (t *SSETracer) ActiveSubscribers() int

+ func (t *SSETracer) Handler() http.HandlerFunc

+ func (t *SSETracer) Publish(executionID string, event SSEEvent)

+ func (t *SSETracer) Subscribe(executionID string) (<-chan SSEEvent, func())

+ type ScanContainerStep struct

+ func (s *ScanContainerStep) Execute(_ context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *ScanContainerStep) Name() string

+ type ScanDepsStep struct

+ func (s *ScanDepsStep) Execute(_ context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *ScanDepsStep) Name() string

+ type ScanResult struct

+ Findings []Finding

+ PassedGate bool

+ Scanner string

+ Summary ScanSummary

+ func NewScanResult(scanner string) *ScanResult

+ func (sr *ScanResult) AddFinding(f Finding)

+ func (sr *ScanResult) ComputeSummary()

+ func (sr *ScanResult) EvaluateGate(threshold string) bool

+ type ScanSASTStep struct

+ func (s *ScanSASTStep) Execute(_ context.Context, _ *PipelineContext) (*StepResult, error)

+ func (s *ScanSASTStep) Name() string

+ type ScanSummary struct

+ Critical int

+ High int

+ Info int

+ Low int

+ Medium int

+ type ScheduleTrigger struct

+ func NewScheduleTrigger() *ScheduleTrigger

+ func NewScheduleTriggerWithNamespace(namespace ModuleNamespaceProvider) *ScheduleTrigger

+ func (t *ScheduleTrigger) Configure(app modular.Application, triggerConfig any) error

+ func (t *ScheduleTrigger) Init(app modular.Application) error

+ func (t *ScheduleTrigger) Name() string

+ func (t *ScheduleTrigger) Start(ctx context.Context) error

+ func (t *ScheduleTrigger) Stop(ctx context.Context) error

+ type ScheduleTriggerConfig struct

+ Jobs []ScheduleTriggerJob

+ type ScheduleTriggerJob struct

+ Action string

+ Cron string

+ Params map[string]any

+ Workflow string

+ type ScheduledJobInfo struct

+ type ScheduledWindow struct

+ EndHour int

+ StartHour int

+ Weekdays []time.Weekday

+ type Scheduler interface

+ Schedule func(job Job) error

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ type SecretsAWSModule struct

+ func NewSecretsAWSModule(name string) *SecretsAWSModule

+ func (m *SecretsAWSModule) Get(ctx context.Context, key string) (string, error)

+ func (m *SecretsAWSModule) Init(app modular.Application) error

+ func (m *SecretsAWSModule) Name() string

+ func (m *SecretsAWSModule) Provider() secrets.Provider

+ func (m *SecretsAWSModule) ProvidesServices() []modular.ServiceProvider

+ func (m *SecretsAWSModule) RequiresServices() []modular.ServiceDependency

+ func (m *SecretsAWSModule) SetAccessKeyID(id string)

+ func (m *SecretsAWSModule) SetRegion(region string)

+ func (m *SecretsAWSModule) SetSecretAccessKey(key string)

+ func (m *SecretsAWSModule) Start(_ context.Context) error

+ func (m *SecretsAWSModule) Stop(_ context.Context) error

+ type SecretsVaultModule struct

+ func NewSecretsVaultModule(name string) *SecretsVaultModule

+ func (m *SecretsVaultModule) Get(ctx context.Context, key string) (string, error)

+ func (m *SecretsVaultModule) Init(app modular.Application) error

+ func (m *SecretsVaultModule) Name() string

+ func (m *SecretsVaultModule) Provider() secrets.Provider

+ func (m *SecretsVaultModule) ProvidesServices() []modular.ServiceProvider

+ func (m *SecretsVaultModule) RequiresServices() []modular.ServiceDependency

+ func (m *SecretsVaultModule) SetAddress(addr string)

+ func (m *SecretsVaultModule) SetMode(mode string)

+ func (m *SecretsVaultModule) SetMountPath(path string)

+ func (m *SecretsVaultModule) SetNamespace(ns string)

+ func (m *SecretsVaultModule) SetToken(token string)

+ func (m *SecretsVaultModule) Start(_ context.Context) error

+ func (m *SecretsVaultModule) Stop(_ context.Context) error

+ type SecurityHeadersConfig struct

+ ContentSecurityPolicy string

+ ContentTypeOptions string

+ FrameOptions string

+ HSTSMaxAge int

+ PermissionsPolicy string

+ ReferrerPolicy string

+ type SecurityHeadersMiddleware struct

+ func NewSecurityHeadersMiddleware(name string, cfg SecurityHeadersConfig) *SecurityHeadersMiddleware

+ func (m *SecurityHeadersMiddleware) Init(app modular.Application) error

+ func (m *SecurityHeadersMiddleware) Middleware() func(http.Handler) http.Handler

+ func (m *SecurityHeadersMiddleware) Name() string

+ func (m *SecurityHeadersMiddleware) Process(next http.Handler) http.Handler

+ func (m *SecurityHeadersMiddleware) ProvidesServices() []modular.ServiceProvider

+ func (m *SecurityHeadersMiddleware) RequiresServices() []modular.ServiceDependency

+ type ServiceInfo struct

+ Implements []string

+ Name string

+ Type string

+ type ServiceModule struct

+ func NewServiceModule(name string, svc any) *ServiceModule

+ func (m *ServiceModule) Init(_ modular.Application) error

+ func (m *ServiceModule) Name() string

+ func (m *ServiceModule) ProvidesServices() []modular.ServiceProvider

+ func (m *ServiceModule) RequiresServices() []modular.ServiceDependency

+ type ServiceRegistry interface

+ GetService func(name string, out any) error

+ RegisterService func(name string, service any) error

+ type SetStep struct

+ func (s *SetStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *SetStep) Name() string

+ type ShellExecStep struct

+ func (s *ShellExecStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ShellExecStep) Name() string

+ type SimpleHTTPHandler struct

+ func NewSimpleHTTPHandler(name string, contentType string) *SimpleHTTPHandler

+ func (h *SimpleHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ func (h *SimpleHTTPHandler) Init(app modular.Application) error

+ func (h *SimpleHTTPHandler) Name() string

+ func (h *SimpleHTTPHandler) ProvidesServices() []modular.ServiceProvider

+ func (h *SimpleHTTPHandler) RequiresServices() []modular.ServiceDependency

+ func (h *SimpleHTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *SimpleHTTPHandler) SetHandleFunc(fn func(w http.ResponseWriter, r *http.Request))

+ type SimpleMessageHandler struct

+ func NewSimpleMessageHandler(name string) *SimpleMessageHandler

+ func NewSimpleMessageHandlerWithNamespace(name string, namespace ModuleNamespaceProvider) *SimpleMessageHandler

+ func NewStandardSimpleMessageHandler(handlerType string, namespace ModuleNamespaceProvider) *SimpleMessageHandler

+ func (h *SimpleMessageHandler) Constructor() modular.ModuleConstructor

+ func (h *SimpleMessageHandler) Dependencies() []string

+ func (h *SimpleMessageHandler) HandleMessage(message []byte) error

+ func (h *SimpleMessageHandler) Init(app modular.Application) error

+ func (h *SimpleMessageHandler) Name() string

+ func (h *SimpleMessageHandler) ProvidesServices() []modular.ServiceProvider

+ func (h *SimpleMessageHandler) RequiresServices() []modular.ServiceDependency

+ func (h *SimpleMessageHandler) SetBrokerDependencies(brokerNames []string)

+ func (h *SimpleMessageHandler) SetHandleFunc(fn func(message []byte) error)

+ func (h *SimpleMessageHandler) SetProducer(producer MessageProducer)

+ func (h *SimpleMessageHandler) SetTargetTopics(topics []string)

+ func (h *SimpleMessageHandler) Start(ctx context.Context) error

+ func (h *SimpleMessageHandler) Stop(ctx context.Context) error

+ type SimpleProxy struct

+ func NewSimpleProxy(name string) *SimpleProxy

+ func (p *SimpleProxy) Handle(w http.ResponseWriter, r *http.Request)

+ func (p *SimpleProxy) Init(_ modular.Application) error

+ func (p *SimpleProxy) Name() string

+ func (p *SimpleProxy) ProvidesServices() []modular.ServiceProvider

+ func (p *SimpleProxy) RequiresServices() []modular.ServiceDependency

+ func (p *SimpleProxy) SetTargets(targets map[string]string) error

+ func (p *SimpleProxy) Start(_ context.Context) error

+ func (p *SimpleProxy) Stop(_ context.Context) error

+ type SimpleTokenProvider struct

+ func (p *SimpleTokenProvider) Authenticate(token string) (bool, map[string]any, error)

+ type SlackNotification struct

+ func NewSlackNotification(name string) *SlackNotification

+ func (s *SlackNotification) HandleMessage(message []byte) error

+ func (s *SlackNotification) Init(app modular.Application) error

+ func (s *SlackNotification) Name() string

+ func (s *SlackNotification) ProvidesServices() []modular.ServiceProvider

+ func (s *SlackNotification) RequiresServices() []modular.ServiceDependency

+ func (s *SlackNotification) SetChannel(channel string)

+ func (s *SlackNotification) SetClient(client *http.Client)

+ func (s *SlackNotification) SetUsername(username string)

+ func (s *SlackNotification) SetWebhookURL(url string)

+ type StandardHTTPHandler struct

+ func (h *StandardHTTPHandler) Handle(w http.ResponseWriter, r *http.Request)

+ func (h *StandardHTTPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request, params map[string]string)

+ type StandardHTTPRouter struct

+ func NewStandardHTTPRouter(name string) *StandardHTTPRouter

+ func (r *StandardHTTPRouter) AddRoute(method, path string, handler HTTPHandler)

+ func (r *StandardHTTPRouter) AddRouteWithMiddleware(method, path string, handler HTTPHandler, middlewares []HTTPMiddleware)

+ func (r *StandardHTTPRouter) Constructor() modular.ModuleConstructor

+ func (r *StandardHTTPRouter) Dependencies() []string

+ func (r *StandardHTTPRouter) HasRoute(method, path string) bool

+ func (r *StandardHTTPRouter) Init(app modular.Application) error

+ func (r *StandardHTTPRouter) Name() string

+ func (r *StandardHTTPRouter) ProvidesServices() []modular.ServiceProvider

+ func (r *StandardHTTPRouter) RequiresServices() []modular.ServiceDependency

+ func (r *StandardHTTPRouter) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (r *StandardHTTPRouter) SetServerDependencies(serverNames []string)

+ func (r *StandardHTTPRouter) Start(ctx context.Context) error

+ func (r *StandardHTTPRouter) Stop(ctx context.Context) error

+ type StandardHTTPServer struct

+ func NewStandardHTTPServer(name, address string) *StandardHTTPServer

+ func (s *StandardHTTPServer) AddRouter(router HTTPRouter)

+ func (s *StandardHTTPServer) Init(app modular.Application) error

+ func (s *StandardHTTPServer) Name() string

+ func (s *StandardHTTPServer) ProvidesServices() []modular.ServiceProvider

+ func (s *StandardHTTPServer) RequiresServices() []modular.ServiceDependency

+ func (s *StandardHTTPServer) Start(ctx context.Context) error

+ func (s *StandardHTTPServer) Stop(ctx context.Context) error

+ type StandardNamespace struct

+ func NewStandardNamespace(prefix string, suffix string) *StandardNamespace

+ func (ns *StandardNamespace) FormatName(baseName string) string

+ func (ns *StandardNamespace) ResolveDependency(dependencyName string) string

+ func (ns *StandardNamespace) ResolveServiceName(serviceName string) string

+ func (ns *StandardNamespace) ValidateModuleName(moduleName string) error

+ type State struct

+ Data map[string]any

+ Description string

+ IsError bool

+ IsFinal bool

+ Name string

+ type StateChangeListener func(previousState, newState string, resourceID string, data map[string]any)

+ type StateInfo struct

+ CurrentState string

+ Data map[string]any

+ ID string

+ LastUpdate time.Time

+ PreviousState string

+ ResourceType string

+ type StateMachineDefinition struct

+ Data map[string]any

+ Description string

+ InitialState string

+ Name string

+ States map[string]*State

+ Transitions map[string]*Transition

+ type StateMachineEngine struct

+ func NewStandardStateMachineEngine(namespace ModuleNamespaceProvider) *StateMachineEngine

+ func NewStateMachineEngine(name string) *StateMachineEngine

+ func NewStateMachineEngineWithNamespace(name string, namespace ModuleNamespaceProvider) *StateMachineEngine

+ func (e *StateMachineEngine) AddGlobalTransitionHandler(handler TransitionHandler)

+ func (e *StateMachineEngine) AddTransitionListener(listener TransitionListener)

+ func (e *StateMachineEngine) CreateWorkflow(workflowType string, id string, initialData map[string]any) (*WorkflowInstance, error)

+ func (e *StateMachineEngine) GetAllInstances() ([]*WorkflowInstance, error)

+ func (e *StateMachineEngine) GetInstance(id string) (*WorkflowInstance, error)

+ func (e *StateMachineEngine) GetInstancesByType(workflowType string) ([]*WorkflowInstance, error)

+ func (e *StateMachineEngine) GetOrphanedInstances() []*WorkflowInstance

+ func (e *StateMachineEngine) GetTransitionHandler() TransitionHandler

+ func (e *StateMachineEngine) HasTransitionHandler() bool

+ func (e *StateMachineEngine) Init(app modular.Application) error

+ func (e *StateMachineEngine) InstanceTTL() time.Duration

+ func (e *StateMachineEngine) LoadAllPersistedInstances() error

+ func (e *StateMachineEngine) MaxInstances() int

+ func (e *StateMachineEngine) Name() string

+ func (e *StateMachineEngine) ProvidesServices() []modular.ServiceProvider

+ func (e *StateMachineEngine) RecoverProcessingInstances(ctx context.Context, processingStates []string) int

+ func (e *StateMachineEngine) RegisterDefinition(def *StateMachineDefinition) error

+ func (e *StateMachineEngine) RegisterWorkflow(def ExternalStateMachineDefinition) error

+ func (e *StateMachineEngine) RequiresServices() []modular.ServiceDependency

+ func (e *StateMachineEngine) SetInstanceTTL(d time.Duration)

+ func (e *StateMachineEngine) SetMaxInstances(n int)

+ func (e *StateMachineEngine) SetPersistence(ps *PersistenceStore)

+ func (e *StateMachineEngine) SetTransitionHandler(handler TransitionHandler)

+ func (e *StateMachineEngine) Start(ctx context.Context) error

+ func (e *StateMachineEngine) Stop(ctx context.Context) error

+ func (e *StateMachineEngine) TrackGoroutine(fn func())

+ func (e *StateMachineEngine) TriggerTransition(ctx context.Context, workflowID string, transitionName string, ...) error

+ type StateMachineStateConfig struct

+ Data map[string]any

+ Description string

+ ID string

+ IsError bool

+ IsFinal bool

+ type StateMachineStateConnector struct

+ func NewStateMachineStateConnector(name string) *StateMachineStateConnector

+ func (c *StateMachineStateConnector) Configure(mappings []ResourceStateMapping) error

+ func (c *StateMachineStateConnector) GetEngineForResourceType(resourceType string) (string, bool)

+ func (c *StateMachineStateConnector) GetResourceState(resourceType, resourceID string) (string, map[string]any, error)

+ func (c *StateMachineStateConnector) Init(app modular.Application) error

+ func (c *StateMachineStateConnector) Name() string

+ func (c *StateMachineStateConnector) ProvidesServices() []modular.ServiceProvider

+ func (c *StateMachineStateConnector) RegisterMapping(resourceType, stateMachine, instanceIDKey string)

+ func (c *StateMachineStateConnector) RequiresServices() []modular.ServiceDependency

+ func (c *StateMachineStateConnector) Start(ctx context.Context) error

+ func (c *StateMachineStateConnector) Stop(ctx context.Context) error

+ func (c *StateMachineStateConnector) UpdateResourceState(resourceType, resourceID string) error

+ type StateMachineTransitionConfig struct

+ AutoTransform bool

+ Condition string

+ Data map[string]any

+ FromState string

+ ID string

+ ToState string

+ type StateTracker struct

+ func NewStateTracker(name string) *StateTracker

+ func (s *StateTracker) AddStateChangeListener(resourceType string, listener StateChangeListener)

+ func (s *StateTracker) GetState(resourceType, resourceID string) (StateInfo, bool)

+ func (s *StateTracker) Init(app modular.Application) error

+ func (s *StateTracker) Name() string

+ func (s *StateTracker) ProvidesServices() []modular.ServiceProvider

+ func (s *StateTracker) RequiresServices() []modular.ServiceDependency

+ func (s *StateTracker) RetentionDays() int

+ func (s *StateTracker) SetRetentionDays(days int)

+ func (s *StateTracker) SetState(resourceType, resourceID, state string, data map[string]any)

+ func (s *StateTracker) Start(ctx context.Context) error

+ func (s *StateTracker) Stop(ctx context.Context) error

+ type StaticFileServer struct

+ func NewStaticFileServer(name, root, prefix string, spaFallback bool, cacheMaxAge int) *StaticFileServer

+ func (s *StaticFileServer) Handle(w http.ResponseWriter, r *http.Request)

+ func (s *StaticFileServer) Init(app modular.Application) error

+ func (s *StaticFileServer) Name() string

+ func (s *StaticFileServer) Prefix() string

+ func (s *StaticFileServer) ProvidesServices() []modular.ServiceProvider

+ func (s *StaticFileServer) RequiresServices() []modular.ServiceDependency

+ func (s *StaticFileServer) RouterName() string

+ func (s *StaticFileServer) SetRouterName(name string)

+ func (s *StaticFileServer) Start(ctx context.Context) error

+ func (s *StaticFileServer) Stop(ctx context.Context) error

+ type StdIntegrationRegistry struct

+ func NewIntegrationRegistry(name string) *StdIntegrationRegistry

+ func (r *StdIntegrationRegistry) GetConnector(name string) (IntegrationConnector, error)

+ func (r *StdIntegrationRegistry) Init(app modular.Application) error

+ func (r *StdIntegrationRegistry) ListConnectors() []string

+ func (r *StdIntegrationRegistry) Name() string

+ func (r *StdIntegrationRegistry) RegisterConnector(connector IntegrationConnector)

+ func (r *StdIntegrationRegistry) Start() error

+ func (r *StdIntegrationRegistry) Stop() error

+ type StepFactory func(name string, config map[string]any, app modular.Application) (PipelineStep, error)

+ func NewAIClassifyStepFactory(registry *ai.AIModelRegistry) StepFactory

+ func NewAICompleteStepFactory(registry *ai.AIModelRegistry) StepFactory

+ func NewAIExtractStepFactory(registry *ai.AIModelRegistry) StepFactory

+ func NewArtifactPullStepFactory() StepFactory

+ func NewArtifactPushStepFactory() StepFactory

+ func NewBuildUIStepFactory() StepFactory

+ func NewCircuitBreakerStepFactory() StepFactory

+ func NewConditionalStepFactory() StepFactory

+ func NewConstraintCheckStepFactory() StepFactory

+ func NewDBExecStepFactory() StepFactory

+ func NewDBQueryStepFactory() StepFactory

+ func NewDelegateStepFactory() StepFactory

+ func NewDeployStepFactory() StepFactory

+ func NewDockerBuildStepFactory() StepFactory

+ func NewDockerPushStepFactory() StepFactory

+ func NewDockerRunStepFactory() StepFactory

+ func NewDriftCheckStepFactory() StepFactory

+ func NewFFGateStepFactory(service *featureflag.Service) StepFactory

+ func NewFeatureFlagStepFactory(service *featureflag.Service) StepFactory

+ func NewGateStepFactory() StepFactory

+ func NewHTTPCallStepFactory() StepFactory

+ func NewJQStepFactory() StepFactory

+ func NewJSONResponseStepFactory() StepFactory

+ func NewLogStepFactory() StepFactory

+ func NewPlatformApplyStepFactory() StepFactory

+ func NewPlatformDestroyStepFactory() StepFactory

+ func NewPlatformPlanStepFactory() StepFactory

+ func NewPlatformTemplateStepFactory() StepFactory

+ func NewPublishStepFactory() StepFactory

+ func NewRateLimitStepFactory() StepFactory

+ func NewRequestParseStepFactory() StepFactory

+ func NewScanContainerStepFactory() StepFactory

+ func NewScanDepsStepFactory() StepFactory

+ func NewScanSASTStepFactory() StepFactory

+ func NewSetStepFactory() StepFactory

+ func NewShellExecStepFactory() StepFactory

+ func NewSubWorkflowStepFactory(registry *plugin.PluginWorkflowRegistry, stepBuilder SubWorkflowStepBuilder) StepFactory

+ func NewTransformStepFactory() StepFactory

+ func NewValidateStepFactory() StepFactory

+ type StepLifecycleEvent struct

+ Action string

+ Connector string

+ Data map[string]any

+ Duration time.Duration

+ Error string

+ Results map[string]any

+ Status string

+ StepName string

+ Timestamp time.Time

+ WorkflowType string

+ type StepRegistry struct

+ func NewStepRegistry() *StepRegistry

+ func (r *StepRegistry) Create(stepType, name string, config map[string]any, app modular.Application) (PipelineStep, error)

+ func (r *StepRegistry) Register(stepType string, factory StepFactory)

+ func (r *StepRegistry) Types() []string

+ type StepResult struct

+ NextStep string

+ Output map[string]any

+ Stop bool

+ type SubWorkflowStep struct

+ func (s *SubWorkflowStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *SubWorkflowStep) Name() string

+ type SubWorkflowStepBuilder func(pipelineName string, cfg *config.WorkflowConfig, app modular.Application) (*Pipeline, error)

+ type TemplateEngine struct

+ func NewTemplateEngine() *TemplateEngine

+ func (te *TemplateEngine) Resolve(tmplStr string, pc *PipelineContext) (string, error)

+ func (te *TemplateEngine) ResolveMap(data map[string]any, pc *PipelineContext) (map[string]any, error)

+ type TestHelper struct

+ func NewTestHelper(app modular.Application) *TestHelper

+ type TestLogger struct

+ Entries []string

+ func NewTestApplication() (modular.Application, *TestLogger)

+ func (l *TestLogger) Debug(msg string, args ...any)

+ func (l *TestLogger) Error(msg string, args ...any)

+ func (l *TestLogger) Fatal(msg string, args ...any)

+ func (l *TestLogger) Info(msg string, args ...any)

+ func (l *TestLogger) Warn(msg string, args ...any)

+ type TransformOperation struct

+ Config map[string]any

+ Type string

+ type TransformPipeline struct

+ Name string

+ Operations []TransformOperation

+ type TransformStep struct

+ func (s *TransformStep) Execute(ctx context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *TransformStep) Name() string

+ type Transition struct

+ AutoTransform bool

+ Condition string

+ Data map[string]any

+ FromState string

+ Name string

+ ToState string

+ type TransitionEvent struct

+ Data map[string]any

+ FromState string

+ Timestamp time.Time

+ ToState string

+ TransitionID string

+ WorkflowID string

+ func (e TransitionEvent) InstanceID() string

+ type TransitionHandler interface

+ HandleTransition func(ctx context.Context, event TransitionEvent) error

+ type TransitionListener func(event TransitionEvent)

+ type TransitionTrigger interface

+ TriggerTransition func(ctx context.Context, workflowID, transitionName string, data map[string]any) error

+ type Trigger interface

+ Configure func(app modular.Application, triggerConfig any) error

+ type TriggerRegistry struct

+ func NewTriggerRegistry() *TriggerRegistry

+ func (r *TriggerRegistry) GetAllTriggers() map[string]Trigger

+ func (r *TriggerRegistry) GetTrigger(name string) (Trigger, bool)

+ func (r *TriggerRegistry) RegisterTrigger(trigger Trigger)

+ type TriggerWorkflower interface

+ TriggerWorkflow func(ctx context.Context, workflowType string, action string, data map[string]any) error

+ type User struct

+ CreatedAt time.Time

+ Email string

+ ID string

+ Metadata map[string]any

+ Name string

+ PasswordHash string

+ type UserRecord struct

+ CreatedAt time.Time

+ Email string

+ ID string

+ Metadata map[string]any

+ Name string

+ PasswordHash string

+ type UserStore struct

+ func NewUserStore(name string) *UserStore

+ func (u *UserStore) CreateUser(email, name, password string, metadata map[string]any) (*User, error)

+ func (u *UserStore) DeleteUser(id string) error

+ func (u *UserStore) GetUser(email string) (*User, bool)

+ func (u *UserStore) GetUserByID(id string) (*User, bool)

+ func (u *UserStore) Init(app modular.Application) error

+ func (u *UserStore) ListUsers() []*User

+ func (u *UserStore) LoadSeedFile(path string) error

+ func (u *UserStore) Name() string

+ func (u *UserStore) ProvidesServices() []modular.ServiceProvider

+ func (u *UserStore) RequiresServices() []modular.ServiceDependency

+ func (u *UserStore) Start(_ context.Context) error

+ func (u *UserStore) Stop(_ context.Context) error

+ func (u *UserStore) UpdateUserMetadata(id string, metadata map[string]any) error

+ func (u *UserStore) UserCount() int

+ func (u *UserStore) VerifyPassword(email, password string) (*User, error)

+ type V1APIHandler struct

+ func NewV1APIHandler(store *V1Store, jwtSecret string) *V1APIHandler

+ func (h *V1APIHandler) HandleV1(w http.ResponseWriter, r *http.Request)

+ func (h *V1APIHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *V1APIHandler) SetDataDir(dir string)

+ func (h *V1APIHandler) SetFeatureFlagService(svc FeatureFlagAdmin)

+ func (h *V1APIHandler) SetReloadFunc(fn func(configYAML string) error)

+ func (h *V1APIHandler) SetRuntimeManager(rm *RuntimeManager)

+ func (h *V1APIHandler) SetWorkspaceHandler(wh *WorkspaceHandler)

+ type V1Company struct

+ CreatedAt string

+ ID string

+ IsSystem bool

+ Metadata string

+ Name string

+ OwnerID string

+ ParentID string

+ Slug string

+ UpdatedAt string

+ type V1Project struct

+ CompanyID string

+ CreatedAt string

+ Description string

+ ID string

+ IsSystem bool

+ Metadata string

+ Name string

+ Slug string

+ UpdatedAt string

+ type V1Store struct

+ func OpenV1Store(dbPath string) (*V1Store, error)

+ func (s *V1Store) Close() error

+ func (s *V1Store) CompleteExecution(id, status string, completedAt time.Time, durationMs int64, errorMsg string) error

+ func (s *V1Store) CompleteExecutionStep(id, status string, completedAt time.Time, durationMs int64, errorMsg string) error

+ func (s *V1Store) CountExecutionsByWorkflow(workflowID string) (map[string]int, error)

+ func (s *V1Store) CountLogsByWorkflow(workflowID string) (map[string]int, error)

+ func (s *V1Store) CreateCompany(name, slug, ownerID string) (*V1Company, error)

+ func (s *V1Store) CreateOrganization(parentID, name, slug, ownerID string) (*V1Company, error)

+ func (s *V1Store) CreateProject(companyID, name, slug, description string) (*V1Project, error)

+ func (s *V1Store) CreateWorkflow(projectID, name, slug, description, configYAML, createdBy string) (*V1Workflow, error)

+ func (s *V1Store) DB() *sql.DB

+ func (s *V1Store) DeleteWorkflow(id string) error

+ func (s *V1Store) EnsureSystemHierarchy(ownerID, adminConfigYAML string) (companyID, orgID, projectID, workflowID string, err error)

+ func (s *V1Store) GetCompany(id string) (*V1Company, error)

+ func (s *V1Store) GetProject(id string) (*V1Project, error)

+ func (s *V1Store) GetSystemWorkflow() (*V1Workflow, error)

+ func (s *V1Store) GetVersion(workflowID string, version int) (*V1WorkflowVersion, error)

+ func (s *V1Store) GetWorkflow(id string) (*V1Workflow, error)

+ func (s *V1Store) GetWorkflowBySlugAndProject(slug, projectID string) (*V1Workflow, error)

+ func (s *V1Store) InsertExecution(id, workflowID, triggerType, status, triggeredBy string, startedAt time.Time) error

+ func (s *V1Store) InsertExecutionStep(id, executionID, stepName, stepType, status string, seqNum int, ...) error

+ func (s *V1Store) InsertLog(workflowID, executionID, level, message, moduleName, fields string, ...) error

+ func (s *V1Store) ListAllProjects() ([]V1Project, error)

+ func (s *V1Store) ListCompanies(ownerID string) ([]V1Company, error)

+ func (s *V1Store) ListOrganizations(parentID string) ([]V1Company, error)

+ func (s *V1Store) ListProjects(companyID string) ([]V1Project, error)

+ func (s *V1Store) ListVersions(workflowID string) ([]V1WorkflowVersion, error)

+ func (s *V1Store) ListWorkflows(projectID string) ([]V1Workflow, error)

+ func (s *V1Store) ResetSystemWorkflow(configYAML string) error

+ func (s *V1Store) SaveVersion(workflowID, configYAML, createdBy string) error

+ func (s *V1Store) SetWorkflowStatus(id, status string) (*V1Workflow, error)

+ func (s *V1Store) SetWorkspaceDir(id, workspaceDir string) error

+ func (s *V1Store) UpdateWorkflow(id string, name, description, configYAML, updatedBy string) (*V1Workflow, error)

+ func (s *V1Store) UpdateWorkflowWorkspaceDir(id, workspaceDir string) error

+ type V1Workflow struct

+ ConfigYAML string

+ CreatedAt string

+ CreatedBy string

+ Description string

+ ID string

+ IsSystem bool

+ Name string

+ ProjectID string

+ Slug string

+ Status string

+ UpdatedAt string

+ UpdatedBy string

+ Version int

+ WorkspaceDir string

+ type V1WorkflowVersion struct

+ ConfigYAML string

+ CreatedAt string

+ CreatedBy string

+ ID string

+ Version int

+ WorkflowID string

+ type ValidateStep struct

+ func (s *ValidateStep) Execute(_ context.Context, pc *PipelineContext) (*StepResult, error)

+ func (s *ValidateStep) Name() string

+ type ValidatingNamespace struct

+ func WithValidation(base ModuleNamespaceProvider) *ValidatingNamespace

+ func (vn *ValidatingNamespace) FormatName(baseName string) string

+ func (vn *ValidatingNamespace) ResolveDependency(dependencyName string) string

+ func (vn *ValidatingNamespace) ResolveServiceName(serviceName string) string

+ func (vn *ValidatingNamespace) ValidateModuleName(moduleName string) error

+ type ValidationIssue struct

+ Field string

+ Message string

+ Severity ValidationSeverity

+ func ValidateModule(m modular.Module) []ValidationIssue

+ func (v ValidationIssue) String() string

+ type ValidationSeverity string

+ const SeverityError

+ const SeverityInfo

+ const SeverityWarning

+ type WebhookConfig struct

+ BackoffMultiplier float64

+ InitialBackoff time.Duration

+ MaxBackoff time.Duration

+ MaxRetries int

+ Timeout time.Duration

+ type WebhookDelivery struct

+ Attempts int

+ CreatedAt time.Time

+ DeliveredAt *time.Time

+ Headers map[string]string

+ ID string

+ LastError string

+ Payload []byte

+ Status string

+ URL string

+ type WebhookIntegrationConnector struct

+ func NewWebhookIntegrationConnector(name, path string, port int) *WebhookIntegrationConnector

+ func (c *WebhookIntegrationConnector) Connect(ctx context.Context) error

+ func (c *WebhookIntegrationConnector) Disconnect(ctx context.Context) error

+ func (c *WebhookIntegrationConnector) Execute(ctx context.Context, action string, params map[string]any) (map[string]any, error)

+ func (c *WebhookIntegrationConnector) GetName() string

+ func (c *WebhookIntegrationConnector) IsConnected() bool

+ func (c *WebhookIntegrationConnector) RegisterEventHandler(eventType string, handler func(context.Context, map[string]any) error)

+ type WebhookSender struct

+ func NewWebhookSender(name string, config WebhookConfig) *WebhookSender

+ func (ws *WebhookSender) GetDeadLetters() []*WebhookDelivery

+ func (ws *WebhookSender) Init(app modular.Application) error

+ func (ws *WebhookSender) Name() string

+ func (ws *WebhookSender) RetryDeadLetter(ctx context.Context, id string) (*WebhookDelivery, error)

+ func (ws *WebhookSender) Send(ctx context.Context, url string, payload []byte, headers map[string]string) (*WebhookDelivery, error)

+ func (ws *WebhookSender) SetClient(client *http.Client)

+ type WorkflowDatabase struct

+ func NewWorkflowDatabase(name string, config DatabaseConfig) *WorkflowDatabase

+ func (w *WorkflowDatabase) Close() error

+ func (w *WorkflowDatabase) DB() *sql.DB

+ func (w *WorkflowDatabase) DeleteRows(ctx context.Context, table string, where string, whereArgs ...any) (int64, error)

+ func (w *WorkflowDatabase) Execute(ctx context.Context, sqlStr string, args ...any) (int64, error)

+ func (w *WorkflowDatabase) Init(app modular.Application) error

+ func (w *WorkflowDatabase) InsertRow(ctx context.Context, table string, data map[string]any) (int64, error)

+ func (w *WorkflowDatabase) Name() string

+ func (w *WorkflowDatabase) Open() (*sql.DB, error)

+ func (w *WorkflowDatabase) Ping(ctx context.Context) error

+ func (w *WorkflowDatabase) ProvidesServices() []modular.ServiceProvider

+ func (w *WorkflowDatabase) Query(ctx context.Context, sqlStr string, args ...any) (*QueryResult, error)

+ func (w *WorkflowDatabase) RequiresServices() []modular.ServiceDependency

+ func (w *WorkflowDatabase) UpdateRows(ctx context.Context, table string, data map[string]any, where string, ...) (int64, error)

+ type WorkflowEngine interface

+ TriggerWorkflow func(ctx context.Context, workflowType string, action string, data map[string]any) error

+ type WorkflowEventEmitter struct

+ func NewWorkflowEventEmitter(app modular.Application) *WorkflowEventEmitter

+ func (e *WorkflowEventEmitter) EmitStepCompleted(ctx context.Context, workflowType, stepName, connector, action string, ...)

+ func (e *WorkflowEventEmitter) EmitStepFailed(ctx context.Context, workflowType, stepName, connector, action string, ...)

+ func (e *WorkflowEventEmitter) EmitStepStarted(ctx context.Context, workflowType, stepName, connector, action string)

+ func (e *WorkflowEventEmitter) EmitWorkflowCompleted(ctx context.Context, workflowType, action string, duration time.Duration, ...)

+ func (e *WorkflowEventEmitter) EmitWorkflowFailed(ctx context.Context, workflowType, action string, duration time.Duration, ...)

+ func (e *WorkflowEventEmitter) EmitWorkflowStarted(ctx context.Context, workflowType, action string, data map[string]any)

+ type WorkflowInstance struct

+ Completed bool

+ CurrentState string

+ Data map[string]any

+ Error string

+ ID string

+ LastUpdated time.Time

+ PreviousState string

+ StartTime time.Time

+ WorkflowType string

+ type WorkflowLifecycleEvent struct

+ Action string

+ Data map[string]any

+ Duration time.Duration

+ Error string

+ Results map[string]any

+ Status string

+ Timestamp time.Time

+ WorkflowType string

+ type WorkflowRegistry struct

+ func NewWorkflowRegistry(name, storageBackend string) *WorkflowRegistry

+ func (w *WorkflowRegistry) Init(app modular.Application) error

+ func (w *WorkflowRegistry) Name() string

+ func (w *WorkflowRegistry) ProvidesServices() []modular.ServiceProvider

+ func (w *WorkflowRegistry) RequiresServices() []modular.ServiceDependency

+ func (w *WorkflowRegistry) Start(_ context.Context) error

+ func (w *WorkflowRegistry) Stop(_ context.Context) error

+ func (w *WorkflowRegistry) Store() *V1Store

+ type WorkflowTriggerInfo struct

+ Action string

+ Data map[string]any

+ WorkflowType string

+ type WorkflowUIHandler struct

+ func NewWorkflowUIHandler(cfg *config.WorkflowConfig) *WorkflowUIHandler

+ func (h *WorkflowUIHandler) HandleGetConfig(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleGetModules(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleGetServices(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleManagement(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandlePutConfig(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleReload(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleStatus(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) HandleValidate(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) RegisterRoutes(mux *http.ServeMux)

+ func (h *WorkflowUIHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (h *WorkflowUIHandler) SetReloadFunc(fn func(*config.WorkflowConfig) error)

+ func (h *WorkflowUIHandler) SetServiceRegistry(fn func() map[string]any)

+ func (h *WorkflowUIHandler) SetStatusFunc(fn func() map[string]any)

+ type WorkspaceHandler struct

+ func NewWorkspaceHandler(wm *store.WorkspaceManager) *WorkspaceHandler

+ func (h *WorkspaceHandler) HandleWorkspace(w http.ResponseWriter, r *http.Request)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL