poll

Documentation

Index

• func NewSecretPoller(name, namespace string, client kubernetes.Interface) syncapi.Poller
• type PollWatcher
  • func NewPollWatcher() *PollWatcher
  • func (self *PollWatcher) IsStopped() bool
  • func (self *PollWatcher) ResultChan() <-chan watch.Event
  • func (self *PollWatcher) Stop()
• type SecretPoller
  • func (self *SecretPoller) Poll(interval time.Duration) watch.Interface

Functions

func NewSecretPoller

func NewSecretPoller(name, namespace string, client kubernetes.Interface) syncapi.Poller

NewSecretPoller returns instance of Poller interface.

Types

type PollWatcher

type PollWatcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Implements watch.Interface

func NewPollWatcher

func NewPollWatcher() *PollWatcher

NewPollWatcher creates instance of PollWatcher.

func (*PollWatcher) IsStopped

func (self *PollWatcher) IsStopped() bool

IsStopped returns whether or not watcher was stopped.

func (*PollWatcher) ResultChan

func (self *PollWatcher) ResultChan() <-chan watch.Event

ResultChan returns result channel that user can watch for incoming events.

func (*PollWatcher) Stop

func (self *PollWatcher) Stop()

Stop stops poll watcher and closes event channel.

type SecretPoller

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

SecretPoller implements Poller interface. See Poller for more information.

func (*SecretPoller) Poll

func (self *SecretPoller) Poll(interval time.Duration) watch.Interface

Poll new secret every 'interval' time and send it to watcher channel. See Poller for more information.