Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataCoord ¶
type DataCoord struct {
// contains filtered or unexported fields
}
DataCoord implements grpc server of DataCoord server
func NewDataCoord ¶
NewDataCoord creates a new DataCoord
type DataNode ¶
type DataNode struct {
// contains filtered or unexported fields
}
DataNode implements DataNode grpc server
func NewDataNode ¶
NewDataNode creates a new DataNode
type IndexCoord ¶
type IndexCoord struct{}
IndexCoord implements IndexCoord grpc server
func NewIndexCoord ¶
func NewIndexCoord(ctx context.Context, factory dependency.Factory) (*IndexCoord, error)
NewIndexCoord creates a new IndexCoord
func (*IndexCoord) GetName ¶
func (s *IndexCoord) GetName() string
func (*IndexCoord) Health ¶
func (s *IndexCoord) Health(ctx context.Context) commonpb.StateCode
GetComponentStates returns indexnode's states
func (*IndexCoord) Prepare ¶
func (s *IndexCoord) Prepare() error
type IndexNode ¶
type IndexNode struct {
// contains filtered or unexported fields
}
IndexNode implements IndexNode grpc server
func NewIndexNode ¶
NewIndexNode creates a new IndexNode
type Proxy ¶
type Proxy struct {
// contains filtered or unexported fields
}
Proxy implements Proxy grpc server
type QueryCoord ¶
type QueryCoord struct {
// contains filtered or unexported fields
}
QueryCoord implements QueryCoord grpc server
func NewQueryCoord ¶
func NewQueryCoord(ctx context.Context, factory dependency.Factory) (*QueryCoord, error)
NewQueryCoord creates a new QueryCoord
func (*QueryCoord) GetName ¶
func (qs *QueryCoord) GetName() string
func (*QueryCoord) Health ¶
func (qs *QueryCoord) Health(ctx context.Context) commonpb.StateCode
GetComponentStates returns QueryCoord's states
func (*QueryCoord) Prepare ¶
func (qs *QueryCoord) Prepare() error
type QueryNode ¶
type QueryNode struct {
// contains filtered or unexported fields
}
QueryNode implements QueryNode grpc server
func NewQueryNode ¶
NewQueryNode creates a new QueryNode
type RootCoord ¶
type RootCoord struct {
// contains filtered or unexported fields
}
RootCoord implements RoodCoord grpc server
func NewRootCoord ¶
NewRootCoord creates a new RoorCoord
type StreamingNode ¶
type StreamingNode struct {
*streamingnode.Server
}
func NewStreamingNode ¶
func NewStreamingNode(_ context.Context, factory dependency.Factory) (*StreamingNode, error)
NewStreamingNode creates a new StreamingNode
func (*StreamingNode) GetName ¶
func (q *StreamingNode) GetName() string
Source Files