server

Documentation

Index

• Constants
• type ExportEdge
• type ExportGraph
• type ExportNode
• type Graph
  • func NewGraph() *Graph
  • func (g *Graph) AddEdge(n1, n2 *Node)
  • func (g *Graph) AddNode(n *Node)
  • func (g *Graph) EnsureEdge(n1, n2 *Node)
  • func (g *Graph) FindNode(id string) *Node
  • func (g *Graph) JSONGraph() ([]byte, error)
  • func (g *Graph) WriteDotGraph(target string) error
• type Node
• type Observer
  • func New(client *kubernetes.Clientset, target string, port int, ...) (*Observer, error)
  • func (srv *Observer) Serve(ctx context.Context)
  • func (srv *Observer) Stop()
• type TraceProviderClient
  • func NewGateway(address string) (*TraceProviderClient, error)

Constants

const (
	// RetryInterval ..
	RetryInterval = 10 * time.Millisecond
)

Types

type ExportEdge

type ExportEdge struct {
	Source string `json:"source"`
	Target string `json:"target"`
	Type   string `json:"type"`
}

type ExportGraph

type ExportGraph struct {
	Nodes []ExportNode `json:"nodes"`
	Edges []ExportEdge `json:"edges"`
}

ExportGraph roughly maps to statusgraph/graph

type ExportNode

type ExportNode struct {
	ID        string `json:"id"`
	ServiceID string `json:"service_id"`
	Type      string `json:"type"`
}

type Graph

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

func NewGraph

func NewGraph() *Graph

NewGraph returns a new graph

func (*Graph) AddEdge

func (g *Graph) AddEdge(n1, n2 *Node)

AddEdge adds an edge

func (*Graph) AddNode

func (g *Graph) AddNode(n *Node)

AddNode adds a node

func (*Graph) EnsureEdge

func (g *Graph) EnsureEdge(n1, n2 *Node)

func (*Graph) FindNode

func (g *Graph) FindNode(id string) *Node

func (*Graph) JSONGraph

func (g *Graph) JSONGraph() ([]byte, error)

func (*Graph) WriteDotGraph

func (g *Graph) WriteDotGraph(target string) error

type Node

type Node struct {
	ServiceID string `json:"service_id"`
}

type Observer

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

func New

func New(client *kubernetes.Clientset, target string, port int, syncInterval time.Duration, bufferSize int) (*Observer, error)

func (*Observer) Serve

func (srv *Observer) Serve(ctx context.Context)

func (*Observer) Stop

func (srv *Observer) Stop()

type TraceProviderClient

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

TraceProviderClient ..

func NewGateway

func NewGateway(address string) (*TraceProviderClient, error)

NewGateway ..