store

Documentation

Index

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

Types

type Event

type Event struct {
	Type EventType
	Obj  interface{}
	Old  interface{}
}

Event holds the context of an event.

type EventType

type EventType string

EventType type of event associated with an informer

const (
	// CreateEvent event associated with new objects in an informer
	CreateEvent EventType = "CREATE"
	// UpdateEvent event associated with an object update in an informer
	UpdateEvent EventType = "UPDATE"
	// DeleteEvent event associated when an object is removed from an informer
	DeleteEvent EventType = "DELETE"
)

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
	Endpoints   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
	Endpoints   corev1.EndpointsLister
}

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(clientset *kubernetes.Clientset,
	dbmanager db.Manager,
	conf option.Config,
	startCh *channels.RingChannel,
	probeCh *channels.RingChannel) Storer

NewStore new app runtime store