Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Int32Slice ¶
type Int32Slice []int32
func (Int32Slice) Len ¶
func (p Int32Slice) Len() int
func (Int32Slice) Less ¶
func (p Int32Slice) Less(i, j int) bool
func (Int32Slice) Swap ¶
func (p Int32Slice) Swap(i, j int)
type T ¶
type T struct {
// contains filtered or unexported fields
}
groupConsumer manages a fleet of topic consumers and disposes of those that have been inactive for the `Config.Consumer.DisposeAfter` period of time.
implements `dispatcher.Factory`. implements `dispatcher.Tier`.
func (*T) KeyOf ¶
func (gc *T) KeyOf(req dispatcher.Request) string
implements `dispatcher.Factory`.
func (*T) NewTier ¶
func (gc *T) NewTier(key string) dispatcher.Tier
implements `dispatcher.Factory`.
func (*T) Requests ¶
func (gc *T) Requests() chan<- dispatcher.Request
implements `dispatcher.Tier`.
func (*T) Start ¶
func (gc *T) Start(stoppedCh chan<- dispatcher.Tier)
implements `dispatcher.Tier`.
Source Files
Click to show internal directories.
Click to hide internal directories.