Versions in this module Expand all Collapse all v2 v2.3.0 Aug 28, 2026 Changes in this version + var ErrConnectionNotFound = errors.New("integrations/runtime: connection not found") + var ErrConnectionRequired = errors.New("integrations/runtime: connection required") + var ErrCredentialInvalid = errors.New("integrations/runtime: credential invalid") + var ErrCredentialNotDeclared = errors.New("integrations/runtime: credential not declared on connection") + var ErrDefinitionNotFound = errors.New("integrations/runtime: definition not found") + var ErrInstallationNotFound = errors.New("integrations/runtime: installation not found") + var ErrInstallationRequired = errors.New("integrations/runtime: installation required") + var ErrOperationConfigInvalid = errors.New("integrations/runtime: operation config invalid") + var ErrOperationNotFound = errors.New("integrations/runtime: operation not found") + var ErrOperationRateLimited = errors.New("integrations/runtime: operation rate limited") + var ErrRuntimeClientNotFound = errors.New("integrations/runtime: runtime client not found") + var ErrUserInputInvalid = errors.New("integrations/runtime: user input invalid") + func IntegrationUnhealthyReason(installation *ent.Integration) string + func SetDefault(rt *Runtime) + type Config struct + CatalogConfig catalog.Config + DB *ent.Client + DefaultLookback time.Duration + DefinitionBuilders []registry.Builder + DevMode bool + FederationIssuer string + Gala *gala.Gala + Keystore *keystore.Store + RedisClient *redis.Client + Registry *registry.Registry + type IntegrationLookup struct + DefinitionID string + IntegrationID string + OwnerID string + type PostExecutionHook func(ctx context.Context, envelope operations.Envelope, err error) + type Runtime struct + func Default() *Runtime + func New(config Config) (*Runtime, error) + func NewForTesting(reg *registry.Registry) *Runtime + func (r *Runtime) AllowN(ctx context.Context, key string, n int, limit int, window time.Duration) (bool, error) + func (r *Runtime) BeginAuth(ctx context.Context, req keymaker.BeginRequest) (keymaker.BeginResponse, error) + func (r *Runtime) BuildClientForIntegration(ctx context.Context, integration *ent.Integration, clientID types.ClientID) (any, error) + func (r *Runtime) Catalog() []types.DefinitionSpec + func (r *Runtime) ClearIntegrationUnhealthy(ctx context.Context, installation *ent.Integration) error + func (r *Runtime) CompleteAuth(ctx context.Context, req keymaker.CompleteRequest) (keymaker.CompleteResult, error) + func (r *Runtime) DB() *ent.Client + func (r *Runtime) Definition(id string) (types.Definition, bool) + func (r *Runtime) Disconnect(ctx context.Context, installation *ent.Integration) (types.DisconnectResult, error) + func (r *Runtime) Dispatch(ctx context.Context, req types.DispatchRequest) (types.DispatchResult, error) + func (r *Runtime) DispatchWebhookEvent(ctx context.Context, integration *ent.Integration, ...) error + func (r *Runtime) EnsureInstallation(ctx context.Context, ownerID, integrationID string, def types.Definition) (*ent.Integration, bool, error) + func (r *Runtime) EnsureWebhook(ctx context.Context, integration *ent.Integration, webhookName string, ...) (*ent.IntegrationWebhook, error) + func (r *Runtime) ExecuteOperation(ctx context.Context, integration *ent.Integration, ...) (json.RawMessage, error) + func (r *Runtime) ExecuteRuntimeOperation(ctx context.Context, definitionID, operationName string, ...) (json.RawMessage, error) + func (r *Runtime) FinalizeWebhookDelivery(ctx context.Context, webhook *ent.IntegrationWebhook, deliveryID string, ...) error + func (r *Runtime) Gala() *gala.Gala + func (r *Runtime) HandleOperation(ctx context.Context, envelope operations.Envelope) error + func (r *Runtime) HandleReconcile(ctx context.Context, envelope operations.ReconcileEnvelope) (int, error) + func (r *Runtime) HandleWebhookEvent(ctx context.Context, envelope operations.WebhookEnvelope) error + func (r *Runtime) LoadCredential(ctx context.Context, installation *ent.Integration, ...) (types.CredentialSet, bool, error) + func (r *Runtime) MarkIntegrationUnhealthy(ctx context.Context, installation *ent.Integration, reason string) error + func (r *Runtime) PrepareWebhookDelivery(ctx context.Context, webhook *ent.IntegrationWebhook, deliveryID string) (bool, error) + func (r *Runtime) PurgeInstallationJobs(ctx context.Context, integrationID string) (int, error) + func (r *Runtime) Reconcile(ctx context.Context, installation *ent.Integration, userInput json.RawMessage, ...) error + func (r *Runtime) Redis() *redis.Client + func (r *Runtime) Registry() *registry.Registry + func (r *Runtime) ResetReconcileLoops(ctx context.Context, installation *ent.Integration) error + func (r *Runtime) ResolveIntegration(ctx context.Context, lookup IntegrationLookup) (*ent.Integration, error) + func (r *Runtime) ResolveOwnerIntegration(ctx context.Context, definitionID, ownerID string, ...) (string, error) + func (r *Runtime) ResolveWebhookByEndpoint(ctx context.Context, endpointID string) (*ent.IntegrationWebhook, error) + func (r *Runtime) SeedReconcileJobs(ctx context.Context) error + func (r *Runtime) SeedReconcileJobsForInstallation(ctx context.Context, inst *ent.Integration) error + func (r *Runtime) SeedScheduledOperations(ctx context.Context) error + func (r *Runtime) SetPostExecutionHook(hook PostExecutionHook) + func (r *Runtime) ValidateUserInput(ctx context.Context, def types.Definition, userInput json.RawMessage) error Other modules containing this package github.com/theopenlane/core
Go to main page