controllers

Documentation

Index

• Constants
• type AlertNotificationSyncer
• type Controller
  • func NewAlertNotificationController(grafanaclientset clientset.Interface, kubeclientset kubernetes.Interface, ...) *Controller
  • func NewController(informer cache.SharedIndexInformer, kubeclientset kubernetes.Interface, ...) *Controller
  • func NewDashboardController(grafanaclientset clientset.Interface, kubeclientset kubernetes.Interface, ...) *Controller
  • func NewDataSourceController(grafanaclientset clientset.Interface, kubeclientset kubernetes.Interface, ...) *Controller
  • func NewFolderController(grafanaclientset clientset.Interface, kubeclientset kubernetes.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, resyncDeletePeriod time.Duration, stopCh <-chan struct{}) error
• type DashboardSyncer
• type DataSourceSyncer
• type FolderSyncer
• type Syncer
• type WorkQueueItem
  • func NewResyncDeletedObjects() WorkQueueItem
  • func NewWorkQueueItem(key string, originalObject runtime.Object, id string) WorkQueueItem
• type WorkQueueItemType

Constants

const (
	SuccessSynced         = "Synced"
	MessageResourceSynced = "Grafana Object synced successfully"

	SuccessDeleted         = "Deleted"
	MessageResourceDeleted = "Grafana Object deleted successfully"
)

const (
	None          = 0
	AddOrUpdate   = 1
	Delete        = 2
	ResyncDeleted = 3
)

Types

type AlertNotificationSyncer

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

AlertNotificationSyncer is the controller implementation for GrafanaAlertNotification resources

type Controller

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

func NewAlertNotificationController

func NewAlertNotificationController(
	grafanaclientset clientset.Interface,
	kubeclientset kubernetes.Interface,
	grafanaClient grafana.Interface,
	grafanaAlertNotificationInformer informers.AlertNotificationInformer) *Controller

NewAlertNotificationController returns a new grafana alert notification controller

func NewController

func NewController(informer cache.SharedIndexInformer,
	kubeclientset kubernetes.Interface,
	syncer Syncer) *Controller

func NewDashboardController

func NewDashboardController(
	grafanaclientset clientset.Interface,
	kubeclientset kubernetes.Interface,
	grafanaClient grafana.Interface,
	grafanaDashboardInformer informers.DashboardInformer,
	grafanaFolderInformer informers.FolderInformer) *Controller

NewDashboardController returns a new grafana dashboard controller

func NewDataSourceController

func NewDataSourceController(
	grafanaclientset clientset.Interface,
	kubeclientset kubernetes.Interface,
	grafanaClient grafana.Interface,
	grafanaDataSourceInformer informers.DataSourceInformer) *Controller

NewDataSourceController returns a new grafana DataSource controller

func NewFolderController

func NewFolderController(
	grafanaclientset clientset.Interface,
	kubeclientset kubernetes.Interface,
	grafanaClient grafana.Interface,
	grafanaFolderInformer informers.FolderInformer) *Controller

NewFolderController returns a new grafana Folder controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, resyncDeletePeriod time.Duration, stopCh <-chan struct{}) error

Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

type DashboardSyncer

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

DashboardSyncer is the controller implementation for Dashboard resources

type DataSourceSyncer

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

DataSourceSyncer is the controller implementation for DataSource resources

type FolderSyncer

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

FolderSyncer is the controller implementation for Folder resources

type Syncer

type Syncer interface {
	// contains filtered or unexported methods
}

type WorkQueueItem

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

func NewResyncDeletedObjects

func NewResyncDeletedObjects() WorkQueueItem

func NewWorkQueueItem

func NewWorkQueueItem(key string, originalObject runtime.Object, id string) WorkQueueItem

type WorkQueueItemType

type WorkQueueItemType int