controller

Documentation

Index

• Constants
• type CheckItem
• type CheckRegistry
  • func NewCheckRegistry(sensuClient *client.SensuClient) CheckRegistry
  • func (c *CheckRegistry) Add(checks []check.Check, resource interface{}, checkSource string)
  • func (c *CheckRegistry) Delete(checks []check.Check, resource interface{}, checkSource string)
  • func (c *CheckRegistry) Update(oldChecks []check.Check, newChecks []check.Check, resource interface{}, ...)
• type DaemonsetAdapter
  • func (c *DaemonsetAdapter) CheckConfigs(resource interface{}) (string, bool)
  • func (c *DaemonsetAdapter) CheckSource(resource interface{}) string
  • func (c *DaemonsetAdapter) DeregisterDefault() bool
  • func (c *DaemonsetAdapter) Informer() cache.SharedInformer
  • func (c *DaemonsetAdapter) Type() string
• type DeploymentAdapter
  • func (c *DeploymentAdapter) CheckConfigs(resource interface{}) (string, bool)
  • func (c *DeploymentAdapter) CheckSource(resource interface{}) string
  • func (c *DeploymentAdapter) DeregisterDefault() bool
  • func (c *DeploymentAdapter) Informer() cache.SharedInformer
  • func (c *DeploymentAdapter) Type() string
• type PodAdapter
  • func (c *PodAdapter) CheckConfigs(resource interface{}) (string, bool)
  • func (c *PodAdapter) CheckSource(resource interface{}) string
  • func (c *PodAdapter) DeregisterDefault() bool
  • func (c *PodAdapter) Informer() cache.SharedInformer
  • func (c *PodAdapter) Type() string
• type ResourceAdapter
  • func ResourceAdapterFactory(t string, i informers.SharedInformerFactory) ResourceAdapter
• type ResourceCheckController
  • func NewResourceCheckController(clientset kubernetes.Interface, sensuClient *client.SensuClient, ...) ResourceCheckController
  • func (c *ResourceCheckController) Run(stopCh chan struct{})
• type ResourceChecks
• type ServiceAdapter
  • func (c *ServiceAdapter) CheckConfigs(resource interface{}) (string, bool)
  • func (c *ServiceAdapter) CheckSource(resource interface{}) string
  • func (c *ServiceAdapter) DeregisterDefault() bool
  • func (c *ServiceAdapter) Informer() cache.SharedInformer
  • func (c *ServiceAdapter) Type() string

Constants

const (
	CheckAnnotation = "hootsuite.com/sensu-checks"
)

Types

type CheckItem

type CheckItem struct {
	UpdateCh chan interface{}
}

type CheckRegistry

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

func NewCheckRegistry

func NewCheckRegistry(sensuClient *client.SensuClient) CheckRegistry

NewCheckRegistry creates a new CheckRegistry

func (*CheckRegistry) Add

func (c *CheckRegistry) Add(checks []check.Check, resource interface{}, checkSource string)

Add adds checks to the registry and starts them

func (*CheckRegistry) Delete

func (c *CheckRegistry) Delete(checks []check.Check, resource interface{}, checkSource string)

Delete stop checks and removes if from the the registry

func (*CheckRegistry) Update

func (c *CheckRegistry) Update(oldChecks []check.Check, newChecks []check.Check, resource interface{}, checkSource string)

Update updates checks in the registry

type DaemonsetAdapter

type DaemonsetAdapter struct {
	I informers_v1beta1.DaemonSetInformer
}

func (*DaemonsetAdapter) CheckConfigs

func (c *DaemonsetAdapter) CheckConfigs(resource interface{}) (string, bool)

func (*DaemonsetAdapter) CheckSource

func (c *DaemonsetAdapter) CheckSource(resource interface{}) string

func (*DaemonsetAdapter) DeregisterDefault

func (c *DaemonsetAdapter) DeregisterDefault() bool

func (*DaemonsetAdapter) Informer

func (c *DaemonsetAdapter) Informer() cache.SharedInformer

func (*DaemonsetAdapter) Type

func (c *DaemonsetAdapter) Type() string

type DeploymentAdapter

type DeploymentAdapter struct {
	I informers_v1beta1.DeploymentInformer
}

func (*DeploymentAdapter) CheckConfigs

func (c *DeploymentAdapter) CheckConfigs(resource interface{}) (string, bool)

func (*DeploymentAdapter) CheckSource

func (c *DeploymentAdapter) CheckSource(resource interface{}) string

func (*DeploymentAdapter) DeregisterDefault

func (c *DeploymentAdapter) DeregisterDefault() bool

func (*DeploymentAdapter) Informer

func (c *DeploymentAdapter) Informer() cache.SharedInformer

func (*DeploymentAdapter) Type

func (c *DeploymentAdapter) Type() string

type PodAdapter

type PodAdapter struct {
	I informers_v1.PodInformer
}

func (*PodAdapter) CheckConfigs

func (c *PodAdapter) CheckConfigs(resource interface{}) (string, bool)

func (*PodAdapter) CheckSource

func (c *PodAdapter) CheckSource(resource interface{}) string

func (*PodAdapter) DeregisterDefault

func (c *PodAdapter) DeregisterDefault() bool

func (*PodAdapter) Informer

func (c *PodAdapter) Informer() cache.SharedInformer

func (*PodAdapter) Type

func (c *PodAdapter) Type() string

type ResourceAdapter

type ResourceAdapter interface {
	CheckSource(resource interface{}) string
	CheckConfigs(resource interface{}) (string, bool)
	Informer() cache.SharedInformer
	Type() string
	DeregisterDefault() bool
}

func ResourceAdapterFactory

func ResourceAdapterFactory(t string, i informers.SharedInformerFactory) ResourceAdapter

ResourceAdapterFactory creates an adapter for the given resource type (t) and informer factory

type ResourceCheckController

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

func NewResourceCheckController

func NewResourceCheckController(clientset kubernetes.Interface, sensuClient *client.SensuClient, adapter ResourceAdapter) ResourceCheckController

NewResourceCheckController creates a new controller for k8s resources based on what adapter is bassed in.

func (*ResourceCheckController) Run

func (c *ResourceCheckController) Run(stopCh chan struct{})

type ResourceChecks

type ResourceChecks map[uint64]CheckItem

type ServiceAdapter

type ServiceAdapter struct {
	I informers_v1.ServiceInformer
}

func (*ServiceAdapter) CheckConfigs

func (c *ServiceAdapter) CheckConfigs(resource interface{}) (string, bool)

func (*ServiceAdapter) CheckSource

func (c *ServiceAdapter) CheckSource(resource interface{}) string

func (*ServiceAdapter) DeregisterDefault

func (c *ServiceAdapter) DeregisterDefault() bool

func (*ServiceAdapter) Informer

func (c *ServiceAdapter) Informer() cache.SharedInformer

func (*ServiceAdapter) Type

func (c *ServiceAdapter) Type() string