pkg

package

v0.3.0 Latest Latest Go to latest Published: Dec 23, 2023 License: Apache-2.0 Imports: 25 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

Repository

github.com/f5devcentral/bigip-kubernetes-gateway

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AS3Deployer(stopCh chan struct{}, bigips []*f5_bigip.BIGIP)
func DeployForEvent(ctx context.Context, impactedClasses []string) error
func HandleBackends(ctx context.Context, namespace string) error
func NewContext() context.Context
func ParseAllForClass(className string) (map[string]interface{}, error)
func ParseClassRelatedServices(gwc []string) (map[string]interface{}, error)
func ParseServices(svcs []string) (map[string]interface{}, error)
func RespHandler(stopCh chan struct{})
func RestToAS3(cfgs map[string]interface{}) map[string]interface{}
func RouteMatches(gwNamespace string, listener *gatewayapi.Listener, ...) bool
type BIGIPConfig
type BIGIPConfigs
type CtxKeyType
type ReferenceGrantFromTo
type SIGCache

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	PendingDeploys *utils.DeployQueue
	DoneDeploys    *utils.DeployQueue
	ActiveSIGs     *SIGCache
	BIGIPs         []*f5_bigip.BIGIP
	BIPConfigs     BIGIPConfigs
	BIPPassword    string

	LogLevel string
)

Functions ¶

func AS3Deployer ¶ added in v0.3.0

func AS3Deployer(stopCh chan struct{}, bigips []*f5_bigip.BIGIP)

AS3Deployer starts a goroutine for accepting DeployRequests and deploy them via AS3.

func DeployForEvent ¶ added in v0.3.0

func DeployForEvent(ctx context.Context, impactedClasses []string) error

func HandleBackends ¶ added in v0.3.0

func HandleBackends(ctx context.Context, namespace string) error

func NewContext ¶ added in v0.3.0

func NewContext() context.Context

func ParseAllForClass ¶ added in v0.3.0

func ParseAllForClass(className string) (map[string]interface{}, error)

func ParseClassRelatedServices ¶ added in v0.3.0

func ParseClassRelatedServices(gwc []string) (map[string]interface{}, error)

ParseRelatedServices parse all refered services

func ParseServices ¶ added in v0.3.0

func ParseServices(svcs []string) (map[string]interface{}, error)

func RespHandler ¶ added in v0.3.0

func RespHandler(stopCh chan struct{})

func RestToAS3 ¶ added in v0.3.0

func RestToAS3(cfgs map[string]interface{}) map[string]interface{}

func RouteMatches ¶

func RouteMatches(gwNamespace string, listener *gatewayapi.Listener, routeNamespace *v1.Namespace, routeType string) bool

Types ¶

type BIGIPConfig ¶

type BIGIPConfig struct {
	Management struct {
		Username  string
		IpAddress string `yaml:"ipAddress"`
		Port      *int
	}
}

type BIGIPConfigs ¶

type BIGIPConfigs []BIGIPConfig

type CtxKeyType ¶

type CtxKeyType string

type ReferenceGrantFromTo ¶

type ReferenceGrantFromTo map[string]map[string]int8

type SIGCache ¶

type SIGCache struct {
	SyncedAtStart  bool
	ControllerName string
	Gateway        map[string]*gatewayapi.Gateway
	HTTPRoute      map[string]*gatewayapi.HTTPRoute
	Endpoints      map[string]*v1.Endpoints
	Service        map[string]*v1.Service
	GatewayClass   map[string]*gatewayapi.GatewayClass
	Namespace      map[string]*v1.Namespace
	ReferenceGrant map[string]*gatewayv1beta1.ReferenceGrant
	Secret         map[string]*v1.Secret
	// contains filtered or unexported fields
}

func (*SIGCache) AllHTTPRoutes ¶

func (c *SIGCache) AllHTTPRoutes() []*gatewayapi.HTTPRoute

func (*SIGCache) AttachedGateways ¶

func (c *SIGCache) AttachedGateways(gwc *gatewayapi.GatewayClass) []*gatewayapi.Gateway

func (*SIGCache) AttachedHTTPRoutes ¶

func (c *SIGCache) AttachedHTTPRoutes(gw *gatewayapi.Gateway) []*gatewayapi.HTTPRoute

func (*SIGCache) AttachedSecrets ¶ added in v0.3.0

func (c *SIGCache) AttachedSecrets(gw *gatewayapi.Gateway) (map[string][]*v1.Secret, error)

func (*SIGCache) AttachedServices ¶

func (c *SIGCache) AttachedServices(hr *gatewayapi.HTTPRoute) []*v1.Service

func (*SIGCache) CanRefer ¶

func (c *SIGCache) CanRefer(from, to client.Object) bool

CanRefer parameter "from" and "to" MUST NOT be nil.

func (*SIGCache) GatewayRefsOfHR ¶ added in v0.3.0

