Package store is a generated GoMock package.



    This section is empty.


    This section is empty.


    This section is empty.


    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

                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
                                                                                                                    	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)
                                                                                                                    	RegisterVolumeTypeListener(string, chan<- *model.TenantServiceVolumeType)
                                                                                                                    	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