cm

Documentation

Index

• Variables
• type CmWatcher
  • func NewCmWatcher(clientset *kubernetes.Clientset) *CmWatcher
  • func (cmw *CmWatcher) CreateOrUpdate(key string, obj interface{}) error
  • func (cmw *CmWatcher) Delete(key string) error
  • func (cmw *CmWatcher) GetNocalhostConfig(application, svcType, svcName string) (*profile.NocalHostAppConfigV2, *profile.ServiceConfigV2, error)
  • func (cmw *CmWatcher) Prepare(namespace string) error
  • func (cmw *CmWatcher) Watch()
  • func (cmw *CmWatcher) WatcherInfo() string

Variables

var NOT_FOUND = errors.New("Not found")

Types

type CmWatcher

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

func NewCmWatcher

func NewCmWatcher(clientset *kubernetes.Clientset) *CmWatcher

func (*CmWatcher) CreateOrUpdate

func (cmw *CmWatcher) CreateOrUpdate(key string, obj interface{}) error

func (*CmWatcher) Delete

func (cmw *CmWatcher) Delete(key string) error

func (*CmWatcher) GetNocalhostConfig

func (cmw *CmWatcher) GetNocalhostConfig(application, svcType, svcName string) (
	*profile.NocalHostAppConfigV2, *profile.ServiceConfigV2, error)

GetNocalhostConfig CAUTION: appCfg may nil!

func (*CmWatcher) Prepare

func (cmw *CmWatcher) Prepare(namespace string) error

func (*CmWatcher) Watch

func (cmw *CmWatcher) Watch()

this method will block until error occur

func (*CmWatcher) WatcherInfo

func (cmw *CmWatcher) WatcherInfo() string