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 ¶
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 Nodes cache.SharedIndexInformer }
Informer kube-api client cache
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
Click to show internal directories.
Click to hide internal directories.