svc_utils

Documentation

Index

• func AcceptedServiceTypes() []string
• func AddObjToClustersetServiceFilter(cname, ns, obj string, port int32) error
• func DeleteObjFromClustersetServiceFilter(cname, ns, obj string, port int32) error
• func GetClustersetServiceFilter() map[string]*NSServiceFilter
• func InitClustersetServiceFilter(clusters []string) (map[string]*NSServiceFilter, error)
• func IsObjectInClustersetFilter(cname, ns, obj string) bool
• func IsServiceOfAcceptedType(svcObj *v1.Service) bool
• func IsSvcPortInClustersetFilter(cname, ns, obj string, port int32) bool
• type NSServiceFilter
  • func InitNSServiceFilter() *NSServiceFilter
  • func (nsvcf *NSServiceFilter) AddToNSServiceFilter(ns, svc string, port int32)
  • func (nsvcf *NSServiceFilter) DeleteFromNSServiceFilter(ns, obj string, port int32)
  • func (nsvcf *NSServiceFilter) IsObjectPresent(ns, obj string) bool
  • func (nsvcf *NSServiceFilter) IsSvcPortPresent(ns, obj string, port int32) bool
• type PortCache
  • func InitPortCache(port int32) *PortCache
  • func (pc *PortCache) Add(port int32)
  • func (pc *PortCache) Delete(port int32) int
  • func (pc *PortCache) IsPortPresent(port int32) bool
• type ServiceCache
  • func InitServiceSet(svcName string, port int32) *ServiceCache
  • func (ss *ServiceCache) Add(svc string, port int32)
  • func (ss *ServiceCache) Delete(svc string, port int32) int
  • func (ss *ServiceCache) IsSvcPortPresent(svc string, port int32) bool
  • func (ss *ServiceCache) IsSvcPresent(svc string) bool

Functions

func AcceptedServiceTypes

func AcceptedServiceTypes() []string

func AddObjToClustersetServiceFilter

func AddObjToClustersetServiceFilter(cname, ns, obj string, port int32) error

func DeleteObjFromClustersetServiceFilter

func DeleteObjFromClustersetServiceFilter(cname, ns, obj string, port int32) error

func GetClustersetServiceFilter

func GetClustersetServiceFilter() map[string]*NSServiceFilter

func InitClustersetServiceFilter

func InitClustersetServiceFilter(clusters []string) (map[string]*NSServiceFilter, error)

func IsObjectInClustersetFilter

func IsObjectInClustersetFilter(cname, ns, obj string) bool

func IsServiceOfAcceptedType

func IsServiceOfAcceptedType(svcObj *v1.Service) bool

func IsSvcPortInClustersetFilter

func IsSvcPortInClustersetFilter(cname, ns, obj string, port int32) bool

Types

type NSServiceFilter

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

func InitNSServiceFilter

func InitNSServiceFilter() *NSServiceFilter

func (*NSServiceFilter) AddToNSServiceFilter

func (nsvcf *NSServiceFilter) AddToNSServiceFilter(ns, svc string, port int32)

func (*NSServiceFilter) DeleteFromNSServiceFilter

func (nsvcf *NSServiceFilter) DeleteFromNSServiceFilter(ns, obj string, port int32)

func (*NSServiceFilter) IsObjectPresent

func (nsvcf *NSServiceFilter) IsObjectPresent(ns, obj string) bool

func (*NSServiceFilter) IsSvcPortPresent

func (nsvcf *NSServiceFilter) IsSvcPortPresent(ns, obj string, port int32) bool

type PortCache

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

func InitPortCache

func InitPortCache(port int32) *PortCache

func (*PortCache) Add

func (pc *PortCache) Add(port int32)

func (*PortCache) Delete

func (pc *PortCache) Delete(port int32) int

func (*PortCache) IsPortPresent

func (pc *PortCache) IsPortPresent(port int32) bool

type ServiceCache

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

func InitServiceSet

func InitServiceSet(svcName string, port int32) *ServiceCache

func (*ServiceCache) Add

func (ss *ServiceCache) Add(svc string, port int32)

func (*ServiceCache) Delete

func (ss *ServiceCache) Delete(svc string, port int32) int

func (*ServiceCache) IsSvcPortPresent

func (ss *ServiceCache) IsSvcPortPresent(svc string, port int32) bool

func (*ServiceCache) IsSvcPresent

func (ss *ServiceCache) IsSvcPresent(svc string) bool