domain

Documentation

Index

• func CreatePDClient(cfg *config.Config) (*pdclient.APIClient, error)
• type ClientMaintainer
  • func NewClientMaintainer() *ClientMaintainer
  • func (cm *ClientMaintainer) Close()
  • func (cm *ClientMaintainer) GetEtcdClient(ctx context.Context) (*clientv3.Client, error)
  • func (cm *ClientMaintainer) GetPDClient(ctx context.Context) (*pdclient.APIClient, error)
  • func (cm *ClientMaintainer) Init(pdCfg config.PD, pdCli *pdclient.APIClient, etcdCli *clientv3.Client)
  • func (cm *ClientMaintainer) IsInitialized() bool
  • func (cm *ClientMaintainer) NeedRecreateClient(pdCfg config.PD) bool
• type Domain
  • func NewDomain() *Domain
  • func NewDomainForTest(pdCli *pdclient.APIClient, etcdCli *clientv3.Client) *Domain
  • func (do *Domain) Close()
  • func (do *Domain) GetEtcdClient() (*clientv3.Client, error)
  • func (do *Domain) GetPDClient() (*pdclient.APIClient, error)

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.