statusmanager

Documentation

Index

• Constants
• type DeployConfigResource
• type StatusManager
  • func NewStatusManager(kubeCRClient *versioned.Interface, crNamespace, crName string) *StatusManager
  • func (sm *StatusManager) AddDeployInformer(informer *cache.SharedIndexInformer, namespace string)
  • func (sm *StatusManager) AddRequest(kind, namespace, name string, exit bool, request interface{})
  • func (sm *StatusManager) GetDeployConfigCR(name, namespace string) *v1.DeployConfig
  • func (sm *StatusManager) Start()
  • func (sm *StatusManager) Stop()
• type StatusManagerInterface
• type StatusRequest

Constants

const (
	DeployConfig       = "deployconfig"
	SingleCluster      = "single-cluster"
	MultiClusterPrefix = "multi-cluster-"
	Ok                 = "Ok"
	Accepted           = "Accepted"
)

Types

type DeployConfigResource

type DeployConfigResource struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type StatusManager

type StatusManager struct {
	Status chan *StatusRequest
	// contains filtered or unexported fields
}

func NewStatusManager

func NewStatusManager(kubeCRClient *versioned.Interface, crNamespace, crName string) *StatusManager

func (*StatusManager) AddDeployInformer

func (sm *StatusManager) AddDeployInformer(informer *cache.SharedIndexInformer, namespace string)

func (*StatusManager) AddRequest

func (sm *StatusManager) AddRequest(kind, namespace, name string, exit bool, request interface{})

func (*StatusManager) GetDeployConfigCR

func (sm *StatusManager) GetDeployConfigCR(name, namespace string) *v1.DeployConfig

func (*StatusManager) Start

func (sm *StatusManager) Start()

Start the StatusManager

func (*StatusManager) Stop

func (sm *StatusManager) Stop()

Stop the StatusManager

type StatusManagerInterface

type StatusManagerInterface interface {
	Start()
	Stop()
	AddRequest(kind, namespace, name string, exit bool, request interface{})
	GetDeployConfigCR(name, namespace string) *v1.DeployConfig

	AddDeployInformer(informer *cache.SharedIndexInformer, namespace string)
	// contains filtered or unexported methods
}

Interface for StatusManager

type StatusRequest

type StatusRequest struct {
	Kind      string
	Name      string
	Namespace string
	Request   interface{}
	Exit      bool
}