redisstream

type Config struct {
	// Address is the Redis server address (host:port), e.g. "redis:6379".
	Address string
	// Password is the Redis AUTH password. Empty means no auth.
	Password string
	// DB selects the Redis logical database index.
	DB int

	// Stream is the Redis Stream (and Watermill topic) task attempts are
	// published to and consumed from; ADR-006's "taskQueue" name.
	Stream string
	// ConsumerGroup is the Redis Streams consumer group every Queue
	// instance for Stream shares. It is what makes claims competing: at
	// most one consumer in the group receives a given stream entry.
	ConsumerGroup string
	// Consumer names this Queue instance's Redis Streams consumer within
	// ConsumerGroup. A generated id is used when empty.
	Consumer string

	// ClaimAfter is how long an unresolved claim (neither Complete nor
	// Nack called) may be held before Claim treats it as abandoned and
	// reclaims it for another attempt -- this Queue's equivalent of a
	// visibility timeout. See Queue's doc comment for why this is
	// enforced against the injected Clock rather than Redis server time.
	ClaimAfter time.Duration

	// DialTimeout bounds the initial Redis connection attempt. Defaults
	// to defaultDialTimeout when zero or negative.
	DialTimeout time.Duration
}

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