util

Documentation

Index

• func DNSDataKeyFunc(obj interface{}) (string, error)
• type DataMeta
• type Decoder
• type EndpointCache
  • func (ep *EndpointCache) GetEndpointByService(svc *bcstypes.BcsService) *bcstypes.BcsEndpoint
  • func (ep *EndpointCache) ListEndpoints() (epList []*bcstypes.BcsEndpoint)
• type EndpointDecoder
  • func (epd *EndpointDecoder) Decode(data []byte) (interface{}, error)
• type ServiceCache
  • func (srv *ServiceCache) GetService(namespace, name string) *bcstypes.BcsService
  • func (srv *ServiceCache) GetServiceByEndpoint(endpoint *bcstypes.BcsEndpoint) *bcstypes.BcsService
• type SvcDecoder
  • func (svcd *SvcDecoder) Decode(data []byte) (interface{}, error)

Functions

func DNSDataKeyFunc

func DNSDataKeyFunc(obj interface{}) (string, error)

DNSDataKeyFunc function for data uniq key

Types

type DataMeta

type DataMeta interface {
	GetName() string
	GetNamespace() string
	GetLabels() map[string]string
	GetAnnotations() map[string]string
}

DataMeta interface for operator namespace/name

type Decoder

type Decoder interface {
	Decode([]byte) (interface{}, error)
}

Decoder decoder for detail data type

type EndpointCache

type EndpointCache struct {
	Store cache.Store // Store for detail
}

EndpointCache cache for bcs-scheduler endpoint data

func (*EndpointCache) GetEndpointByService

func (ep *EndpointCache) GetEndpointByService(svc *bcstypes.BcsService) *bcstypes.BcsEndpoint

GetEndpointByService get endpoint info from BcsService

func (*EndpointCache) ListEndpoints

func (ep *EndpointCache) ListEndpoints() (epList []*bcstypes.BcsEndpoint)

ListEndpoints list all endpoints, change interface into *BcsEndpoint

type EndpointDecoder

type EndpointDecoder struct{}

EndpointDecoder decoder for EndpointCache

func (*EndpointDecoder) Decode

func (epd *EndpointDecoder) Decode(data []byte) (interface{}, error)

Decode implementation of Decoder

type ServiceCache

type ServiceCache struct {
	Store cache.Store
}

ServiceCache cache for bcs-scheduler service data

func (*ServiceCache) GetService

func (srv *ServiceCache) GetService(namespace, name string) *bcstypes.BcsService

GetService get Service by name and namespace

func (*ServiceCache) GetServiceByEndpoint

func (srv *ServiceCache) GetServiceByEndpoint(endpoint *bcstypes.BcsEndpoint) *bcstypes.BcsService

GetServiceByEndpoint get service info by Endpoint

type SvcDecoder

type SvcDecoder struct{}

SvcDecoder decoder for ServiceCache

func (*SvcDecoder) Decode

func (svcd *SvcDecoder) Decode(data []byte) (interface{}, error)

Decode implementation of Decoder