mqtest

type Caps struct {
	// PerTenantBudget: a full queue refuses its own tenant alone, so Fill on
	// one tenant leaves another publishing.
	PerTenantBudget bool
	// PurgesAcked: PurgeAcked removes acknowledged events past the cutoff,
	// rather than leaving retention to the broker's operator.
	PurgesAcked bool
	// UnbudgetedNotFound: DeadLetterCounts of a tenant never given a budget
	// is mq.ErrNoDeadLetterQueue rather than zero counts.
	UnbudgetedNotFound bool
	// ConfiguresDurables: CreateConsumer applies cfg.AckWait to the durable,
	// rather than checking it against one the operator configured.
	ConfiguresDurables bool
}

type Harness struct {
	// New returns a fresh broker, isolated from every other New's, in which
	// Acme and Globex can publish, budgets already applied as the wiring
	// would. Its cleanup is registered on t and must tolerate the broker
	// having been closed already.
	New func(t *testing.T) mq.Broker
	// EndDelivery ends delivery underneath a running consumer of Durable, as
	// the broker's operator or the network could (the #587 failure path):
	// deleting the durable, or closing the connection for good.
	EndDelivery func(t *testing.T, b mq.Broker)
	// Fill makes the next Publish for id refuse with mq.ErrQueueFull. nil
	// skips the cases that need it.
	Fill func(t *testing.T, b mq.Broker, id tenant.ID)
	Caps Caps
}