Documentation
¶
Index ¶
- func DatabaseConfigFromEnv(defaults DBDefaults) forma.DatabaseConfig
- func EntityConfigFromEnv(defaults forma.EntityConfig) forma.EntityConfig
- func Env(key, defaultValue string) string
- func EnvBool(key string, defaultValue bool) bool
- func EnvInt(key string, defaultValue int) int
- func NewPostgresPoolFromConfig(config forma.DatabaseConfig) (*pgxpool.Pool, error)
- func NewPostgresPoolFromConfigContext(ctx context.Context, config forma.DatabaseConfig) (*pgxpool.Pool, error)
- func NewS3Client(ctx context.Context, opts S3Options) (*s3.Client, error)
- func TableNamesFromEnv(defaults forma.TableNames) forma.TableNames
- type DBDefaults
- type S3Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DatabaseConfigFromEnv ¶
func DatabaseConfigFromEnv(defaults DBDefaults) forma.DatabaseConfig
func EntityConfigFromEnv ¶ added in v0.2.0
func EntityConfigFromEnv(defaults forma.EntityConfig) forma.EntityConfig
EntityConfigFromEnv overlays operator-settable entity options onto defaults.
This exists because #314's rollout is staged: creates are always enforced, but updates start report-only so that rows written before enforcement stay updatable. Flipping to enforcing is an operational decision, so it has to be reachable from the environment and not only by library embedders.
func EnvBool ¶ added in v0.2.0
EnvBool reads a boolean env var, treating "true"/"1" (case-insensitive) as true. Any other non-empty value is false; an unset var returns the default.
func NewPostgresPoolFromConfig ¶
func NewPostgresPoolFromConfig(config forma.DatabaseConfig) (*pgxpool.Pool, error)
func NewPostgresPoolFromConfigContext ¶ added in v0.0.29
func NewS3Client ¶ added in v0.2.0
NewS3Client builds an S3 client for the read path.
Credential precedence mirrors internal/cdc/flusher.go setupAWSClient: static credentials from opts win, then AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY from the environment as a static provider (only when both are non-empty), then whatever the default chain resolved.
func TableNamesFromEnv ¶
func TableNamesFromEnv(defaults forma.TableNames) forma.TableNames