paths

Jul 20, 2016

Changes in this version

+ func FromSource(src *ipb.Source) []*ipb.Path

+ func KeyValue(sortKey string, p *ipb.Path) (*ipb.SortedKeyValue, error)

+ func OriginalNode(n *ipb.Path_Node) (g *srvpb.Node)

+ func RawAnchor(n *ipb.Path_Node) *srvpb.RawAnchor

+ func ReverseSinglePath(p *ipb.Path) *ipb.Path

+ func ToString(p *ipb.Path) string

+ type Reducer struct

+ Func func(context.Context, *ipb.Path_Node, ReducerIO) error

+ OutputSort func(*ipb.Path) string

+ func (r *Reducer) End(_ context.Context) error

+ func (r *Reducer) Reduce(ctx context.Context, rio reduce.IO) error

+ func (r *Reducer) Start(_ context.Context) error

+ type ReducerIO interface

+ Emit func(ctx context.Context, p *ipb.Path) error

+ Next func() (sortKey string, p *ipb.Path, err error)