Versions in this module Expand all Collapse all v0 v0.3.8 Jul 6, 2026 v0.3.2 May 13, 2026 Changes in this version + func ValidateProviderTarget(provider string, target DeployTarget) error + type Connection interface + Close func() error + Provider func() string + type DeployTarget string + const TargetAWSECS + const TargetAWSEKS + const TargetAWSKinesis + const TargetAWSManagedKafka + const TargetDigitalOceanApp + const TargetDigitalOceanManagedKafka + const TargetKubernetes + const TargetSelfHosted + type HealthCheck struct + Err error + Status HealthStatus + URI string + type HealthStatus string + const HealthStatusDegraded + const HealthStatusHealthy + const HealthStatusUnreachable + type MessageHandler func(ctx context.Context, msg *eventbusv1.Message) error + type Provider interface + ConnectionString func(state iac.State, env string) (string, error) + Name func() string + Probe func(uri string) HealthCheck + Resources func(cfg *eventbusv1.ClusterConfig, target DeployTarget) ([]iac.Resource, error) + StreamResources func(streams []*eventbusv1.StreamConfig, state iac.State) ([]iac.Resource, error) + type RuntimeBroker interface + Ack func(ctx context.Context, conn Connection, ackToken string) error + Connect func(ctx context.Context, cfg *eventbusv1.ClusterConfig) (Connection, error) + Consume func(ctx context.Context, conn Connection, streamName string, ...) (*eventbusv1.ConsumeResponse, error) + EnsureConsumer func(ctx context.Context, conn Connection, streamName string, ...) error + EnsureStream func(ctx context.Context, conn Connection, cfg *eventbusv1.StreamConfig) error + Publish func(ctx context.Context, conn Connection, req *eventbusv1.PublishRequest) (*eventbusv1.PublishResponse, error) + Subscribe func(ctx context.Context, conn Connection, streamName, consumerName string, ...) error
Go to main page