controller

Documentation

Index

• Constants
• type AggregationController
  • func NewController(istioClient *istioclient.Clientset, kubeClient *kubernetes.Clientset, ...) *AggregationController
  • func (c *AggregationController) AddCluster(name string, client *kubernetes.Clientset) error
  • func (c *AggregationController) ClusterClient(name string) *kubernetes.Clientset
  • func (c *AggregationController) HandleAccess(fromIP, svcID, toIP string) error
  • func (c *AggregationController) IP2ServiceID(targetIP string) string
  • func (c *AggregationController) Run()
• type Cluster
  • func NewCluster(name string, client *kubernetes.Clientset) *Cluster

Constants

const (
	// ResourcePrefix ...
	ResourcePrefix = "lazyxds-"
	// EgressGatewayFullName ...
	EgressGatewayFullName = config.IstioNamespace + "/" + config.EgressGatewayName
	// ServiceAddressKey ...
	ServiceAddressKey = "lazyxds-service-address"
)

const PlaceHolderService = "lazyxds-placeholder-service"

PlaceHolderService ...

Types

type AggregationController

type AggregationController struct {
	KubeClient *kubernetes.Clientset
	// contains filtered or unexported fields
}

AggregationController ...

func NewController

func NewController(istioClient *istioclient.Clientset, kubeClient *kubernetes.Clientset, stop <-chan struct{}) *AggregationController

NewController ...

func (*AggregationController) AddCluster

func (c *AggregationController) AddCluster(name string, client *kubernetes.Clientset) error

AddCluster ...

func (*AggregationController) ClusterClient

func (c *AggregationController) ClusterClient(name string) *kubernetes.Clientset

ClusterClient ...

func (*AggregationController) HandleAccess

func (c *AggregationController) HandleAccess(fromIP, svcID, toIP string) error

HandleAccess ...

func (*AggregationController) IP2ServiceID

func (c *AggregationController) IP2ServiceID(targetIP string) string

IP2ServiceID ...

func (*AggregationController) Run

func (c *AggregationController) Run()

Run ...

type Cluster

type Cluster struct {
	Client   *kubernetes.Clientset
	Informer informers.SharedInformerFactory
	// contains filtered or unexported fields
}

Cluster ...

func NewCluster

func NewCluster(name string, client *kubernetes.Clientset) *Cluster

NewCluster ...