subscription

Documentation

Index

• type ConfigMapSubscription
  • func (p *ConfigMapSubscription) IsComplete() <-chan bool
  • func (p *ConfigMapSubscription) Reconcile(object runtime.Object, event watch.EventType)
  • func (p *ConfigMapSubscription) Subscribe() (watch.Interface, error)
• type ISubscription
• type PodSubscription
  • func (p *PodSubscription) IsComplete() <-chan bool
  • func (p *PodSubscription) Reconcile(object runtime.Object, event watch.EventType)
  • func (p *PodSubscription) Subscribe() (watch.Interface, error)

Types

type ConfigMapSubscription

type ConfigMapSubscription struct {
	ClientSet  kubernetes.Interface
	Ctx        context.Context
	Completion chan bool
	// Specific behaviours for our Operator
	PlatformConfig *platformConfig
	// contains filtered or unexported fields
}

func (*ConfigMapSubscription) IsComplete

func (p *ConfigMapSubscription) IsComplete() <-chan bool

func (*ConfigMapSubscription) Reconcile

func (p *ConfigMapSubscription) Reconcile(object runtime.Object, event watch.EventType)

func (*ConfigMapSubscription) Subscribe

func (p *ConfigMapSubscription) Subscribe() (watch.Interface, error)

type ISubscription

type ISubscription interface {
	Subscribe() (watch.Interface, error)
	Reconcile(object runtime.Object, event watch.EventType)
	IsComplete() <-chan bool
}

type PodSubscription

type PodSubscription struct {
	ClientSet  kubernetes.Interface
	Ctx        context.Context
	Completion chan bool
	// This specific reference to ConfigMapSubscription is for updating pod annotations
	ConfigMapSubscriptRef *ConfigMapSubscription
	// contains filtered or unexported fields
}

func (*PodSubscription) IsComplete

func (p *PodSubscription) IsComplete() <-chan bool

func (*PodSubscription) Reconcile

func (p *PodSubscription) Reconcile(object runtime.Object, event watch.EventType)

func (*PodSubscription) Subscribe

func (p *PodSubscription) Subscribe() (watch.Interface, error)