core

Feb 22, 2026

Changes in this version

type IntegrationContext

+ FindSubscription func(predicate func(IntegrationSubscriptionContext) bool) (IntegrationSubscriptionContext, error)

type IntegrationMessageContext

+ FindExecutionByKV func(key string, value string) (*ExecutionContext, error)

Feb 15, 2026

Changes in this version

type ActionContext

+ Secrets SecretsContext

type ExecutionContext

+ Webhook NodeWebhookContext

type SetupContext

+ Webhook NodeWebhookContext

type WebhookHandler

+ Merge func(current, requested any) (merged any, changed bool, err error)

type WebhookRequestContext

+ HTTP HTTPContext

+ Integration IntegrationContext

+ Logger *log.Entry

+ Metadata MetadataContext

Feb 8, 2026

Changes in this version

+ var ErrSecretKeyNotFound = errors.New("secret or key not found")

type Component

+ Cleanup func(ctx SetupContext) error

type ExecutionContext

+ Secrets SecretsContext

type IntegrationActionContext

+ HTTP HTTPContext

+ WebhooksBaseURL string

type IntegrationMessageContext

+ HTTP HTTPContext

+ NodeMetadata MetadataContext

type ListResourcesContext

+ Parameters map[string]string

+ type SecretsContext interface

+ GetKey func(secretName, keyName string) ([]byte, error)

type SyncContext

+ Logger *logrus.Entry

type Trigger

+ Cleanup func(ctx TriggerContext) error

+ type WebhookHandler interface

+ Cleanup func(ctx WebhookHandlerContext) error

+ CompareConfig func(a, b any) (bool, error)

+ Setup func(ctx WebhookHandlerContext) (any, error)

+ type WebhookHandlerContext struct

+ HTTP HTTPContext

+ Integration IntegrationContext

+ Logger *logrus.Entry

+ Webhook WebhookContext

Feb 1, 2026

Changes in this version

type Integration

+ Actions func() []Action

+ Cleanup func(ctx IntegrationCleanupContext) error

+ HandleAction func(ctx IntegrationActionContext) error

+ type IntegrationActionContext struct

+ Configuration any

+ Integration IntegrationContext

+ Logger *logrus.Entry

+ Name string

+ Parameters any

+ Requests RequestContext

+ type IntegrationCleanupContext struct

+ BaseURL string

+ Configuration any

+ HTTP HTTPContext

+ InstallationID string

+ Integration IntegrationContext

+ Logger *logrus.Entry

+ OrganizationID string

type IntegrationContext

+ Error func(message string)

+ Ready func()

+ ScheduleActionCall func(actionName string, parameters any, interval time.Duration) error

Jan 27, 2026

Changes in this version

type CleanupWebhookContext

+ Integration IntegrationContext

type HTTPRequestContext

+ Integration IntegrationContext

+ type Integration interface

+ CleanupWebhook func(ctx CleanupWebhookContext) error

+ CompareWebhookConfig func(a, b any) (bool, error)

+ Components func() []Component

+ Configuration func() []configuration.Field

+ Description func() string

+ HandleRequest func(ctx HTTPRequestContext)

+ Icon func() string

+ Instructions func() string

+ Label func() string

+ ListResources func(resourceType string, ctx ListResourcesContext) ([]IntegrationResource, error)

+ Name func() string

+ SetupWebhook func(ctx SetupWebhookContext) (any, error)

+ Sync func(ctx SyncContext) error

+ Triggers func() []Trigger

+ type IntegrationComponent interface

+ OnIntegrationMessage func(ctx IntegrationMessageContext) error

type IntegrationContext

+ GetConfig func(name string) ([]byte, error)

+ GetMetadata func() any

+ GetSecrets func() ([]IntegrationSecret, error)

+ GetState func() string

+ ID func() uuid.UUID

+ ListSubscriptions func() ([]IntegrationSubscriptionContext, error)

+ NewBrowserAction func(action BrowserAction)

+ RemoveBrowserAction func()

+ RequestWebhook func(configuration any) error

+ ScheduleResync func(interval time.Duration) error

+ SetMetadata func(any)

+ SetSecret func(name string, value []byte) error

+ SetState func(state, stateDescription string)

