Documentation
¶
Overview ¶
Package respipe contains utilities for running pipelines on android resources.
Index ¶
- func EmitPathInfos(ctx context.Context, pis []*res.PathInfo) <-chan *res.PathInfo
- func EmitPathInfosDir(ctx context.Context, base string) (<-chan *res.PathInfo, <-chan error)
- func EmitPathInfosDirs(ctx context.Context, dirs []string) (<-chan *res.PathInfo, <-chan error)
- func Errorf(ctx context.Context, fmts string, a ...interface{}) error
- func MergeErrStreams(ctx context.Context, errCs []<-chan error) <-chan error
- func MergePathInfoStreams(ctx context.Context, piCs []<-chan *res.PathInfo) <-chan *res.PathInfo
- func MergeResStreams(ctx context.Context, resCs []<-chan *rdpb.Resource) <-chan *rdpb.Resource
- func PrefixErr(ctx context.Context, add string) context.Context
- func SendErr(ctx context.Context, errC chan<- error, err error) bool
- func SendRes(ctx context.Context, resC chan<- *rdpb.Resource, r *rdpb.Resource) bool
- type ResInput
- type ResOutput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EmitPathInfos ¶
EmitPathInfos takes the list of provided PathInfos and emits them via its returned channel.
func EmitPathInfosDir ¶
EmitPathInfosDir descends a provided directory and emits PathInfo objects via its returned channel. It also emits any errors encountered during the walk to its error channel.
func EmitPathInfosDirs ¶
EmitPathInfosDirs descends a provided directories and emits PathsInfo objects via its returned channel. It also emits any errors encountered during the walk to its error channel.
func Errorf ¶
Errorf returns a formatted error with any context sensitive information prefixed to the error
func MergeErrStreams ¶
MergeErrStreams fans in multiple error streams into a single stream.
func MergePathInfoStreams ¶
MergePathInfoStreams fans in multiple PathInfo streams into a single stream.
func MergeResStreams ¶
MergeResStreams fans in multiple Resource streams into a single stream.
Source Files