ingest

package

v0.2.0 Latest Latest Go to latest Published: Nov 3, 2026 License: MIT-0 Imports: 19 Imported by: 0

Details

Package ingest consumes mxRaven notification events and stores inbound mail.

This section is empty.

This section is empty.

This section is empty.

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

Ingester consumes the MTA listener's notification stream and, in S3 mode, reconciles the mxRaven archive bucket.

func New(cfg config.Config, st *store.Store, s3 *blob.S3, h *hub.Hub, log *slog.Logger) *Ingester

New creates an ingester. s3 may be nil in SQLite mode.

func (i *Ingester) ReconcileOnce(ctx context.Context) error

ReconcileOnce runs one S3 bucket reconciliation pass.

func (i *Ingester) Run(ctx context.Context) error

Run consumes all configured MTA listeners until ctx is cancelled and runs the S3 reconciler when configured. It returns the first terminal error.