mesos

package
v1.20.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2021 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient

func NewClient(config string, handler cache.ResourceEventHandler, syncPeriod time.Duration) (svcclient.Client, error)

NewClient create mesos etcd storage client for AppService

Types

type Manager

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

Manager implement svcclient for mesos container meta data convertion all mesos data structures reference to bk-bcs/bcs-mesos/pkg/apis

func (*Manager) Close

func (mm *Manager) Close()

Close client, clean resource

func (*Manager) GetAppService

func (mm *Manager) GetAppService(ns, name string) (*svcclient.AppService, error)

GetAppService get service by specified namespace & name

func (*Manager) ListAppService

func (mm *Manager) ListAppService(label map[string]string) ([]*svcclient.AppService, error)

ListAppService list all service in cache, filter by Label selector comes from Set.AsSelector() see: k8s.io/apimachinery/pkg/labels.Set

func (*Manager) ListAppServiceFromStatefulSet

func (mm *Manager) ListAppServiceFromStatefulSet(ns, svcname string) ([]*svcclient.AppService, error)

ListAppServiceFromStatefulSet list app services, for each stateful node, generate a AppService object

func (*Manager) OnBcsEndpointAdd

func (mm *Manager) OnBcsEndpointAdd(obj interface{})

OnBcsEndpointAdd add event implementation

func (*Manager) OnBcsEndpointDelete

func (mm *Manager) OnBcsEndpointDelete(obj interface{})

OnBcsEndpointDelete delete event implementation

func (*Manager) OnBcsEndpointUpdate

func (mm *Manager) OnBcsEndpointUpdate(oldObj, newObj interface{})

OnBcsEndpointUpdate upadte event implementation

func (*Manager) OnBcsServiceAdd

func (mm *Manager) OnBcsServiceAdd(obj interface{})

OnBcsServiceAdd add event implementation

func (*Manager) OnBcsServiceDelete

func (mm *Manager) OnBcsServiceDelete(obj interface{})

OnBcsServiceDelete delete event implementation

func (*Manager) OnBcsServiceUpdate

func (mm *Manager) OnBcsServiceUpdate(oldObj, newObj interface{})

OnBcsServiceUpdate update event implementation

func (*Manager) OnBcsTaskgroupAdd

func (mm *Manager) OnBcsTaskgroupAdd(obj interface{})

OnBcsTaskgroupAdd taskgroup add event handler

func (*Manager) OnBcsTaskgroupDelete

func (mm *Manager) OnBcsTaskgroupDelete(obj interface{})

OnBcsTaskgroupDelete taskgroup delete event handler

func (*Manager) OnBcsTaskgroupUpdate

func (mm *Manager) OnBcsTaskgroupUpdate(oldObj, newObj interface{})

OnBcsTaskgroupUpdate taskgroup update event handler

Jump to

Keyboard shortcuts

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