store

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

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

 Go to latest Published: Oct 16, 2020 License: LGPL-3.0 Imports: 36 Imported by: 0

Documentation

Overview

Package store is a generated GoMock package.

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 {
	Namespace               cache.SharedIndexInformer
	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
	StorageClass            cache.SharedIndexInformer
	Claims                  cache.SharedIndexInformer
	Events                  cache.SharedIndexInformer
	HorizontalPodAutoscaler 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
	Nodes                   corev1.NodeLister
	StorageClass            storagev1.StorageClassLister
	Claims                  corev1.PersistentVolumeClaimLister
	HorizontalPodAutoscaler autoscalingv2.HorizontalPodAutoscalerLister
}

Lister kube-api client cache

type MockStorer 

type MockStorer struct {
	// contains filtered or unexported fields
}

MockStorer is a mock of Storer interface

func NewMockStorer 

func NewMockStorer(ctrl *gomock.Controller) *MockStorer

NewMockStorer creates a new mock instance

func (*MockStorer) EXPECT 

func (m *MockStorer) EXPECT() *MockStorerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockStorer) GetAllAppServices 

func (m *MockStorer) GetAllAppServices() []*v1.AppService

GetAllAppServices mocks base method

func (*MockStorer) GetAppService 

func (m *MockStorer) GetAppService(serviceID string) *v1.AppService

GetAppService mocks base method

func (*MockStorer) GetAppServiceStatus 

func (m *MockStorer) GetAppServiceStatus(serviceID string) string

GetAppServiceStatus mocks base method

func (*MockStorer) GetAppServicesStatus 

func (m *MockStorer) GetAppServicesStatus(serviceIDs []string) map[string]string

GetAppServicesStatus mocks base method

func (*MockStorer) GetNeedBillingStatus 

func (m *MockStorer) GetNeedBillingStatus(serviceIDs []string) map[string]string

GetNeedBillingStatus mocks base method

func (*MockStorer) GetPodLister 

func (m *MockStorer) GetPodLister() v11.PodLister

GetPodLister mocks base method

func (*MockStorer) GetTenantResource 

func (m *MockStorer) GetTenantResource(tenantID string) *v1.TenantResource

GetTenantResource mocks base method

func (*MockStorer) GetTenantRunningApp 

func (m *MockStorer) GetTenantRunningApp(tenantID string) []*v1.AppService

GetTenantRunningApp mocks base method

func (*MockStorer) InitOneThirdPartService 

func (m *MockStorer) InitOneThirdPartService(service *model.TenantServices) error

InitOneThirdPartService mocks base method

func (*MockStorer) OnDeletes 

func (m *MockStorer) OnDeletes(obj ...interface{})

OnDeletes mocks base method

func (*MockStorer) Ready 

func (m *MockStorer) Ready() bool

Ready mocks base method

func (*MockStorer) RegistAppService 

func (m *MockStorer) RegistAppService(arg0 *v1.AppService)

RegistAppService mocks base method

func (*MockStorer) RegistPodUpdateListener 

func (m *MockStorer) RegistPodUpdateListener(arg0 string, arg1 chan<- *v10.Pod)

RegistPodUpdateListener mocks base method

func (*MockStorer) RegisterVolumeTypeListener 

func (m *MockStorer) RegisterVolumeTypeListener(arg0 string, arg1 chan<- *model.TenantServiceVolumeType)

RegisterVolumeTypeListener mocks base method

func (*MockStorer) Start 

func (m *MockStorer) Start() error

Start mocks base method

func (*MockStorer) UnRegistPodUpdateListener 

func (m *MockStorer) UnRegistPodUpdateListener(arg0 string)

UnRegistPodUpdateListener mocks base method

func (*MockStorer) UnRegisterVolumeTypeListener 

func (m *MockStorer) UnRegisterVolumeTypeListener(arg0 string)

UnRegisterVolumeTypeListener mocks base method

func (*MockStorer) UpdateGetAppService 

func (m *MockStorer) UpdateGetAppService(serviceID string) *v1.AppService

UpdateGetAppService mocks base method

type MockStorerMockRecorder 

type MockStorerMockRecorder struct {
	// contains filtered or unexported fields
}

MockStorerMockRecorder is the mock recorder for MockStorer

func (*MockStorerMockRecorder) GetAllAppServices 

func (mr *MockStorerMockRecorder) GetAllAppServices() *gomock.Call

GetAllAppServices indicates an expected call of GetAllAppServices

func (*MockStorerMockRecorder) GetAppService 

func (mr *MockStorerMockRecorder) GetAppService(serviceID interface{}) *gomock.Call

GetAppService indicates an expected call of GetAppService

func (*MockStorerMockRecorder) GetAppServiceStatus 

func (mr *MockStorerMockRecorder) GetAppServiceStatus(serviceID interface{}) *gomock.Call

GetAppServiceStatus indicates an expected call of GetAppServiceStatus

func (*MockStorerMockRecorder) GetAppServicesStatus 

func (mr *MockStorerMockRecorder) GetAppServicesStatus(serviceIDs interface{}) *gomock.Call

GetAppServicesStatus indicates an expected call of GetAppServicesStatus

func (*MockStorerMockRecorder) GetNeedBillingStatus 

func (mr *MockStorerMockRecorder) GetNeedBillingStatus(serviceIDs interface{}) *gomock.Call

