controller

package

Go to main page

Versions in this module

v1

v1.0.0-alpha

Nov 8, 2018

v0

v0.4.0

Nov 8, 2018

v0.3.1

Oct 31, 2018

v0.3.0

Oct 12, 2018

Changes in this version

+ const NotDDLOwnerError

type ActionType

+ const GetEvictLeaderSchedulersActionType

+ const GetPDLeaderActionType

+ const TransferPDLeaderActionType

type FakePDClient

+ func (pc *FakePDClient) GetEvictLeaderSchedulers() ([]string, error)

+ func (pc *FakePDClient) GetPDLeader() (*pdpb.Member, error)

+ func (pc *FakePDClient) TransferPDLeader(memberName string) error

type FakeTiDBControl

+ func (ftd *FakeTiDBControl) NotDDLOwner(notDDLOwner bool)

+ func (ftd *FakeTiDBControl) ResignDDLOwner(tc *v1alpha1.TidbCluster, ordinal int32) (bool, error)

+ func (ftd *FakeTiDBControl) SetResignDDLOwnerError(err error)

type PDClient

+ GetEvictLeaderSchedulers func() ([]string, error)

+ GetPDLeader func() (*pdpb.Member, error)

+ TransferPDLeader func(name string) error

type TiDBControlInterface

+ ResignDDLOwner func(tc *v1alpha1.TidbCluster, ordinal int32) (bool, error)

v0.2.1

Sep 20, 2018

Changes in this version

+ func IsRequeueError(err error) bool

+ func RequeueErrorf(format string, a ...interface{}) error

+ type RequeueError struct

+ func (re *RequeueError) Error() string

v0.2.0

Sep 11, 2018

Changes in this version

+ var TestClusterID string = "222"

+ var TestComponentName string = "tikv"

+ var TestManagedByName string = "tidb-operator"

+ var TestMemberID string = "111"

+ var TestName string = "tidb-cluster"

+ var TestStoreID string = "000"

+ func TiDBPeerMemberName(clusterName string) string

type FakePodControl

+ func (fpc *FakePodControl) DeletePod(_ *v1alpha1.TidbCluster, pod *corev1.Pod) error

+ func (fpc *FakePodControl) SetDeletePodError(err error, after int)

+ func (fpc *FakePodControl) UpdatePod(_ *v1alpha1.TidbCluster, pod *corev1.Pod) error

+ type FakeTiDBControl struct

+ func NewFakeTiDBControl() *FakeTiDBControl

+ func (ftd *FakeTiDBControl) GetHealth(tc *v1alpha1.TidbCluster) map[string]bool

+ func (ftd *FakeTiDBControl) SetHealth(healthInfo map[string]bool)

+ type FakeTidbClusterControl struct

+ TcIndexer cache.Indexer

+ TcLister listers.TidbClusterLister

+ func NewFakeTidbClusterControl(tcInformer tcinformers.TidbClusterInformer) *FakeTidbClusterControl

+ func (ssc *FakeTidbClusterControl) SetUpdateTidbClusterError(err error, after int)

+ func (ssc *FakeTidbClusterControl) UpdateTidbCluster(tc *v1alpha1.TidbCluster) (*v1alpha1.TidbCluster, error)

type PodControlInterface

+ DeletePod func(*v1alpha1.TidbCluster, *corev1.Pod) error

+ UpdatePod func(*v1alpha1.TidbCluster, *corev1.Pod) error

+ type TiDBControlInterface interface

+ GetHealth func(tc *v1alpha1.TidbCluster) map[string]bool

+ func NewDefaultTiDBControl() TiDBControlInterface

+ type TidbClusterControlInterface interface

+ UpdateTidbCluster func(*v1alpha1.TidbCluster) (*v1alpha1.TidbCluster, error)

+ func NewRealTidbClusterControl(cli versioned.Interface, tcLister listers.TidbClusterLister, ...) TidbClusterControlInterface

v0.1.0

Aug 22, 2018

Changes in this version

+ var ClusterScoped bool

