hub

Documentation

Index

• type HubController
  • func NewHubController(conf HubControllerConfig) *HubController
  • func (c *HubController) Clientset(name string) kubernetes.Interface
  • func (c *HubController) GetHub(name string) *v1alpha2.Hub
  • func (c *HubController) GetHubGateway(hubName string, forHub string) v1alpha2.HubSpecGateway
  • func (c *HubController) GetIdentity(name string) string
  • func (c *HubController) GetPortPeer(importHubName string, cluster, namespace, name string, port int32) int32
  • func (c *HubController) ListServices(name string) []*corev1.Service
  • func (c *HubController) LoadPortPeer(importHubName string, list *corev1.ServiceList)
  • func (c *HubController) RegistryServiceCallback(exportHubName, importHubName string, cb func())
  • func (c *HubController) Run(ctx context.Context) error
  • func (c *HubController) UnregistryServiceCallback(exportHubName, importHubName string)
• type HubControllerConfig

Types

type HubController

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

func NewHubController

func NewHubController(conf HubControllerConfig) *HubController

func (*HubController) Clientset

func (c *HubController) Clientset(name string) kubernetes.Interface

func (*HubController) GetHub

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

func (*HubController) GetHubGateway

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

func (*HubController) GetIdentity

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

func (*HubController) GetPortPeer

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

func (*HubController) ListServices

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

func (*HubController) LoadPortPeer

func (c *HubController) LoadPortPeer(importHubName string, list *corev1.ServiceList)

func (*HubController) RegistryServiceCallback

func (c *HubController) RegistryServiceCallback(exportHubName, importHubName string, cb func())

func (*HubController) Run

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

func (*HubController) UnregistryServiceCallback

func (c *HubController) UnregistryServiceCallback(exportHubName, importHubName string)

type HubControllerConfig

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