mppcoordmanager

Documentation

Index

• Variables
• type CoordinatorUniqueID
• type MPPCoordinatorManager
  • func (m *MPPCoordinatorManager) GetServerAddr() (serverOn bool, serverAddr string)
  • func (m *MPPCoordinatorManager) InitServerAddr(serverOn bool, serverAddr string)
  • func (m *MPPCoordinatorManager) Register(coordID CoordinatorUniqueID, mppCoord kv.MppCoordinator) error
  • func (m *MPPCoordinatorManager) ReportStatus(request *mpp.ReportTaskStatusRequest) *mpp.ReportTaskStatusResponse
  • func (m *MPPCoordinatorManager) Run()
  • func (m *MPPCoordinatorManager) Stop()
  • func (m *MPPCoordinatorManager) Unregister(coordID CoordinatorUniqueID)

Variables

var InstanceMPPCoordinatorManager = newMPPCoordinatorManger()

InstanceMPPCoordinatorManager is a local instance mpp coordinator manager

Types

type CoordinatorUniqueID

type CoordinatorUniqueID struct {
	MPPQueryID kv.MPPQueryID
	GatherID   uint64
}

CoordinatorUniqueID identifies a unique coordinator

type MPPCoordinatorManager

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

MPPCoordinatorManager manages all mpp coordinator instances

func (*MPPCoordinatorManager) GetServerAddr

func (m *MPPCoordinatorManager) GetServerAddr() (serverOn bool, serverAddr string)

GetServerAddr returns grpcServer address, empty serverAddr if server not on

func (*MPPCoordinatorManager) InitServerAddr

func (m *MPPCoordinatorManager) InitServerAddr(serverOn bool, serverAddr string)

InitServerAddr init grpcServer address

func (*MPPCoordinatorManager) Register

func (m *MPPCoordinatorManager) Register(coordID CoordinatorUniqueID, mppCoord kv.MppCoordinator) error

Register is to register mpp coordinator

func (*MPPCoordinatorManager) ReportStatus

func (m *MPPCoordinatorManager) ReportStatus(request *mpp.ReportTaskStatusRequest) *mpp.ReportTaskStatusResponse

ReportStatus reports mpp task execution status to specific coordinator

func (*MPPCoordinatorManager) Run

func (m *MPPCoordinatorManager) Run()

Run use a loop to detect and remove out of time Coordinators

func (*MPPCoordinatorManager) Stop

func (m *MPPCoordinatorManager) Stop()

Stop stops background goroutine

func (*MPPCoordinatorManager) Unregister

func (m *MPPCoordinatorManager) Unregister(coordID CoordinatorUniqueID)

Unregister is to unregister mpp coordinator