mesosdriver

package

v1.19.1 Latest Latest Go to latest Published: Oct 25, 2022 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	ZkAddr string
	//http client cert config
	ClientCert *types.CertConfig
}

Config client configuration

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

MesosDriverClient client for mesosdriver

func NewMesosDriverClient(conf *Config) (*MesosDriverClient, error)

NewMesosDriverClient new MesosDriverClient object

func (m *MesosDriverClient) CeateDeployment(clusterid string, deploy []byte) error

CeateDeployment deploy application

func (m *MesosDriverClient) FetchDeployment(deploy *types.DeployDetection) (interface{}, error)

FetchDeployment fetch application

func (m *MesosDriverClient) FetchPods(clusterid, ns, name string) ([]byte, error)

FetchPods fetch application't pods

func (m *MesosDriverClient) GetNodes(clusterid string) ([]*types.NodeInfo, error)

GetNodes get cluster all nodes

func (m *MesosDriverClient) UpdateAgentExtendedResources(clusterID string, er *commtypes.ExtendedResource) error

UpdateAgentExtendedResources update agent external resources