inmem

Documentation

Overview

Package inmem provides an in-memory graph implementation.

Index

• type Graph
  • func NewGraph() *Graph
  • func (g *Graph) Edges(fromID, toID uuid.UUID, updatedBefore time.Time) (graph.EdgeIterator, error)
  • func (g *Graph) FindLink(id uuid.UUID) (*graph.Link, error)
  • func (g *Graph) Links(fromID, toID uuid.UUID, retrievedBefore time.Time) (graph.LinkIterator, error)
  • func (g *Graph) RemoveStaleEdges(fromID uuid.UUID, updatedBefore time.Time) error
  • func (g *Graph) UpsertEdge(edge *graph.Edge) error
  • func (g *Graph) UpsertLink(link *graph.Link) error

Types

type Graph

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

Graph implements an in-memory link graph that can be concurrently accessed by multiple clients.

func NewGraph

func NewGraph() *Graph

NewGraph creates a new in-memory link graph.

func (*Graph) Edges

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

Edges returns an iterator for the set of edges whose source vertex IDs belong to the [fromID, toID) range and were updated before the provided timestamp.

func (*Graph) FindLink

func (g *Graph) FindLink(id uuid.UUID) (*graph.Link, error)

FindLink looks up a copy of a link by its ID.

func (*Graph) Links

func (g *Graph) Links(fromID, toID uuid.UUID, retrievedBefore time.Time) (graph.LinkIterator, error)

Links returns an iterator for the set of links whose IDs belong to the [fromID, toID) range and were retrieved before the provided timestamp.

func (*Graph) RemoveStaleEdges

func (g *Graph) RemoveStaleEdges(fromID uuid.UUID, updatedBefore time.Time) error

RemoveStaleEdges removes any edge that originates from the specified link ID and was updated before the specified timestamp.

func (*Graph) UpsertEdge

func (g *Graph) UpsertEdge(edge *graph.Edge) error

UpsertEdge creates a new edge or updates an existing edge.

func (*Graph) UpsertLink

func (g *Graph) UpsertLink(link *graph.Link) error

UpsertLink creates a new link or updates an existing link.