milvus¸÷×é¼þµÄ½á¹¹Ìå·ÖÎö

runComponent(ctx, localMsg, wg, components.NewRootCoord, metrics.RegisterRootCoord)
runComponent(ctx, localMsg, wg, components.NewProxy, metrics.RegisterProxy)
runComponent(ctx, localMsg, wg, components.NewQueryCoord, metrics.RegisterQueryCoord)
runComponent(ctx, localMsg, wg, components.NewQueryNode, metrics.RegisterQueryNode)
runComponent(ctx, localMsg, wg, components.NewDataCoord, metrics.RegisterDataCoord)
runComponent(ctx, localMsg, wg, components.NewDataNode, metrics.RegisterDataNode)
runComponent(ctx, localMsg, wg, components.NewIndexCoord, func(registry *prometheus.Registry)
runComponent(ctx, localMsg, wg, components.NewIndexNode, metrics.RegisterIndexNode)

type RootCoord struct {
    // ´«µÝÉÏÏÂÎÄ
    ctx context.Context
    // ʵÏÖ RoodCoord grpc server
    svr *grpcrootcoord.Server
}

type Proxy struct {
    // ʵÏÖ Proxy grpc server
    svr *grpcproxy.Server
}

type QueryCoord struct {
    // ´«µÝÉÏÏÂÎÄ
    ctx context.Context
    // ʵÏÖ QueryCoord grpc server
    svr *grpcquerycoord.Server
}

type QueryNode struct {
    // ´«µÝÉÏÏÂÎÄ
    ctx context.Context
    // ʵÏÖ QueryNode grpc server
    svr *grpcquerynode.Server
}

type DataCoord struct {
    // ´«µÝÉÏÏÂÎÄ
    ctx context.Context
    // ʵÏÖ DataCoord grpc server
    svr *grpcdatacoord.Server
}

type DataNode struct {
    // ´«µÝÉÏÏÂÎÄ
    ctx context.Context
    // ʵÏÖ DataNode grpc server
    svr *grpcdatanode.Server
}

type IndexCoord struct{}

type IndexNode struct {
    // ʵÏÖ IndexNode grpc server
    svr *grpcindexnode.Server
}

ctx, cancel := context.WithCancel(context.Background())

ctx1, cancel := context.WithCancel(ctx)

internal\distributed\rootcoord\service.go
internal\distributed\proxy\service.go
internal\distributed\querycoord\service.go
internal\distributed\querynode\service.go
internal\distributed\datacoord\service.go
internal\distributed\datanode\service.go
internal\distributed\indexnode\service.go