store

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

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

 Go to latest Published: Oct 22, 2019 License: LGPL-3.0 Imports: 30 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 {
	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

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 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) OnDelete 

func (m *MockStorer) OnDelete(obj interface{})

OnDelete 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) 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) 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) OnDelete 

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

OnDelete indicates an expected call of OnDelete

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) 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) UpdateGetAppService 

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

UpdateGetAppService indicates an expected call of UpdateGetAppService

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
	RegistPodUpdateListener(string, chan<- *corev1.Pod)
	UnRegistPodUpdateListener(string)
	InitOneThirdPartService(service *model.TenantServices) error
}

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

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.