saltnodemanager

Documentation

Overview

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func GetStorageNodeInstance(hostname string, sProfiles []models.StorageProfile, ctxt string) (*models.Node, bool)
• func SetupSkynetService(hostname string, ctxt string) error
• type SaltNodeManager
  • func NewSaltNodeManager(config io.Reader) (*SaltNodeManager, error)
  • func (a SaltNodeManager) AcceptNode(node string, fingerprint string, ctxt string) (bool, error)
  • func (a SaltNodeManager) AddMonitoringPlugin(nodes []string, master string, plugin monitoring.Plugin, ctxt string) (map[string]interface{}, error)
  • func (a SaltNodeManager) AddNode(master string, node string, port uint, fingerprint string, username string, ...) (bool, error)
  • func (a SaltNodeManager) DisableMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)
  • func (a SaltNodeManager) DisableNode(node string, ctxt string) (bool, error)
  • func (a SaltNodeManager) EnableMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)
  • func (a SaltNodeManager) EnableNode(node string, ctxt string) (bool, error)
  • func (a SaltNodeManager) EnforceMonitoring(plugin_names []string, nodes []string, master string, ...) (map[string]interface{}, error)
  • func (a SaltNodeManager) GetCpuMetricFromCollectd(nodes []string, ctxt string) (result map[string]models.CollectdCpuMetric, err error)
  • func (a SaltNodeManager) GetFingerPrint(hostname string, ctxt string) (string, error)
  • func (a SaltNodeManager) GetSingleValuedMetricFromCollectd(nodes []string, metricName string, ctxt string) (map[string]models.CollectdSingleValuedMetric, error)
  • func (a SaltNodeManager) GetUnmanagedNodes(ctxt string) (*models.UnmanagedNodes, error)
  • func (a SaltNodeManager) IgnoreNode(node string, ctxt string) (bool, error)
  • func (a SaltNodeManager) IsNodeUp(hostname string, ctxt string) (bool, error)
  • func (a SaltNodeManager) NodeUptime(hostname string, ctxt string) (string, error)
  • func (a SaltNodeManager) RemoveMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)
  • func (a SaltNodeManager) RemoveNode(node string, ctxt string) (bool, error)
  • func (a SaltNodeManager) SetUpMonitoring(node string, master string, ctxt string) (map[string]interface{}, error)
  • func (a SaltNodeManager) SyncModules(node string, ctxt string) (bool, error)
  • func (a SaltNodeManager) SyncStorageDisks(node string, sProfiles []models.StorageProfile, ctxt string) (bool, error)
  • func (a SaltNodeManager) UpdateMonitoringConfiguration(nodes []string, config []monitoring.Plugin, ctxt string) (map[string]string, error)

Constants

const (
	NodeManagerName = "SaltNodeManager"
)

Functions

func GetStorageNodeInstance

func GetStorageNodeInstance(hostname string, sProfiles []models.StorageProfile, ctxt string) (*models.Node, bool)

func SetupSkynetService

func SetupSkynetService(hostname string, ctxt string) error

Types

type SaltNodeManager

type SaltNodeManager struct {
}

func NewSaltNodeManager

func NewSaltNodeManager(config io.Reader) (*SaltNodeManager, error)

func (SaltNodeManager) AcceptNode

func (a SaltNodeManager) AcceptNode(node string, fingerprint string, ctxt string) (bool, error)

func (SaltNodeManager) AddMonitoringPlugin

func (a SaltNodeManager) AddMonitoringPlugin(nodes []string, master string, plugin monitoring.Plugin, ctxt string) (map[string]interface{}, error)

func (SaltNodeManager) AddNode

func (a SaltNodeManager) AddNode(master string, node string, port uint, fingerprint string, username string, password string, ctxt string) (bool, error)

func (SaltNodeManager) DisableMonitoringPlugin

func (a SaltNodeManager) DisableMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)

func (SaltNodeManager) DisableNode

func (a SaltNodeManager) DisableNode(node string, ctxt string) (bool, error)

func (SaltNodeManager) EnableMonitoringPlugin

func (a SaltNodeManager) EnableMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)

func (SaltNodeManager) EnableNode

func (a SaltNodeManager) EnableNode(node string, ctxt string) (bool, error)

func (SaltNodeManager) EnforceMonitoring

func (a SaltNodeManager) EnforceMonitoring(plugin_names []string, nodes []string, master string, plugins []monitoring.Plugin, ctxt string) (map[string]interface{}, error)

func (SaltNodeManager) GetCpuMetricFromCollectd

func (a SaltNodeManager) GetCpuMetricFromCollectd(nodes []string, ctxt string) (result map[string]models.CollectdCpuMetric, err error)

func (SaltNodeManager) GetFingerPrint

func (a SaltNodeManager) GetFingerPrint(hostname string, ctxt string) (string, error)

func (SaltNodeManager) GetSingleValuedMetricFromCollectd

func (a SaltNodeManager) GetSingleValuedMetricFromCollectd(nodes []string, metricName string, ctxt string) (map[string]models.CollectdSingleValuedMetric, error)

func (SaltNodeManager) GetUnmanagedNodes

func (a SaltNodeManager) GetUnmanagedNodes(ctxt string) (*models.UnmanagedNodes, error)

func (SaltNodeManager) IgnoreNode

func (a SaltNodeManager) IgnoreNode(node string, ctxt string) (bool, error)

func (SaltNodeManager) IsNodeUp

func (a SaltNodeManager) IsNodeUp(hostname string, ctxt string) (bool, error)

func (SaltNodeManager) NodeUptime

func (a SaltNodeManager) NodeUptime(hostname string, ctxt string) (string, error)

func (SaltNodeManager) RemoveMonitoringPlugin

func (a SaltNodeManager) RemoveMonitoringPlugin(nodes []string, pluginName string, ctxt string) (map[string]string, error)

func (SaltNodeManager) RemoveNode

func (a SaltNodeManager) RemoveNode(node string, ctxt string) (bool, error)

func (SaltNodeManager) SetUpMonitoring

func (a SaltNodeManager) SetUpMonitoring(node string, master string, ctxt string) (map[string]interface{}, error)

func (SaltNodeManager) SyncModules

func (a SaltNodeManager) SyncModules(node string, ctxt string) (bool, error)

func (SaltNodeManager) SyncStorageDisks

func (a SaltNodeManager) SyncStorageDisks(node string, sProfiles []models.StorageProfile, ctxt string) (bool, error)

func (SaltNodeManager) UpdateMonitoringConfiguration

func (a SaltNodeManager) UpdateMonitoringConfiguration(nodes []string, config []monitoring.Plugin, ctxt string) (map[string]string, error)