state

Documentation

Index

• type BackendPaths
• type IngressState
• type IngressStateManager
  • func New(ctx context.Context, client kubernetes.Interface, ingressClassName string) *IngressStateManager
  • func (stateManager *IngressStateManager) GetStateChan() <-chan *IngressState
• type PathConfig
• type TlsCert
• type TlsCerts

Types

type BackendPaths

type BackendPaths map[string][]*PathConfig // host->ingressPath

type IngressState

type IngressState struct {
	BackendPaths BackendPaths
	TlsCerts     TlsCerts
}

type IngressStateManager

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

func New

func New(ctx context.Context, client kubernetes.Interface, ingressClassName string) *IngressStateManager

New creates a new Kubernetes Ingress state. The ctx can be used to cancel the listening to updates from the Kubernetes API.

func (*IngressStateManager) GetStateChan

func (stateManager *IngressStateManager) GetStateChan() <-chan *IngressState

GetStateChan returns a channel where state updates are delivered. This is the main method used to fetch the current status.

type PathConfig

type PathConfig struct {
	PathType    *v1Net.PathType
	Path        string
	Namespace   string
	ServiceName string
	ServicePort int32
}

type TlsCert

type TlsCert struct {
	Cert []byte
	Key  []byte
}

type TlsCerts

type TlsCerts map[string]*TlsCert // host->secret