+ var DefaultStorageClassName string

+ var ExternalTrafficPolicy string

+ var TestAppName string = "tikv"

+ var TestClusterId string = "222"

+ var TestClusterName string = "test"

+ var TestMemberId string = "111"

+ var TestOwnerName string = "tidbCluster"

+ var TestPodName string = "pod-1"

+ var TestStoreId string = "000"

+ func AnnProm() map[string]string

+ func DefaultPushGatewayRequest() corev1.ResourceRequirements

+ func DeferClose(c io.Closer, err *error)

+ func GetOwnerRef(tc *v1alpha1.TidbCluster) metav1.OwnerReference

+ func GetPushgatewayImage(cluster *v1alpha1.TidbCluster) string

+ func GetServiceType(services []v1alpha1.Service, serviceName string) corev1.ServiceType

+ func MonitorMemberName(clusterName string) string

+ func PDMemberName(clusterName string) string

+ func PDPeerMemberName(clusterName string) string

+ func PriTiDBMemberName(clusterName string) string

+ func TiDBMemberName(clusterName string) string

+ func TiKVCapacity(limits *v1alpha1.ResourceRequirement) string

+ func TiKVMemberName(clusterName string) string

+ func TiKVPeerMemberName(clusterName string) string

+ type Action struct

+ ID uint64

+ Labels map[string]string

+ Name string

+ type ActionType string

+ const BeginEvictLeaderActionType

+ const DeleteMemberActionType

+ const DeleteMemberByIDActionType

+ const DeleteStoreActionType

+ const EndEvictLeaderActionType

+ const GetClusterActionType

+ const GetConfigActionType

+ const GetHealthActionType

+ const GetMembersActionType

+ const GetStoreActionType

+ const GetStoresActionType

+ const GetTombStoneStoresActionType

+ const SetStoreLabelsActionType

+ type FakePDClient struct

+ func NewFakePDClient() *FakePDClient

+ func (pc *FakePDClient) AddReaction(actionType ActionType, reaction Reaction)

+ func (pc *FakePDClient) BeginEvictLeader(storeID uint64) error

+ func (pc *FakePDClient) DeleteMember(name string) error

+ func (pc *FakePDClient) DeleteMemberByID(id uint64) error

+ func (pc *FakePDClient) DeleteStore(id uint64) error

+ func (pc *FakePDClient) EndEvictLeader(storeID uint64) error

+ func (pc *FakePDClient) GetCluster() (*metapb.Cluster, error)

+ func (pc *FakePDClient) GetConfig() (*server.Config, error)

+ func (pc *FakePDClient) GetHealth() (*HealthInfo, error)

+ func (pc *FakePDClient) GetMembers() (*MembersInfo, error)

+ func (pc *FakePDClient) GetStore(id uint64) (*StoreInfo, error)

+ func (pc *FakePDClient) GetStores() (*StoresInfo, error)

+ func (pc *FakePDClient) GetTombStoneStores() (*StoresInfo, error)

+ func (pc *FakePDClient) SetStoreLabels(storeID uint64, labels map[string]string) (bool, error)

+ type FakePDControl struct

+ func NewFakePDControl() *FakePDControl

+ func (fpc *FakePDControl) SetPDClient(tc *v1alpha1.TidbCluster, pdclient PDClient)

+ func (pdc *FakePDControl) GetPDClient(tc *v1alpha1.TidbCluster) PDClient

+ type FakePVCControl struct

+ PVCIndexer cache.Indexer

+ func NewFakePVCControl(pvcInformer coreinformers.PersistentVolumeClaimInformer) *FakePVCControl

+ func (fpc *FakePVCControl) DeletePVC(tc *v1alpha1.TidbCluster, pvc *corev1.PersistentVolumeClaim) error

+ func (fpc *FakePVCControl) SetDeletePVCError(err error, after int)

+ func (fpc *FakePVCControl) SetUpdatePVCError(err error, after int)

