store

Documentation

Index

• type Informer
  • func (i *Informer) Ready() bool
  • func (i *Informer) Start(stop chan struct{})
• type Lister
• type Storer
  • func NewStore(dbmanager db.Manager, conf option.Config) Storer

Types

type Informer

type Informer struct {
	Ingress     cache.SharedIndexInformer
	Service     cache.SharedIndexInformer
	Secret      cache.SharedIndexInformer
	StatefulSet cache.SharedIndexInformer
	Deployment  cache.SharedIndexInformer
	Pod         cache.SharedIndexInformer
	ConfigMap   cache.SharedIndexInformer
	ReplicaSet  cache.SharedIndexInformer
}

Informer kube-api client cache

func (*Informer) Ready

func (i *Informer) Ready() bool

Ready if all kube informers is syncd, store is ready

func (*Informer) Start

func (i *Informer) Start(stop chan struct{})

Start statrt

type Lister

type Lister struct {
	Ingress     v1beta1.IngressLister
	Service     corev1.ServiceLister
	Secret      corev1.SecretLister
	StatefulSet appsv1.StatefulSetLister
	Deployment  appsv1.DeploymentLister
	Pod         corev1.PodLister
	ConfigMap   corev1.ConfigMapLister
}

Lister kube-api client cache

type Storer

type Storer interface {
	Start() error
	Ready() bool
	RegistAppService(*v1.AppService)
	GetAppService(serviceID string) *v1.AppService
	UpdateGetAppService(serviceID string) *v1.AppService
	GetAllAppServices() []*v1.AppService
	GetAppServiceStatus(serviceID string) string
	GetAppServicesStatus(serviceIDs []string) map[string]string
	GetTenantResource(tenantID string) *v1.TenantResource
	GetTenantRunningApp(tenantID string) []*v1.AppService
	GetNeedBillingStatus(serviceIDs []string) map[string]string
	OnDelete(obj interface{})
	GetPodLister() listcorev1.PodLister
}

Storer app runtime store interface

func NewStore

func NewStore(dbmanager db.Manager, conf option.Config) Storer

NewStore new app runtime store