Versions in this module Expand all Collapse all v0 v0.0.2 Feb 16, 2026 Changes in this version + type Bus interface + Close func() error + Publish func(ctx context.Context, event *Event) error + Subscribe func(handler Handler, types ...Type) Subscription + type Event struct + ActorID string + ID id.ID + InstanceID id.ID + Payload map[string]any + TenantID string + Timestamp time.Time + Type Type + func NewEvent(t Type, tenantID string) *Event + func (e *Event) WithActor(actorID string) *Event + func (e *Event) WithInstance(instanceID id.ID) *Event + func (e *Event) WithPayload(payload map[string]any) *Event + type Handler func(ctx context.Context, event *Event) error + type InMemoryBus struct + func NewInMemoryBus() *InMemoryBus + func (b *InMemoryBus) Close() error + func (b *InMemoryBus) Publish(ctx context.Context, evt *Event) error + func (b *InMemoryBus) Subscribe(handler Handler, types ...Type) Subscription + type Subscription interface + Unsubscribe func() + type Type string + const CertExpiring + const CertProvisioned + const DeployFailed + const DeployRolledBack + const DeployStarted + const DeploySucceeded + const DomainAdded + const DomainRemoved + const DomainVerified + const HealthCheckFailed + const HealthCheckPassed + const HealthDegraded + const HealthRecovered + const InstanceCreated + const InstanceDeleted + const InstanceFailed + const InstanceScaled + const InstanceStarted + const InstanceStopped + const InstanceSuspended + const InstanceUnsuspended + const QuotaExceeded + const TenantCreated + const TenantDeleted + const TenantSuspended + type Webhook struct + Active bool + Events []Type + Secret string + TenantID string + URL string + type WebhookDelivery struct + Attempts int + Error string + EventID id.ID + NextRetry *time.Time + StatusCode int + WebhookID id.ID v0.0.1 Feb 13, 2026
Go to main page