graph

package

v0.41.0 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/knative/eventing

Links

Open Source Insights

Documentation ¶

Index ¶

func EmptyEventType() *eventingv1beta3.EventType
type Edge
type EventTypeTransform
- func (ett EventTypeTransform) Apply(et *eventingv1beta3.EventType, tfc TransformFunctionContext) (*eventingv1beta3.EventType, TransformFunctionContext)
- func (ett EventTypeTransform) Name() string
type Graph
- func NewGraph() *Graph
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
type Vertices

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL