annotations

Documentation

Index

• Constants
• Variables
• func Ref(cluster string, watch *api.DNSAnnotation) (resources.ClusterObjectKey, error)
• type AnnotationState
• type Annotations
• type Handler
• type ObjectKind
• type ObjectState
• type State
  • func GetOrCreateWatches(controller controller.Interface) *State
  • func NewWatches() *State
  • func (this *State) Add(logger logger.LogContext, annotation resources.Object) error
  • func (this *State) Get(gk schema.GroupKind) resources.ClusterObjectKeySet
  • func (this *State) GetInfoFor(key resources.ClusterObjectKey) Annotations
  • func (this *State) RegisterHandler(log logger.LogContext, gk schema.GroupKind, h Handler)
  • func (this *State) Remove(logger logger.LogContext, watch resources.ClusterObjectKey)
  • func (this *State) SetActive(key resources.ClusterObjectKey, active bool) error
  • func (this *State) UnRegisterHandler(log logger.LogContext, gk schema.GroupKind, h Handler)

Constants

const KEY_STATE = "key-watches"

Variables

var WatchResourceKind = abstract.NewGroupKind(api.GroupName, api.DNSAnnotationKind)

Functions

func Ref

func Ref(cluster string, watch *api.DNSAnnotation) (resources.ClusterObjectKey, error)

Types

type AnnotationState

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

type Annotations

type Annotations map[string]string

type Handler

type Handler interface {
	ObjectUpdated(key resources.ClusterObjectKey)
}

Handler is used to notify interesting parties about changes of watch state of an object

type ObjectKind

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

type ObjectState

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

type State

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

func GetOrCreateWatches

func GetOrCreateWatches(controller controller.Interface) *State

func NewWatches

func NewWatches() *State

func (*State) Add

func (this *State) Add(logger logger.LogContext, annotation resources.Object) error

func (*State) Get

func (this *State) Get(gk schema.GroupKind) resources.ClusterObjectKeySet

func (*State) GetInfoFor

func (this *State) GetInfoFor(key resources.ClusterObjectKey) Annotations

func (*State) RegisterHandler

func (this *State) RegisterHandler(log logger.LogContext, gk schema.GroupKind, h Handler)

func (*State) Remove

func (this *State) Remove(logger logger.LogContext, watch resources.ClusterObjectKey)

func (*State) SetActive

func (this *State) SetActive(key resources.ClusterObjectKey, active bool) error

func (*State) UnRegisterHandler

func (this *State) UnRegisterHandler(log logger.LogContext, gk schema.GroupKind, h Handler)