watch

Documentation

Overview

Package watch provides netlink watchers via multicast groups.

Index

• type RateLimitedTrigger
  • func NewDefaultRateLimitedTrigger(ctx context.Context, trigger Trigger) *RateLimitedTrigger
  • func NewRateLimitedTrigger(ctx context.Context, trigger Trigger, rateLimit rate.Limit, burst int) *RateLimitedTrigger
  • func (t *RateLimitedTrigger) QueueReconcile()
• type Trigger
• type Watcher
  • func NewEthtool(trigger Trigger) (Watcher, error)
  • func NewRtNetlink(trigger Trigger, groups uint32) (Watcher, error)

Types

type RateLimitedTrigger

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

RateLimitedTrigger wraps a Trigger with rate limiting.

func NewDefaultRateLimitedTrigger

func NewDefaultRateLimitedTrigger(ctx context.Context, trigger Trigger) *RateLimitedTrigger

NewDefaultRateLimitedTrigger creates a new RateLimitedTrigger with default params.

func NewRateLimitedTrigger

func NewRateLimitedTrigger(ctx context.Context, trigger Trigger, rateLimit rate.Limit, burst int) *RateLimitedTrigger

NewRateLimitedTrigger creates a new RateLimitedTrigger with specified params.

Trigger's goroutine exists when the context is canceled.

func (*RateLimitedTrigger) QueueReconcile

func (t *RateLimitedTrigger) QueueReconcile()

QueueReconcile implements Trigger interface.

The event is queued if the goroutine is ready to accept it (otherwise it's already busy processing a previous event). This function returns immediately.

type Trigger

type Trigger interface {
	QueueReconcile()
}

Trigger is used by watcher to trigger reconcile loops.

type Watcher

type Watcher interface {
	Done()
}

Watcher interface allows to stop watching.

func NewEthtool

func NewEthtool(trigger Trigger) (Watcher, error)

NewEthtool starts ethtool watch.

func NewRtNetlink

func NewRtNetlink(trigger Trigger, groups uint32) (Watcher, error)

NewRtNetlink starts rtnetlink watch over specified groups.