dispatcher

type Factory interface {
	// dispatchKey returns a key that a child created for the specified `req`
	// should have.
	KeyOf(req Request) string

	// NewTier creates a new dispatch tier to handle requests with the
	// specified dispatch key.
	NewTier(key string) Tier
}

type Request struct {
	Timestamp  time.Time
	Group      string
	Topic      string
	ResponseCh chan<- Response
}

type Response struct {
	Msg *consumer.Message
	Err error
}

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

type Tier interface {
	// Key returns the dispatch key of the tier.
	Key() string

	// Requests returns a channel to send requests dispatched to the tier to.
	Requests() chan<- Request

	// Start spins up the tier's goroutine(s).
	Start(stoppedCh chan<- Tier)

	// Stop makes all tier goroutines stop and releases all resources.
	Stop()
}