types

Documentation

Index

• func NewEndpointInfo(baseInfo *k8sproxy.BaseEndpointInfo) k8sproxy.Endpoint
• func NewGroupCounter() *groupCounter
• func NewServiceInfo(port *corev1.ServicePort, service *corev1.Service, ...) k8sproxy.ServicePort
• type EndpointsMap
• type GroupCounter
• type ServiceInfo
  • func (si *ServiceInfo) Equal(bSvcInfo *ServiceInfo) bool

Functions

func NewEndpointInfo

func NewEndpointInfo(baseInfo *k8sproxy.BaseEndpointInfo) k8sproxy.Endpoint

NewEndpointInfo returns a new k8sproxy.Endpoint which abstracts an endpointsInfo.

func NewGroupCounter

func NewGroupCounter() *groupCounter

func NewServiceInfo

func NewServiceInfo(port *corev1.ServicePort, service *corev1.Service, baseInfo *k8sproxy.BaseServiceInfo) k8sproxy.ServicePort

NewServiceInfo returns a new k8sproxy.ServicePort which abstracts a serviceInfo.

Types

type EndpointsMap

type EndpointsMap map[k8sproxy.ServicePortName]map[string]k8sproxy.Endpoint

type GroupCounter

type GroupCounter interface {
	// Get generates a global unique group ID for a specific service.
	// If the group ID of the service has been generated, then return the
	// prior one. The bool return value indicates whether the groupID is newly
	// generated.
	Get(svcPortName k8sproxy.ServicePortName) (binding.GroupIDType, bool)
	// Recycle removes a Service Group ID mapping. The recycled groupID can be
	// reused.
	Recycle(svcPortName k8sproxy.ServicePortName) bool
}

GroupCounter generates and manages global unique group ID.

type ServiceInfo

type ServiceInfo struct {
	*k8sproxy.BaseServiceInfo
	// cache for performance
	OFProtocol openflow.Protocol
}

ServiceInfo is the internal struct for caching service information.

func (*ServiceInfo) Equal

func (si *ServiceInfo) Equal(bSvcInfo *ServiceInfo) bool