client

Documentation

Index

• Constants
• type HostState
  • func NewHostState(log logr.Logger, host *common.HostPortPB, dialer dial.Dialer) (*HostState, error)
  • func (h *HostState) Close() error
• type YBClient
  • func (c *YBClient) Close()
  • func (c *YBClient) Connect() error
  • func (c *YBClient) GetDialer() (dial.Dialer, error)
  • func (c *YBClient) OverrideDialer(dialer dial.Dialer)

Constants

const DefaultMasterPort = 7100

const DefaultTserverPort = 9100

Types

type HostState

type HostState struct {
	Status                   *server.ServerStatusPB
	GenericService           server.GenericService
	MasterService            master.MasterService
	TabletServerService      tserver.TabletServerService
	TabletServerAdminService tserver.TabletServerAdminService
	ConsensusService         consensus.ConsensusService
	CDCService               cdc.CDCService
	// contains filtered or unexported fields
}

func NewHostState

func NewHostState(log logr.Logger, host *common.HostPortPB, dialer dial.Dialer) (*HostState, error)

func (*HostState) Close

func (h *HostState) Close() error

type YBClient

type YBClient struct {
	Log logr.Logger
	Fs  vfs.Filesystem

	Config *config.UniverseConfigPB

	Master *HostState

	TServersUUIDMap map[uuid.UUID]*HostState
	TServersHostMap map[string]*HostState
	// contains filtered or unexported fields
}

func (*YBClient) Close

func (c *YBClient) Close()

TODO: Log errors

func (*YBClient) Connect

func (c *YBClient) Connect() error

func (*YBClient) GetDialer

func (c *YBClient) GetDialer() (dial.Dialer, error)

func (*YBClient) OverrideDialer

func (c *YBClient) OverrideDialer(dialer dial.Dialer)