graph

Documentation

Index

• func EmptyEventType() *eventingv1beta3.EventType
• type Edge
  • func (e *Edge) From() *Vertex
  • func (e *Edge) Reference() *duckv1.Destination
  • func (e *Edge) To() *Vertex
  • func (e *Edge) Transform(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)
• type EventTypeTransform
  • func (ett EventTypeTransform) Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)
  • func (ett EventTypeTransform) Name() string
• type Graph
  • func NewGraph() *Graph
  • func (g *Graph) AddBroker(broker eventingv1.Broker)
  • func (g *Graph) AddChannel(channel messagingv1.Channel)
  • func (g *Graph) AddEventType(et *eventingv1beta3.EventType) error
  • func (g *Graph) AddTrigger(trigger eventingv1.Trigger) error
  • func (g *Graph) GetPrimaryOutEdgeWithRef(edgeRef *duckv1.KReference) *Edge
  • func (g *Graph) Lineage() []*Vertex
  • func (g *Graph) Sources() Vertices
  • func (g *Graph) UnvisitAll()
  • func (g *Graph) Vertices() Vertices
• type NoTransform
  • func (nt NoTransform) Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)
  • func (nt NoTransform) Name() string
• type Transform
• type TransformFunctionContext
  • func (t TransformFunctionContext) DeepCopy() TransformFunctionContext
• type Vertex
  • func (v *Vertex) AddEdge(to *Vertex, edgeRef *duckv1.Destination, transform Transform, isDLS bool)
  • func (v *Vertex) InDegree() int
  • func (v *Vertex) InEdges() []*Edge
  • func (v *Vertex) Lineage(et *eventingv1beta3.EventType, tfc TransformFunctionContext) *Vertex
  • func (v *Vertex) NewWithSameRef() *Vertex
  • func (v *Vertex) OutDegree() int
  • func (v *Vertex) OutEdges() []*Edge
  • func (v *Vertex) Reference() *duckv1.Destination
  • func (v *Vertex) Unvisit()
  • func (v *Vertex) Visit()
  • func (v *Vertex) Visited() bool
• type Vertices

Functions

func EmptyEventType

func EmptyEventType() *eventingv1beta3.EventType

Types

type Edge

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

func (*Edge) From

func (e *Edge) From() *Vertex

func (*Edge) Reference

func (e *Edge) Reference() *duckv1.Destination

func (*Edge) To

func (e *Edge) To() *Vertex

func (*Edge) Transform

func (e *Edge) Transform(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)

type EventTypeTransform

type EventTypeTransform struct {
	EventType *eventingv1beta3.EventType
}

func (EventTypeTransform) Apply

func (ett EventTypeTransform) Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)

func (EventTypeTransform) Name

func (ett EventTypeTransform) Name() string

type Graph

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

func NewGraph

func NewGraph() *Graph

func (*Graph) AddBroker

func (g *Graph) AddBroker(broker eventingv1.Broker)

func (*Graph) AddChannel

func (g *Graph) AddChannel(channel messagingv1.Channel)

func (*Graph) AddEventType

func (g *Graph) AddEventType(et *eventingv1beta3.EventType) error

func (*Graph) AddTrigger

func (g *Graph) AddTrigger(trigger eventingv1.Trigger) error

func (*Graph) GetPrimaryOutEdgeWithRef

func (g *Graph) GetPrimaryOutEdgeWithRef(edgeRef *duckv1.KReference) *Edge

func (*Graph) Lineage

func (g *Graph) Lineage() []*Vertex

func (*Graph) Sources

func (g *Graph) Sources() Vertices

Sources returns all of the sources vertices in a graph A source vertex is defined as a graph with an in degree of 0 and an out degree >= 1 This means that there are only outward edges from the vertex, and no inward edges

func (*Graph) UnvisitAll

func (g *Graph) UnvisitAll()

func (*Graph) Vertices

func (g *Graph) Vertices() Vertices

type NoTransform

type NoTransform struct{}

func (NoTransform) Apply

func (nt NoTransform) Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)

func (NoTransform) Name

func (nt NoTransform) Name() string

type Transform

type Transform interface {
	Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)
	Name() string
}

type TransformFunctionContext

type TransformFunctionContext struct{}

TODO(cali0707): flesh this out more, know we need it, not sure what needs to be in it yet

func (TransformFunctionContext) DeepCopy

func (t TransformFunctionContext) DeepCopy() TransformFunctionContext

type Vertex

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

func (*Vertex) AddEdge

func (v *Vertex) AddEdge(to *Vertex, edgeRef *duckv1.Destination, transform Transform, isDLS bool)

func (*Vertex) InDegree

func (v *Vertex) InDegree() int

func (*Vertex) InEdges

func (v *Vertex) InEdges() []*Edge

func (*Vertex) Lineage

func (v *Vertex) Lineage(et *eventingv1beta3.EventType, tfc TransformFunctionContext) *Vertex

computes the lineage from the given vertex with the given input eventtype

func (*Vertex) NewWithSameRef

func (v *Vertex) NewWithSameRef() *Vertex

func (*Vertex) OutDegree

func (v *Vertex) OutDegree() int

func (*Vertex) OutEdges

func (v *Vertex) OutEdges() []*Edge

func (*Vertex) Reference

func (v *Vertex) Reference() *duckv1.Destination

func (*Vertex) Unvisit

func (v *Vertex) Unvisit()

func (*Vertex) Visit

func (v *Vertex) Visit()

func (*Vertex) Visited

func (v *Vertex) Visited() bool

type Vertices

type Vertices []*Vertex