Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HubInterface ¶
type HubInterface interface { GetService(hubName string, namespace, name string) (*corev1.Service, bool) ListServices(name string) []*corev1.Service GetHub(name string) *v1alpha2.Hub GetHubGateway(hubName string, forHub string) v1alpha2.HubSpecGateway GetAuthorized(name string) string Clientset(name string) client.Interface LoadPortPeer(importHubName string, cluster, namespace, name string, port, bindPort int32) error GetPortPeer(importHubName string, cluster, namespace, name string, port int32) (int32, error) DeletePortPeer(importHubName string, cluster, namespace, name string, port int32) (int32, error) RegistryServiceCallback(exportHubName, importHubName string, cb func()) UnregistryServiceCallback(exportHubName, importHubName string) HubReady(hubName string) bool }
type MappingController ¶
type MappingController struct {
// contains filtered or unexported fields
}
func NewMappingController ¶
func NewMappingController(conf MappingControllerConfig) *MappingController
func (*MappingController) Close ¶
func (m *MappingController) Close()
func (*MappingController) SetRoutes ¶
func (m *MappingController) SetRoutes(routes []*v1alpha2.Route)
func (*MappingController) Sync ¶
func (m *MappingController) Sync()
type MappingControllerConfig ¶
type MappingControllerConfig struct { Namespace string ExportHubName string ImportHubName string HubInterface HubInterface RouteInterface RouteInterface Logger logr.Logger }
type RouteController ¶
type RouteController struct {
// contains filtered or unexported fields
}
func NewRouteController ¶
func NewRouteController(conf *RouteControllerConfig) *RouteController
func (*RouteController) Sync ¶
func (c *RouteController) Sync(ctx context.Context)
func (*RouteController) UpdateRouteCondition ¶
func (c *RouteController) UpdateRouteCondition(name string, conditions []metav1.Condition) error
type RouteControllerConfig ¶
type RouteControllerConfig struct { Logger logr.Logger Config *restclient.Config HubInterface HubInterface Namespace string SyncFunc func() }
Click to show internal directories.
Click to hide internal directories.