GetNeedBillingStatus indicates an expected call of GetNeedBillingStatus

func (*MockStorerMockRecorder) GetPodLister 

func (mr *MockStorerMockRecorder) GetPodLister() *gomock.Call

GetPodLister indicates an expected call of GetPodLister

func (*MockStorerMockRecorder) GetTenantResource 

func (mr *MockStorerMockRecorder) GetTenantResource(tenantID interface{}) *gomock.Call

GetTenantResource indicates an expected call of GetTenantResource

func (*MockStorerMockRecorder) GetTenantRunningApp 

func (mr *MockStorerMockRecorder) GetTenantRunningApp(tenantID interface{}) *gomock.Call

GetTenantRunningApp indicates an expected call of GetTenantRunningApp

func (*MockStorerMockRecorder) InitOneThirdPartService 

func (mr *MockStorerMockRecorder) InitOneThirdPartService(service interface{}) *gomock.Call

InitOneThirdPartService indicates an expected call of InitOneThirdPartService

func (*MockStorerMockRecorder) OnDeletes 

func (mr *MockStorerMockRecorder) OnDeletes(obj ...interface{}) *gomock.Call

OnDeletes indicates an expected call of OnDeletes

func (*MockStorerMockRecorder) Ready 

func (mr *MockStorerMockRecorder) Ready() *gomock.Call

Ready indicates an expected call of Ready

func (*MockStorerMockRecorder) RegistAppService 

func (mr *MockStorerMockRecorder) RegistAppService(arg0 interface{}) *gomock.Call

RegistAppService indicates an expected call of RegistAppService

func (*MockStorerMockRecorder) RegistPodUpdateListener 

func (mr *MockStorerMockRecorder) RegistPodUpdateListener(arg0, arg1 interface{}) *gomock.Call

RegistPodUpdateListener indicates an expected call of RegistPodUpdateListener

func (*MockStorerMockRecorder) RegisterVolumeTypeListener 

func (mr *MockStorerMockRecorder) RegisterVolumeTypeListener(arg0, arg1 interface{}) *gomock.Call

RegisterVolumeTypeListener indicates an expected call of RegisterVolumeTypeListener

func (*MockStorerMockRecorder) Start 

func (mr *MockStorerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockStorerMockRecorder) UnRegistPodUpdateListener 

func (mr *MockStorerMockRecorder) UnRegistPodUpdateListener(arg0 interface{}) *gomock.Call

UnRegistPodUpdateListener indicates an expected call of UnRegistPodUpdateListener

func (*MockStorerMockRecorder) UnRegisterVolumeTypeListener 

func (mr *MockStorerMockRecorder) UnRegisterVolumeTypeListener(arg0 interface{}) *gomock.Call

UnRegisterVolumeTypeListener indicates an expected call of UnRegisterVolumeTypeListener

func (*MockStorerMockRecorder) UpdateGetAppService 

func (mr *MockStorerMockRecorder) UpdateGetAppService(serviceID interface{}) *gomock.Call

UpdateGetAppService indicates an expected call of UpdateGetAppService

type NamespaceResource 

type NamespaceResource map[string]*v1.PodResource

NamespaceResource namespace resource

func (*NamespaceResource) RemovePod 

func (r *NamespaceResource) RemovePod(podName string)

RemovePod remove pod resource

func (*NamespaceResource) SetPodResource 

func (r *NamespaceResource) SetPodResource(podName string, pr *v1.PodResource)

SetPodResource set pod resource

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 ResourceCache 

type ResourceCache struct {
	// contains filtered or unexported fields
}

ResourceCache resource cache

func NewResourceCache 

func NewResourceCache() *ResourceCache

NewResourceCache new resource cache

func (*ResourceCache) GetAllTenantResource 

func (r *ResourceCache) GetAllTenantResource() (trs []TenantResource)

GetAllTenantResource get all tenant resources

func (*ResourceCache) GetTenantResource 

func (r *ResourceCache) GetTenantResource(namespace string) (tr TenantResource)

GetTenantResource get tenant resource

func (*ResourceCache) RemovePod 

func (r *ResourceCache) RemovePod(pod *corev1.Pod)

RemovePod remove pod resource

func (*ResourceCache) SetPodResource 

func (r *ResourceCache) SetPodResource(pod *corev1.Pod)

SetPodResource set pod resource

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) TenantResource
	GetTenantResourceList() []TenantResource
	GetTenantRunningApp(tenantID string) []*v1.AppService
	GetNeedBillingStatus(serviceIDs []string) map[string]string
	OnDeletes(obj ...interface{})
	GetPodLister() listcorev1.PodLister
	RegistPodUpdateListener(string, chan<- *corev1.Pod)
	UnRegistPodUpdateListener(string)
	RegisterVolumeTypeListener(string, chan<- *model.TenantServiceVolumeType)
	UnRegisterVolumeTypeListener(string)
	InitOneThirdPartService(service *model.TenantServices) error
}

Storer app runtime store interface

func NewStore 

func NewStore(clientset kubernetes.Interface,
	dbmanager db.Manager,
	conf option.Config,
	startCh *channels.RingChannel,
	probeCh *channels.RingChannel) Storer

NewStore new app runtime store

type TenantResource 

type TenantResource struct {
	Namespace     string
	MemoryRequest int64
	MemoryLimit   int64
	CPURequest    int64
	CPULimit      int64
}

TenantResource tenant resource

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.