common

type APIConfig struct {
	Port int `json:"port,omitempty"`
}

type ConnectionStringBuilder struct {
	// contains filtered or unexported fields
}

type FailoverStorageConfig struct {
	// Storage is the backend definition. Type must be "gcs", "s3", or "file".
	// When Storage is nil, failover mode is disabled and existing
	// behavior is unchanged: a NATS outage causes the producer to
	// crash-loop until NATS recovers (the pre-failover-mode default).
	// Pointer (vs embedded struct) so the inner `required` tags only
	// fire when the user actually configured failover mode.
	Storage *ObjectStorageConfig `json:"storage,omitempty"`
	// RecoveryPollSeconds is how often to probe NATS while in failover
	// mode. Defaults to 30.
	RecoveryPollSeconds int `json:"recovery_poll_seconds,omitempty"`
	// MaxConcurrentDrainSubjects caps the number of parallel subject-drain
	// goroutines. Defaults to 4.
	MaxConcurrentDrainSubjects int `json:"max_concurrent_drain_subjects,omitempty"`
}

type HTTPConfig struct {
	Port int `json:"port" validate:"required"`
}

type NATSConfig struct {
	// Replicas is the number of stream replicas in the NATS cluster.
	// Defaults to 1 when 0 or unset.
	Replicas int `json:"replicas,omitempty"`
	// MaxAgeSeconds is the maximum age of messages in the stream, in seconds.
	// Messages older than this are automatically removed. Defaults to 0
	// (unlimited / keep forever) when unset.
	MaxAgeSeconds int `json:"max_age_seconds,omitempty"`
	// OversizeBucketTTLSeconds is the time-to-live for objects in the oversize
	// bucket, in seconds. Objects older than this are automatically removed.
	// Defaults to 0 (unlimited / keep forever) when unset.
	OversizeBucketTTLSeconds int `json:"oversize_bucket_ttl_seconds,omitempty"`
}

type NATSTLSConfig struct {
	CACertPath     *string `json:"ca_cert_path,omitempty"`
	ClientCertPath *string `json:"client_cert_path,omitempty"`
	ClientKeyPath  *string `json:"client_key_path,omitempty"`
}

type ObjectStorageConfig struct {
	// Identifier is the unique name of this storage backend.
	Identifier string `json:"identifier" validate:"required"`
	// Type selects the backend implementation: "gcs", "s3", "file", or "nats".
	Type string `json:"type" validate:"required,oneof=gcs file nats s3"`
	// BucketName is the GCS/S3 bucket name, the local directory for "file",
	// or the NATS ObjectStore bucket name for "nats".
	BucketName string `json:"bucket_name" validate:"required"`
}

type QueuingConfig struct {
	Driver                        string        `json:"driver" validate:"required"`
	URL                           string        `json:"url,omitempty"`
	TLSConfig                     NATSTLSConfig `json:"tls_config,omitempty"`
	NATS                          NATSConfig    `json:"nats_config,omitempty"`
	Username                      string        `json:"username,omitempty"`
	Password                      string        `json:"password,omitempty"`
	StreamName                    string        `json:"stream_name,omitempty"`
	TempStreamName                string        `json:"temp_stream_name,omitempty"`
	SnapshotStreamName            string        `json:"snapshot_stream_name,omitempty"`
	SnapshotStatusBucketName      string        `json:"snapshot_status_bucket_name,omitempty"`
	SnapshotStatusEnabled         bool          `json:"snapshot_status_enabled,omitempty"`
	SnapshotSubjectName           string        `json:"snapshot_subject_name,omitempty"`
	LowestAckPurgeEnabled         bool          `json:"lowest_ack_purge_enabled,omitempty"`
	LowestAckPurgeScheduleSeconds int           `json:"lowest_ack_purge_schedule_seconds,omitempty"`
	OversizeLimitBytes            int64         `json:"oversize_limit_bytes,omitempty"`
	// ObjectStorageConfig configures the durable storage backend used for
	// oversize and snapshot events. When nil, oversize/snapshot events
	// will fail at runtime if they occur. When non-nil, all inner fields
	// (identifier, type, bucket_name) are required.
	ObjectStorageConfig *ObjectStorageConfig `json:"object_storage_config,omitempty"`
	// FailoverStorage configures durable buffering for the case where
	// NATS becomes unavailable. When unset, failover mode is disabled.
	FailoverStorage FailoverStorageConfig `json:"failover_storage,omitempty"`
	// AckWaitSeconds is the time NATS waits before redelivering an unacknowledged
	// message. Defaults to 30 seconds (NATS default) when 0 or unset.
	AckWaitSeconds int `json:"ack_wait_seconds,omitempty"`
	// SnapshotRequestsStreamName is the stream snapshot requests are published
	// to and consumed from. Defaults to StreamName. A dedicated stream keeps the
	// rarely used request subject out of the busy main stream, where fetching a
	// new request after a quiet week scans every block written since the last
	// one and stalls writes to the stream.
	SnapshotRequestsStreamName string `json:"snapshot_requests_stream_name,omitempty"`
}

type SortedStringSlice struct {
	sync.Mutex
	// contains filtered or unexported fields
}