monitor

Documentation

Index

• Constants
• func GetGrafanaConfigMapName(monitor *v1alpha1.TidbMonitor) string
• func GetMonitorFirstPVCName(name string) string
• func GetMonitorInstanceName(monitor *v1alpha1.TidbMonitor, shard int32) string
• func GetMonitorObjectName(monitor *v1alpha1.TidbMonitor) string
• func GetMonitorObjectNameCrossNamespace(monitor *v1alpha1.TidbMonitor) string
• func GetMonitorShardName(name string, shard int32) string
• func GetPromConfigMapName(monitor *v1alpha1.TidbMonitor) string
• func GetTLSAssetsSecretName(name string) string
• func GrafanaName(name string, shard int32) string
• func GreaterThanOrEqual(left *semver.Version, right *semver.Version) bool
• func PrometheusName(name string, shard int32) string
• func RenderPrometheusConfig(model *MonitorConfigModel) (yaml.MapSlice, error)
• type BasicAuthCredentials
• type ClusterRegexInfo
• type MonitorConfigModel
• type MonitorManager
  • func NewMonitorManager(deps *controller.Dependencies) *MonitorManager
  • func (m *MonitorManager) SyncMonitor(monitor *v1alpha1.TidbMonitor) error
• type Store
  • func NewStore(secretLister corelisterv1.SecretLister) *Store
  • func (s *Store) AddBasicAuth(ns string, ba *v1alpha1.BasicAuth, key string) error
• type TLSAsset
• type TLSAssetKey
  • func (k TLSAssetKey) String() string

Constants

const (
	FailedSync  = "FailedSync"
	SuccessSync = "SuccessSync"
)

Functions

func GetGrafanaConfigMapName

func GetGrafanaConfigMapName(monitor *v1alpha1.TidbMonitor) string

func GetMonitorFirstPVCName

func GetMonitorFirstPVCName(name string) string

func GetMonitorInstanceName

func GetMonitorInstanceName(monitor *v1alpha1.TidbMonitor, shard int32) string

func GetMonitorObjectName

func GetMonitorObjectName(monitor *v1alpha1.TidbMonitor) string

func GetMonitorObjectNameCrossNamespace

func GetMonitorObjectNameCrossNamespace(monitor *v1alpha1.TidbMonitor) string

func GetMonitorShardName

func GetMonitorShardName(name string, shard int32) string

func GetPromConfigMapName

func GetPromConfigMapName(monitor *v1alpha1.TidbMonitor) string

func GetTLSAssetsSecretName

func GetTLSAssetsSecretName(name string) string

func GrafanaName

func GrafanaName(name string, shard int32) string

func GreaterThanOrEqual

func GreaterThanOrEqual(left *semver.Version, right *semver.Version) bool

func PrometheusName

func PrometheusName(name string, shard int32) string

func RenderPrometheusConfig

func RenderPrometheusConfig(model *MonitorConfigModel) (yaml.MapSlice, error)

Types

type BasicAuthCredentials

type BasicAuthCredentials struct {
	Username string
	Password string
}

type ClusterRegexInfo

type ClusterRegexInfo struct {
	Name      string
	Namespace string
	// contains filtered or unexported fields
}

ClusterRegexInfo is the monitor cluster info

type MonitorConfigModel

type MonitorConfigModel struct {
	AlertmanagerURL           string
	ClusterInfos              []ClusterRegexInfo
	DMClusterInfos            []ClusterRegexInfo
	ExternalLabels            model.LabelSet
	RemoteWriteCfg            *yaml.MapItem
	EnableAlertRules          bool
	EnableExternalRuleConfigs bool
	// contains filtered or unexported fields
}

type MonitorManager

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

func NewMonitorManager

func NewMonitorManager(deps *controller.Dependencies) *MonitorManager

func (*MonitorManager) SyncMonitor

func (m *MonitorManager) SyncMonitor(monitor *v1alpha1.TidbMonitor) error

type Store

type Store struct {
	TLSAssets       map[TLSAssetKey]TLSAsset
	BasicAuthAssets map[string]BasicAuthCredentials
	// contains filtered or unexported fields
}

Store is a store that fetches and caches TLS materials, bearer tokens and auth credentials from configmaps and secrets. Data can be referenced directly from a TiDBMonitor object. In practice a new store is created and used by each reconciliation loop.

Store doesn't support concurrent access.

func NewStore

func NewStore(secretLister corelisterv1.SecretLister) *Store

NewStore returns an empty assetStore.

func (*Store) AddBasicAuth

func (s *Store) AddBasicAuth(ns string, ba *v1alpha1.BasicAuth, key string) error

AddBasicAuth processes the given *BasicAuth and adds the referenced credentials to the store.

type TLSAsset

type TLSAsset string

TLSAsset represents any TLS related opaque string, e.g. CA files, client certificates.

type TLSAssetKey

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

TLSAssetKey is a key for a TLS asset.

func (TLSAssetKey) String

func (k TLSAssetKey) String() string

String implements the fmt.Stringer interface.