mesos

Documentation

Index

• func NewClient(config string, handler cache.ResourceEventHandler, syncPeriod time.Duration) (svcclient.Client, error)
• type Manager
  • func (mm *Manager) Close()
  • func (mm *Manager) GetAppService(ns, name string) (*svcclient.AppService, error)
  • func (mm *Manager) ListAppService(label map[string]string) ([]*svcclient.AppService, error)
  • func (mm *Manager) ListAppServiceFromStatefulSet(ns, svcname string) ([]*svcclient.AppService, error)
  • func (mm *Manager) OnBcsEndpointAdd(obj interface{})
  • func (mm *Manager) OnBcsEndpointDelete(obj interface{})
  • func (mm *Manager) OnBcsEndpointUpdate(oldObj, newObj interface{})
  • func (mm *Manager) OnBcsServiceAdd(obj interface{})
  • func (mm *Manager) OnBcsServiceDelete(obj interface{})
  • func (mm *Manager) OnBcsServiceUpdate(oldObj, newObj interface{})
  • func (mm *Manager) OnBcsTaskgroupAdd(obj interface{})
  • func (mm *Manager) OnBcsTaskgroupDelete(obj interface{})
  • func (mm *Manager) OnBcsTaskgroupUpdate(oldObj, newObj interface{})

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