Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Grouper ¶
type Grouper func(ctx context.Context, in <-chan *assets.Asset, out chan<- *assets.Asset, gOut chan<- *assets.Group)
Grouper is an interface for a type that can group assets.
type GrouperPipeline ¶
type GrouperPipeline struct {
// contains filtered or unexported fields
}
func NewGrouperPipeline ¶
func NewGrouperPipeline(ctx context.Context, gs ...Grouper) *GrouperPipeline
func (*GrouperPipeline) PipeGrouper ¶
func (p *GrouperPipeline) PipeGrouper(ctx context.Context, in chan *assets.Asset) chan *assets.Group
PipeGrouper groups assets in a pipeline of groupers. Group opens and closes intermediate channels as required.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.