+ Subscribe func(any) (*uuid.UUID, error)

+ type IntegrationMessageContext struct

+ Configuration any

+ Events EventContext

+ Integration IntegrationContext

+ Logger *logrus.Entry

+ Message any

+ type IntegrationResource struct

+ ID string

+ Name string

+ Type string

+ type IntegrationSecret struct

+ Name string

+ Value []byte

+ type IntegrationSubscriptionContext interface

+ Configuration func() any

+ SendMessage func(any) error

+ type IntegrationTrigger interface

+ OnIntegrationMessage func(ctx IntegrationMessageContext) error

type ListResourcesContext

+ Integration IntegrationContext

type SetupWebhookContext

+ Integration IntegrationContext

type SyncContext

+ Integration IntegrationContext

type TriggerActionContext

+ Integration IntegrationContext

Jan 26, 2026

Changes in this version

type Component

+ Documentation func() string

type SyncContext

+ OIDC oidc.Provider

type Trigger

+ Documentation func() string

Jan 21, 2026

Changes in this version

+ type AppComponent interface

+ OnAppMessage func(ctx AppMessageContext) error

type AppInstallationContext

+ ListSubscriptions func() ([]AppSubscriptionContext, error)

+ Subscribe func(any) (*uuid.UUID, error)

+ type AppMessageContext struct

+ AppInstallation AppInstallationContext

+ Configuration any

+ Events EventContext

+ Logger *logrus.Entry

+ Message any

+ type AppSubscriptionContext interface

+ Configuration func() any

+ SendMessage func(any) error

+ type AppTrigger interface

+ OnAppMessage func(ctx AppMessageContext) error

type Application

+ InstallationInstructions func() string

type Component

+ ExampleOutput func() map[string]any

type ExecutionContext

+ ExpressionEnv func(expression string) (map[string]any, error)

+ SourceNodeID string

type ProcessQueueContext

+ ExpressionEnv func(expression string) (map[string]any, error)

type SetupWebhookContext

+ Logger *logrus.Entry

type Trigger

+ ExampleData func() map[string]any

Jan 15, 2026

Changes in this version

type ActionContext

+ HTTP HTTPContext

+ Notifications NotificationContext

type Application

+ ListResources func(resourceType string, ctx ListResourcesContext) ([]ApplicationResource, error)

+ type ApplicationResource struct

+ ID string

+ Name string

+ Type string

type CleanupWebhookContext

+ HTTP HTTPContext

type ExecutionContext

+ BaseURL string

+ HTTP HTTPContext

+ NodeID string

+ Notifications NotificationContext

+ OrganizationID string

+ type HTTPContext interface

+ Do func(*http.Request) (*http.Response, error)

type HTTPRequestContext

+ HTTP HTTPContext

+ type ListResourcesContext struct

+ AppInstallation AppInstallationContext

+ HTTP HTTPContext

+ Logger *logrus.Entry

+ type NotificationContext interface

+ Send func(title, body, url, urlLabel string, receivers NotificationReceivers) error

+ type NotificationReceivers struct

+ Emails []string

+ Groups []string

+ Roles []string

type SetupContext

+ HTTP HTTPContext

type SetupWebhookContext

+ HTTP HTTPContext

type SyncContext

+ HTTP HTTPContext

type TriggerActionContext

+ HTTP HTTPContext

type TriggerContext

+ HTTP HTTPContext

Jan 8, 2026

Changes in this version

type ActionContext

+ AppInstallation AppInstallationContext

+ Auth AuthContext

+ ExecutionState ExecutionStateContext

+ Integration IntegrationContext

+ Metadata MetadataContext

+ Requests RequestContext

type ExecutionContext

+ AppInstallation AppInstallationContext

+ Auth AuthContext

+ ExecutionState ExecutionStateContext

+ Integration IntegrationContext

+ Metadata MetadataContext

+ NodeMetadata MetadataContext

+ Requests RequestContext

type SetupContext

+ AppInstallation AppInstallationContext

+ Auth AuthContext

+ Integration IntegrationContext

+ Metadata MetadataContext

+ Requests RequestContext

type TriggerActionContext

+ AppInstallation AppInstallationContext

+ Events EventContext

