mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-08 01:58:34 +08:00
parent
6d43ac4a6e
commit
bad79d9179
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcdatacoordclient "github.com/milvus-io/milvus/internal/distributed/datacoord"
|
grpcdatacoordclient "github.com/milvus-io/milvus/internal/distributed/datacoord"
|
||||||
@ -49,6 +50,7 @@ func (s *DataCoord) Run() error {
|
|||||||
if err := s.svr.Run(); err != nil {
|
if err := s.svr.Run(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Debug("DataCoord successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcindexcoord "github.com/milvus-io/milvus/internal/distributed/indexcoord"
|
grpcindexcoord "github.com/milvus-io/milvus/internal/distributed/indexcoord"
|
||||||
@ -47,6 +48,7 @@ func (s *IndexCoord) Run() error {
|
|||||||
if err := s.svr.Run(); err != nil {
|
if err := s.svr.Run(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Debug("IndexCoord successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcindexnode "github.com/milvus-io/milvus/internal/distributed/indexnode"
|
grpcindexnode "github.com/milvus-io/milvus/internal/distributed/indexnode"
|
||||||
@ -47,6 +48,7 @@ func (n *IndexNode) Run() error {
|
|||||||
if err := n.svr.Run(); err != nil {
|
if err := n.svr.Run(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Debug("IndexNode successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcproxy "github.com/milvus-io/milvus/internal/distributed/proxy"
|
grpcproxy "github.com/milvus-io/milvus/internal/distributed/proxy"
|
||||||
@ -48,6 +49,7 @@ func (n *Proxy) Run() error {
|
|||||||
if err := n.svr.Run(); err != nil {
|
if err := n.svr.Run(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Debug("Proxy successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcquerycoord "github.com/milvus-io/milvus/internal/distributed/querycoord"
|
grpcquerycoord "github.com/milvus-io/milvus/internal/distributed/querycoord"
|
||||||
@ -49,6 +50,7 @@ func (qs *QueryCoord) Run() error {
|
|||||||
if err := qs.svr.Run(); err != nil {
|
if err := qs.svr.Run(); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
log.Debug("QueryCoord successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -19,6 +19,7 @@ package components
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
grpcquerynode "github.com/milvus-io/milvus/internal/distributed/querynode"
|
grpcquerynode "github.com/milvus-io/milvus/internal/distributed/querynode"
|
||||||
@ -50,6 +51,7 @@ func (q *QueryNode) Run() error {
|
|||||||
if err := q.svr.Run(); err != nil {
|
if err := q.svr.Run(); err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
log.Debug("QueryNode successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -20,6 +20,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
|
"github.com/milvus-io/milvus/internal/log"
|
||||||
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
"github.com/milvus-io/milvus/internal/proto/internalpb"
|
||||||
|
|
||||||
rc "github.com/milvus-io/milvus/internal/distributed/rootcoord"
|
rc "github.com/milvus-io/milvus/internal/distributed/rootcoord"
|
||||||
@ -53,6 +54,7 @@ func (rc *RootCoord) Run() error {
|
|||||||
if err := rc.svr.Run(); err != nil {
|
if err := rc.svr.Run(); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
log.Debug("RootCoord successfully started")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user