+ func (fpc *FakePVCControl) UpdateMetaInfo(tc *v1alpha1.TidbCluster, pvc *corev1.PersistentVolumeClaim, pod *corev1.Pod) error

+ func (fpc *FakePVCControl) UpdatePVC(tc *v1alpha1.TidbCluster, pvc *corev1.PersistentVolumeClaim) error

+ type FakePVControl struct

+ PVCLister corelisters.PersistentVolumeClaimLister

+ PVIndexer cache.Indexer

+ func NewFakePVControl(pvInformer coreinformers.PersistentVolumeInformer, ...) *FakePVControl

+ func (fpc *FakePVControl) PatchPVReclaimPolicy(tc *v1alpha1.TidbCluster, pv *corev1.PersistentVolume, ...) error

+ func (fpc *FakePVControl) SetUpdatePVError(err error, after int)

+ func (fpc *FakePVControl) UpdateMetaInfo(tc *v1alpha1.TidbCluster, pv *corev1.PersistentVolume) error

+ type FakePodControl struct

+ PodIndexer cache.Indexer

+ func NewFakePodControl(podInformer coreinformers.PodInformer) *FakePodControl

+ func (fpc *FakePodControl) SetGetClusterError(err error, after int)

+ func (fpc *FakePodControl) SetGetMemberError(err error, after int)

+ func (fpc *FakePodControl) SetGetStoreError(err error, after int)

+ func (fpc *FakePodControl) SetUpdatePodError(err error, after int)

+ func (fpc *FakePodControl) UpdateMetaInfo(tc *v1alpha1.TidbCluster, pod *corev1.Pod) error

+ type FakeServiceControl struct

+ SvcIndexer cache.Indexer

+ SvcLister corelisters.ServiceLister

+ TcIndexer cache.Indexer

+ TcLister v1listers.TidbClusterLister

+ func NewFakeServiceControl(svcInformer coreinformers.ServiceInformer, ...) *FakeServiceControl

+ func (ssc *FakeServiceControl) CreateService(tc *v1alpha1.TidbCluster, svc *corev1.Service) error

+ func (ssc *FakeServiceControl) DeleteService(tc *v1alpha1.TidbCluster, svc *corev1.Service) error

+ func (ssc *FakeServiceControl) SetCreateServiceError(err error, after int)

+ func (ssc *FakeServiceControl) SetDeleteServiceError(err error, after int)

+ func (ssc *FakeServiceControl) SetUpdateServiceError(err error, after int)

+ func (ssc *FakeServiceControl) UpdateService(tc *v1alpha1.TidbCluster, svc *corev1.Service) error

+ type FakeStatefulSetControl struct

+ SetIndexer cache.Indexer

+ SetLister appslisters.StatefulSetLister

+ TcIndexer cache.Indexer

+ TcLister v1listers.TidbClusterLister

+ func NewFakeStatefulSetControl(setInformer appsinformers.StatefulSetInformer, ...) *FakeStatefulSetControl

+ func (ssc *FakeStatefulSetControl) CreateStatefulSet(tc *v1alpha1.TidbCluster, set *apps.StatefulSet) error

+ func (ssc *FakeStatefulSetControl) DeleteStatefulSet(tc *v1alpha1.TidbCluster, set *apps.StatefulSet) error

+ func (ssc *FakeStatefulSetControl) SetCreateStatefulSetError(err error, after int)

+ func (ssc *FakeStatefulSetControl) SetDeleteStatefulSetError(err error, after int)

+ func (ssc *FakeStatefulSetControl) SetStatusChange(fn func(*apps.StatefulSet))

+ func (ssc *FakeStatefulSetControl) SetUpdateStatefulSetError(err error, after int)

+ func (ssc *FakeStatefulSetControl) UpdateStatefulSet(tc *v1alpha1.TidbCluster, set *apps.StatefulSet) error

+ type HealthInfo struct

+ Healths []MemberHealth

+ type MemberHealth struct

+ ClientUrls []string

+ Health bool

+ MemberID uint64

+ Name string

+ type MembersInfo struct

+ EtcdLeader *pdpb.Member

