mirror of
https://github.com/anyproto/any-sync.git
synced 2025-06-07 21:47:02 +09:00
Update test
This commit is contained in:
parent
bdcb1bf35b
commit
b21c98f497
2 changed files with 11 additions and 1 deletions
|
@ -93,6 +93,16 @@ type RpcServer struct {
|
||||||
sync.Mutex
|
sync.Mutex
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (r *RpcServer) StoreDiff(ctx2 context.Context, request *spacesyncproto.StoreDiffRequest) (*spacesyncproto.StoreDiffResponse, error) {
|
||||||
|
//TODO implement me
|
||||||
|
panic("implement me")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *RpcServer) StoreElements(stream spacesyncproto.DRPCSpaceSync_StoreElementsStream) error {
|
||||||
|
//TODO implement me
|
||||||
|
panic("implement me")
|
||||||
|
}
|
||||||
|
|
||||||
func NewRpcServer() *RpcServer {
|
func NewRpcServer() *RpcServer {
|
||||||
return &RpcServer{
|
return &RpcServer{
|
||||||
spaces: make(map[string]Space),
|
spaces: make(map[string]Space),
|
||||||
|
|
|
@ -3,7 +3,7 @@ package coordinatorproto
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
|
||||||
"github.com/anyproto/any-sync/net/rpc/rpcerr"u
|
"github.com/anyproto/any-sync/net/rpc/rpcerr"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue