pq

Documentation

Overview

Package pq implements the Kythe serving api.Interface using a Postgres database backend. The database can be populated using the DB.CopyGraphStore method.

Index

• type DB
  • func Open(spec string) (*DB, error)
  • func (d *DB) CopyEntries(entries <-chan *spb.Entry) error
  • func (d *DB) CorpusRoots(ctx context.Context, req *ftpb.CorpusRootsRequest) (*ftpb.CorpusRootsReply, error)
  • func (d *DB) CrossReferences(ctx context.Context, req *xpb.CrossReferencesRequest) (*xpb.CrossReferencesReply, error)
  • func (d *DB) Decorations(ctx context.Context, req *xpb.DecorationsRequest) (*xpb.DecorationsReply, error)
  • func (d *DB) Directory(ctx context.Context, req *ftpb.DirectoryRequest) (*ftpb.DirectoryReply, error)
  • func (d *DB) Documentation(ctx context.Context, req *xpb.DocumentationRequest) (*xpb.DocumentationReply, error)
  • func (d *DB) Edges(ctx context.Context, req *xpb.EdgesRequest) (*xpb.EdgesReply, error)
  • func (d *DB) Nodes(ctx context.Context, req *xpb.NodesRequest) (*xpb.NodesReply, error)

Types

type DB

type DB struct {
	*sql.DB
	// contains filtered or unexported fields
}

DB implements the api.Interface

func Open

func Open(spec string) (*DB, error)

Open returns an api.Interface wrapper around the connection returned by sql.Open("postgres", spec).

func (*DB) CopyEntries

func (d *DB) CopyEntries(entries <-chan *spb.Entry) error

CopyEntries completely recreates the database using the given stream of GraphStore-ordered entries.

func (*DB) CorpusRoots

func (d *DB) CorpusRoots(ctx context.Context, req *ftpb.CorpusRootsRequest) (*ftpb.CorpusRootsReply, error)

CorpusRoots implements part of the filetree.Interface.

func (*DB) CrossReferences

func (d *DB) CrossReferences(ctx context.Context, req *xpb.CrossReferencesRequest) (*xpb.CrossReferencesReply, error)

CrossReferences implements part of the xrefs.Interface.

func (*DB) Decorations

func (d *DB) Decorations(ctx context.Context, req *xpb.DecorationsRequest) (*xpb.DecorationsReply, error)

Decorations implements part of the xrefs.Interface.

func (*DB) Directory

func (d *DB) Directory(ctx context.Context, req *ftpb.DirectoryRequest) (*ftpb.DirectoryReply, error)

Directory implements part of the filetree.Interface.

func (*DB) Documentation

func (d *DB) Documentation(ctx context.Context, req *xpb.DocumentationRequest) (*xpb.DocumentationReply, error)

Documentation implements part of the xrefs.Interface.

func (*DB) Edges

func (d *DB) Edges(ctx context.Context, req *xpb.EdgesRequest) (*xpb.EdgesReply, error)

Edges implements part of the xrefs.Interface.

func (*DB) Nodes

func (d *DB) Nodes(ctx context.Context, req *xpb.NodesRequest) (*xpb.NodesReply, error)

Nodes implements part of the xrefs.Interface.