parsedmarc.application 🔗

InboundWorker 🔗

InboundWorker(
    queue: Queue[Job], sink_workers: list[SinkWorker]
)

Bases: Worker

Worker that handles passing jobs from sources to all sinks

New in 9.0.

OutboundWorker(sink_workers: list[SinkWorker])

Bases: Worker

Worker than handles passing completed jobs from sinks to sources

New in 9.0.

SinkWorker(
    sink: Sink,
    in_queue: Queue[Job],
    out_queue: Queue[tuple[Job, JobStatus]],
)

Bases: Worker

Sink Worker

New in 9.0.

PARAMETER	DESCRIPTION
`sink`	sink to send jobs to TYPE: `Sink`
`in_queue`	jobs to store TYPE: `Queue[Job]`
`out_queue`	response to jobs TYPE: `Queue[tuple[Job, JobStatus]]`

SourceWorker(source: Source, queue: Queue[Job])

Bases: Worker

Source Worker

New in 9.0.

PARAMETER	DESCRIPTION
`source`	Source for this worker to make jobs from TYPE: `Source`
`queue`	output queue to send jobs to TYPE: `Queue[Job]`

Bases: Application

ParseDMARC application with streaming implementation.

This is a fork of the original ParseDMARC project.

New in 9.0.

Worker()

Bases: LoggingMixin

Base class for workers.

New in 9.0.