parser

Documentation

Index

• func CreateEndpointAddress(endpoints *corev1.Endpoints, address *corev1.EndpointAddress, ...)
• func CreateServicePort(service *corev1.Service, servicePort *corev1.ServicePort, persistence string, ...)
• func DeleteEndpointsBackends(endpoints *corev1.Endpoints, backendPathsChan chan<- string)
• func DeleteMaxConnsService(service *corev1.Service)
• func DeleteServiceFarms(service *corev1.Service, farmPathsChan chan<- string)
• func EndpointsAsFarms(endpoints *corev1.Endpoints) *types.Farms
• func FormatExternalIPFarmName(resourceName string, resourcePortName string, index int) string
• func FormatFarmName(resourceName string, resourcePortName string) string
• func FormatNodePortFarmName(resourceName string, resourcePortName string) string
• func NetworkPolicyAsFarms(nwPolicy *networkingv1.NetworkPolicy) (*types.Farms, error)
• func NetworkPolicyAsPolicies(nwPolicy *networkingv1.NetworkPolicy) (*types.Policies, error)
• func NetworkPolicyNamesAsPolicies(nwPolicy *networkingv1.NetworkPolicy) *types.Policies
• func ServiceAsFarms(service *corev1.Service) *types.Farms
• func StructAsJSON(data interface{}) (string, error)

Functions

func CreateEndpointAddress

func CreateEndpointAddress(endpoints *corev1.Endpoints, address *corev1.EndpointAddress, subset *corev1.EndpointSubset, farms *[]types.Farm, wg *sync.WaitGroup)

CreateEndpointAddress appends farms parsed from a EndpointAddress to a Farm slice.

func CreateServicePort

func CreateServicePort(service *corev1.Service, servicePort *corev1.ServicePort, persistence string, persistTTL string, farms *[]types.Farm, wg *sync.WaitGroup)

CreateServicePort appends farms parsed from a ServicePort to a Farm slice.

func DeleteEndpointsBackends

func DeleteEndpointsBackends(endpoints *corev1.Endpoints, backendPathsChan chan<- string)

DeleteEndpointsBackends sends backend paths through a channel to the controller. The controller then deletes every backend.

func DeleteMaxConnsService

func DeleteMaxConnsService(service *corev1.Service)

DeleteMaxConnsService deletes the key:value pair from maxConnsMap.

func DeleteServiceFarms

func DeleteServiceFarms(service *corev1.Service, farmPathsChan chan<- string)

DeleteServiceFarms sends farm paths through a channel to the controller. The controller then deletes every farm.

func EndpointsAsFarms

func EndpointsAsFarms(endpoints *corev1.Endpoints) *types.Farms

EndpointsAsFarms reads a Endpoints and returns a filled Farms struct.

func FormatExternalIPFarmName

func FormatExternalIPFarmName(resourceName string, resourcePortName string, index int) string

FormatExternalIPFarmName returns a formatted farm name (--externalIP-index suffix) string for nftlb.

func FormatFarmName

func FormatFarmName(resourceName string, resourcePortName string) string

FormatFarmName returns a formatted farm name string for nftlb (regular Service).

func FormatNodePortFarmName

func FormatNodePortFarmName(resourceName string, resourcePortName string) string

FormatNodePortFarmName returns a formatted farm name (--nodePort suffix) for nftlb.

func NetworkPolicyAsFarms

func NetworkPolicyAsFarms(nwPolicy *networkingv1.NetworkPolicy) (*types.Farms, error)

NetworkPolicyAsFarms

func NetworkPolicyAsPolicies

func NetworkPolicyAsPolicies(nwPolicy *networkingv1.NetworkPolicy) (*types.Policies, error)

NetworkPolicyAsPolicies

func NetworkPolicyNamesAsPolicies

func NetworkPolicyNamesAsPolicies(nwPolicy *networkingv1.NetworkPolicy) *types.Policies

NetworkPolicyNamesAsPolicies

func ServiceAsFarms

func ServiceAsFarms(service *corev1.Service) *types.Farms

ServiceAsFarms reads a Service and returns a filled Farms struct.

func StructAsJSON

func StructAsJSON(data interface{}) (string, error)

StructAsJSON parses a given struct and returns a JSON string that can be interpreted by nftlb.