hub

package

v0.8.1 Latest Latest Go to latest Published: Oct 9, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Details

This section is empty.

This section is empty.

func IsEnabledMCS(f *trafficv1alpha2.Hub) bool

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

func NewHubController(conf HubControllerConfig) *HubController

func (c *HubController) Clientset(hubName string) (client.Interface, error)

func (c *HubController) DeletePortPeer(importHubName string, cluster, namespace, name string, port int32) (int32, error)

func (c *HubController) GetAuthorized(name string) string

func (c *HubController) GetHub(name string) *trafficv1alpha2.Hub

func (c *HubController) GetHubGateway(hubName string, forHub string) trafficv1alpha2.HubSpecGateway

func (c *HubController) GetPortPeer(importHubName string, cluster, namespace, name string, port int32) (int32, error)

func (c *HubController) GetService(hubName string, namespace, name string) (*corev1.Service, bool)

func (c *HubController) GetTunnelAddressInControlPlane(hubName string) string

func (c *HubController) HubReady(hubName string) bool

func (c *HubController) ListHubs() []*trafficv1alpha2.Hub

func (c *HubController) ListMCS(namespace string) (map[string][]*mcsv1alpha1.ServiceImport, map[string][]*mcsv1alpha1.ServiceExport)

func (c *HubController) ListServices(hubName string) []*corev1.Service

func (c *HubController) LoadPortPeer(importHubName string, cluster, namespace, name string, port, bindPort int32) error

func (c *HubController) ResetClientset(hubName string)

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

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

func (c *HubController) UpdateClientset(hubName string) (client.Interface, error)

func (c *HubController) UpdateHubConditions(name string, conditions []metav1.Condition)

type HubControllerConfig struct {
	Logger    logr.Logger
	Clientset client.Interface
	Namespace string
	SyncFunc  func()
}