k8s

Documentation

Index

• Constants
• func NewConfig(kubeConfig string) (*rest.Config, error)
• type DefaultResourceHandler
  • func (h *DefaultResourceHandler) IsTopLevel() bool
• type PolicyPoint
  • func (val PolicyPoint) String() string
• type PolicyTarget
  • func (val PolicyTarget) String() string
• type PolicyType
  • func (val PolicyType) String() string
• type Probe
  • func NewK8sProbe(g *graph.Graph) (*Probe, error)
  • func NewProbe(manager, clusterName string, g *graph.Graph, subprobes map[string]Subprobe, ...) (*Probe, error)
  • func (p *Probe) Start()
  • func (p *Probe) Stop()
• type ResourceCache
  • func NewResourceCache(restClient rest.Interface, objType runtime.Object, resources string, ...) *ResourceCache
  • func (c *ResourceCache) OnAdd(obj interface{})
  • func (c *ResourceCache) OnDelete(obj interface{})
  • func (c *ResourceCache) OnUpdate(oldObj, newObj interface{})
  • func (c *ResourceCache) Start()
  • func (c *ResourceCache) Stop()
• type ResourceHandler
• type Subprobe

Constants

const ClusterName = "cluster"

const (
	Manager = "k8s"
)

Functions

func NewConfig

func NewConfig(kubeConfig string) (*rest.Config, error)

NewConfig returns a new Kubernetes configuration object

Types

type DefaultResourceHandler

type DefaultResourceHandler struct {
}

func (*DefaultResourceHandler) IsTopLevel

func (h *DefaultResourceHandler) IsTopLevel() bool

type PolicyPoint

type PolicyPoint string

const (
	PolicyPointBegin PolicyPoint = "begin"
	PolicyPointEnd   PolicyPoint = "end"
)

func (PolicyPoint) String

func (val PolicyPoint) String() string

type PolicyTarget

type PolicyTarget string

const (
	PolicyTargetDeny  PolicyTarget = "deny"
	PolicyTargetAllow PolicyTarget = "allow"
)

func (PolicyTarget) String

func (val PolicyTarget) String() string

type PolicyType

type PolicyType string

const (
	PolicyTypeIngress PolicyType = "ingress"
	PolicyTypeEgress  PolicyType = "egress"
)

func (PolicyType) String

func (val PolicyType) String() string

type Probe

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

Probe for tracking k8s events

func NewK8sProbe

func NewK8sProbe(g *graph.Graph) (*Probe, error)

NewK8sProbe returns a new Kubernetes probe

func NewProbe

func NewProbe(manager, clusterName string, g *graph.Graph, subprobes map[string]Subprobe, linkers []probe.Probe) (*Probe, error)

NewProbe creates the probe for tracking k8s events

func (*Probe) Start

func (p *Probe) Start()

Start k8s probe

func (*Probe) Stop

func (p *Probe) Stop()

Stop k8s probe

type ResourceCache

type ResourceCache struct {
	*graph.GraphEventHandler
	// contains filtered or unexported fields
}

ResourceCache describes a cache for a specific kind of Kubernetes resource. It is in charge of listening to Kubernetes events and creating the according resource in the graph with the informations returned by the associated resource handler

func NewResourceCache

func NewResourceCache(restClient rest.Interface, objType runtime.Object, resources string, g *graph.Graph, handler ResourceHandler) *ResourceCache

NewResourceCache returns a new cache using the associed Kubernetes client and with the handler for the resource that this cache manages.

func (*ResourceCache) OnAdd

func (c *ResourceCache) OnAdd(obj interface{})

OnAdd is called when a new Kubernetes resource has been created

func (*ResourceCache) OnDelete

func (c *ResourceCache) OnDelete(obj interface{})

OnDelete is called when a Kubernetes resource has been deleted

func (*ResourceCache) OnUpdate

func (c *ResourceCache) OnUpdate(oldObj, newObj interface{})

OnUpdate is called when a Kubernetes resource has been updated

func (*ResourceCache) Start

func (c *ResourceCache) Start()

Start begin waiting on Kubernetes events

func (*ResourceCache) Stop

func (c *ResourceCache) Stop()

Stop end waiting on Kubernetes events

type ResourceHandler

type ResourceHandler interface {
	Map(obj interface{}) (graph.Identifier, graph.Metadata)
	Dump(obj interface{}) string
	IsTopLevel() bool
}

ResourceHandler is used to map Kubernetes resources to objets in the graph

type Subprobe

type Subprobe interface {
	probe.Probe
	graph.GraphListenerHandler
}