pkg

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.