Documentation
¶
Overview ¶
Package pd is a generated GoMock package.
Index ¶
- Variables
- func CacheKeys(pdg *v1alpha1.PDGroup) ([]string, error)
- func NewMemberLister(cluster string, c pdapi.PDClient) timanager.Lister[pdv1.Member, *pdv1.Member, *pdv1.MemberList]
- func NewMemberPoller(name string, logger logr.Logger, c pdapi.PDClient) timanager.Poller
- func NewStoreLister(cluster string, c pdapi.PDClient) timanager.Lister[pdv1.Store, *pdv1.Store, *pdv1.StoreList]
- func NewStorePoller(name string, logger logr.Logger, c pdapi.PDClient) timanager.Poller
- func NewTSOMemberLister(cluster string, c pdapi.PDClient) timanager.Lister[pdv1.TSOMember, *pdv1.TSOMember, *pdv1.TSOMemberList]
- func NewTSOMemberPoller(name string, logger logr.Logger, c pdapi.PDClient) timanager.Poller
- type MemberCache
- type MockMemberCache
- type MockMemberCacheMockRecorder
- type MockPDClient
- type MockPDClientMockRecorder
- type MockStoreCache
- type MockStoreCacheMockRecorder
- type PDClient
- type PDClientManager
- type StoreCache
- type TSOMemberCache
Constants ¶
This section is empty.
Variables ¶
var NewUnderlayClientFunc = func(c client.Client) timanager.NewUnderlayClientFunc[*v1alpha1.PDGroup, pdapi.PDClient] { return func(pdg *v1alpha1.PDGroup) (pdapi.PDClient, error) { ctx := context.Background() var cluster v1alpha1.Cluster if err := c.Get(ctx, client.ObjectKey{ Name: pdg.Spec.Cluster.Name, Namespace: pdg.Namespace, }, &cluster); err != nil { return nil, fmt.Errorf("cannot find cluster %s: %w", pdg.Spec.Cluster.Name, err) } host := fmt.Sprintf("%s-pd.%s:%d", pdg.Name, pdg.Namespace, coreutil.PDGroupClientPort(pdg)) if coreutil.IsTLSClusterEnabled(&cluster) { tlsConfig, err := apicall.GetClientTLSConfig[scope.PDGroup](ctx, c, pdg) if err != nil { return nil, fmt.Errorf("cannot get tls config from secret: %w", err) } addr := "https://" + host return pdapi.NewPDClient(addr, pdRequestTimeout, tlsConfig), nil } addr := "http://" + host pc := pdapi.NewPDClient(addr, pdRequestTimeout, nil) return pc, nil } }
Functions ¶
func CacheKeys ¶
CacheKeys returns the keys of the PDGroup. If any keys are changed, client will be renewed The first key is primary key to get client from manager
func NewMemberLister ¶
func NewMemberPoller ¶
func NewStoreLister ¶
func NewStorePoller ¶
func NewTSOMemberLister ¶
Types ¶
type MemberCache ¶
func NewMemberCache ¶
func NewMemberCache(cluster string, informerFactory timanager.SharedInformerFactory[pdapi.PDClient]) MemberCache
type MockMemberCache ¶
type MockMemberCache[T any, PT timanager.Object[T]] struct { // contains filtered or unexported fields }
MockMemberCache is a mock of MemberCache interface.
func NewMockMemberCache ¶
func NewMockMemberCache[T any, PT timanager.Object[T]](ctrl *gomock.Controller) *MockMemberCache[T, PT]
NewMockMemberCache creates a new mock instance.
func (*MockMemberCache[T, PT]) EXPECT ¶
func (m *MockMemberCache[T, PT]) EXPECT() *MockMemberCacheMockRecorder[T, PT]
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMemberCache[T, PT]) Get ¶
func (m *MockMemberCache[T, PT]) Get(name string) (*v1.Member, error)
Get mocks base method.
func (*MockMemberCache[T, PT]) Refresh ¶
func (m *MockMemberCache[T, PT]) Refresh()
Refresh mocks base method.
type MockMemberCacheMockRecorder ¶
type MockMemberCacheMockRecorder[T any, PT timanager.Object[T]] struct { // contains filtered or unexported fields }
MockMemberCacheMockRecorder is the mock recorder for MockMemberCache.
func (*MockMemberCacheMockRecorder[T, PT]) Get ¶
func (mr *MockMemberCacheMockRecorder[T, PT]) Get(name any) *gomock.Call
Get indicates an expected call of Get.
func (*MockMemberCacheMockRecorder[T, PT]) List ¶
func (mr *MockMemberCacheMockRecorder[T, PT]) List(selector any) *gomock.Call
List indicates an expected call of List.
func (*MockMemberCacheMockRecorder[T, PT]) Refresh ¶
func (mr *MockMemberCacheMockRecorder[T, PT]) Refresh() *gomock.Call
Refresh indicates an expected call of Refresh.
type MockPDClient ¶
type MockPDClient struct {
// contains filtered or unexported fields
}
MockPDClient is a mock of PDClient interface.
func NewMockPDClient ¶
func NewMockPDClient(ctrl *gomock.Controller) *MockPDClient
NewMockPDClient creates a new mock instance.
func (*MockPDClient) EXPECT ¶
func (m *MockPDClient) EXPECT() *MockPDClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPDClient) HasSynced ¶
func (m *MockPDClient) HasSynced() bool
HasSynced mocks base method.
func (*MockPDClient) Members ¶
func (m *MockPDClient) Members() MemberCache
Members mocks base method.
func (*MockPDClient) TSOMembers ¶
func (m *MockPDClient) TSOMembers() TSOMemberCache
TSOMembers mocks base method.
func (*MockPDClient) Underlay ¶
func (m *MockPDClient) Underlay() pdapi.PDClient
Underlay mocks base method.
type MockPDClientMockRecorder ¶
type MockPDClientMockRecorder struct {
// contains filtered or unexported fields
}
MockPDClientMockRecorder is the mock recorder for MockPDClient.
func (*MockPDClientMockRecorder) HasSynced ¶
func (mr *MockPDClientMockRecorder) HasSynced() *gomock.Call
HasSynced indicates an expected call of HasSynced.
func (*MockPDClientMockRecorder) Members ¶
func (mr *MockPDClientMockRecorder) Members() *gomock.Call
Members indicates an expected call of Members.
func (*MockPDClientMockRecorder) Stores ¶
func (mr *MockPDClientMockRecorder) Stores() *gomock.Call
Stores indicates an expected call of Stores.
func (*MockPDClientMockRecorder) TSOMembers ¶
func (mr *MockPDClientMockRecorder) TSOMembers() *gomock.Call
TSOMembers indicates an expected call of TSOMembers.
func (*MockPDClientMockRecorder) Underlay ¶
func (mr *MockPDClientMockRecorder) Underlay() *gomock.Call
Underlay indicates an expected call of Underlay.
type MockStoreCache ¶
type MockStoreCache[T any, PT timanager.Object[T]] struct { // contains filtered or unexported fields }
MockStoreCache is a mock of StoreCache interface.
func NewMockStoreCache ¶
func NewMockStoreCache[T any, PT timanager.Object[T]](ctrl *gomock.Controller) *MockStoreCache[T, PT]
NewMockStoreCache creates a new mock instance.
func (*MockStoreCache[T, PT]) EXPECT ¶
func (m *MockStoreCache[T, PT]) EXPECT() *MockStoreCacheMockRecorder[T, PT]
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStoreCache[T, PT]) Get ¶
func (m *MockStoreCache[T, PT]) Get(name string) (*v1.Store, error)
Get mocks base method.
func (*MockStoreCache[T, PT]) Refresh ¶
func (m *MockStoreCache[T, PT]) Refresh()
Refresh mocks base method.
type MockStoreCacheMockRecorder ¶
type MockStoreCacheMockRecorder[T any, PT timanager.Object[T]] struct { // contains filtered or unexported fields }
MockStoreCacheMockRecorder is the mock recorder for MockStoreCache.
func (*MockStoreCacheMockRecorder[T, PT]) Get ¶
func (mr *MockStoreCacheMockRecorder[T, PT]) Get(name any) *gomock.Call
Get indicates an expected call of Get.
func (*MockStoreCacheMockRecorder[T, PT]) List ¶
func (mr *MockStoreCacheMockRecorder[T, PT]) List(selector any) *gomock.Call
List indicates an expected call of List.
func (*MockStoreCacheMockRecorder[T, PT]) Refresh ¶
func (mr *MockStoreCacheMockRecorder[T, PT]) Refresh() *gomock.Call
Refresh indicates an expected call of Refresh.
type PDClient ¶
type PDClient interface {
HasSynced() bool
Stores() StoreCache
Members() MemberCache
TSOMembers() TSOMemberCache
// TODO: only returns write interface
Underlay() pdapi.PDClient
}
type PDClientManager ¶
func NewPDClientManager ¶
func NewPDClientManager(logger logr.Logger, c client.Client) PDClientManager
type StoreCache ¶
func NewStoreCache ¶
func NewStoreCache(cluster string, informerFactory timanager.SharedInformerFactory[pdapi.PDClient]) StoreCache
type TSOMemberCache ¶
func NewTSOMemberCache ¶
func NewTSOMemberCache(cluster string, informerFactory timanager.SharedInformerFactory[pdapi.PDClient]) TSOMemberCache
Source Files