kube

Documentation

Index

• Variables
• type ConfigMapWatcher
  • func NewConfigMapWatcher(client kubernetes.Interface, ns, selector string, quitCH <-chan struct{}) (*ConfigMapWatcher, error)
  • func (cmw *ConfigMapWatcher) ListConfigMaps() (map[string][]string, error)
  • func (cmw *ConfigMapWatcher) WatchConfigMaps(resultCH chan<- map[string][]string) error
• type Tuple
  • func NewTuple(k, v string) Tuple
  • func (t Tuple) String() string

Variables

var (
	ErrClosedChannel = errors.New("closed watch channel")
)

Types

type ConfigMapWatcher

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

func NewConfigMapWatcher

func NewConfigMapWatcher(client kubernetes.Interface, ns, selector string, quitCH <-chan struct{}) (*ConfigMapWatcher, error)

func (*ConfigMapWatcher) ListConfigMaps

func (cmw *ConfigMapWatcher) ListConfigMaps() (map[string][]string, error)

func (*ConfigMapWatcher) WatchConfigMaps

func (cmw *ConfigMapWatcher) WatchConfigMaps(resultCH chan<- map[string][]string) error

type Tuple

type Tuple struct {
	Key   string
	Value string
}

func NewTuple

func NewTuple(k, v string) Tuple

func (Tuple) String

func (t Tuple) String() string