+ Header *pdpb.ResponseHeader

+ Leader *pdpb.Member

+ Members []*pdpb.Member

+ type MetaStore struct

+ StateName string

+ type NotFoundReaction struct

+ func (nfr *NotFoundReaction) Error() string

+ type PDClient interface

+ BeginEvictLeader func(storeID uint64) error

+ DeleteMember func(name string) error

+ DeleteMemberByID func(memberID uint64) error

+ DeleteStore func(storeID uint64) error

+ EndEvictLeader func(storeID uint64) error

+ GetCluster func() (*metapb.Cluster, error)

+ GetConfig func() (*server.Config, error)

+ GetHealth func() (*HealthInfo, error)

+ GetMembers func() (*MembersInfo, error)

+ GetStore func(storeID uint64) (*StoreInfo, error)

+ GetStores func() (*StoresInfo, error)

+ GetTombStoneStores func() (*StoresInfo, error)

+ SetStoreLabels func(storeID uint64, labels map[string]string) (bool, error)

+ func NewPDClient(url string, timeout time.Duration) PDClient

+ type PDControlInterface interface

+ GetPDClient func(tc *v1alpha1.TidbCluster) PDClient

+ func NewDefaultPDControl() PDControlInterface

+ type PVCControlInterface interface

+ DeletePVC func(*v1alpha1.TidbCluster, *corev1.PersistentVolumeClaim) error

+ UpdateMetaInfo func(*v1alpha1.TidbCluster, *corev1.PersistentVolumeClaim, *corev1.Pod) error

+ UpdatePVC func(*v1alpha1.TidbCluster, *corev1.PersistentVolumeClaim) error

+ func NewRealPVCControl(kubeCli kubernetes.Interface, recorder record.EventRecorder, ...) PVCControlInterface

+ type PVControlInterface interface

+ PatchPVReclaimPolicy func(*v1alpha1.TidbCluster, *corev1.PersistentVolume, ...) error

+ UpdateMetaInfo func(*v1alpha1.TidbCluster, *corev1.PersistentVolume) error

+ func NewRealPVControl(kubeCli kubernetes.Interface, ...) PVControlInterface

+ type PodControlInterface interface

+ UpdateMetaInfo func(*v1alpha1.TidbCluster, *corev1.Pod) error

+ func NewRealPodControl(kubeCli kubernetes.Interface, pdControl PDControlInterface, ...) PodControlInterface

+ type Reaction func(action *Action) (interface{}, error)

+ type ServiceControlInterface interface

+ CreateService func(*v1alpha1.TidbCluster, *corev1.Service) error

+ DeleteService func(*v1alpha1.TidbCluster, *corev1.Service) error

+ UpdateService func(*v1alpha1.TidbCluster, *corev1.Service) error

+ func NewRealServiceControl(kubeCli kubernetes.Interface, svcLister corelisters.ServiceLister, ...) ServiceControlInterface

+ type StatefulSetControlInterface interface

+ CreateStatefulSet func(*v1alpha1.TidbCluster, *apps.StatefulSet) error

+ DeleteStatefulSet func(*v1alpha1.TidbCluster, *apps.StatefulSet) error

+ UpdateStatefulSet func(*v1alpha1.TidbCluster, *apps.StatefulSet) error

+ func NewRealStatefuSetControl(kubeCli kubernetes.Interface, setLister appslisters.StatefulSetLister, ...) StatefulSetControlInterface

+ type StoreInfo struct

+ Status *StoreStatus

+ Store *MetaStore

+ type StoreStatus struct

+ ApplyingSnapCount uint32

+ Available typeutil.ByteSize

+ Capacity typeutil.ByteSize

+ IsBusy bool

+ LastHeartbeatTS time.Time

+ LeaderCount int

+ ReceivingSnapCount uint32

+ RegionCount int

+ SendingSnapCount uint32

+ StartTS time.Time

+ Uptime typeutil.Duration

+ type StoresInfo struct

+ Count int

+ Stores []*StoreInfo

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