skyring

package

Go to main page

Versions in this module

v0

v0.0.44

Sep 29, 2016

v0.0.43

Sep 20, 2016

v0.0.42

Sep 12, 2016

v0.0.41

Aug 5, 2016

v0.0.40

Aug 5, 2016

v0.0.39

Aug 1, 2016

v0.0.38

Jul 28, 2016

v0.0.37

Jul 27, 2016

v0.0.36

Jul 22, 2016

Changes in this version

+ var ClusterStatus = map[string]models.AlarmStatus

v0.0.35

Jul 20, 2016

v0.0.34

Jul 13, 2016

v0.0.33

Jul 12, 2016

v0.0.32

Jul 8, 2016

v0.0.31

Jul 5, 2016

v0.0.30

Jul 1, 2016

v0.0.29

Jun 28, 2016

v0.0.28

Jun 24, 2016

v0.0.27

Jun 24, 2016

v0.0.26

Jun 20, 2016

v0.0.25

Jun 18, 2016

Changes in this version

+ func FetchStatFromGraphiteWithErrorIndicate(ctxt string, hostname string, resourceName string) (value float64, isSuccess bool)

+ func SyncNodeUtilization(ctxt string, node models.Node, time_stamp_str string)

type App

+ func (a *App) POST_ReSyncClusterSummary(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_ReSyncNodeSummary(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_ReSyncNodesSummary(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_ReSyncSystemSummary(w http.ResponseWriter, r *http.Request)

v0.0.24

Jun 14, 2016

v0.0.23

Jun 13, 2016

v0.0.22

Jun 7, 2016

Changes in this version

type App

+ func (a *App) DiskHierarchy(w http.ResponseWriter, r *http.Request)

v0.0.21

May 30, 2016

v0.0.20

May 27, 2016

Changes in this version

+ func ComputeClusterSummary(cluster models.Cluster, ctxt string)

type App

+ func (a *App) GET_Slus(w http.ResponseWriter, r *http.Request)

v0.0.19

May 19, 2016

Changes in this version

+ const DEFAULT_API_PREFIX

+ const DefaultEmail

+ const DefaultMaxAge

+ const DefaultPassword

+ const DefaultRole

+ const DefaultUserName

+ const LoggingCtxt

+ const Timeout

+ var AuthProviderInstance authprovider.AuthInterface

+ var CORE_ROUTES []CoreRoute

+ var CORE_ROUTES_NOAUTH []CoreRoute

+ var ClusterMonitoringSchedules map[uuid.UUID]uuid.UUID

+ var CoreNodeManager nodemanager.NodeManagerInterface

+ var DbManager dbprovider.DbInterface

+ var EventTypes map[string]string

+ var Event_severity = map[string]models.AlarmStatus

+ var MonitoringManager monitoring.MonitoringManagerInterface

+ var STORAGE_STATUS_DOWN = "down"

+ var STORAGE_STATUS_UP = "up"

+ var Store *mongostore.MongoStore

+ var TaskManager task.Manager

+ func AddDefaultProfiles() error

+ func AddDefaultUser() error

+ func AddStorageNodeToDB(hostname string, node_state models.NodeState, node_status models.NodeStatus, ...) error

+ func AverageAndUpdateDb(ctxt string, mValue float64, count int, time_stamp_str string, ...) float64

+ func Check_status(hostname string, ctxt string)

+ func ClusterUnmanaged(cluster_id uuid.UUID) (bool, error)

+ func ComputeSystemSummary(p map[string]interface{})

+ func DeleteClusterSchedule(clusterId uuid.UUID)

+ func FailStillCreatingClusters(ctxt string)

+ func FetchAggregatedStatsFromGraphite(ctxt string, hostname string, resourceName string, counter *int, ...) (value float64)

+ func FetchStatFromGraphite(ctxt string, hostname string, resourceName string, counter *int) (value float64)

+ func GetAuthProvider() authprovider.AuthInterface

+ func GetCluster(cluster_id *uuid.UUID) (cluster models.Cluster, err error)

+ func GetClusterByName(clusterName string) (cluster models.Cluster, err error)

+ func GetClusterNameById(clusterId *uuid.UUID) (string, error)

+ func GetClusters() (models.Clusters, error)

+ func GetContext(r *http.Request) (string, error)

+ func GetCoreNodeManager() nodemanager.NodeManagerInterface

+ func GetDbProvider() dbprovider.DbInterface

+ func GetDetails(m map[string]interface{}) (models.MailNotifier, error)

+ func GetEventById(w http.ResponseWriter, r *http.Request)

+ func GetEvents(rw http.ResponseWriter, req *http.Request)

+ func GetMonitoringManager() monitoring.MonitoringManagerInterface

+ func GetNode(node_id uuid.UUID) (node models.Node, err error)

+ func GetSLU(cluster_id *uuid.UUID, slu_id uuid.UUID) (slu models.StorageLogicalUnit, err error)

+ func GetSluIds(storage_profile string, clusterid uuid.UUID, ctxt string) ([]uuid.UUID, error)

+ func HandleHttpError(rw http.ResponseWriter, err error)

+ func HttpResponse(w http.ResponseWriter, status_code int, msg string, args ...string)

+ func InitMonitoringSchedules()

+ func Initialize(node string, ctxt string) error

+ func LockCluster(ctxt string, cluster models.Cluster, operation string) (*lock.AppLock, error)

+ func LockNodes(ctxt string, nodes models.Nodes, operation string) (*lock.AppLock, error)

+ func Paginate(pageNo int, pageSize int, apiLimit int) (startIndex int, endIndex int)

+ func ParseStatFromCollectd(mValue string) (float64, error)

+ func PatchEvent(w http.ResponseWriter, r *http.Request)

+ func RefreshDBSession(params map[string]interface{})

+ func ScheduleCluster(clusterId uuid.UUID, intervalInSecs int)

+ func SyncNodeUtilizations(params map[string]interface{})

+ func SynchroniseScheduleMaintainers(clusterId uuid.UUID) (schedule.Scheduler, error)

+ func UpdateMetricToTimeSeriesDb(ctxt string, mValue float64, time_stamp_str string, tableName string)

+ func UpdateStorageNodeToDB(hostname string, node_state models.NodeState, node_status models.NodeStatus, ...) error

+ type APIError struct

+ Error string

+ type App struct

+ func GetApp() *App

+ func NewApp(configDir string, binDir string) *App

+ func (a *App) About(w http.ResponseWriter, r *http.Request)

+ func (a *App) AddMailNotifier(rw http.ResponseWriter, req *http.Request)

+ func (a *App) DELETE_BlockDevice(w http.ResponseWriter, r *http.Request)

+ func (a *App) DELETE_Node(w http.ResponseWriter, r *http.Request)

+ func (a *App) DELETE_Nodes(w http.ResponseWriter, r *http.Request)

+ func (a *App) DELETE_StorageProfile(w http.ResponseWriter, r *http.Request)

+ func (a *App) DEL_Storage(w http.ResponseWriter, r *http.Request)

+ func (a *App) Expand_Cluster(w http.ResponseWriter, r *http.Request)

+ func (a *App) FetchClusterDetailsFromProvider(ctxt string, clusterId uuid.UUID) (retVal map[string]map[string]interface{}, err error)

+ func (a *App) FetchMonitoringDetailsFromProviders(ctxt string) (retVal map[string]map[string]interface{}, err error)

+ func (a *App) Forget_Cluster(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_AllStorages(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_BlockDevice(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_BlockDevices(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Cluster(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterBlockDevices(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterConfig(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterNode(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterNodes(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterNodesForImport(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterSlu(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterSlus(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_ClusterStorageBlockDevices(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Clusters(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Disk(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Disks(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_LookupNode(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_MonitoringPlugins(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Node(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_NodeSlus(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_NodeSummary(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Nodes(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_SshFingerprint(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Storage(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_StorageProfile(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_StorageProfiles(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Storages(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_UnmanagedNodes(w http.ResponseWriter, r *http.Request)

+ func (a *App) GET_Utilization(w http.ResponseWriter, r *http.Request)

+ func (a *App) GetLockManager() lock.LockManager

+ func (a *App) GetMailNotifier(rw http.ResponseWriter, req *http.Request)

+ func (a *App) GetProviderFromClusterId(ctxt string, cluster_id uuid.UUID) *Provider

+ func (a *App) GetTaskManager() *task.Manager

+ func (a *App) Get_ClusterSummary(w http.ResponseWriter, r *http.Request)

+ func (a *App) Get_Summary(w http.ResponseWriter, r *http.Request)

+ func (a *App) Get_SystemUtilization(w http.ResponseWriter, r *http.Request)

+ func (a *App) ImportCluster(w http.ResponseWriter, r *http.Request)

+ func (a *App) InitializeApplication(sysConfig conf.SkyringCollection, configDir string) error

+ func (a *App) LoadEventTypes(configDir string, configFile string) error

+ func (a *App) LoadRoutes()

+ func (a *App) LoggingContext(w http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ func (a *App) LoginRequired(w http.ResponseWriter, r *http.Request, next http.HandlerFunc)

+ func (a *App) Manage_Cluster(w http.ResponseWriter, r *http.Request)

+ func (a *App) MonitorCluster(params map[string]interface{})

+ func (a *App) PATCH_ClusterSlu(w http.ResponseWriter, r *http.Request)

+ func (a *App) PATCH_Clusters(w http.ResponseWriter, r *http.Request)

+ func (a *App) PATCH_Disk(w http.ResponseWriter, r *http.Request)

+ func (a *App) PATCH_ResizeBlockDevice(w http.ResponseWriter, r *http.Request)

+ func (a *App) PATCH_Storage(w http.ResponseWriter, r *http.Request)

+ func (a *App) PATCH_StorageProfile(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_AcceptUnamangedNode(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_Actions(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_AddMonitoringPlugin(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_BlockDevices(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_Clusters(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_MonitoringPluginDisable(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_MonitoringPluginEnable(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_Nodes(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_StorageProfiles(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_Storages(w http.ResponseWriter, r *http.Request)

+ func (a *App) POST_froceUpdateMonitoringConfiguration(w http.ResponseWriter, r *http.Request)

+ func (a *App) PUT_Thresholds(w http.ResponseWriter, r *http.Request)

+ func (a *App) PatchMailNotifier(rw http.ResponseWriter, req *http.Request)

+ func (a *App) PostInitApplication(sysConfig conf.SkyringCollection) error

+ func (a *App) ProviderHandler(w http.ResponseWriter, r *http.Request)

+ func (a *App) REMOVE_MonitoringPlugin(w http.ResponseWriter, r *http.Request)

+ func (a *App) RouteProviderBasedMonitoring(ctxt string, cluster_id uuid.UUID)

+ func (a *App) RouteProviderEvents(ctxt string, event models.AppEvent) error

+ func (a *App) SetRoutes(router *mux.Router) error

+ func (a *App) StartProviders(configDir string, binDir string) error

+ func (a *App) SyncClusterDetails(params map[string]interface{})

+ func (a *App) TestMailNotifier(rw http.ResponseWriter, req *http.Request)

+ func (a *App) Unmanage_Cluster(w http.ResponseWriter, r *http.Request)

+ type ContextKey int

+ type CoreRoute struct

+ HandlerFunc http.HandlerFunc

+ Method string

+ Name string

+ Pattern string

+ Version int

+ type Provider struct

+ Client *rpc.Client

+ Name string

+ ProvisionerName provisioner.Provisioner

v0.0.19-1

May 20, 2016

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL