kube

package

v0.10.2 Latest Latest Go to latest Published: Sep 22, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/v3io/scaler

Links

Open Source Insights

Documentation ¶

Index ¶

type IngressValue
type IngressWatcher
- func NewIngressWatcher(dlxCtx context.Context, dlxLogger logger.Logger, ...) (*IngressWatcher, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type IngressValue ¶

type IngressValue struct {
	Name    string
	Host    string
	Path    string
	Targets []string
}

type IngressWatcher ¶

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

IngressWatcher watches for changes in Kubernetes Ingress resources and updates the ingress cache accordingly

func NewIngressWatcher ¶

func NewIngressWatcher(
	dlxCtx context.Context,
	dlxLogger logger.Logger,
	kubeClient kubernetes.Interface,
	resolveTargetsCallback scalertypes.ResolveTargetsFromIngressCallback,
	resyncInterval scalertypes.Duration,
	namespace string,
	labelSelector string,
) (*IngressWatcher, error)

func (*IngressWatcher) AddHandler ¶

func (iw *IngressWatcher) AddHandler(obj interface{})

func (*IngressWatcher) DeleteHandler ¶

func (iw *IngressWatcher) DeleteHandler(obj interface{})

func (*IngressWatcher) GetIngressHostCacheReader ¶

func (iw *IngressWatcher) GetIngressHostCacheReader() ingresscache.IngressHostCacheReader

GetIngressHostCacheReader expose read-only access to the ingress cache

func (*IngressWatcher) Start ¶

func (iw *IngressWatcher) Start() error

func (*IngressWatcher) Stop ¶

func (iw *IngressWatcher) Stop()

func (*IngressWatcher) UpdateHandler ¶

func (iw *IngressWatcher) UpdateHandler(oldObj, newObj interface{})

Source Files ¶

View all Source files

ingress.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL