utils

Documentation

Index

• type InfluxDBUtils
  • func (db *InfluxDBUtils) GetApplicationInstances(ip string) (*protocol.ApplicationInstanceMapInfo, error)
  • func (db *InfluxDBUtils) GetApplicationInstancesNodeMapping(time string) (map[string]string, error)
  • func (db *InfluxDBUtils) GetApplicationMetrix(ip string, time string, instance string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeInstances(ip string) (*protocol.NodeInstanceMapInfo, error)
  • func (db *InfluxDBUtils) GetNodeMetrix(ip string, time string, measurement string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixCpu(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixFileSystem(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixInterfaces(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixMemory(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixNet(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixPage(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodeMetrixProcess(ip string, time string) (map[string][]client.Result, error)
  • func (db *InfluxDBUtils) GetNodes(ip string) ([]protocol.NodeMapInfo, error)
  • func (db *InfluxDBUtils) Init(address string, DBName string) error
• type MongoDBUtils
  • func (db *MongoDBUtils) AddApplicationInstance(instance protocol.ApplicationInstance) error
  • func (db *MongoDBUtils) AddApplicationInstanceNodeMapping(mapping protocol.ApplicationInstanceNodeMapping) error
  • func (db *MongoDBUtils) AddApplicationInstancesToModule(project string, service string, module string, instances []string) error
  • func (db *MongoDBUtils) AddModule(project string, service string, module protocol.Module) error
  • func (db *MongoDBUtils) AddNode(node protocol.Node) error
  • func (db *MongoDBUtils) AddProject(project protocol.Project) error
  • func (db *MongoDBUtils) AddService(project string, service protocol.Service) error
  • func (db *MongoDBUtils) DelApplicationInstance(instance string) error
  • func (db *MongoDBUtils) DelApplicationInstancesFromModule(project string, service string, module string, instances []string) error
  • func (db *MongoDBUtils) DelModule(project string, service string, module string) error
  • func (db *MongoDBUtils) DelNode(ip string) error
  • func (db *MongoDBUtils) DelProject(project string) error
  • func (db *MongoDBUtils) DelService(project string, service string) error
  • func (db *MongoDBUtils) GetApplicationInstance(instance string) ([]protocol.ApplicationInstance, error)
  • func (db *MongoDBUtils) GetApplicationInstanceNodeMappingByIP(ip string) ([]protocol.ApplicationInstanceNodeMapping, error)
  • func (db *MongoDBUtils) GetApplicationInstanceNodeMappingByInstance(instance string) ([]protocol.ApplicationInstanceNodeMapping, error)
  • func (db *MongoDBUtils) GetModule(project string, service string, module string) ([]protocol.Module, error)
  • func (db *MongoDBUtils) GetNode(ip string) ([]protocol.Node, error)
  • func (db *MongoDBUtils) GetProject(project string) ([]protocol.Project, error)
  • func (db *MongoDBUtils) GetService(project string, service string) ([]protocol.Service, error)
  • func (db *MongoDBUtils) Init(address string, database string) error
  • func (db *MongoDBUtils) SearchApplicationInstance(text string) ([]protocol.ApplicationInstance, error)
  • func (db *MongoDBUtils) SetModule(project string, service string, module protocol.Module) error
  • func (db *MongoDBUtils) SetProject(project protocol.Project) error
  • func (db *MongoDBUtils) SetService(project string, service protocol.Service) error

Types

type InfluxDBUtils

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

func (*InfluxDBUtils) GetApplicationInstances

func (db *InfluxDBUtils) GetApplicationInstances(ip string) (*protocol.ApplicationInstanceMapInfo, error)

Get application instances

func (*InfluxDBUtils) GetApplicationInstancesNodeMapping

func (db *InfluxDBUtils) GetApplicationInstancesNodeMapping(time string) (map[string]string, error)

Get application instances and node mapping

func (*InfluxDBUtils) GetApplicationMetrix

func (db *InfluxDBUtils) GetApplicationMetrix(ip string, time string, instance string) (map[string][]client.Result, error)

Get application metrix

func (*InfluxDBUtils) GetNodeInstances

func (db *InfluxDBUtils) GetNodeInstances(ip string) (*protocol.NodeInstanceMapInfo, error)

Get node instances (Not using)

func (*InfluxDBUtils) GetNodeMetrix

func (db *InfluxDBUtils) GetNodeMetrix(ip string, time string, measurement string) (map[string][]client.Result, error)

Get node metrix (Not using)

func (*InfluxDBUtils) GetNodeMetrixCpu

func (db *InfluxDBUtils) GetNodeMetrixCpu(ip string, time string) (map[string][]client.Result, error)

Get cpu metrix

func (*InfluxDBUtils) GetNodeMetrixFileSystem

func (db *InfluxDBUtils) GetNodeMetrixFileSystem(ip string, time string) (map[string][]client.Result, error)

Get file system metrix

func (*InfluxDBUtils) GetNodeMetrixInterfaces

func (db *InfluxDBUtils) GetNodeMetrixInterfaces(ip string, time string) (map[string][]client.Result, error)

Get interfaces metrix

func (*InfluxDBUtils) GetNodeMetrixMemory

func (db *InfluxDBUtils) GetNodeMetrixMemory(ip string, time string) (map[string][]client.Result, error)

Get memory metrix

func (*InfluxDBUtils) GetNodeMetrixNet

func (db *InfluxDBUtils) GetNodeMetrixNet(ip string, time string) (map[string][]client.Result, error)

Get net metrix

func (*InfluxDBUtils) GetNodeMetrixPage

func (db *InfluxDBUtils) GetNodeMetrixPage(ip string, time string) (map[string][]client.Result, error)

Get page metrix

func (*InfluxDBUtils) GetNodeMetrixProcess

func (db *InfluxDBUtils) GetNodeMetrixProcess(ip string, time string) (map[string][]client.Result, error)

Get process metrix

func (*InfluxDBUtils) GetNodes

func (db *InfluxDBUtils) GetNodes(ip string) ([]protocol.NodeMapInfo, error)

Get nodes information

func (*InfluxDBUtils) Init

func (db *InfluxDBUtils) Init(address string, DBName string) error

Init influxdb

type MongoDBUtils

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

func (*MongoDBUtils) AddApplicationInstance

func (db *MongoDBUtils) AddApplicationInstance(instance protocol.ApplicationInstance) error

******************Application instance*****************// Add application

func (*MongoDBUtils) AddApplicationInstanceNodeMapping

func (db *MongoDBUtils) AddApplicationInstanceNodeMapping(mapping protocol.ApplicationInstanceNodeMapping) error

******************Application instance & node mapping*****************// Add application instance & node mapping

func (*MongoDBUtils) AddApplicationInstancesToModule

func (db *MongoDBUtils) AddApplicationInstancesToModule(project string, service string, module string, instances []string) error

Add application instance to module

func (*MongoDBUtils) AddModule

func (db *MongoDBUtils) AddModule(project string, service string, module protocol.Module) error

Add module

func (*MongoDBUtils) AddNode

func (db *MongoDBUtils) AddNode(node protocol.Node) error

******************Node*****************// Add node

func (*MongoDBUtils) AddProject

func (db *MongoDBUtils) AddProject(project protocol.Project) error

******************View*****************// Add project

func (*MongoDBUtils) AddService

func (db *MongoDBUtils) AddService(project string, service protocol.Service) error

Add service

func (*MongoDBUtils) DelApplicationInstance

func (db *MongoDBUtils) DelApplicationInstance(instance string) error

Del application instance

func (*MongoDBUtils) DelApplicationInstancesFromModule

func (db *MongoDBUtils) DelApplicationInstancesFromModule(project string, service string, module string, instances []string) error

Del application instance from module

func (*MongoDBUtils) DelModule

func (db *MongoDBUtils) DelModule(project string, service string, module string) error

Del module

func (*MongoDBUtils) DelNode

func (db *MongoDBUtils) DelNode(ip string) error

Del node

func (*MongoDBUtils) DelProject

func (db *MongoDBUtils) DelProject(project string) error

Del project

func (*MongoDBUtils) DelService

func (db *MongoDBUtils) DelService(project string, service string) error

Del service

func (*MongoDBUtils) GetApplicationInstance

func (db *MongoDBUtils) GetApplicationInstance(instance string) ([]protocol.ApplicationInstance, error)

Get application instance

func (*MongoDBUtils) GetApplicationInstanceNodeMappingByIP

func (db *MongoDBUtils) GetApplicationInstanceNodeMappingByIP(ip string) ([]protocol.ApplicationInstanceNodeMapping, error)

Get application instance by ip

func (*MongoDBUtils) GetApplicationInstanceNodeMappingByInstance

func (db *MongoDBUtils) GetApplicationInstanceNodeMappingByInstance(instance string) ([]protocol.ApplicationInstanceNodeMapping, error)

Get application instance by instance

func (*MongoDBUtils) GetModule

func (db *MongoDBUtils) GetModule(project string, service string, module string) ([]protocol.Module, error)

Get module

func (*MongoDBUtils) GetNode

func (db *MongoDBUtils) GetNode(ip string) ([]protocol.Node, error)

Get node

func (*MongoDBUtils) GetProject

func (db *MongoDBUtils) GetProject(project string) ([]protocol.Project, error)

Get project

func (*MongoDBUtils) GetService

func (db *MongoDBUtils) GetService(project string, service string) ([]protocol.Service, error)

Get service

func (*MongoDBUtils) Init

func (db *MongoDBUtils) Init(address string, database string) error

Init mongodb

func (*MongoDBUtils) SearchApplicationInstance

func (db *MongoDBUtils) SearchApplicationInstance(text string) ([]protocol.ApplicationInstance, error)

Search application instance

func (*MongoDBUtils) SetModule

func (db *MongoDBUtils) SetModule(project string, service string, module protocol.Module) error

Set module

func (*MongoDBUtils) SetProject

func (db *MongoDBUtils) SetProject(project protocol.Project) error

Set project

func (*MongoDBUtils) SetService

func (db *MongoDBUtils) SetService(project string, service protocol.Service) error

Set service