relay

func (*Server) Close ¶

func (s *Server) Close() error

func (*Server) ListenAndServe ¶

func (s *Server) ListenAndServe() error

func (*Server) SetEnforcer ¶ added in v0.3.0

func (s *Server) SetEnforcer(e limits.Enforcer)

SetEnforcer wires in the resource-limits enforcer used to reject inbound recipients whose owner has hit the message-flow or storage cap. When nil (the default) every RCPT TO is accepted as far as the limits subsystem is concerned — handy for tests and for self-host operators who run without limits enabled. The cmd/e2a runtime always sets it.

func (*Server) SetOutbox ¶ added in v0.3.0

func (s *Server) SetOutbox(o webhookpub.Outbox)

SetOutbox wires the slice-1 transactional outbox. When set AND its FeatureFlag is enabled, the inbound trigger commits the messages row and the webhook_events outbox row in a single transaction (per design §4.2). The legacy SetPublisher path is preserved for backward compat during the slice 3 → slice 11 rollout window.

func (*Server) SetPublisher ¶ added in v0.3.0

func (s *Server) SetPublisher(p webhookpub.Publisher)

SetPublisher wires the legacy webhooks-as-a-resource publisher. Same optional-setter pattern as SetEnforcer — keeps NewServer's signature unchanged for the existing call sites and tests that don't care about the new path.