config

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 19, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package config loads and validates the process configuration.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Endpoint, Region, InputBucket, IntakeQueueURL, ChunkQueueURL, OutputQueueURL string
	// CompletionQueueURL is the SQS queue where the Worker sends technical
	// conclusion events. It is separate from the record-envelope output queue.
	CompletionQueueURL                             string
	LedgerTable                                    string
	Environment                                    string
	FileConfigPath                                 string
	GlobalLimitsParameter                          string
	RecordsPerChunk, BatchSize, MaxReceiveCount    int
	LedgerRetentionDays                            int
	MaxEventBytes                                  int
	MaxFileBytes, MaxChunkBytes, TargetChunkBytes  int64
	EventSchemaID, EventSchemaVersion, EventFormat string
	// OutputMode and its limits are copied to explicit organizer jobs. Prefix
	// configurations override these values for S3-triggered admissions.
	OutputMode             f2e.OutputMode
	MaxEnvelopesPerMessage int
	MaxMessageBytes        int
	// PublishConcurrency is the maximum number of SQS SendMessageBatch calls
	// that may be in-flight simultaneously within a single chunk processing.
	// Default is 1 (sequential). Values 2–16 are valid; higher is capped to 16.
	PublishConcurrency int
}

func Load

func Load() (Config, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL