k8s

Documentation

Index

• func GenericIngressEqual(a, b *Ingress) bool
• func NewListWatch(client *kubernetes.Clientset) *cache.ListWatch
• type Aggregator
  • func NewAggregator(k8sClients []*kubernetes.Clientset, ctx context.Context, syncSecrets bool) *Aggregator
  • func (a *Aggregator) Events() chan SyncDataEvent
  • func (a *Aggregator) EventsIngresses(ctx context.Context, informer cache.SharedIndexInformer)
  • func (a *Aggregator) EventsSecrets(ctx context.Context, informer cache.SharedIndexInformer)
  • func (a *Aggregator) GetGenericIngresses() ([]*Ingress, error)
  • func (a *Aggregator) GetSecrets() ([]*v1.Secret, error)
  • func (a *Aggregator) Run()
• type Ingress
• type IngressLister
• type IngressTLS
• type SyncDataEvent
• type SyncType

Functions

func GenericIngressEqual

func GenericIngressEqual(a, b *Ingress) bool

func NewListWatch

func NewListWatch(client *kubernetes.Clientset) *cache.ListWatch

Types

type Aggregator

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

func NewAggregator

func NewAggregator(k8sClients []*kubernetes.Clientset, ctx context.Context, syncSecrets bool) *Aggregator

NewAggregator returns a new Aggregator initialized with resource informers

func (*Aggregator) Events

func (a *Aggregator) Events() chan SyncDataEvent

func (*Aggregator) EventsIngresses

func (a *Aggregator) EventsIngresses(ctx context.Context, informer cache.SharedIndexInformer)

func (*Aggregator) EventsSecrets

func (a *Aggregator) EventsSecrets(ctx context.Context, informer cache.SharedIndexInformer)

func (*Aggregator) GetGenericIngresses

func (a *Aggregator) GetGenericIngresses() ([]*Ingress, error)

Get ingresses from stores and convert them to apiGroup-agnostic ingresses

func (*Aggregator) GetSecrets

func (a *Aggregator) GetSecrets() ([]*v1.Secret, error)

func (*Aggregator) Run

func (a *Aggregator) Run()

Run is the synchronization loop

type Ingress

type Ingress struct {
	Namespace   string
	Name        string
	Class       *string
	Annotations map[string]string
	RulesHosts  []string
	Upstreams   []string
	TLS         map[string]*IngressTLS
}

Ingress is the version-agnostic description of an ingress

type IngressLister

type IngressLister interface {
	List() ([]v1beta1.Ingress, error)
}

type IngressTLS

type IngressTLS struct {
	Host       string
	SecretName string
}

IngressTLS describes the transport layer security associated with an Ingress.

type SyncDataEvent

type SyncDataEvent struct {
	SyncType
	Data interface{}
	// contains filtered or unexported fields
}

SyncDataEvent represents converted k8s received message

type SyncType

type SyncType string

SyncType represents the type of k8s received message

const (
	COMMAND SyncType = "COMMAND"
	INGRESS SyncType = "INGRESS"
	SECRET  SyncType = "SECRET"
)