route_policy

Documentation

Index

• func BuildMirrorTunnelRoutes(hubs []*v1alpha2.Hub, importHubName string) []*v1alpha2.Route
• type HubInterface
• type RoutePolicyController
  • func NewRoutePolicyController(conf RoutePolicyControllerConfig) *RoutePolicyController
  • func (c *RoutePolicyController) Run(ctx context.Context) error
  • func (c *RoutePolicyController) Sync(ctx context.Context)
  • func (c *RoutePolicyController) UpdateRoutePolicyCondition(name string, routeCount int) error
• type RoutePolicyControllerConfig

Functions

func BuildMirrorTunnelRoutes

func BuildMirrorTunnelRoutes(hubs []*v1alpha2.Hub, importHubName string) []*v1alpha2.Route

Types

type HubInterface

type HubInterface interface {
	ListHubs() []*v1alpha2.Hub
	ListServices(hubName string) []*corev1.Service
}

type RoutePolicyController

type RoutePolicyController struct {
	// contains filtered or unexported fields
}

func NewRoutePolicyController

func NewRoutePolicyController(conf RoutePolicyControllerConfig) *RoutePolicyController

func (*RoutePolicyController) Run

func (c *RoutePolicyController) Run(ctx context.Context) error

func (*RoutePolicyController) Sync

func (c *RoutePolicyController) Sync(ctx context.Context)

func (*RoutePolicyController) UpdateRoutePolicyCondition

func (c *RoutePolicyController) UpdateRoutePolicyCondition(name string, routeCount int) error

type RoutePolicyControllerConfig

type RoutePolicyControllerConfig struct {
	Logger       logr.Logger
	Config       *restclient.Config
	HubInterface HubInterface
	Namespace    string
	SyncFunc     func()
}