nodes

func BuildCommits(ctx context.Context, builder p2plab.Builder, commits []string) (linkByCommit map[string]string, err error)

func CollectReports(ctx context.Context, ns []p2plab.Node) (map[string]metadata.ReportNode, error)

func Connect(ctx context.Context, ns []p2plab.Node) error

func ResolveUniqueCommits(ctx context.Context, builder p2plab.Builder, ns []p2plab.Node) (commitByRef map[string]string, err error)

func Session(ctx context.Context, ns []p2plab.Node, fn func(context.Context) error) (opentracing.Span, error)

func Update(ctx context.Context, builder p2plab.Builder, ns []p2plab.Node) error

func WaitHealthy(ctx context.Context, ns []p2plab.Node) error