mesosdriver

Documentation

Overview

Package mesosdriver xxx

Index

• Constants
• type MesosDriver
  • func NewMesosDriverServer(conf *config.MesosDriverConfig) (*MesosDriver, error)
  • func (m *MesosDriver) DiscvScheduler()
  • func (m *MesosDriver) Filter(req *restful.Request, resp *restful.Response, filterChain *restful.FilterChain)
  • func (m *MesosDriver) IsHealthy() (bool, string)
  • func (m *MesosDriver) RegDiscover()
  • func (m *MesosDriver) RunMetric()
  • func (m *MesosDriver) Start() error
  • func (m *MesosDriver) Stop() error

Constants

const (
	// Module tunnel module
	Module = "BCS-API-Tunnel-Module"
	// RegisterToken token information key
	RegisterToken = "BCS-API-Tunnel-Token"
	// Params for ws tunnel
	Params = "BCS-API-Tunnel-Params"
	// Cluster ID for ws tunnel
	Cluster = "BCS-API-Tunnel-ClusterId"
	// ModuleName definition
	ModuleName = "mesosdriver"
)

Types

type MesosDriver

type MesosDriver struct {
	CurrScheduler string
	// contains filtered or unexported fields
}

MesosDriver is data struct of mesos driver

func NewMesosDriverServer

func NewMesosDriverServer(conf *config.MesosDriverConfig) (*MesosDriver, error)

NewMesosDriverServer create mesosdriver according config

func (*MesosDriver) DiscvScheduler

func (m *MesosDriver) DiscvScheduler()

DiscvScheduler discovery scheduler master

func (*MesosDriver) Filter

func (m *MesosDriver) Filter(req *restful.Request, resp *restful.Response, filterChain *restful.FilterChain)

Filter filte request not belong to local cluster

func (*MesosDriver) IsHealthy

func (m *MesosDriver) IsHealthy() (bool, string)

IsHealthy healthy interface for bcs-health(deprecated)

func (*MesosDriver) RegDiscover

func (m *MesosDriver) RegDiscover()

RegDiscover register local service information

func (*MesosDriver) RunMetric

func (m *MesosDriver) RunMetric()

RunMetric run metric feaature deprecated, change to promethus collector

func (*MesosDriver) Start

func (m *MesosDriver) Start() error

Start start mesosdriver

func (*MesosDriver) Stop

func (m *MesosDriver) Stop() error

Stop driver stop