circuitfactory

Documentation

Index

• func DOTGraph(graph *policymonitoringv1.Graph) string
• func DecodePortMap(config any, circuitID string) (runtime.PortToSignals, error)
• func FactoryModule() fx.Option
• func FactoryModuleForPolicyApp(circuitAPI runtime.CircuitAPI) fx.Option
• func MermaidGraph(graph *policymonitoringv1.Graph) string
• func Module() fx.Option
• type Circuit
  • func CompileFromProto(policyProto *policylangv1.Policy, policyReadAPI iface.Policy) (*Circuit, fx.Option, error)
  • func (circuit *Circuit) CircuitView() (*policymonitoringv1.CircuitView, error)
  • func (circuit *Circuit) Components() []*runtime.ConfiguredComponent
• type Tree
  • func NewComponentAndOptions(componentProto *policylangv1.Component, componentID runtime.ComponentID, ...) (Tree, []*runtime.ConfiguredComponent, fx.Option, error)
  • func ParseNestedCircuit(nestedCircuitID runtime.ComponentID, nestedCircuit *policylangv1.NestedCircuit, ...) (Tree, []*runtime.ConfiguredComponent, fx.Option, error)
  • func RootTree(circuitProto *policylangv1.Circuit) (Tree, error)
  • func (tree *Tree) CreateComponents(componentsProto []*policylangv1.Component, circuitID runtime.ComponentID, ...) ([]*runtime.ConfiguredComponent, fx.Option, error)
  • func (tree *Tree) ExpandCircuit(depth int) []*runtime.ConfiguredComponent
  • func (tree *Tree) ExpandSubCircuit(componentID runtime.ComponentID, depth int) ([]*runtime.ConfiguredComponent, []*runtime.ConfiguredComponent, error)
  • func (tree *Tree) GetSubGraph(componentID runtime.ComponentID, depth int) (*policymonitoringv1.Graph, error)
  • func (tree *Tree) TreeGraph() (*policymonitoringv1.Tree, error)

Functions

func DOTGraph

func DOTGraph(graph *policymonitoringv1.Graph) string

DOTGraph returns Components and Links as a DOT graph description.

func DecodePortMap

func DecodePortMap(config any, circuitID string) (runtime.PortToSignals, error)

DecodePortMap decodes a proto port map into a PortToSignals map.

func FactoryModule

func FactoryModule() fx.Option

FactoryModule for component factory run via the main app.

func FactoryModuleForPolicyApp

func FactoryModuleForPolicyApp(circuitAPI runtime.CircuitAPI) fx.Option

FactoryModuleForPolicyApp for component factory run via the policy app. For singletons in the Policy scope.

func MermaidGraph

func MermaidGraph(graph *policymonitoringv1.Graph) string

MermaidGraph returns Components and Links as a mermaid graph.

func Module

func Module() fx.Option

Module for circuit and component factory run via the main app.

Types

type Circuit

type Circuit struct {
	Tree           Tree
	LeafComponents []*runtime.ConfiguredComponent
}

Circuit is a compiled Circuit

Circuit can also be converted to its graph view.

func CompileFromProto

func CompileFromProto(
	policyProto *policylangv1.Policy,
	policyReadAPI iface.Policy,
) (*Circuit, fx.Option, error)

CompileFromProto compiles a protobuf circuit definition into a Circuit.

This is helper for CreateComponents + runtime.Compile.

func (*Circuit) CircuitView

func (circuit *Circuit) CircuitView() (*policymonitoringv1.CircuitView, error)

CircuitView returns a CircuitView of the circuit.

func (*Circuit) Components

func (circuit *Circuit) Components() []*runtime.ConfiguredComponent

Components returns a list of CompiledComponents, ready to create runtime.Circuit.

type Tree

type Tree struct {
	Node     *runtime.ConfiguredComponent
	Children []Tree
}

Tree is a graph view of a Circuit.

func NewComponentAndOptions

func NewComponentAndOptions(
	componentProto *policylangv1.Component,
	componentID runtime.ComponentID,
	policyReadAPI iface.Policy,
) (Tree, []*runtime.ConfiguredComponent, fx.Option, error)

NewComponentAndOptions creates parent and leaf components and their fx options for a component spec.

func ParseNestedCircuit

func ParseNestedCircuit(
	nestedCircuitID runtime.ComponentID,
	nestedCircuit *policylangv1.NestedCircuit,
	policyReadAPI iface.Policy,
) (Tree, []*runtime.ConfiguredComponent, fx.Option, error)

ParseNestedCircuit parses a nested circuit and returns the parent, leaf components, and options.

func RootTree

func RootTree(circuitProto *policylangv1.Circuit) (Tree, error)

RootTree returns Tree to represent Circuit root.

func (*Tree) CreateComponents

func (tree *Tree) CreateComponents(
	componentsProto []*policylangv1.Component,
	circuitID runtime.ComponentID,
	policyReadAPI iface.Policy,
) ([]*runtime.ConfiguredComponent, fx.Option, error)

CreateComponents creates circuit components along with their identifiers and fx options.

Note that number of returned components might be greater than number of components in componentsProto, as some components may be composite multi-component stacks or nested circuits.

func (*Tree) ExpandCircuit

func (tree *Tree) ExpandCircuit(depth int) []*runtime.ConfiguredComponent

ExpandCircuit returns a list of ConfiguredComponents in the circuit expanded up to given depth.

func (*Tree) ExpandSubCircuit

func (tree *Tree) ExpandSubCircuit(componentID runtime.ComponentID, depth int) ([]*runtime.ConfiguredComponent, []*runtime.ConfiguredComponent, error)

ExpandSubCircuit returns a list of ConfiguredComponents in the circuit with the component at componentID expanded up to given depth.

func (*Tree) GetSubGraph

func (tree *Tree) GetSubGraph(componentID runtime.ComponentID, depth int) (*policymonitoringv1.Graph, error)

GetSubGraph returns a subgraph of the tree.

func (*Tree) TreeGraph

func (tree *Tree) TreeGraph() (*policymonitoringv1.Tree, error)

TreeGraph walks the tree and gets graph representation of the links amongst the children of each node.