config

Feb 6, 2026

Changes in this version

type ClickHouseConfig

+ TLSEnabled bool

type Config

+ RetryVisibilityTimeoutSeconds int

type IDGenConfig

+ AttemptPrefix string

type RedisConfig

+ Username string

Dec 17, 2025

Changes in this version

type PortalConfig

+ EnableDestinationFilter bool

+ EnableWebhookCustomHeaders bool

Dec 10, 2025

Changes in this version

type Config

+ func (c *Config) LogConfigurationSummary() []zap.Field

Nov 17, 2025

Changes in this version

type Config

+ RetryPollBackoffMs int

type MQsConfig

+ AutoProvision *bool

Nov 7, 2025

Changes in this version

type Config

+ DeliveryIdempotencyKeyTTL int

+ IDGen IDGenConfig

+ PublishIdempotencyKeyTTL int

+ RetrySchedule []int

+ func (c *Config) GetRetryBackoff() (backoff.Backoff, int)

type DestinationWebhookConfig

+ Mode string

+ type IDGenConfig struct

+ DeliveryEventPrefix string

+ DeliveryPrefix string

+ DestinationPrefix string

+ EventPrefix string

+ Type string

Oct 13, 2025

Changes in this version

+ var ErrInvalidDeploymentID = errors.New(...)

type Config

+ DeploymentID string

type DestinationWebhookConfig

+ ProxyURL string

Oct 6, 2025

Changes in this version

type DestinationsConfig

+ IncludeMillisecondTimestamp bool

Oct 2, 2025

Changes in this version

type RedisConfig

+ ClusterEnabled bool

+ DevClusterHostOverride bool

+ TLSEnabled bool

Jul 25, 2025

Changes in this version

type AzureServiceBusConfig

+ ConnectionString string

+ type PublishAzureServiceBusConfig struct

+ ConnectionString string

+ Subscription string

+ Topic string

type PublishMQConfig

+ AzureServiceBus PublishAzureServiceBusConfig

Jun 12, 2025

Changes in this version

type AWSSQSConfig

+ func (c *AWSSQSConfig) GetProviderType() string

+ func (c *AWSSQSConfig) IsConfigured() bool

+ func (c *AWSSQSConfig) ToInfraConfig(queueType string) *mqinfra.MQInfraConfig

+ func (c *AWSSQSConfig) ToQueueConfig(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

+ type AzureServiceBusConfig struct

+ ClientID string

+ ClientSecret string

+ DeliverySubscription string

+ DeliveryTopic string

+ LogSubscription string

+ LogTopic string

+ Namespace string

+ ResourceGroup string

+ SubscriptionID string

+ TenantID string

+ func (c *AzureServiceBusConfig) GetProviderType() string

+ func (c *AzureServiceBusConfig) IsConfigured() bool

+ func (c *AzureServiceBusConfig) ToInfraConfig(queueType string) *mqinfra.MQInfraConfig

+ func (c *AzureServiceBusConfig) ToQueueConfig(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

type GCPPubSubConfig

+ func (c *GCPPubSubConfig) GetProviderType() string

+ func (c *GCPPubSubConfig) IsConfigured() bool

+ func (c *GCPPubSubConfig) ToInfraConfig(queueType string) *mqinfra.MQInfraConfig

+ func (c *GCPPubSubConfig) ToQueueConfig(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

+ type MQConfigAdapter interface

+ GetProviderType func() string

+ IsConfigured func() bool

+ ToInfraConfig func(queueType string) *mqinfra.MQInfraConfig

+ ToQueueConfig func(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

type MQsConfig

+ AzureServiceBus AzureServiceBusConfig

+ func (c *MQsConfig) ToInfraConfig(queueType string) *mqinfra.MQInfraConfig

+ func (c *MQsConfig) ToQueueConfig(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

type RabbitMQConfig

+ func (c *RabbitMQConfig) GetProviderType() string

+ func (c *RabbitMQConfig) IsConfigured() bool

+ func (c *RabbitMQConfig) ToInfraConfig(queueType string) *mqinfra.MQInfraConfig

+ func (c *RabbitMQConfig) ToQueueConfig(ctx context.Context, queueType string) (*mqs.QueueConfig, error)

May 6, 2025

Changes in this version

+ const Namespace

+ const OTelProtocolGRPC

+ const OTelProtocolHTTP

+ var ErrInvalidOTelProtocol = errors.New(...)

+ var ErrInvalidPortalProxyURL = errors.New("config validation error: invalid portal proxy url")

+ var ErrInvalidServiceType = errors.New("config validation error: invalid service type")

+ var ErrMismatchedServiceType = errors.New("config validation error: service type mismatch")

+ var ErrMissingAESSecret = errors.New("config validation error: AES encryption secret is required")

+ var ErrMissingLogStorage = errors.New("config validation error: log storage must be provided")

+ var ErrMissingMQs = errors.New("config validation error: message queue configuration is required")

+ var ErrMissingRedis = errors.New("config validation error: redis configuration is required")

+ type AWSSQSConfig struct

+ AccessKeyID string

+ DeliveryQueue string

+ Endpoint string

+ LogQueue string

+ Region string

+ SecretAccessKey string

+ type AlertConfig struct

+ AutoDisableDestination bool

+ CallbackURL string

+ ConsecutiveFailureCount int

+ type ClickHouseConfig struct

+ Addr string

+ Database string

+ Password string

+ Username string

+ func (c *ClickHouseConfig) ToConfig() *clickhouse.ClickHouseConfig

+ type Config struct

+ AESEncryptionSecret string

+ APIJWTSecret string

+ APIKey string

+ APIPort int

+ Alert AlertConfig

+ AuditLog bool

+ ClickHouse ClickHouseConfig

+ DeliveryMaxConcurrency int

+ DeliveryTimeoutSeconds int

+ DestinationMetadataPath string

+ Destinations DestinationsConfig

+ DisableTelemetry bool

+ GinMode string

+ HTTPUserAgent string

+ LogBatchSize int

+ LogBatchThresholdSeconds int

+ LogLevel string

+ LogMaxConcurrency int

+ MQs MQsConfig

+ MaxDestinationsPerTenant int

+ OpenTelemetry OpenTelemetryConfig

+ OrganizationName string

+ Portal PortalConfig

+ PostgresURL string

+ PublishMQ PublishMQConfig

+ PublishMaxConcurrency int

+ Redis RedisConfig

+ RetryIntervalSeconds int

+ RetryMaxLimit int

+ Service string

+ Telemetry TelemetryConfig

+ Topics []string

+ func Parse(flags Flags) (*Config, error)

+ func ParseWithOS(flags Flags, osInterface OSInterface) (*Config, error)

+ func ParseWithoutValidation(flags Flags, osInterface OSInterface) (*Config, error)

+ func (c *Config) ConfigFilePath() string

+ func (c *Config) GetPortalConfig() portal.PortalConfig

+ func (c *Config) GetService() (ServiceType, error)

+ func (c *Config) InitDefaults()

+ func (c *Config) MustGetService() ServiceType

+ func (c *Config) ToMigratorOpts() migrator.MigrationOpts

+ func (c *Config) ToTelemetryApplicationInfo() telemetry.ApplicationInfo

+ func (c *Config) Validate(flags Flags) error

+ type DestinationAWSKinesisConfig struct

+ MetadataInPayload bool

+ type DestinationWebhookConfig struct

+ DisableDefaultEventIDHeader bool

+ DisableDefaultSignatureHeader bool

+ DisableDefaultTimestampHeader bool

+ DisableDefaultTopicHeader bool

+ HeaderPrefix string

+ SignatureAlgorithm string

+ SignatureContentTemplate string

+ SignatureEncoding string

+ SignatureHeaderTemplate string

+ type DestinationsConfig struct

+ AWSKinesis DestinationAWSKinesisConfig

+ MetadataPath string

+ Webhook DestinationWebhookConfig

+ func (c *DestinationsConfig) ToConfig(cfg *Config) destregistrydefault.RegisterDefaultDestinationOptions

+ type Flags struct

+ Config string

+ Service string

+ Version bool

+ func ParseFlags() Flags

+ type GCPPubSubConfig struct

+ DeliverySubscription string

+ DeliveryTopic string

+ LogSubscription string

+ LogTopic string

+ Project string

+ ServiceAccountCredentials string

+ type MQsConfig struct

+ AWSSQS AWSSQSConfig

+ GCPPubSub GCPPubSubConfig

+ RabbitMQ RabbitMQConfig

+ func (c MQsConfig) GetDeliveryQueueConfig() *mqs.QueueConfig

+ func (c MQsConfig) GetInfraType() string

+ func (c MQsConfig) GetLogQueueConfig() *mqs.QueueConfig

+ type OSInterface interface

+ Environ func() []string

+ Getenv func(key string) string

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

+ Stat func(name string) (os.FileInfo, error)

+ type OpenTelemetryConfig struct

+ Logs OpenTelemetryTypeConfig

+ Metrics OpenTelemetryTypeConfig

+ ServiceName string

+ Traces OpenTelemetryTypeConfig

+ func (c *OpenTelemetryConfig) GetServiceName() string

+ func (c *OpenTelemetryConfig) ToConfig() *otel.OpenTelemetryConfig

+ func (c *OpenTelemetryConfig) Validate() error

+ type OpenTelemetryTypeConfig struct

+ Exporter string

+ Protocol string

+ type PortalConfig struct

+ BrandColor string

+ DisableOutpostBranding bool

+ FaviconURL string

+ ForceTheme string

+ Logo string

+ LogoDark string

+ OrgName string

+ ProxyURL string

+ RefererURL string

+ type PublishAWSSQSConfig struct

+ AccessKeyID string

+ Endpoint string

+ Queue string

+ Region string

+ SecretAccessKey string

+ type PublishGCPPubSubConfig struct

+ Project string

+ ServiceAccountCredentials string

+ Subscription string

+ Topic string

+ type PublishMQConfig struct

+ AWSSQS PublishAWSSQSConfig

+ GCPPubSub PublishGCPPubSubConfig

+ RabbitMQ PublishRabbitMQConfig

+ func (c *PublishMQConfig) GetQueueConfig() *mqs.QueueConfig

+ func (c PublishMQConfig) GetInfraType() string

+ type PublishRabbitMQConfig struct

+ Exchange string

+ Queue string

+ ServerURL string

+ type RabbitMQConfig struct

+ DeliveryQueue string

+ Exchange string

+ LogQueue string

+ ServerURL string

+ type RedisConfig struct

+ Database int

+ Host string

+ Password string

+ Port int

+ func (c *RedisConfig) ToConfig() *redis.RedisConfig

+ type ServiceType int

+ const ServiceTypeAPI

+ const ServiceTypeAll

+ const ServiceTypeDelivery

+ const ServiceTypeLog

+ func ServiceTypeFromString(s string) (ServiceType, error)

+ func (s ServiceType) String() string

+ type TelemetryConfig struct

+ BatchInterval int

+ BatchSize int

+ Disabled bool

+ HookdeckSourceURL string

+ SentryDSN string

+ func (c *TelemetryConfig) ToTelemetryConfig() telemetry.TelemetryConfig