distributed

Documentation

Index

• type ConnectionManager
  • func NewConnectionManager(session *sessionutil.Session) *ConnectionManager
  • func (cm *ConnectionManager) AddDependency(roleName string) error
  • func (cm *ConnectionManager) GetDataCoordClient() (datapb.DataCoordClient, bool)
  • func (cm *ConnectionManager) GetDataNodeClients() (map[int64]datapb.DataNodeClient, bool)
  • func (cm *ConnectionManager) GetIndexNodeClients() (map[int64]workerpb.IndexNodeClient, bool)
  • func (cm *ConnectionManager) GetQueryCoordClient() (querypb.QueryCoordClient, bool)
  • func (cm *ConnectionManager) GetQueryNodeClients() (map[int64]querypb.QueryNodeClient, bool)
  • func (cm *ConnectionManager) GetRootCoordClient() (rootcoordpb.RootCoordClient, bool)
  • func (cm *ConnectionManager) Start()
  • func (cm *ConnectionManager) Stop()

Types

type ConnectionManager

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

ConnectionManager handles connection to other components of the system

func NewConnectionManager

func NewConnectionManager(session *sessionutil.Session) *ConnectionManager

NewConnectionManager creates a new connection manager.

func (*ConnectionManager) AddDependency

func (cm *ConnectionManager) AddDependency(roleName string) error

AddDependency add a dependency by role name.

func (*ConnectionManager) GetDataCoordClient

func (cm *ConnectionManager) GetDataCoordClient() (datapb.DataCoordClient, bool)

func (*ConnectionManager) GetDataNodeClients

func (cm *ConnectionManager) GetDataNodeClients() (map[int64]datapb.DataNodeClient, bool)

func (*ConnectionManager) GetIndexNodeClients

func (cm *ConnectionManager) GetIndexNodeClients() (map[int64]workerpb.IndexNodeClient, bool)

func (*ConnectionManager) GetQueryCoordClient

func (cm *ConnectionManager) GetQueryCoordClient() (querypb.QueryCoordClient, bool)

func (*ConnectionManager) GetQueryNodeClients

func (cm *ConnectionManager) GetQueryNodeClients() (map[int64]querypb.QueryNodeClient, bool)

func (*ConnectionManager) GetRootCoordClient

func (cm *ConnectionManager) GetRootCoordClient() (rootcoordpb.RootCoordClient, bool)

func (*ConnectionManager) Start

func (cm *ConnectionManager) Start()

func (*ConnectionManager) Stop

func (cm *ConnectionManager) Stop()