mapping

Documentation

Index

• type ClusterCache
• type MappingController
  • func NewMappingController(conf MappingControllerConfig) *MappingController
  • func (d *MappingController) Close()
  • func (d *MappingController) SetRoutes(rules []*v1alpha2.Route)
  • func (d *MappingController) Start(ctx context.Context) error
  • func (d *MappingController) Sync()
  • func (d *MappingController) Way() []string
• type MappingControllerConfig

Types

type ClusterCache

type ClusterCache interface {
	ListServices(name string) []*corev1.Service
	GetHub(name string) *v1alpha2.Hub
	GetHubGateway(hubName string, forHub string) v1alpha2.HubSpecGateway
	GetIdentity(name string) string
	Clientset(name string) kubernetes.Interface
	LoadPortPeer(importHubName string, cluster, namespace, name string, ports []services.MappingPort)
	GetPortPeer(importHubName string, cluster, namespace, name string, port int32) int32
	RegistryServiceCallback(exportHubName, importHubName string, cb func())
	UnregistryServiceCallback(exportHubName, importHubName string)
}

type MappingController

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

func NewMappingController

func NewMappingController(conf MappingControllerConfig) *MappingController

func (*MappingController) Close

func (d *MappingController) Close()

func (*MappingController) SetRoutes

func (d *MappingController) SetRoutes(rules []*v1alpha2.Route)

func (*MappingController) Start

func (d *MappingController) Start(ctx context.Context) error

func (*MappingController) Sync

func (d *MappingController) Sync()

func (*MappingController) Way

func (d *MappingController) Way() []string

type MappingControllerConfig

type MappingControllerConfig struct {
	Namespace     string
	ExportHubName string
	ImportHubName string
	ClusterCache  ClusterCache
	Logger        logr.Logger
}