state

Documentation

Index

• type BackendPaths
• type Config
• type ConfigOption
  • func DebounceDuration(timeout time.Duration) ConfigOption
• 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 Config

type Config struct {
	//DebounceDuration is the duration for Kubernetes status update debouncing.
	// Only when for this duration no update has been received the status is updated.
	// Defaults to 1 second.
	DebounceDuration time.Duration
}

Config is a data structure that holds the config options for the kubernetes state

type ConfigOption

type ConfigOption func(*Config)

ConfigOption is used to implement the functional parameter pattern for the kubernetes state

func DebounceDuration

func DebounceDuration(timeout time.Duration) ConfigOption

DebounceDuration sets the timeout for waiting for the backend response for the kubernetes state

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, options ...ConfigOption) *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