Add client and grpc service
Signed-off-by:
sunby <bingyi.sun@zilliz.com>
Showing
- docs/developer_guides/chap04_message_stream.md 38 additions, 29 deletionsdocs/developer_guides/chap04_message_stream.md
- internal/dataservice/channel.go 65 additions, 21 deletionsinternal/dataservice/channel.go
- internal/dataservice/dd_handler.go 0 additions, 129 deletionsinternal/dataservice/dd_handler.go
- internal/dataservice/grpc_service.go 0 additions, 63 deletionsinternal/dataservice/grpc_service.go
- internal/dataservice/meta.go 68 additions, 16 deletionsinternal/dataservice/meta.go
- internal/dataservice/param.go 9 additions, 262 deletionsinternal/dataservice/param.go
- internal/dataservice/scheduler.go 0 additions, 89 deletionsinternal/dataservice/scheduler.go
- internal/dataservice/segment_allocator.go 12 additions, 8 deletionsinternal/dataservice/segment_allocator.go
- internal/dataservice/server.go 335 additions, 5 deletionsinternal/dataservice/server.go
- internal/dataservice/task.go 0 additions, 126 deletionsinternal/dataservice/task.go
- internal/dataservice/watcher.go 20 additions, 44 deletionsinternal/dataservice/watcher.go
- internal/distributed/dataservice/client.go 64 additions, 0 deletionsinternal/distributed/dataservice/client.go
- internal/distributed/dataservice/grpc_service.go 65 additions, 0 deletionsinternal/distributed/dataservice/grpc_service.go
- internal/proto/data_service.proto 43 additions, 7 deletionsinternal/proto/data_service.proto
- internal/proto/datapb/data_service.pb.go 574 additions, 112 deletionsinternal/proto/datapb/data_service.pb.go
- internal/proto/internal.proto 3 additions, 1 deletioninternal/proto/internal.proto
- internal/proto/internalpb2/internal.pb.go 106 additions, 89 deletionsinternal/proto/internalpb2/internal.pb.go
- internal/timesync/time_sync_producer.go 47 additions, 46 deletionsinternal/timesync/time_sync_producer.go
- internal/timesync/timesync.go 81 additions, 107 deletionsinternal/timesync/timesync.go
- internal/timesync/timetick_watcher.go 21 additions, 12 deletionsinternal/timesync/timetick_watcher.go
Please register or sign in to comment