pkg

Documentation

Index

• Variables
• func ParseGatewayRelatedForClass(className string, gwObjs []*gatewayv1beta1.Gateway) (map[string]interface{}, error)
• func ParseReferedServiceKeys(svcs []string) (map[string]interface{}, error)
• func ParseServicesRelatedForAll() (map[string]interface{}, error)
• func RouteMatches(gwNamespace string, listener *gatewayv1beta1.Listener, ...) bool
• type BIGIPConfig
• type BIGIPConfigs
• type CtxKeyType
• type ReferenceGrantFromTo
• type SIGCache
  • func (c *SIGCache) AllAttachedServiceKeys() []string
  • func (c *SIGCache) AllHTTPRoutes() []*gatewayv1beta1.HTTPRoute
  • func (c *SIGCache) AttachedGateways(gwc *gatewayv1beta1.GatewayClass) []*gatewayv1beta1.Gateway
  • func (c *SIGCache) AttachedHTTPRoutes(gw *gatewayv1beta1.Gateway) []*gatewayv1beta1.HTTPRoute
  • func (c *SIGCache) AttachedServices(hr *gatewayv1beta1.HTTPRoute) []*v1.Service
  • func (c *SIGCache) CanRefer(from, to client.Object) bool
  • func (c *SIGCache) GatewayRefsOf(hr *gatewayv1beta1.HTTPRoute) []*gatewayv1beta1.Gateway
  • func (c *SIGCache) GetEndpoints(keyname string) *v1.Endpoints
  • func (c *SIGCache) GetGateway(keyname string) *gatewayv1beta1.Gateway
  • func (c *SIGCache) GetGatewayClass(keyname string) *gatewayv1beta1.GatewayClass
  • func (c *SIGCache) GetHTTPRoute(keyname string) *gatewayv1beta1.HTTPRoute
  • func (c *SIGCache) GetNamespace(keyname string) *v1.Namespace
  • func (c *SIGCache) GetNeighborGateways(gw *gatewayv1beta1.Gateway) []*gatewayv1beta1.Gateway
  • func (c *SIGCache) GetRootGateways(svcs []*v1.Service) []*gatewayv1beta1.Gateway
  • func (c *SIGCache) GetSecret(keyname string) *v1.Secret
  • func (c *SIGCache) GetService(keyname string) *v1.Service
  • func (c *SIGCache) HTTPRoutesRefsOf(svc *v1.Service) []*gatewayv1beta1.HTTPRoute
  • func (c *SIGCache) SetEndpoints(eps *v1.Endpoints)
  • func (c *SIGCache) SetGateway(obj *gatewayv1beta1.Gateway)
  • func (c *SIGCache) SetGatewayClass(obj *gatewayv1beta1.GatewayClass)
  • func (c *SIGCache) SetHTTPRoute(obj *gatewayv1beta1.HTTPRoute)
  • func (c *SIGCache) SetNamespace(obj *v1.Namespace)
  • func (c *SIGCache) SetReferenceGrant(rg *gatewayv1beta1.ReferenceGrant)
  • func (c *SIGCache) SetSecret(scrt *v1.Secret)
  • func (c *SIGCache) SetService(svc *v1.Service)
  • func (c *SIGCache) SyncAllResources(mgr manager.Manager)
  • func (c *SIGCache) UnsetEndpoints(keyname string)
  • func (c *SIGCache) UnsetGateway(keyname string)
  • func (c *SIGCache) UnsetGatewayClass(keyname string)
  • func (c *SIGCache) UnsetHTTPRoute(keyname string)
  • func (c *SIGCache) UnsetNamespace(keyname string)
  • func (c *SIGCache) UnsetReferenceGrant(keyname string)
  • func (c *SIGCache) UnsetSerect(keyname string)
  • func (c *SIGCache) UnsetService(keyname string)

Variables

var (
	PendingDeploys chan deployer.DeployRequest
	DoneDeploys    *deployer.DeployResponses
	ActiveSIGs     *SIGCache
	BIGIPs         []*f5_bigip.BIGIP
	BIPConfigs     BIGIPConfigs
	BIPPassword    string

	LogLevel string
)

Functions

func ParseGatewayRelatedForClass

func ParseGatewayRelatedForClass(className string, gwObjs []*gatewayv1beta1.Gateway) (map[string]interface{}, error)

func ParseReferedServiceKeys

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

func ParseServicesRelatedForAll

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

ParseServicesRelatedForAll parse all refered services

func RouteMatches

func RouteMatches(gwNamespace string, listener *gatewayv1beta1.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]*gatewayv1beta1.Gateway
	HTTPRoute      map[string]*gatewayv1beta1.HTTPRoute
	Endpoints      map[string]*v1.Endpoints
	Service        map[string]*v1.Service
	GatewayClass   map[string]*gatewayv1beta1.GatewayClass
	Namespace      map[string]*v1.Namespace
	ReferenceGrant map[string]*gatewayv1beta1.ReferenceGrant
	Secret         map[string]*v1.Secret
	// contains filtered or unexported fields
}

func (*SIGCache) AllAttachedServiceKeys

func (c *SIGCache) AllAttachedServiceKeys() []string

func (*SIGCache) AllHTTPRoutes

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

func (*SIGCache) AttachedGateways

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

func (*SIGCache) AttachedHTTPRoutes

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

func (*SIGCache) AttachedServices

func (c *SIGCache) AttachedServices(hr *gatewayv1beta1.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) GatewayRefsOf

func (c *SIGCache) GatewayRefsOf(hr *gatewayv1beta1.HTTPRoute) []*gatewayv1beta1.Gateway

func (*SIGCache) GetEndpoints

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

func (*SIGCache) GetGateway

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

func (*SIGCache) GetGatewayClass

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

func (*SIGCache) GetHTTPRoute

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

func (*SIGCache) GetNamespace

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

func (*SIGCache) GetNeighborGateways

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

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

func (*SIGCache) GetRootGateways

func (c *SIGCache) GetRootGateways(svcs []*v1.Service) []*gatewayv1beta1.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) HTTPRoutesRefsOf

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

func (*SIGCache) SetEndpoints

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

func (*SIGCache) SetGateway

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

func (*SIGCache) SetGatewayClass

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

func (*SIGCache) SetHTTPRoute

func (c *SIGCache) SetHTTPRoute(obj *gatewayv1beta1.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)