func (c *SIGCache) GatewayRefsOfHR(hr *gatewayapi.HTTPRoute) []*gatewayapi.Gateway

func (*SIGCache) GatewayRefsOfSecret ¶ added in v0.3.0

func (c *SIGCache) GatewayRefsOfSecret(scrt *v1.Secret) ([]*gatewayapi.Gateway, error)

func (*SIGCache) GetEndpoints ¶

func (c *SIGCache) GetEndpoints(keyname string) *v1.Endpoints

func (*SIGCache) GetGateway ¶

func (c *SIGCache) GetGateway(keyname string) *gatewayapi.Gateway

func (*SIGCache) GetGatewayClass ¶

func (c *SIGCache) GetGatewayClass(keyname string) *gatewayapi.GatewayClass

func (*SIGCache) GetHTTPRoute ¶

func (c *SIGCache) GetHTTPRoute(keyname string) *gatewayapi.HTTPRoute

func (*SIGCache) GetNamespace ¶

func (c *SIGCache) GetNamespace(keyname string) *v1.Namespace

func (*SIGCache) GetNeighborGateways ¶

func (c *SIGCache) GetNeighborGateways(gw *gatewayapi.Gateway) []*gatewayapi.Gateway

GetNeighborGateways get neighbor gateways(itself is not included) for all gateway class.

func (*SIGCache) GetReferenceGrant ¶ added in v0.3.0

func (c *SIGCache) GetReferenceGrant(keyname string) *gatewayv1beta1.ReferenceGrant

func (*SIGCache) GetRootGateways ¶

func (c *SIGCache) GetRootGateways(svcs []*v1.Service) []*gatewayapi.Gateway

func (*SIGCache) GetSecret ¶

func (c *SIGCache) GetSecret(keyname string) *v1.Secret

func (*SIGCache) GetService ¶

func (c *SIGCache) GetService(keyname string) *v1.Service

func (*SIGCache) GetServicesWithNamespace ¶ added in v0.3.0

func (c *SIGCache) GetServicesWithNamespace(namespace string) []*v1.Service

func (*SIGCache) HTTPRoutesRefsOf ¶

func (c *SIGCache) HTTPRoutesRefsOf(svc *v1.Service) []*gatewayapi.HTTPRoute

func (*SIGCache) NSImpactedGatewayClasses ¶ added in v0.3.0

func (c *SIGCache) NSImpactedGatewayClasses(ns *v1.Namespace) []string

func (*SIGCache) RGImpactedGatewayClasses ¶ added in v0.3.0

func (c *SIGCache) RGImpactedGatewayClasses(rg *gatewayv1beta1.ReferenceGrant) []string

func (*SIGCache) RelatedServices ¶ added in v0.3.0

func (c *SIGCache) RelatedServices(gwc *gatewayapi.GatewayClass) []*v1.Service

func (*SIGCache) SetEndpoints ¶

func (c *SIGCache) SetEndpoints(eps *v1.Endpoints)

func (*SIGCache) SetGateway ¶

func (c *SIGCache) SetGateway(obj *gatewayapi.Gateway)

func (*SIGCache) SetGatewayClass ¶

func (c *SIGCache) SetGatewayClass(obj *gatewayapi.GatewayClass)

func (*SIGCache) SetHTTPRoute ¶

func (c *SIGCache) SetHTTPRoute(obj *gatewayapi.HTTPRoute)

func (*SIGCache) SetNamespace ¶

func (c *SIGCache) SetNamespace(obj *v1.Namespace)

func (*SIGCache) SetReferenceGrant ¶

func (c *SIGCache) SetReferenceGrant(rg *gatewayv1beta1.ReferenceGrant)

func (*SIGCache) SetSecret ¶

func (c *SIGCache) SetSecret(scrt *v1.Secret)

func (*SIGCache) SetService ¶

func (c *SIGCache) SetService(svc *v1.Service)

func (*SIGCache) SyncAllResources ¶

func (c *SIGCache) SyncAllResources(mgr manager.Manager)

func (*SIGCache) UnsetEndpoints ¶

func (c *SIGCache) UnsetEndpoints(keyname string)

func (*SIGCache) UnsetGateway ¶

func (c *SIGCache) UnsetGateway(keyname string)

func (*SIGCache) UnsetGatewayClass ¶

func (c *SIGCache) UnsetGatewayClass(keyname string)

func (*SIGCache) UnsetHTTPRoute ¶

func (c *SIGCache) UnsetHTTPRoute(keyname string)

func (*SIGCache) UnsetNamespace ¶

func (c *SIGCache) UnsetNamespace(keyname string)

func (*SIGCache) UnsetReferenceGrant ¶

func (c *SIGCache) UnsetReferenceGrant(keyname string)

func (*SIGCache) UnsetSerect ¶

func (c *SIGCache) UnsetSerect(keyname string)

func (*SIGCache) UnsetService ¶

func (c *SIGCache) UnsetService(keyname string)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL