mirror of
https://github.com/anyproto/any-sync.git
synced 2025-06-08 05:57:03 +09:00
coordinator proto
This commit is contained in:
Sergey Cherepanov
parent
37c685981f
commit
b11552ad0f
3 changed files with 899 additions and 138 deletions
File diff suppressed because it is too large
Load diff
|
|
@ -44,6 +44,8 @@ type DRPCCoordinatorClient interface {
|
|||
SpaceStatusCheck(ctx context.Context, in *SpaceStatusCheckRequest) (*SpaceStatusCheckResponse, error)
|
||||
SpaceStatusCheckMany(ctx context.Context, in *SpaceStatusCheckManyRequest) (*SpaceStatusCheckManyResponse, error)
|
||||
SpaceStatusChange(ctx context.Context, in *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
|
||||
SpaceMakeShareable(ctx context.Context, in *SpaceMakeShareableRequest) (*SpaceMakeShareableResponse, error)
|
||||
SpaceMakeUnshareable(ctx context.Context, in *SpaceMakeUnshareableRequest) (*SpaceMakeUnshareableResponse, error)
|
||||
NetworkConfiguration(ctx context.Context, in *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
|
||||
DeletionLog(ctx context.Context, in *DeletionLogRequest) (*DeletionLogResponse, error)
|
||||
SpaceDelete(ctx context.Context, in *SpaceDeleteRequest) (*SpaceDeleteResponse, error)
|
||||
|
|
@ -100,6 +102,24 @@ func (c *drpcCoordinatorClient) SpaceStatusChange(ctx context.Context, in *Space
|
|||
return out, nil
|
||||
}
|
||||
|
||||
func (c *drpcCoordinatorClient) SpaceMakeShareable(ctx context.Context, in *SpaceMakeShareableRequest) (*SpaceMakeShareableResponse, error) {
|
||||
out := new(SpaceMakeShareableResponse)
|
||||
err := c.cc.Invoke(ctx, "/coordinator.Coordinator/SpaceMakeShareable", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}, in, out)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *drpcCoordinatorClient) SpaceMakeUnshareable(ctx context.Context, in *SpaceMakeUnshareableRequest) (*SpaceMakeUnshareableResponse, error) {
|
||||
out := new(SpaceMakeUnshareableResponse)
|
||||
err := c.cc.Invoke(ctx, "/coordinator.Coordinator/SpaceMakeUnshareable", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}, in, out)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return out, nil
|
||||
}
|
||||
|
||||
func (c *drpcCoordinatorClient) NetworkConfiguration(ctx context.Context, in *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error) {
|
||||
out := new(NetworkConfigurationResponse)
|
||||
err := c.cc.Invoke(ctx, "/coordinator.Coordinator/NetworkConfiguration", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}, in, out)
|
||||
|
|
@ -177,6 +197,8 @@ type DRPCCoordinatorServer interface {
|
|||
SpaceStatusCheck(context.Context, *SpaceStatusCheckRequest) (*SpaceStatusCheckResponse, error)
|
||||
SpaceStatusCheckMany(context.Context, *SpaceStatusCheckManyRequest) (*SpaceStatusCheckManyResponse, error)
|
||||
SpaceStatusChange(context.Context, *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
|
||||
SpaceMakeShareable(context.Context, *SpaceMakeShareableRequest) (*SpaceMakeShareableResponse, error)
|
||||
SpaceMakeUnshareable(context.Context, *SpaceMakeUnshareableRequest) (*SpaceMakeUnshareableResponse, error)
|
||||
NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
|
||||
DeletionLog(context.Context, *DeletionLogRequest) (*DeletionLogResponse, error)
|
||||
SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error)
|
||||
|
|
@ -205,6 +227,14 @@ func (s *DRPCCoordinatorUnimplementedServer) SpaceStatusChange(context.Context,
|
|||
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
|
||||
}
|
||||
|
||||
func (s *DRPCCoordinatorUnimplementedServer) SpaceMakeShareable(context.Context, *SpaceMakeShareableRequest) (*SpaceMakeShareableResponse, error) {
|
||||
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
|
||||
}
|
||||
|
||||
func (s *DRPCCoordinatorUnimplementedServer) SpaceMakeUnshareable(context.Context, *SpaceMakeUnshareableRequest) (*SpaceMakeUnshareableResponse, error) {
|
||||
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
|
||||
}
|
||||
|
||||
func (s *DRPCCoordinatorUnimplementedServer) NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error) {
|
||||
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
|
||||
}
|
||||
|
|
@ -239,7 +269,7 @@ func (s *DRPCCoordinatorUnimplementedServer) AccountLimitsSet(context.Context, *
|
|||
|
||||
type DRPCCoordinatorDescription struct{}
|
||||
|
||||
func (DRPCCoordinatorDescription) NumMethods() int { return 12 }
|
||||
func (DRPCCoordinatorDescription) NumMethods() int { return 14 }
|
||||
|
||||
func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) {
|
||||
switch n {
|
||||
|
|
@ -280,6 +310,24 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
)
|
||||
}, DRPCCoordinatorServer.SpaceStatusChange, true
|
||||
case 4:
|
||||
return "/coordinator.Coordinator/SpaceMakeShareable", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
SpaceMakeShareable(
|
||||
ctx,
|
||||
in1.(*SpaceMakeShareableRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.SpaceMakeShareable, true
|
||||
case 5:
|
||||
return "/coordinator.Coordinator/SpaceMakeUnshareable", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
SpaceMakeUnshareable(
|
||||
ctx,
|
||||
in1.(*SpaceMakeUnshareableRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.SpaceMakeUnshareable, true
|
||||
case 6:
|
||||
return "/coordinator.Coordinator/NetworkConfiguration", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -288,7 +336,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*NetworkConfigurationRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.NetworkConfiguration, true
|
||||
case 5:
|
||||
case 7:
|
||||
return "/coordinator.Coordinator/DeletionLog", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -297,7 +345,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*DeletionLogRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.DeletionLog, true
|
||||
case 6:
|
||||
case 8:
|
||||
return "/coordinator.Coordinator/SpaceDelete", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -306,7 +354,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*SpaceDeleteRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.SpaceDelete, true
|
||||
case 7:
|
||||
case 9:
|
||||
return "/coordinator.Coordinator/AccountDelete", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -315,7 +363,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*AccountDeleteRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.AccountDelete, true
|
||||
case 8:
|
||||
case 10:
|
||||
return "/coordinator.Coordinator/AccountRevertDeletion", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -324,7 +372,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*AccountRevertDeletionRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.AccountRevertDeletion, true
|
||||
case 9:
|
||||
case 11:
|
||||
return "/coordinator.Coordinator/AclAddRecord", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -333,7 +381,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*AclAddRecordRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.AclAddRecord, true
|
||||
case 10:
|
||||
case 12:
|
||||
return "/coordinator.Coordinator/AclGetRecords", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -342,7 +390,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
|
|||
in1.(*AclGetRecordsRequest),
|
||||
)
|
||||
}, DRPCCoordinatorServer.AclGetRecords, true
|
||||
case 11:
|
||||
case 13:
|
||||
return "/coordinator.Coordinator/AccountLimitsSet", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{},
|
||||
func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
|
||||
return srv.(DRPCCoordinatorServer).
|
||||
|
|
@ -424,6 +472,38 @@ func (x *drpcCoordinator_SpaceStatusChangeStream) SendAndClose(m *SpaceStatusCha
|
|||
return x.CloseSend()
|
||||
}
|
||||
|
||||
type DRPCCoordinator_SpaceMakeShareableStream interface {
|
||||
drpc.Stream
|
||||
SendAndClose(*SpaceMakeShareableResponse) error
|
||||
}
|
||||
|
||||
type drpcCoordinator_SpaceMakeShareableStream struct {
|
||||
drpc.Stream
|
||||
}
|
||||
|
||||
func (x *drpcCoordinator_SpaceMakeShareableStream) SendAndClose(m *SpaceMakeShareableResponse) error {
|
||||
if err := x.MsgSend(m, drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}); err != nil {
|
||||
return err
|
||||
}
|
||||
return x.CloseSend()
|
||||
}
|
||||
|
||||
type DRPCCoordinator_SpaceMakeUnshareableStream interface {
|
||||
drpc.Stream
|
||||
SendAndClose(*SpaceMakeUnshareableResponse) error
|
||||
}
|
||||
|
||||
type drpcCoordinator_SpaceMakeUnshareableStream struct {
|
||||
drpc.Stream
|
||||
}
|
||||
|
||||
func (x *drpcCoordinator_SpaceMakeUnshareableStream) SendAndClose(m *SpaceMakeUnshareableResponse) error {
|
||||
if err := x.MsgSend(m, drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}); err != nil {
|
||||
return err
|
||||
}
|
||||
return x.CloseSend()
|
||||
}
|
||||
|
||||
type DRPCCoordinator_NetworkConfigurationStream interface {
|
||||
drpc.Stream
|
||||
SendAndClose(*NetworkConfigurationResponse) error
|
||||
|
|
|
|||
|
|
@ -16,6 +16,12 @@ service Coordinator {
|
|||
// SpaceStatusChange changes the status of space - Deprecated
|
||||
rpc SpaceStatusChange(SpaceStatusChangeRequest) returns (SpaceStatusChangeResponse);
|
||||
|
||||
// SpaceMakeShareable makes space shareable
|
||||
rpc SpaceMakeShareable(SpaceMakeShareableRequest) returns (SpaceMakeShareableResponse);
|
||||
|
||||
// SpaceMakeUnshareable marks space unshareable
|
||||
rpc SpaceMakeUnshareable(SpaceMakeUnshareableRequest) returns (SpaceMakeUnshareableResponse);
|
||||
|
||||
// NetworkConfiguration retrieves the latest network configuration
|
||||
rpc NetworkConfiguration(NetworkConfigurationRequest) returns (NetworkConfigurationResponse);
|
||||
|
||||
|
|
@ -87,6 +93,7 @@ message SpaceStatusPayload {
|
|||
int64 deletionTimestamp = 2;
|
||||
SpacePermissions permissions = 3;
|
||||
SpaceLimits limits = 4;
|
||||
bool isShared = 5;
|
||||
}
|
||||
|
||||
message SpaceSignResponse {
|
||||
|
|
@ -146,6 +153,18 @@ message SpaceStatusChangeResponse {
|
|||
SpaceStatusPayload payload = 1;
|
||||
}
|
||||
|
||||
message SpaceMakeShareableRequest {
|
||||
string spaceId = 1;
|
||||
}
|
||||
|
||||
message SpaceMakeShareableResponse {}
|
||||
|
||||
message SpaceMakeUnshareableRequest {
|
||||
string spaceId = 1;
|
||||
}
|
||||
|
||||
message SpaceMakeUnshareableResponse {}
|
||||
|
||||
// NetworkConfigurationRequest contains currenId of the client configuration, it can be empty
|
||||
message NetworkConfigurationRequest {
|
||||
// currenId of the client configuration
|
||||
|
|
@ -331,6 +350,7 @@ message AccountLimitsSetRequest {
|
|||
uint64 fileStorageLimitBytes = 3;
|
||||
uint32 spaceMembersRead = 4;
|
||||
uint32 spaceMembersWrite = 5;
|
||||
uint32 sharedSpacesLimit = 6;
|
||||
}
|
||||
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue