mempubsub

type Config struct {
	// Timeout is the time that we should wait for an Ack or a Nack.
	Timeout time.Duration

	// Concurrency specifies the maximum number of concurrent requests.
	Concurrency int

	// BufferSize is the size of the Go channel buffer for a subscription.
	BufferSize int
}

type PubSub struct {
	*lifecycle.Lifecycle
	Config
	// contains filtered or unexported fields
}