+ Metadata MetadataContext

+ Requests RequestContext

+ Webhook NodeWebhookContext

type TriggerContext

+ AppInstallation AppInstallationContext

+ Events EventContext

+ Integration IntegrationContext

+ Metadata MetadataContext

+ Requests RequestContext

+ Webhook NodeWebhookContext

type WebhookRequestContext

+ Events EventContext

+ Webhook NodeWebhookContext

Jan 7, 2026

Changes in this version

+ type CleanupWebhookContext struct

+ AppInstallation AppInstallationContext

+ Webhook WebhookContext

+ type NodeWebhookContext interface

+ GetBaseURL func() string

+ GetSecret func() ([]byte, error)

+ ResetSecret func() ([]byte, []byte, error)

+ Setup func(options *WebhookSetupOptions) (string, error)

+ type SetupWebhookContext struct

+ AppInstallation AppInstallationContext

+ Webhook WebhookContext

type WebhookContext

+ GetConfiguration func() any

+ GetID func() string

+ GetMetadata func() any

+ GetURL func() string

+ SetSecret func([]byte) error

Jan 6, 2026

Changes in this version

type AppInstallationContext

+ ScheduleResync func(interval time.Duration) error

Jan 6, 2026

Changes in this version

type HTTPRequestContext

+ WebhooksBaseURL string

type SyncContext

+ WebhooksBaseURL string

type WebhookContext

+ GetBaseURL func() string

+ ResetSecret func() ([]byte, []byte, error)

+ type Widget interface

+ Color func() string

+ Configuration func() []configuration.Field

+ Description func() string

+ Icon func() string

+ Label func() string

+ Name func() string

Dec 28, 2025

Changes in this version

+ var DefaultOutputChannel = OutputChannel

+ type Action struct

+ Description string

+ Name string

+ Parameters []configuration.Field

+ UserAccessible bool

+ type ActionContext struct

+ AppInstallationContext AppInstallationContext

+ AuthContext AuthContext

+ Configuration any

+ ExecutionStateContext ExecutionStateContext

+ IntegrationContext IntegrationContext

+ Logger *log.Entry

+ MetadataContext MetadataContext

+ Name string

+ Parameters map[string]any

+ RequestContext RequestContext

+ type AppInstallationContext interface

+ GetConfig func(name string) ([]byte, error)

+ GetMetadata func() any

+ GetSecrets func() ([]InstallationSecret, error)

+ GetState func() string

+ ID func() uuid.UUID

+ NewBrowserAction func(action BrowserAction)

+ RemoveBrowserAction func()

+ RequestWebhook func(configuration any) error

+ SetMetadata func(any)

+ SetSecret func(name string, value []byte) error

+ SetState func(state, stateDescription string)

+ type Application interface

+ CleanupWebhook func(ctx AppInstallationContext, options WebhookOptions) error

+ CompareWebhookConfig func(a, b any) (bool, error)

+ Components func() []Component

+ Configuration func() []configuration.Field

+ Description func() string

+ HandleRequest func(ctx HTTPRequestContext)

+ Icon func() string

+ Label func() string

+ Name func() string

+ SetupWebhook func(ctx AppInstallationContext, options WebhookOptions) (any, error)

+ Sync func(ctx SyncContext) error

+ Triggers func() []Trigger

+ type AuthContext interface

+ AuthenticatedUser func() *User

+ GetUser func(id uuid.UUID) (*User, error)

+ HasRole func(role string) (bool, error)

+ InGroup func(group string) (bool, error)

+ type BrowserAction struct

+ Description string

+ FormFields map[string]string

+ Method string

+ URL string

+ type Component interface

+ Actions func() []Action

+ Cancel func(ctx ExecutionContext) error

+ Color func() string

+ Configuration func() []configuration.Field

+ Description func() string

+ Execute func(ctx ExecutionContext) error

+ HandleAction func(ctx ActionContext) error

+ HandleWebhook func(ctx WebhookRequestContext) (int, error)

+ Icon func() string

+ Label func() string

+ Name func() string

+ OutputChannels func(configuration any) []OutputChannel

+ ProcessQueueItem func(ctx ProcessQueueContext) (*uuid.UUID, error)

