domain

package
v0.0.0-...-1f1d885 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreatePDClient

func CreatePDClient(cfg *config.Config) (*pdclient.APIClient, error)

Types

type ClientMaintainer

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

func NewClientMaintainer

func NewClientMaintainer() *ClientMaintainer

func (*ClientMaintainer) Close

func (cm *ClientMaintainer) Close()

func (*ClientMaintainer) GetEtcdClient

func (cm *ClientMaintainer) GetEtcdClient(ctx context.Context) (*clientv3.Client, error)

WARN: call this function will blocked until successfully created etcd client.

func (*ClientMaintainer) GetPDClient

func (cm *ClientMaintainer) GetPDClient(ctx context.Context) (*pdclient.APIClient, error)

WARN: call this function will blocked until successfully created PD client.

func (*ClientMaintainer) Init

func (cm *ClientMaintainer) Init(pdCfg config.PD, pdCli *pdclient.APIClient, etcdCli *clientv3.Client)

func (*ClientMaintainer) IsInitialized

func (cm *ClientMaintainer) IsInitialized() bool

func (*ClientMaintainer) NeedRecreateClient

func (cm *ClientMaintainer) NeedRecreateClient(pdCfg config.PD) bool

type Domain

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

func NewDomain

func NewDomain() *Domain

func NewDomainForTest

func NewDomainForTest(pdCli *pdclient.APIClient, etcdCli *clientv3.Client) *Domain

func (*Domain) Close

func (do *Domain) Close()

func (*Domain) GetEtcdClient

func (do *Domain) GetEtcdClient() (*clientv3.Client, error)

WARN: call this function will blocked until successfully created etcd client.

func (*Domain) GetPDClient

func (do *Domain) GetPDClient() (*pdclient.APIClient, error)

WARN: call this function will blocked until successfully created PD client.

Jump to

Keyboard shortcuts

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