aboutsummaryrefslogtreecommitdiffstats
path: root/kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go
diff options
context:
space:
mode:
Diffstat (limited to 'kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go')
-rw-r--r--kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go137
1 files changed, 0 insertions, 137 deletions
diff --git a/kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go b/kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go
deleted file mode 100644
index 96b2fe3..0000000
--- a/kube2msb/src/vendor/k8s.io/kubernetes/pkg/watch/watch.go
+++ /dev/null
@@ -1,137 +0,0 @@
-/*
-Copyright 2014 The Kubernetes Authors.
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package watch
-
-import (
- "sync"
-
- "k8s.io/kubernetes/pkg/runtime"
-)
-
-// Interface can be implemented by anything that knows how to watch and report changes.
-type Interface interface {
- // Stops watching. Will close the channel returned by ResultChan(). Releases
- // any resources used by the watch.
- Stop()
-
- // Returns a chan which will receive all the events. If an error occurs
- // or Stop() is called, this channel will be closed, in which case the
- // watch should be completely cleaned up.
- ResultChan() <-chan Event
-}
-
-// EventType defines the possible types of events.
-type EventType string
-
-const (
- Added EventType = "ADDED"
- Modified EventType = "MODIFIED"
- Deleted EventType = "DELETED"
- Error EventType = "ERROR"
-)
-
-// Event represents a single event to a watched resource.
-type Event struct {
- Type EventType
-
- // Object is:
- // * If Type is Added or Modified: the new state of the object.
- // * If Type is Deleted: the state of the object immediately before deletion.
- // * If Type is Error: *api.Status is recommended; other types may make sense
- // depending on context.
- Object runtime.Object
-}
-
-type emptyWatch chan Event
-
-// NewEmptyWatch returns a watch interface that returns no results and is closed.
-// May be used in certain error conditions where no information is available but
-// an error is not warranted.
-func NewEmptyWatch() Interface {
- ch := make(chan Event)
- close(ch)
- return emptyWatch(ch)
-}
-
-// Stop implements Interface
-func (w emptyWatch) Stop() {
-}
-
-// ResultChan implements Interface
-func (w emptyWatch) ResultChan() <-chan Event {
- return chan Event(w)
-}
-
-// FakeWatcher lets you test anything that consumes a watch.Interface; threadsafe.
-type FakeWatcher struct {
- result chan Event
- Stopped bool
- sync.Mutex
-}
-
-func NewFake() *FakeWatcher {
- return &FakeWatcher{
- result: make(chan Event),
- }
-}
-
-// Stop implements Interface.Stop().
-func (f *FakeWatcher) Stop() {
- f.Lock()
- defer f.Unlock()
- if !f.Stopped {
- close(f.result)
- f.Stopped = true
- }
-}
-
-// Reset prepares the watcher to be reused.
-func (f *FakeWatcher) Reset() {
- f.Lock()
- defer f.Unlock()
- f.Stopped = false
- f.result = make(chan Event)
-}
-
-func (f *FakeWatcher) ResultChan() <-chan Event {
- return f.result
-}
-
-// Add sends an add event.
-func (f *FakeWatcher) Add(obj runtime.Object) {
- f.result <- Event{Added, obj}
-}
-
-// Modify sends a modify event.
-func (f *FakeWatcher) Modify(obj runtime.Object) {
- f.result <- Event{Modified, obj}
-}
-
-// Delete sends a delete event.
-func (f *FakeWatcher) Delete(lastValue runtime.Object) {
- f.result <- Event{Deleted, lastValue}
-}
-
-// Error sends an Error event.
-func (f *FakeWatcher) Error(errValue runtime.Object) {
- f.result <- Event{Error, errValue}
-}
-
-// Action sends an event of the requested type, for table-based testing.
-func (f *FakeWatcher) Action(action EventType, obj runtime.Object) {
- f.result <- Event{action, obj}
-}