+ Setup func(ctx SetupContext) error

+ type EventContext interface

+ Emit func(payloadType string, payload any) error

+ type ExecutionContext struct

+ AppInstallationContext AppInstallationContext

+ AuthContext AuthContext

+ Configuration any

+ Data any

+ ExecutionStateContext ExecutionStateContext

+ ID uuid.UUID

+ IntegrationContext IntegrationContext

+ Logger *log.Entry

+ MetadataContext MetadataContext

+ NodeMetadataContext MetadataContext

+ RequestContext RequestContext

+ WorkflowID string

+ type ExecutionStateContext interface

+ Emit func(channel, payloadType string, payloads []any) error

+ Fail func(reason, message string) error

+ IsFinished func() bool

+ Pass func() error

+ SetKV func(key, value string) error

+ type HTTPRequestContext struct

+ AppInstallation AppInstallationContext

+ BaseURL string

+ Logger *logrus.Entry

+ OrganizationID string

+ Request *http.Request

+ Response http.ResponseWriter

+ type InstallationSecret struct

+ Name string

+ Value []byte

+ type IntegrationContext interface

+ GetIntegration func(ID string) (integrations.ResourceManager, error)

+ type MetadataContext interface

+ Get func() any

+ Set func(any) error

+ type OutputChannel struct

+ Description string

+ Label string

+ Name string

+ type ProcessQueueContext struct

+ Configuration any

+ CountDistinctIncomingSources func() (int, error)

+ CreateExecution func() (*ExecutionContext, error)

+ DefaultProcessing func() (*uuid.UUID, error)

+ DequeueItem func() error

+ EventID string

+ FindExecutionByKV func(key string, value string) (*ExecutionContext, error)

+ Input any

+ NodeID string

+ RootEventID string

+ SourceNodeID string

+ UpdateNodeState func(state string) error

+ WorkflowID string

+ type RequestContext interface

+ ScheduleActionCall func(actionName string, parameters map[string]any, interval time.Duration) error

+ type SetupContext struct

+ AppInstallationContext AppInstallationContext

+ AuthContext AuthContext

+ Configuration any

+ IntegrationContext IntegrationContext

+ Logger *log.Entry

+ MetadataContext MetadataContext

+ RequestContext RequestContext

+ type SyncContext struct

+ AppInstallation AppInstallationContext

+ BaseURL string

+ Configuration any

+ InstallationID string

+ OrganizationID string

+ type Trigger interface

+ Actions func() []Action

+ Color func() string

+ Configuration func() []configuration.Field

+ Description func() string

+ HandleAction func(ctx TriggerActionContext) error

+ HandleWebhook func(ctx WebhookRequestContext) (int, error)

+ Icon func() string

+ Label func() string

+ Name func() string

+ Setup func(ctx TriggerContext) error

+ type TriggerActionContext struct

+ AppInstallationContext AppInstallationContext

+ Configuration any

+ EventContext EventContext

+ Logger *log.Entry

+ MetadataContext MetadataContext

+ Name string

+ Parameters map[string]any

+ RequestContext RequestContext

+ WebhookContext WebhookContext

+ type TriggerContext struct

+ AppInstallationContext AppInstallationContext

+ Configuration any

+ EventContext EventContext

+ IntegrationContext IntegrationContext

+ Logger *log.Entry

+ MetadataContext MetadataContext

+ RequestContext RequestContext

+ WebhookContext WebhookContext

+ type User struct

+ Email string

+ ID string

+ Name string

+ type WebhookContext interface

+ GetSecret func() ([]byte, error)

+ Setup func(options *WebhookSetupOptions) error

+ type WebhookOptions struct

+ Configuration any

+ ID string

+ Metadata any

+ Secret []byte

+ URL string

+ type WebhookRequestContext struct

+ Body []byte

+ Configuration any

+ EventContext EventContext

+ FindExecutionByKV func(key string, value string) (*ExecutionContext, error)

+ Headers http.Header

+ NodeID string

+ WebhookContext WebhookContext

+ WorkflowID string

+ type WebhookSetupOptions struct

+ AppInstallationID *uuid.UUID

+ Configuration any

+ IntegrationID *uuid.UUID

+ Resource integrations.Resource