topology

Documentation

Index

• Constants
• func ComponentCostRun()
• func ComponentRun()
• func ComponentStatusSummarySync()
• func NewTopologyParams(values url.Values) duty.TopologyOptions
• func Query(params duty.TopologyOptions) (*duty.TopologyResponse, error)
• func Run(opts TopologyRunOptions, s v1.Topology) []*pkg.Component
• func SyncComponentRelationships(parentComponentID uuid.UUID, relationships []*pkg.ComponentRelationship) error
• func SyncComponents(opts TopologyRunOptions, topology v1.Topology) error
• type ComponentContext
  • func NewComponentContext(client *kommons.Client, kubernetes kubernetes.Interface, system v1.Topology) *ComponentContext
  • func (c *ComponentContext) Clone() *ComponentContext
  • func (c *ComponentContext) GetTemplater() ktemplate.StructTemplater
  • func (c *ComponentContext) SetCurrentComponent(component *pkg.Component)
  • func (c *ComponentContext) TemplateComponent(component *v1.ComponentSpec) error
  • func (c *ComponentContext) TemplateConfig(config *v1.Config) error
  • func (c *ComponentContext) TemplateProperty(property *v1.Property) error
  • func (c *ComponentContext) TemplateStruct(data interface{}) error
  • func (c *ComponentContext) WithComponents(components *pkg.Components, current *pkg.Component) *ComponentContext
• type TopologyRunOptions

Constants

const DefaultDepth = 3

Functions

func ComponentCostRun

func ComponentCostRun()

func ComponentRun

func ComponentRun()

Fetches and updates the selected component for components

func ComponentStatusSummarySync

func ComponentStatusSummarySync()

func NewTopologyParams

func NewTopologyParams(values url.Values) duty.TopologyOptions

func Query

func Query(params duty.TopologyOptions) (*duty.TopologyResponse, error)

func Run

func Run(opts TopologyRunOptions, s v1.Topology) []*pkg.Component

func SyncComponentRelationships

func SyncComponentRelationships(parentComponentID uuid.UUID, relationships []*pkg.ComponentRelationship) error

func SyncComponents

func SyncComponents(opts TopologyRunOptions, topology v1.Topology) error

Types

type ComponentContext

type ComponentContext struct {
	*context.KubernetesContext
	Topology     v1.Topology
	ComponentAPI v1.Component
	// Components keep track of the components that properties can apply to,
	// properties can return a map of component names to properties to facilitate
	// queries that are more efficient to perform for all components rather than a component at a time
	Components *pkg.Components
	// Properties can either be looked up on an individual component, or act as a summary across all components
	CurrentComponent *pkg.Component
	// contains filtered or unexported fields
}

func NewComponentContext

func NewComponentContext(client *kommons.Client, kubernetes kubernetes.Interface, system v1.Topology) *ComponentContext

func (*ComponentContext) Clone

func (c *ComponentContext) Clone() *ComponentContext

func (*ComponentContext) GetTemplater

func (c *ComponentContext) GetTemplater() ktemplate.StructTemplater

func (*ComponentContext) SetCurrentComponent

func (c *ComponentContext) SetCurrentComponent(component *pkg.Component)

func (*ComponentContext) TemplateComponent

func (c *ComponentContext) TemplateComponent(component *v1.ComponentSpec) error

func (*ComponentContext) TemplateConfig

func (c *ComponentContext) TemplateConfig(config *v1.Config) error

func (*ComponentContext) TemplateProperty

func (c *ComponentContext) TemplateProperty(property *v1.Property) error

func (*ComponentContext) TemplateStruct

func (c *ComponentContext) TemplateStruct(data interface{}) error

func (*ComponentContext) WithComponents

func (c *ComponentContext) WithComponents(components *pkg.Components, current *pkg.Component) *ComponentContext

type TopologyRunOptions

type TopologyRunOptions struct {
	*kommons.Client
	Kubernetes kubernetes.Interface
	Depth      int
	Namespace  string
}