graph

Documentation

Index

• Constants
• type Edge
• type Follow
  • func NewFollow() Follow
  • func (f *Follow) Add(from, to int64)
  • func (f *Follow) CountAll() int
  • func (f *Follow) Exists(from, to int64) bool
  • func (f *Follow) Fof(from int64, skip, limit int) map[int64]Node
  • func (f *Follow) FofIds(from int64, skip, limit int) []int64
  • func (f *Follow) GetLeaders(from int64) []int64
  • func (f *Follow) List(from int64) ([]int64, error)
  • func (f *Follow) Remove(from, to int64)
  • func (f *Follow) SuggestByUser(user int64, limit int) []int64
• type Graph
  • func NewGraph() *Graph
  • func (g *Graph) AddFollow(from, to int64) *Graph
  • func (g *Graph) Close() error
  • func (g *Graph) GetFollows(from int64) ([]int64, error)
  • func (g *Graph) GetFriendsOfFriends(from int64) ([]int64, error)
  • func (g *Graph) GetMetrics() Metrics
  • func (g *Graph) Load(name string) error
  • func (g *Graph) RemoveFollow(from, to int64) *Graph
  • func (g *Graph) SetQueryOptions(opts QueryOptions) *Graph
  • func (g *Graph) SuggestByUser(user int64) *Graph
• type Metrics
  • func (m *Metrics) IncReadCount() *Metrics
  • func (m *Metrics) IncWriteCount() *Metrics
• type Node
• type QueryOptions
  • func QueryOptionsDefault() QueryOptions

Constants

const AppVersion = "0.0.5"

const DefaultQueryLimit = 10

Types

type Edge

type Edge struct {
	Name string
	From int64
	To   int64
}

type Follow

type Follow struct {
	Data      map[int64]map[int64]Node
	AdjMatrix map[int64]map[int64]bool
}

func NewFollow

func NewFollow() Follow

func (*Follow) Add

func (f *Follow) Add(from, to int64)

func (*Follow) CountAll

func (f *Follow) CountAll() int

func (*Follow) Exists

func (f *Follow) Exists(from, to int64) bool

func (*Follow) Fof

func (f *Follow) Fof(from int64, skip, limit int) map[int64]Node

func (*Follow) FofIds

func (f *Follow) FofIds(from int64, skip, limit int) []int64

func (*Follow) GetLeaders

func (f *Follow) GetLeaders(from int64) []int64

GetLeaders returns the list of users who followed by the current from user

func (*Follow) List

func (f *Follow) List(from int64) ([]int64, error)

func (*Follow) Remove

func (f *Follow) Remove(from, to int64)

func (*Follow) SuggestByUser

func (f *Follow) SuggestByUser(user int64, limit int) []int64

type Graph

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

Graph

func NewGraph

func NewGraph() *Graph

func (*Graph) AddFollow

func (g *Graph) AddFollow(from, to int64) *Graph

func (*Graph) Close

func (g *Graph) Close() error

func (*Graph) GetFollows

func (g *Graph) GetFollows(from int64) ([]int64, error)

func (*Graph) GetFriendsOfFriends

func (g *Graph) GetFriendsOfFriends(from int64) ([]int64, error)

func (*Graph) GetMetrics

func (g *Graph) GetMetrics() Metrics

func (*Graph) Load

func (g *Graph) Load(name string) error

func (*Graph) RemoveFollow

func (g *Graph) RemoveFollow(from, to int64) *Graph

func (*Graph) SetQueryOptions

func (g *Graph) SetQueryOptions(opts QueryOptions) *Graph

func (*Graph) SuggestByUser

func (g *Graph) SuggestByUser(user int64) *Graph

type Metrics

type Metrics struct {
	FollowCount int   `json:"follow_count"`
	WriteCount  int64 `json:"write_count"`
	ReadCount   int64 `json:"read_count"`
}

func (*Metrics) IncReadCount

func (m *Metrics) IncReadCount() *Metrics

func (*Metrics) IncWriteCount

func (m *Metrics) IncWriteCount() *Metrics

type Node

type Node struct{}

type QueryOptions

type QueryOptions struct {
	Limit int
	Skip  int
}

func QueryOptionsDefault

func QueryOptionsDefault() QueryOptions