watch

type CreateFn ¶

type CreateFn func(ctx context.Context, ns, name string) (Interface, error)

CreateFn creates a watch for the named object.

type Event ¶

type Event = watch.Event

type EventType ¶

type EventType = watch.EventType

type FileWatch ¶

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

FileWatch monitors a file for changes. It implements the apimachinery watch.Interface and generates events similar to the ones generated by an apimachinery watch for custom resources or configmaps.

func (w *FileWatch) ResultChan() <-chan Event

func (w *FileWatch) Stop()

type Interface ¶

type Interface = watch.Interface

func File(file string, unmarshal UnmarshalFn) (Interface, error)

func Object(ctx context.Context, ns, name string, create CreateFn) (Interface, error)

type ObjectWatch ¶

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

ObjectWatch is a wrapper for apimachinery watches that monitor a single object. The wrapper transparently reopens the watch when it expires.

func (w *ObjectWatch) ResultChan() <-chan Event

func (w *ObjectWatch) Stop()

type UnmarshalFn ¶

type UnmarshalFn func([]byte, string) (runtime.Object, error)

UnmarshalFn unmarshals YAML data into an object.