mesos

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

NewClient create mesos etcd storage client for AppService

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 (mm *Manager) Close()

Close client, clean resource

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

GetAppService get service by specified namespace & name

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 (mm *Manager) ListAppServiceFromStatefulSet(ns, name string) ([]*svcclient.AppService, error)

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

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

OnBcsEndpointAdd add event implementation

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

OnBcsEndpointDelete delete event implementation

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

OnBcsEndpointUpdate upadte event implementation

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

OnBcsServiceAdd add event implementation

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

OnBcsServiceDelete delete event implementation

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

OnBcsServiceUpdate update event implementation