store

type Informer ¶

type Informer struct {
	Ingress cache.SharedIndexInformer
	Service cache.SharedIndexInformer
	Secret  cache.SharedIndexInformer
	Node    cache.SharedIndexInformer
}

func (i *Informer) Run(stopCh chan struct{})

type IngressLister ¶

type IngressLister struct {
	cache.Store
}

IngressLister makes a Store that lists Ingress.

func (l IngressLister) ByKey(key string) (*networkv1.Ingress, error)

func (l IngressLister) ListIngress() []*networkv1.Ingress

type Lister ¶

type Lister struct {
	Ingress IngressLister
	Service ServiceLister
	Secret  SecretLister
	Node    NodeLister
}

type NodeLister ¶

type NodeLister struct {
	cache.Store
}

SecretLister makes a Store that lists Secrets.

func (l *NodeLister) NodesIpList() []string

type NotExistsError ¶

type NotExistsError string

NotExistsError is returned when an object does not exist in a local store.

func (e NotExistsError) Error() string

type SecretLister ¶

type SecretLister struct {
	cache.Store
}

SecretLister makes a Store that lists Secrets.

func (l *SecretLister) ByKey(key string) (*corev1.Secret, error)

type ServiceInfo ¶

type ServiceInfo struct {
	Hosts       []string
	NodeIps     []string
	NodePort    int
	Annotations map[string]string
}

ServiceInfo represents helper struct for ingress service

type ServiceLister ¶

type ServiceLister struct {
	cache.Store
}

ServiceLister makes a Store that lists Services.

func (l *ServiceLister) ByKey(key string) (*corev1.Service, error)

type Store ¶

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

Store represents cache store, implements Storer

func New(
	namespace string,
	resyncPeriod time.Duration,
	client *kubernetes.Clientset,
	ingressClass string,
	recorder record.EventRecorder,
	queue workqueue.RateLimitingInterface,
) *Store

func (s *Store) GetIngress(key string) (*networkv1.Ingress, error)

func (s *Store) GetIngressServiceInfo(ingress *networkv1.Ingress) (map[string]ServiceInfo, error)

func (s *Store) GetNodesIpList() []string

func (s *Store) GetSecret(key string) (*corev1.Secret, error)

func (s *Store) GetService(key string) (*corev1.Service, error)

func (s *Store) ListIngress() []*networkv1.Ingress

func (s *Store) Run(stopCh chan struct{})

type Storer ¶

type Storer interface {
	Run(chan struct{})
	GetSecret(key string) (*corev1.Secret, error)
	GetIngress(key string) (*networkv1.Ingress, error)
	ListIngress() []*networkv1.Ingress
	GetService(key string) (*corev1.Service, error)
	GetNodesIpList() []string
	GetIngressServiceInfo(ingress *networkv1.Ingress) (map[string]ServiceInfo, error)
}

Storer is the interface that wraps the required methods to gather information about ingresses, services, secrets and ingress annotations.