delivery

type Config ¶

type Config struct {
	InstallationID string
	Owner          string
	Concurrency    int
	PollInterval   time.Duration
	CallTimeout    time.Duration
	StoreTimeout   time.Duration
	LeaseDuration  time.Duration
	RetryMin       time.Duration
	RetryMax       time.Duration
}

Config bounds work separately for each destination. Concurrency is the maximum number of calls, including calls whose sink ignores context cancellation.

type Option ¶

type Option func(*Publisher)

Option configures a Publisher beyond its Config.

func WithTelemetry(t *telemetry.Telemetry) Option

type Publisher ¶

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

func New(store durable.OutboxStore, config Config, sinks map[durable.Destination]Sink, opts ...Option) (*Publisher, error)

func (p *Publisher) Start() error

func (p *Publisher) Status(ctx context.Context, destination durable.Destination) (Status, error)

func (p *Publisher) Stop(ctx context.Context) error

type Sink ¶

type Sink interface {
	Accept(context.Context, durable.Delivery) (durable.SinkReceipt, error)
}

Sink accepts an immutable envelope durably. Identical retries, including after an unknown outcome, must return the same receipt. Conflicting content must fail. A transport acknowledgement alone does not satisfy this contract.

type Status ¶

type Status struct {
	Blocked          int64
	Pending          int64
	OldestAcceptedAt time.Time
	InFlight         int
	ErrorCategory    string
}