Documentation
¶
Index ¶
- func AddMCISvcListToFilter(mci *mciapi.MultiClusterIngress) error
- func DeleteMCISvcListFromFilter(mci *mciapi.MultiClusterIngress) error
- func DiffMCIServicesAndUpdateFilter(oldMCI, newMCI *mciapi.MultiClusterIngress) ([]*MCIServiceElement, []*MCIServiceElement, error)
- func GetMCIServicesChecksum(mciObj *mciapi.MultiClusterIngress) uint32
- func GetMCIsDiff(oldMCI, newMCI *mciapi.MultiClusterIngress) ([]*MCIServiceElement, []*MCIServiceElement, error)
- func GetServiceListStr(mciObj *mciapi.MultiClusterIngress) []string
- func MCIEventHandlers(numWorkers uint32, clusterList []string) cache.ResourceEventHandler
- func ValidateMCIObj(mciObj *mciapi.MultiClusterIngress, clusterList []string) error
- type MCIController
- type MCIServiceElement
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddMCISvcListToFilter ¶
func AddMCISvcListToFilter(mci *mciapi.MultiClusterIngress) error
func DeleteMCISvcListFromFilter ¶
func DeleteMCISvcListFromFilter(mci *mciapi.MultiClusterIngress) error
func DiffMCIServicesAndUpdateFilter ¶
func DiffMCIServicesAndUpdateFilter(oldMCI, newMCI *mciapi.MultiClusterIngress) ([]*MCIServiceElement, []*MCIServiceElement, error)
func GetMCIServicesChecksum ¶
func GetMCIServicesChecksum(mciObj *mciapi.MultiClusterIngress) uint32
func GetMCIsDiff ¶
func GetMCIsDiff(oldMCI, newMCI *mciapi.MultiClusterIngress) ([]*MCIServiceElement, []*MCIServiceElement, error)
func GetServiceListStr ¶
func GetServiceListStr(mciObj *mciapi.MultiClusterIngress) []string
func MCIEventHandlers ¶
func MCIEventHandlers(numWorkers uint32, clusterList []string) cache.ResourceEventHandler
func ValidateMCIObj ¶
func ValidateMCIObj(mciObj *mciapi.MultiClusterIngress, clusterList []string) error
Types ¶
type MCIController ¶
type MCIController struct {
// contains filtered or unexported fields
}
func InitializeMCIController ¶
func InitializeMCIController(kubeClient *kubernetes.Clientset, mciClient *mcics.Clientset, mciInformerFactory mciinformers.SharedInformerFactory, clusterList []string) *MCIController
func (*MCIController) Run ¶
func (mciController *MCIController) Run(stopCh <-chan struct{}) error
type MCIServiceElement ¶
type MCIServiceElement struct {
// contains filtered or unexported fields
}
func GetServiceList ¶
func GetServiceList(mciObj *mciapi.MultiClusterIngress) ([]*MCIServiceElement, error)
func InitServiceElement ¶
func InitServiceElement(cname, namespace, name string, port int32) *MCIServiceElement
func (*MCIServiceElement) Cluster ¶
func (se *MCIServiceElement) Cluster() string
func (*MCIServiceElement) Name ¶
func (se *MCIServiceElement) Name() string
func (*MCIServiceElement) Namespace ¶
func (se *MCIServiceElement) Namespace() string
func (*MCIServiceElement) Port ¶
func (se *MCIServiceElement) Port() int32
Source Files
Click to show internal directories.
Click to hide internal directories.