state

Documentation

Index

• type BackendPath
• type DomainConfig
• type IngressState
• type IngressStateManager
  • func New(ctx context.Context, client kubernetes.Interface, ingressClassName string, ...) (*IngressStateManager, error)
  • func (stateManager *IngressStateManager) CleanIngressStatus(ctx context.Context) []error
  • func (stateManager *IngressStateManager) GetStateChan() <-chan IngressState
• type TlsCert

Types

type BackendPath

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

type DomainConfig

type DomainConfig struct {
	BackendPaths []*BackendPath
	TlsCert      *TlsCert
}

type IngressState

type IngressState map[string]*DomainConfig

type IngressStateManager

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

func New

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

New creates a new Kubernetes IngressInformer state. The ctx can be used to cancel the listening to updates from the Kubernetes API. The hostIp is an optional argument. If and only if it is set the ingress status is updated.

func (*IngressStateManager) CleanIngressStatus

func (stateManager *IngressStateManager) CleanIngressStatus(ctx context.Context) []error

CleanIngressStatus is supposed to be called during shutdown and removes all ingress status entries set by this instance. The internal state channel is not updated.

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 TlsCert

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