store

package
v5.1.6-release+incompa... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2019 License: LGPL-3.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event

type Event struct {
	Type EventType
	Obj  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

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
	Nodes       corev1.NodeLister
}

Lister kube-api client cache

type ProbeInfo

type ProbeInfo struct {
	Sid  string `json:"sid"`
	UUID string `json:"uuid"`
	IP   string `json:"ip"`
	Port int32  `json:"port"`
}

ProbeInfo holds the context of a probe.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL