Skip to content

M
milvus

milvus / milvus
11 个月 前同步成功

通知 261
Star 22476
Fork 2472
M
milvus

体验新版 GitCode，发现更多精彩内容 >>

未验证 提交 b84e4df1 编写于 作者: R ryjiang 提交者： GitHub
浏览文件
操作

[skip ci]Format markdown for chap09_data_coord.md (#9599) 

Signed-off-by: Nruiyi.jiang <ruiyi.jiang@zilliz.com>
上级 3cb28640
隐藏空白更改
内联 并排
Showing with 54 addition and 66 deletion
docs/developer_guides/chap09_data_coord.md
浏览文件 @ b84e4df1
## 9. Data Service
#### 9.1 Overview
<img src="./figs/data_coord.png" width=700>
......@@ -32,9 +28,7 @@ type DataCoord interface {
}
```
* *MsgBase*
- _MsgBase_
```go
type MsgBase struct {
......@@ -45,7 +39,7 @@ type MsgBase struct {
}
```
* *Flush*
- _Flush_
```go
type FlushRequest struct {
......@@ -55,7 +49,7 @@ type FlushRequest struct {
}
```
* *AssignSegmentID*
- _AssignSegmentID_
```go
type SegmentIDRequest struct {
......@@ -66,9 +60,9 @@ type SegmentIDRequest struct {
}
type AssignSegmentIDRequest struct {
NodeID int64
PeerRole string
SegmentIDRequests []*SegmentIDRequest
NodeID int64
PeerRole string
SegmentIDRequests []*SegmentIDRequest
}
type SegIDAssignment struct {
......@@ -87,13 +81,12 @@ type AssignSegmentIDResponse struct {
}
```
* *GetSegmentStates*
- _GetSegmentStates_
```go
type GetSegmentStatesRequest struct {
Base *commonpb.MsgBase
SegmentIDs []int64
Base *commonpb.MsgBase
SegmentIDs []int64
}
type SegmentState int32
......@@ -121,7 +114,7 @@ type GetSegmentStatesResponse struct {
}
```
* *GetInsertBinlogPaths*
- _GetInsertBinlogPaths_
```go
type GetInsertBinlogPathsRequest struct {
......@@ -136,7 +129,7 @@ type GetInsertBinlogPathsResponse struct {
}
```
* *GetCollectionStatistics*
- _GetCollectionStatistics_
```go
type GetCollectionStatisticsRequest struct {
......@@ -151,7 +144,7 @@ type GetCollectionStatisticsResponse struct {
}
```
* *GetPartitionStatistics*
- _GetPartitionStatistics_
```go
type GetPartitionStatisticsRequest struct {
......@@ -167,7 +160,7 @@ type GetPartitionStatisticsResponse struct {
}
```
* *GetSegmentInfo*
- _GetSegmentInfo_
```go
type GetSegmentInfoRequest struct{
......@@ -176,16 +169,16 @@ type GetSegmentInfoRequest struct{
}
type SegmentInfo struct {
ID int64
CollectionID int64
PartitionID int64
InsertChannel string
NumOfRows int64
State commonpb.SegmentState
DmlPosition *internalpb.MsgPosition
MaxRowNum int64
LastExpireTime uint64
StartPosition *internalpb.MsgPosition
ID int64
CollectionID int64
PartitionID int64
InsertChannel string
NumOfRows int64
State commonpb.SegmentState
DmlPosition *internalpb.MsgPosition
MaxRowNum int64
LastExpireTime uint64
StartPosition *internalpb.MsgPosition
}
type GetSegmentInfoResponse struct{
......@@ -194,60 +187,58 @@ type GetSegmentInfoResponse struct{
}
```
* *GetRecoveryInfo*
- _GetRecoveryInfo_
```go
type GetRecoveryInfoRequest struct {
Base *commonpb.MsgBase
CollectionID int64
PartitionID int64
Base *commonpb.MsgBase
CollectionID int64
PartitionID int64
}
type VchannelInfo struct {
CollectionID int64
ChannelName string
SeekPosition *internalpb.MsgPosition
UnflushedSegments []*SegmentInfo
FlushedSegments []int64
CollectionID int64
ChannelName string
SeekPosition *internalpb.MsgPosition
UnflushedSegments []*SegmentInfo
FlushedSegments []int64
}
type SegmentBinlogs struct {
SegmentID int64
FieldBinlogs []*FieldBinlog
SegmentID int64
FieldBinlogs []*FieldBinlog
}
type GetRecoveryInfoResponse struct {
Status *commonpb.Status
Channels []*VchannelInfo
Binlogs []*SegmentBinlogs
Status *commonpb.Status
Channels []*VchannelInfo
Binlogs []*SegmentBinlogs
}
```
* *SaveBinlogPaths*
- _SaveBinlogPaths_
```go
type SegmentStartPosition struct {
StartPosition *internalpb.MsgPosition
SegmentID int64
StartPosition *internalpb.MsgPosition
SegmentID int64
}
type SaveBinlogPathsRequest struct {
Base *commonpb.MsgBase
SegmentID int64
CollectionID int64
Field2BinlogPaths []*ID2PathList
CheckPoints []*CheckPoint
StartPositions []*SegmentStartPosition
Flushed bool
Base *commonpb.MsgBase
SegmentID int64
CollectionID int64
Field2BinlogPaths []*ID2PathList
CheckPoints []*CheckPoint
StartPositions []*SegmentStartPosition
Flushed bool
}
```
#### 9.3 Insert Channel
* *InsertMsg*
- _InsertMsg_
```go
type InsertRequest struct {
......@@ -271,8 +262,6 @@ type InsertMsg struct {
}
```
#### 9.4 Data Node Interface
```go
......@@ -284,7 +273,7 @@ type DataNode interface {
}
```
* *WatchDmChannels*
- _WatchDmChannels_
```go
type WatchDmChannelRequest struct {
......@@ -293,7 +282,7 @@ type WatchDmChannelRequest struct {
}
```
* *FlushSegments*
- _FlushSegments_
```go
type FlushSegmentsRequest struct {
......@@ -304,10 +293,9 @@ type FlushSegmentsRequest struct {
}
```
#### 9.5 SegmentStatistics Update Channel
* *SegmentStatisticsMsg*
- _SegmentStatisticsMsg_
```go
type SegmentStatisticsUpdates struct {
......@@ -331,9 +319,10 @@ type SegmentStatisticsMsg struct {
}
```
#### 9.6 DataNode Time Tick Channel
* *DataNode Tt Msg*
- _DataNode Tt Msg_
```go
message DataNodeTtMsg {
......@@ -342,4 +331,3 @@ message DataNodeTtMsg {
Timestamp uint64
}
```
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或