Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for NewProxyWatcher (0.23 sec)

  1. staging/src/k8s.io/apimachinery/pkg/watch/watch.go

    type ProxyWatcher struct {
    	result chan Event
    	stopCh chan struct{}
    
    	mutex   sync.Mutex
    	stopped bool
    }
    
    var _ Interface = &ProxyWatcher{}
    
    // NewProxyWatcher creates new ProxyWatcher by wrapping a channel
    func NewProxyWatcher(ch chan Event) *ProxyWatcher {
    	return &ProxyWatcher{
    		result:  ch,
    		stopCh:  make(chan struct{}),
    		stopped: false,
    	}
    }
    
    // Stop implements Interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:06:22 UTC 2024
    - 8.1K bytes
    - Viewed (1)
Back to top