pipeline

Documentation

Overview

Package pipeline implements an in-process pipeline to create a combined filetree and xrefs serving table from a graphstore Service.

Index

• func Run(ctx context.Context, gs graphstore.Service, db keyvalue.DB, opts *Options) error
• type Options

Functions

func Run

func Run(ctx context.Context, gs graphstore.Service, db keyvalue.DB, opts *Options) error

Run writes the xrefs and filetree serving tables to db based on the given graphstore.Service.

Types

type Options

type Options struct {
	// MaxEdgePageSize is maximum number of edges that are allowed in the
	// PagedEdgeSet and any EdgePage.  If MaxEdgePageSize <= 0, no paging is
	// attempted.
	MaxEdgePageSize int
}

Options controls the behavior of pipeline.Run.