Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + const IPPortGap + func GetApplicationName(metric *types.Metric) string + func GetFilePath(tempDir, namespace string, ct types.ClusterType) (target string, err error) + func GetIPMetaFromDynamic(raw []byte, metric *types.Metric) (ipMeta map[string]btypes.ObjectMeta, err error) + func GetK8SIPMeta(raw []byte, metric *types.Metric) (ipMeta map[string]btypes.ObjectMeta, err error) + func GetMesosIPMeta(raw []byte, metric *types.Metric) (ipMeta map[string]btypes.ObjectMeta, err error) + func LoadResourceJson(tempDir, namespace string, ct types.ClusterType) (*simplejson.Json, error) + type ClusterDriver interface + CreateApplication func(data []byte) error + DeleteApplication func(data []byte) error + GetApplicationJson func(imageBase string) (*simplejson.Json, error) + GetCollectorTypeName func() string + GetIPMeta func() (map[string]btypes.ObjectMeta, error) + func GetClusterDriver(m *types.Metric, c *config.Config, s storage.Storage, r route.Route, z zk.Zk) (ClusterDriver, error) + func NewComponentsDriver(config *config.Config, zk zk.Zk) ClusterDriver + func NewK8SDriver(m *types.Metric, config *config.Config, s storage.Storage, r route.Route) ClusterDriver + func NewMesosDriver(m *types.Metric, config *config.Config, s storage.Storage, r route.Route) ClusterDriver + type ComponentsDriver struct + func (cd *ComponentsDriver) CreateApplication(data []byte) error + func (cd *ComponentsDriver) DeleteApplication(data []byte) error + func (cd *ComponentsDriver) GetApplicationJson(string) (*simplejson.Json, error) + func (cd *ComponentsDriver) GetCollectorTypeName() string + func (cd *ComponentsDriver) GetIPMeta() (map[string]btypes.ObjectMeta, error) + type K8SDriver struct + func (kd *K8SDriver) CreateApplication(data []byte) (err error) + func (kd *K8SDriver) DeleteApplication(data []byte) (err error) + func (kd *K8SDriver) GetApplicationJson(imageBase string) (js *simplejson.Json, err error) + func (kd *K8SDriver) GetCollectorTypeName() string + func (kd *K8SDriver) GetIPMeta() (map[string]btypes.ObjectMeta, error) + type MesosDriver struct + func (md *MesosDriver) CreateApplication(data []byte) (err error) + func (md *MesosDriver) DeleteApplication(data []byte) (err error) + func (md *MesosDriver) GetApplicationJson(imageBase string) (js *simplejson.Json, err error) + func (md *MesosDriver) GetCollectorTypeName() string + func (md *MesosDriver) GetIPMeta() (map[string]btypes.ObjectMeta, error) + type ResourceData struct + Name string + type StoragePodIf struct + Data struct{ ... } + Namespace string + type StorageTaskGroupIf struct + Data btypes.BcsPodStatus + Namespace string