db

Documentation

Index

• type DbGraph
  • func NewCockroachDbGraph(dsn string) (*DbGraph, error)
  • func (d *DbGraph) Close() error
  • func (d *DbGraph) Edges(fromID, toID uuid.UUID, updatedBefore time.Time) (graph.EdgeIterator, error)
  • func (d *DbGraph) FindLink(id uuid.UUID) (*graph.Link, error)
  • func (d *DbGraph) Links(fromID, toID uuid.UUID, accessedBefore time.Time) (graph.LinkIterator, error)
  • func (d *DbGraph) RemoveStaleEdges(fromID uuid.UUID, updatedBefore time.Time) error
  • func (d *DbGraph) UpsertEdge(edge *graph.Edge) error
  • func (d *DbGraph) UpsertLink(link *graph.Link) error

Types

type DbGraph

type DbGraph struct {
	// contains filtered or unexported fields
}

func NewCockroachDbGraph

func NewCockroachDbGraph(dsn string) (*DbGraph, error)

NewCockroachDbGraph returns a CockroachDbGraph instance that connects to the cockroachdb instance specified by dsn.

func (*DbGraph) Close

func (d *DbGraph) Close() error

Close

func (*DbGraph) Edges

func (d *DbGraph) Edges(fromID, toID uuid.UUID, updatedBefore time.Time) (graph.EdgeIterator, error)

func (*DbGraph) FindLink

func (d *DbGraph) FindLink(id uuid.UUID) (*graph.Link, error)

FindLink looks up a link bt its ID.

func (*DbGraph) Links

func (d *DbGraph) Links(fromID, toID uuid.UUID, accessedBefore time.Time) (graph.LinkIterator, error)

Links returns an iterator for the set of links whose IDs belong to the [fromID, toID) range were last accessed before provideed value

func (*DbGraph) RemoveStaleEdges

func (d *DbGraph) RemoveStaleEdges(fromID uuid.UUID, updatedBefore time.Time) error

func (*DbGraph) UpsertEdge

func (d *DbGraph) UpsertEdge(edge *graph.Edge) error

func (*DbGraph) UpsertLink

func (d *DbGraph) UpsertLink(link *graph.Link) error

UpsertLink