k8s

type Aggregator ¶ added in v0.16.0

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

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 ¶ added in v0.16.0

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 ¶ added in v0.16.0

type IngressTLS struct {
	Host       string
	SecretName string
}

IngressTLS describes the transport layer security associated with an Ingress.

type SyncDataEvent ¶ added in v0.16.0

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

SyncDataEvent represents converted k8s received message

type SyncType ¶ added in v0.16.0

type SyncType string

SyncType represents the type of k8s received message

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