anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-09 09:35:03 +09:00
Code Activity

Add explicit space delete request

Browse source
This commit is contained in:
mcrakhman 2023-10-19 21:25:25 +02:00
parent f4640056e7
commit 4dd3c61c2b
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
3 changed files with 582 additions and 131 deletions
Download patch file Download diff file Expand all files Collapse all files

651
coordinator/coordinatorproto/coordinator.pb.go
View file

@ -796,7 +796,6 @@ type SpaceStatusChangeRequest struct {
DeletionPayloadId string `protobuf:"bytes,2,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
DeletionPayload []byte `protobuf:"bytes,3,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
DeletionPayloadType DeletionPayloadType `protobuf:"varint,4,opt,name=deletionPayloadType,proto3,enum=coordinator.DeletionPayloadType" json:"deletionPayloadType,omitempty"`
DeletionDuration int64 `protobuf:"varint,5,opt,name=deletionDuration,proto3" json:"deletionDuration,omitempty"`
}
func (m *SpaceStatusChangeRequest) Reset() { *m = SpaceStatusChangeRequest{} }
@ -860,13 +859,6 @@ func (m *SpaceStatusChangeRequest) GetDeletionPayloadType() DeletionPayloadType
return DeletionPayloadType_Tree
}
func (m *SpaceStatusChangeRequest) GetDeletionDuration() int64 {
if m != nil {
return m.DeletionDuration
}
return 0
}
// SpaceStatusChangeResponse contains changed status of space
type SpaceStatusChangeResponse struct {
Payload *SpaceStatusPayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
@ -1411,6 +1403,112 @@ func (m *DeletionLogRecord) GetTimestamp() int64 {
return 0
}
// SpaceDeleteRequest contains the deletion confirmation for the space to be deleted
type SpaceDeleteRequest struct {
SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
DeletionPayloadId string `protobuf:"bytes,2,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
DeletionPayload []byte `protobuf:"bytes,3,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
}
func (m *SpaceDeleteRequest) Reset() { *m = SpaceDeleteRequest{} }
func (m *SpaceDeleteRequest) String() string { return proto.CompactTextString(m) }
func (*SpaceDeleteRequest) ProtoMessage() {}
func (*SpaceDeleteRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{21}
}
func (m *SpaceDeleteRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *SpaceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_SpaceDeleteRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *SpaceDeleteRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SpaceDeleteRequest.Merge(m, src)
}
func (m *SpaceDeleteRequest) XXX_Size() int {
return m.Size()
}
func (m *SpaceDeleteRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SpaceDeleteRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SpaceDeleteRequest proto.InternalMessageInfo
func (m *SpaceDeleteRequest) GetSpaceId() string {
if m != nil {
return m.SpaceId
}
return ""
}
func (m *SpaceDeleteRequest) GetDeletionPayloadId() string {
if m != nil {
return m.DeletionPayloadId
}
return ""
}
func (m *SpaceDeleteRequest) GetDeletionPayload() []byte {
if m != nil {
return m.DeletionPayload
}
return nil
}
// SpaceDeleteResponse contains timestamp when the space is finally deleted
type SpaceDeleteResponse struct {
ToBeDeletedTimestamp int64 `protobuf:"varint,1,opt,name=toBeDeletedTimestamp,proto3" json:"toBeDeletedTimestamp,omitempty"`
}
func (m *SpaceDeleteResponse) Reset() { *m = SpaceDeleteResponse{} }
func (m *SpaceDeleteResponse) String() string { return proto.CompactTextString(m) }
func (*SpaceDeleteResponse) ProtoMessage() {}
func (*SpaceDeleteResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{22}
}
func (m *SpaceDeleteResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *SpaceDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_SpaceDeleteResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *SpaceDeleteResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SpaceDeleteResponse.Merge(m, src)
}
func (m *SpaceDeleteResponse) XXX_Size() int {
return m.Size()
}
func (m *SpaceDeleteResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SpaceDeleteResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SpaceDeleteResponse proto.InternalMessageInfo
func (m *SpaceDeleteResponse) GetToBeDeletedTimestamp() int64 {
if m != nil {
return m.ToBeDeletedTimestamp
}
return 0
}
// AccountDeleteRequest contains payload for account deletion
type AccountDeleteRequest struct {
DeletionPayloadId string `protobuf:"bytes,1,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
@ -1421,7 +1519,7 @@ func (m *AccountDeleteRequest) Reset() { *m = AccountDeleteRequest{} }
func (m *AccountDeleteRequest) String() string { return proto.CompactTextString(m) }
func (*AccountDeleteRequest) ProtoMessage() {}
func (*AccountDeleteRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{21}
return fileDescriptor_d94f6f99586adae2, []int{23}
}
func (m *AccountDeleteRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1480,7 +1578,7 @@ func (m *AccountDeletionConfirmPayload) Reset() { *m = AccountDeletionCo
func (m *AccountDeletionConfirmPayload) String() string { return proto.CompactTextString(m) }
func (*AccountDeletionConfirmPayload) ProtoMessage() {}
func (*AccountDeletionConfirmPayload) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{22}
return fileDescriptor_d94f6f99586adae2, []int{24}
}
func (m *AccountDeletionConfirmPayload) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1546,7 +1644,7 @@ func (m *AccountDeleteResponse) Reset() { *m = AccountDeleteResponse{} }
func (m *AccountDeleteResponse) String() string { return proto.CompactTextString(m) }
func (*AccountDeleteResponse) ProtoMessage() {}
func (*AccountDeleteResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{23}
return fileDescriptor_d94f6f99586adae2, []int{25}
}
func (m *AccountDeleteResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1590,7 +1688,7 @@ func (m *AccountRevertDeletionRequest) Reset() { *m = AccountRevertDelet
func (m *AccountRevertDeletionRequest) String() string { return proto.CompactTextString(m) }
func (*AccountRevertDeletionRequest) ProtoMessage() {}
func (*AccountRevertDeletionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{24}
return fileDescriptor_d94f6f99586adae2, []int{26}
}
func (m *AccountRevertDeletionRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1627,7 +1725,7 @@ func (m *AccountRevertDeletionResponse) Reset() { *m = AccountRevertDele
func (m *AccountRevertDeletionResponse) String() string { return proto.CompactTextString(m) }
func (*AccountRevertDeletionResponse) ProtoMessage() {}
func (*AccountRevertDeletionResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_d94f6f99586adae2, []int{25}
return fileDescriptor_d94f6f99586adae2, []int{27}
}
func (m *AccountRevertDeletionResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
@ -1683,6 +1781,8 @@ func init() {
proto.RegisterType((*DeletionLogRequest)(nil), "coordinator.DeletionLogRequest")
proto.RegisterType((*DeletionLogResponse)(nil), "coordinator.DeletionLogResponse")
proto.RegisterType((*DeletionLogRecord)(nil), "coordinator.DeletionLogRecord")
proto.RegisterType((*SpaceDeleteRequest)(nil), "coordinator.SpaceDeleteRequest")
proto.RegisterType((*SpaceDeleteResponse)(nil), "coordinator.SpaceDeleteResponse")
proto.RegisterType((*AccountDeleteRequest)(nil), "coordinator.AccountDeleteRequest")
proto.RegisterType((*AccountDeletionConfirmPayload)(nil), "coordinator.AccountDeletionConfirmPayload")
proto.RegisterType((*AccountDeleteResponse)(nil), "coordinator.AccountDeleteResponse")
@ -1695,93 +1795,95 @@ func init() {
}
var fileDescriptor_d94f6f99586adae2 = []byte{
// 1372 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x58, 0xbf, 0x73, 0x13, 0xc7,
0x17, 0xd7, 0x9e, 0xe4, 0x1f, 0x7a, 0x32, 0xe2, 0xbc, 0xd8, 0x46, 0x5f, 0x21, 0x84, 0xbf, 0x07,
0x21, 0x42, 0xc9, 0x00, 0x23, 0x26, 0x99, 0x30, 0xa4, 0x80, 0x18, 0x32, 0x63, 0x02, 0xc6, 0xb3,
0x60, 0x32, 0x09, 0x45, 0xe6, 0xb8, 0x5b, 0xdb, 0x37, 0x96, 0xef, 0x94, 0xbd, 0x15, 0xe0, 0x22,
0xff, 0x41, 0x8a, 0x74, 0x99, 0x14, 0xe9, 0x53, 0xa4, 0x48, 0x9f, 0x99, 0xd4, 0x29, 0x29, 0x53,
0x66, 0xa0, 0xce, 0xff, 0x90, 0xd9, 0xbd, 0xdd, 0xbb, 0xbd, 0xd3, 0x49, 0x76, 0x26, 0x45, 0x1a,
0xc4, 0x7e, 0xf6, 0xbd, 0xb7, 0x9f, 0xf7, 0x63, 0xdf, 0xbe, 0x33, 0x7c, 0xe0, 0x45, 0x11, 0xf3,
0x83, 0xd0, 0xe5, 0x11, 0xbb, 0x66, 0xfc, 0x7f, 0xc4, 0x22, 0x1e, 0x5d, 0x93, 0xff, 0xc6, 0x26,
0x7e, 0x55, 0x42, 0xb8, 0x61, 0x40, 0xce, 0x6f, 0x08, 0xec, 0xc7, 0x23, 0xd7, 0xa3, 0x8f, 0x83,
0xbd, 0x90, 0xd0, 0xaf, 0xc7, 0x34, 0xe6, 0xb8, 0x05, 0x0b, 0xb1, 0xc0, 0x36, 0xfd, 0x16, 0x5a,
0x47, 0xbd, 0x3a, 0xd1, 0x4b, 0xbc, 0x06, 0xf3, 0xfb, 0xd4, 0xf5, 0x29, 0x6b, 0x59, 0xeb, 0xa8,
0xb7, 0x44, 0xd4, 0x0a, 0xaf, 0x43, 0x23, 0x1a, 0xfa, 0x9b, 0x3e, 0x0d, 0x79, 0xc0, 0x8f, 0x5a,
0x55, 0xb9, 0x69, 0x42, 0x78, 0x00, 0x2b, 0x21, 0x7d, 0xa9, 0x97, 0xe2, 0x34, 0x97, 0x8f, 0x19,
0x6d, 0xd5, 0xa4, 0x68, 0xe9, 0x1e, 0x76, 0x60, 0x69, 0x37, 0x62, 0x1e, 0x55, 0xbc, 0x5a, 0x73,
0xeb, 0xa8, 0xb7, 0x48, 0x72, 0x98, 0xc3, 0x01, 0x27, 0xfc, 0xb9, 0xcb, 0xc7, 0xf1, 0xb6, 0x7b,
0x34, 0x8c, 0x5c, 0x1f, 0x5f, 0x87, 0xf9, 0x58, 0x02, 0xd2, 0x81, 0xe6, 0xa0, 0x75, 0xd5, 0x8c,
0x83, 0xa1, 0x40, 0x94, 0x1c, 0x7e, 0x1f, 0x96, 0x7d, 0x3a, 0xa4, 0x3c, 0x88, 0xc2, 0x27, 0xc1,
0x21, 0x8d, 0xb9, 0x7b, 0x38, 0x92, 0x4e, 0x56, 0xc9, 0xe4, 0x86, 0xb3, 0x03, 0xcb, 0x46, 0xd4,
0xe2, 0x51, 0x14, 0xc6, 0x14, 0xdf, 0x86, 0x05, 0x46, 0x3d, 0x1a, 0x8c, 0xb8, 0x3c, 0xb5, 0x31,
0xb8, 0x3c, 0x79, 0x2a, 0x49, 0x04, 0x3e, 0x0f, 0xf8, 0x7e, 0xea, 0x27, 0xd1, 0x6a, 0xce, 0x01,
0xfc, 0x6f, 0xaa, 0x14, 0xbe, 0x0e, 0x67, 0x62, 0x63, 0x53, 0xb9, 0x2a, 0x8f, 0x5a, 0x22, 0x65,
0x5b, 0xb8, 0x03, 0xf5, 0x38, 0x0d, 0x74, 0x92, 0xb0, 0x0c, 0x70, 0x7e, 0x42, 0xb0, 0x64, 0x9e,
0x36, 0x3b, 0xed, 0x23, 0x4a, 0xd9, 0xa6, 0x2f, 0xad, 0xd4, 0x89, 0x5a, 0xe1, 0x1e, 0x9c, 0x76,
0x3d, 0x2f, 0x1a, 0x87, 0xbc, 0x90, 0xfa, 0x22, 0x2c, 0xa8, 0x84, 0x94, 0xbf, 0x8c, 0xd8, 0xc1,
0xa6, 0x2f, 0x73, 0x5e, 0x27, 0x19, 0x80, 0xbb, 0x00, 0x2f, 0xdc, 0x61, 0xe0, 0xef, 0x84, 0x3c,
0x18, 0xca, 0x34, 0xd7, 0x88, 0x81, 0x38, 0xcf, 0x60, 0xf5, 0xd3, 0x60, 0x48, 0x1f, 0x04, 0x87,
0x01, 0xdf, 0xd8, 0xa7, 0xde, 0x81, 0xae, 0xd4, 0x12, 0x02, 0xa8, 0x9c, 0x80, 0xe1, 0x9c, 0x95,
0x73, 0xce, 0xd9, 0x82, 0xb5, 0xa2, 0x71, 0x95, 0xd0, 0x15, 0x98, 0x1b, 0x0a, 0x54, 0xda, 0xac,
0x91, 0x64, 0x21, 0xc8, 0xc6, 0x3c, 0x62, 0xee, 0x1e, 0xfd, 0x8c, 0x1e, 0x29, 0x63, 0x06, 0xe2,
0xdc, 0x80, 0xb3, 0x46, 0x81, 0xe5, 0xe8, 0x4e, 0x8d, 0xb0, 0xb3, 0x03, 0xad, 0x49, 0x25, 0x45,
0xe3, 0x26, 0x2c, 0x8c, 0x8c, 0x64, 0x37, 0x06, 0x17, 0xa6, 0x55, 0xb3, 0x4a, 0x3c, 0xd1, 0xf2,
0xce, 0x4d, 0x38, 0x57, 0x34, 0xfb, 0xd0, 0x0d, 0x8f, 0x34, 0x9f, 0x36, 0x2c, 0x2a, 0x02, 0xe2,
0xa2, 0x54, 0x7b, 0x75, 0x92, 0xae, 0x9d, 0x67, 0xd0, 0x29, 0x57, 0x55, 0xac, 0x6e, 0xc1, 0xa2,
0x3a, 0x25, 0xd1, 0x3d, 0x01, 0xad, 0x54, 0xc1, 0xf9, 0xd6, 0x2a, 0xf8, 0xeb, 0x86, 0x7b, 0xf4,
0xf8, 0xf6, 0x63, 0x5c, 0x52, 0x65, 0x33, 0x4d, 0xe7, 0xe4, 0x86, 0x28, 0x8e, 0x02, 0xa8, 0xab,
0xb3, 0x00, 0x63, 0x02, 0x67, 0x0a, 0xd0, 0x93, 0xa3, 0x51, 0xd2, 0x9b, 0x9a, 0x83, 0xf5, 0x9c,
0x5b, 0x77, 0x27, 0xe5, 0x48, 0x99, 0x32, 0xee, 0x83, 0xad, 0xe1, 0xbb, 0x63, 0xe6, 0x8a, 0x5f,
0x59, 0xd9, 0x55, 0x32, 0x81, 0x3b, 0x4f, 0xd5, 0xbd, 0xcf, 0x47, 0xe3, 0xdf, 0xa7, 0xff, 0x16,
0x9c, 0xdb, 0x4a, 0x2e, 0xd9, 0x46, 0x14, 0xee, 0x06, 0x7b, 0xea, 0x3c, 0x1d, 0xe8, 0x0e, 0xd4,
0xbd, 0x31, 0x63, 0x54, 0x5c, 0x13, 0x15, 0xea, 0x0c, 0x70, 0x7e, 0x45, 0xd0, 0x29, 0xd7, 0x56,
0xc4, 0x7a, 0x70, 0xda, 0x33, 0x37, 0x52, 0x23, 0x45, 0x38, 0x7f, 0xfb, 0xad, 0xe2, 0xed, 0x7f,
0x17, 0xe6, 0xc2, 0xc8, 0xa7, 0x71, 0xab, 0x2a, 0xcb, 0x68, 0x39, 0xe7, 0xde, 0x56, 0xe4, 0x53,
0x92, 0xec, 0x8b, 0x90, 0x7a, 0x8c, 0xba, 0xba, 0x15, 0xef, 0x84, 0xc1, 0x2b, 0x99, 0xa3, 0x1a,
0x99, 0xc0, 0x9d, 0x00, 0x6a, 0x42, 0xd5, 0x68, 0x5d, 0x28, 0xd7, 0xba, 0x3a, 0x50, 0x77, 0x7d,
0x9f, 0xd1, 0x38, 0xa6, 0x71, 0xcb, 0x92, 0xb5, 0x9f, 0x01, 0xf8, 0x3d, 0x98, 0xe3, 0x47, 0x23,
0x45, 0xa9, 0x39, 0x58, 0x9d, 0xa0, 0x24, 0xf3, 0x9e, 0xc8, 0x38, 0x87, 0x70, 0x51, 0x57, 0x85,
0x0c, 0x14, 0x3b, 0x54, 0x89, 0xc8, 0xf7, 0xef, 0x92, 0x72, 0x44, 0xe5, 0xe5, 0x38, 0xbb, 0x6f,
0xff, 0x82, 0x60, 0xad, 0xfc, 0xbc, 0xff, 0xb0, 0x83, 0x77, 0xa0, 0xce, 0xd3, 0x67, 0x33, 0x29,
0xf3, 0x0c, 0x70, 0xee, 0x02, 0xd6, 0x8c, 0x1f, 0x44, 0x7b, 0xc6, 0x3d, 0x77, 0x77, 0xb9, 0x91,
0x1b, 0xbd, 0xcc, 0x1a, 0xaf, 0x20, 0x7b, 0x4a, 0x35, 0x5e, 0x27, 0x80, 0x33, 0x39, 0x2b, 0xaa,
0x0c, 0x3f, 0x92, 0xcf, 0x6e, 0xc4, 0xd2, 0x3e, 0xd4, 0x2d, 0xbd, 0xb0, 0x52, 0x45, 0x88, 0x11,
0x2d, 0x2e, 0x08, 0xec, 0xbb, 0xf1, 0xc3, 0x48, 0x45, 0x79, 0x91, 0xe8, 0xa5, 0xf3, 0x03, 0x82,
0xe5, 0x09, 0x45, 0xdc, 0x04, 0x2b, 0xd0, 0x5c, 0xad, 0xc0, 0x9f, 0xfe, 0xa6, 0xe0, 0x8f, 0xd3,
0xf9, 0xa3, 0x2a, 0x7b, 0xc8, 0xa5, 0xd9, 0x94, 0x0a, 0xb3, 0x48, 0x2e, 0x98, 0xb5, 0x62, 0x30,
0x43, 0x58, 0xb9, 0x93, 0xe4, 0x46, 0xda, 0x49, 0xdb, 0x66, 0x69, 0x73, 0x44, 0xff, 0xa0, 0x39,
0x5a, 0xa5, 0xd5, 0xe8, 0xfc, 0x88, 0xe0, 0xbc, 0x79, 0xe0, 0x64, 0xd9, 0x4d, 0xbb, 0x63, 0x25,
0xc5, 0x65, 0x9d, 0xa0, 0xb8, 0xaa, 0x33, 0x8b, 0x6b, 0x22, 0x1e, 0xf7, 0x60, 0xb5, 0x10, 0x0f,
0x55, 0x18, 0xa5, 0x23, 0x1d, 0x9a, 0x36, 0xd2, 0x75, 0xa1, 0xa3, 0xcc, 0x10, 0xfa, 0x82, 0xb2,
0xd4, 0x57, 0x3d, 0x68, 0x5e, 0x48, 0xa3, 0x50, 0xdc, 0x4f, 0x8e, 0xeb, 0x7f, 0x8f, 0x00, 0xee,
0x31, 0x16, 0xb1, 0x0d, 0xd9, 0xac, 0x9a, 0x00, 0x3b, 0x21, 0x7d, 0x35, 0xa2, 0x1e, 0xa7, 0xbe,
0x5d, 0xc1, 0xb6, 0x9a, 0xb6, 0x12, 0x92, 0xbe, 0x8d, 0x70, 0x0b, 0x56, 0x32, 0x44, 0x04, 0x9c,
0x86, 0x7e, 0x10, 0xee, 0xd9, 0x56, 0x2a, 0xbb, 0x21, 0xba, 0x1a, 0xf5, 0xed, 0x2a, 0xc6, 0xd0,
0x94, 0xc8, 0x56, 0xc4, 0xef, 0xbd, 0x0a, 0x62, 0x1e, 0xdb, 0x35, 0xbc, 0xaa, 0x86, 0x50, 0x39,
0xb9, 0x10, 0xea, 0x7a, 0xfb, 0xd4, 0xb7, 0xe7, 0xb0, 0x0d, 0x0d, 0x49, 0xe3, 0xd1, 0xee, 0x6e,
0x4c, 0xb9, 0xfd, 0xb3, 0xd5, 0xff, 0x06, 0x1a, 0xc6, 0x2b, 0x81, 0xd7, 0x72, 0x23, 0xb3, 0x3e,
0xa3, 0x82, 0xbb, 0xd0, 0x36, 0x1f, 0x93, 0x84, 0x8d, 0x26, 0x67, 0xa3, 0xc2, 0xbe, 0xde, 0x78,
0xcc, 0x5d, 0x26, 0xf4, 0xad, 0x82, 0x5d, 0xed, 0x67, 0xb5, 0x7f, 0x1f, 0x16, 0x75, 0xcb, 0xc4,
0x0d, 0x58, 0x78, 0xc2, 0x28, 0xbd, 0xb3, 0xbd, 0x69, 0x57, 0xc4, 0x42, 0x4c, 0x5e, 0x62, 0x81,
0x84, 0x87, 0x1b, 0xd9, 0x1d, 0x11, 0x98, 0x8c, 0xc3, 0x86, 0x88, 0x6d, 0x18, 0x8f, 0x63, 0x81,
0x54, 0xfb, 0x37, 0xb3, 0x1e, 0x60, 0x3e, 0xb6, 0x8b, 0x50, 0x13, 0x66, 0x13, 0x9b, 0xaa, 0x3a,
0x6d, 0x24, 0x16, 0x2a, 0x67, 0xb6, 0xd5, 0xbf, 0x0d, 0x67, 0xa7, 0x5c, 0x3c, 0x3c, 0x0f, 0xd6,
0xa3, 0x03, 0xbb, 0x82, 0x97, 0xe1, 0x14, 0xa1, 0x87, 0xd1, 0x0b, 0xba, 0xcd, 0xe8, 0xc8, 0x65,
0xd4, 0x46, 0x18, 0x60, 0x3e, 0x81, 0x6c, 0x6b, 0xf0, 0xd7, 0x3c, 0x34, 0x0c, 0x8e, 0xf8, 0x3e,
0xd4, 0xd3, 0xaf, 0x00, 0x7c, 0xbe, 0xe4, 0x55, 0xce, 0xbe, 0xa9, 0xda, 0xdd, 0x69, 0xdb, 0xaa,
0x58, 0xbf, 0x80, 0x66, 0x7e, 0x0a, 0xc5, 0x4e, 0x4e, 0xa3, 0x74, 0xfe, 0x6d, 0x5f, 0x9c, 0x29,
0xa3, 0x4c, 0x7f, 0xa5, 0x3f, 0xf1, 0xb2, 0x49, 0x0e, 0x5f, 0x9a, 0x36, 0x43, 0xe4, 0xcc, 0xbf,
0x73, 0x8c, 0x94, 0x3a, 0xe0, 0x40, 0x15, 0x72, 0x61, 0x54, 0xc4, 0xbd, 0x99, 0xea, 0xc6, 0x20,
0xda, 0xbe, 0x72, 0x02, 0x49, 0x75, 0xd8, 0x73, 0xfd, 0xe9, 0x65, 0xcc, 0x4a, 0x78, 0x06, 0x51,
0x63, 0xb2, 0x6c, 0x5f, 0x3e, 0x4e, 0x2c, 0x73, 0xa8, 0x6c, 0xf2, 0x29, 0x38, 0x34, 0x63, 0xb4,
0x2a, 0x38, 0x34, 0x73, 0x8c, 0xda, 0x86, 0x86, 0x51, 0x97, 0xf8, 0xc2, 0xf4, 0xa7, 0x22, 0x31,
0xbd, 0x3e, 0x5d, 0x40, 0x59, 0x7c, 0x0a, 0xa7, 0x72, 0x1d, 0x11, 0xff, 0x3f, 0xa7, 0x52, 0xf6,
0x7a, 0xb4, 0x9d, 0x59, 0x22, 0xca, 0x6e, 0x98, 0x76, 0xda, 0x7c, 0x0b, 0xc4, 0x57, 0xca, 0x94,
0x4b, 0xdb, 0x68, 0xbb, 0x7f, 0x12, 0xd1, 0xe4, 0xbc, 0x4f, 0x3e, 0xfc, 0xfd, 0x4d, 0x17, 0xbd,
0x7e, 0xd3, 0x45, 0x7f, 0xbe, 0xe9, 0xa2, 0xef, 0xde, 0x76, 0x2b, 0xaf, 0xdf, 0x76, 0x2b, 0x7f,
0xbc, 0xed, 0x56, 0xbe, 0xec, 0xcc, 0xfa, 0xd3, 0xc7, 0xf3, 0x79, 0xf9, 0x73, 0xe3, 0xef, 0x00,
0x00, 0x00, 0xff, 0xff, 0xc3, 0x74, 0x44, 0x34, 0x21, 0x11, 0x00, 0x00,
// 1398 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x58, 0xbd, 0x73, 0x13, 0x47,
0x14, 0xd7, 0x9e, 0xe4, 0x0f, 0x3d, 0x19, 0x71, 0x5e, 0x7f, 0xa0, 0x08, 0x21, 0x9c, 0x83, 0x10,
0xa1, 0x64, 0x80, 0x11, 0x93, 0x4c, 0x18, 0x52, 0x00, 0x86, 0xcc, 0x98, 0x80, 0xf1, 0x2c, 0x98,
0x4c, 0x42, 0x91, 0x39, 0x74, 0x6b, 0xfb, 0xc6, 0xf2, 0x9d, 0xb2, 0xb7, 0x02, 0x54, 0xa4, 0x4d,
0x9d, 0x2e, 0x93, 0x22, 0x7d, 0x8a, 0x14, 0xe9, 0x33, 0x93, 0xb4, 0x29, 0x29, 0x53, 0x32, 0xf0,
0x8f, 0x64, 0x76, 0x6f, 0xef, 0x6e, 0xef, 0xb4, 0x12, 0xce, 0xa4, 0xa0, 0xb1, 0xbd, 0xbf, 0x7d,
0xef, 0xed, 0xef, 0x7d, 0xec, 0xdb, 0x77, 0x86, 0x4f, 0xfa, 0x61, 0xc8, 0x3c, 0x3f, 0x70, 0x79,
0xc8, 0x2e, 0x6b, 0x7f, 0x0f, 0x59, 0xc8, 0xc3, 0xcb, 0xf2, 0x67, 0xa4, 0xe3, 0x97, 0x24, 0x84,
0x6b, 0x1a, 0xe4, 0xfc, 0x89, 0xc0, 0x7e, 0x38, 0x74, 0xfb, 0xf4, 0xa1, 0xbf, 0x1f, 0x10, 0xfa,
0xdd, 0x88, 0x46, 0x1c, 0x37, 0x60, 0x21, 0x12, 0xd8, 0x96, 0xd7, 0x40, 0x1b, 0xa8, 0x53, 0x25,
0xc9, 0x12, 0xaf, 0xc3, 0xfc, 0x01, 0x75, 0x3d, 0xca, 0x1a, 0xd6, 0x06, 0xea, 0x2c, 0x11, 0xb5,
0xc2, 0x1b, 0x50, 0x0b, 0x07, 0xde, 0x96, 0x47, 0x03, 0xee, 0xf3, 0x71, 0xa3, 0x2c, 0x37, 0x75,
0x08, 0xf7, 0x60, 0x35, 0xa0, 0xcf, 0x93, 0xa5, 0x38, 0xcd, 0xe5, 0x23, 0x46, 0x1b, 0x15, 0x29,
0x6a, 0xdc, 0xc3, 0x0e, 0x2c, 0xed, 0x85, 0xac, 0x4f, 0x15, 0xaf, 0xc6, 0xdc, 0x06, 0xea, 0x2c,
0x92, 0x1c, 0xe6, 0x70, 0xc0, 0x31, 0x7f, 0xee, 0xf2, 0x51, 0xb4, 0xe3, 0x8e, 0x07, 0xa1, 0xeb,
0xe1, 0x2b, 0x30, 0x1f, 0x49, 0x40, 0x3a, 0x50, 0xef, 0x35, 0x2e, 0xe9, 0x71, 0xd0, 0x14, 0x88,
0x92, 0xc3, 0x1f, 0xc3, 0xb2, 0x47, 0x07, 0x94, 0xfb, 0x61, 0xf0, 0xc8, 0x3f, 0xa2, 0x11, 0x77,
0x8f, 0x86, 0xd2, 0xc9, 0x32, 0x99, 0xdc, 0x70, 0x76, 0x61, 0x59, 0x8b, 0x5a, 0x34, 0x0c, 0x83,
0x88, 0xe2, 0x1b, 0xb0, 0xc0, 0x68, 0x9f, 0xfa, 0x43, 0x2e, 0x4f, 0xad, 0xf5, 0x2e, 0x4c, 0x9e,
0x4a, 0x62, 0x81, 0xaf, 0x7c, 0x7e, 0x90, 0xfa, 0x49, 0x12, 0x35, 0xe7, 0x10, 0xde, 0x9b, 0x2a,
0x85, 0xaf, 0xc0, 0x4a, 0xa4, 0x6d, 0x2a, 0x57, 0xe5, 0x51, 0x4b, 0xc4, 0xb4, 0x85, 0x5b, 0x50,
0x8d, 0xd2, 0x40, 0xc7, 0x09, 0xcb, 0x00, 0xe7, 0x57, 0x04, 0x4b, 0xfa, 0x69, 0xb3, 0xd3, 0x3e,
0xa4, 0x94, 0x6d, 0x79, 0xd2, 0x4a, 0x95, 0xa8, 0x15, 0xee, 0xc0, 0x49, 0xb7, 0xdf, 0x0f, 0x47,
0x01, 0x2f, 0xa4, 0xbe, 0x08, 0x0b, 0x2a, 0x01, 0xe5, 0xcf, 0x43, 0x76, 0xb8, 0xe5, 0xc9, 0x9c,
0x57, 0x49, 0x06, 0xe0, 0x36, 0xc0, 0x33, 0x77, 0xe0, 0x7b, 0xbb, 0x01, 0xf7, 0x07, 0x32, 0xcd,
0x15, 0xa2, 0x21, 0xce, 0x13, 0x58, 0xfb, 0xc2, 0x1f, 0xd0, 0x7b, 0xfe, 0x91, 0xcf, 0x37, 0x0f,
0x68, 0xff, 0x30, 0xa9, 0x54, 0x03, 0x01, 0x64, 0x26, 0xa0, 0x39, 0x67, 0xe5, 0x9c, 0x73, 0xb6,
0x61, 0xbd, 0x68, 0x5c, 0x25, 0x74, 0x15, 0xe6, 0x06, 0x02, 0x95, 0x36, 0x2b, 0x24, 0x5e, 0x08,
0xb2, 0x11, 0x0f, 0x99, 0xbb, 0x4f, 0xbf, 0xa4, 0x63, 0x65, 0x4c, 0x43, 0x9c, 0xab, 0x70, 0x4a,
0x2b, 0xb0, 0x1c, 0xdd, 0xa9, 0x11, 0x76, 0x76, 0xa1, 0x31, 0xa9, 0xa4, 0x68, 0x5c, 0x83, 0x85,
0xa1, 0x96, 0xec, 0x5a, 0xef, 0xec, 0xb4, 0x6a, 0x56, 0x89, 0x27, 0x89, 0xbc, 0x73, 0x0d, 0x4e,
0x17, 0xcd, 0xde, 0x77, 0x83, 0x71, 0xc2, 0xa7, 0x09, 0x8b, 0x8a, 0x80, 0xb8, 0x28, 0xe5, 0x4e,
0x95, 0xa4, 0x6b, 0xe7, 0x09, 0xb4, 0xcc, 0xaa, 0x8a, 0xd5, 0x75, 0x58, 0x54, 0xa7, 0xc4, 0xba,
0xc7, 0xa0, 0x95, 0x2a, 0x38, 0xaf, 0x50, 0xc1, 0x5f, 0x37, 0xd8, 0xa7, 0x6f, 0x6f, 0x3f, 0xda,
0x25, 0x55, 0x36, 0xd3, 0x74, 0x4e, 0x6e, 0x88, 0xe2, 0x28, 0x80, 0x49, 0x75, 0x16, 0x60, 0x4c,
0x60, 0xa5, 0x00, 0x3d, 0x1a, 0x0f, 0xe3, 0xde, 0x54, 0xef, 0x6d, 0xe4, 0xdc, 0xba, 0x3d, 0x29,
0x47, 0x4c, 0xca, 0xce, 0x63, 0x75, 0x97, 0xf3, 0x1e, 0xfe, 0xff, 0x94, 0x5e, 0x87, 0xd3, 0xdb,
0xf1, 0xc5, 0xd9, 0x0c, 0x83, 0x3d, 0x7f, 0x7f, 0xc4, 0x5c, 0x71, 0x74, 0x12, 0xbc, 0x16, 0x54,
0xfb, 0x23, 0xc6, 0xa8, 0x28, 0x7d, 0x15, 0xbe, 0x0c, 0x70, 0xfe, 0x40, 0xd0, 0x32, 0x6b, 0x2b,
0x62, 0x1d, 0x38, 0xd9, 0xd7, 0x37, 0x52, 0x23, 0x45, 0x38, 0x7f, 0xa3, 0xad, 0xe2, 0x8d, 0xfe,
0x10, 0xe6, 0x82, 0xd0, 0xa3, 0x51, 0xa3, 0x2c, 0x4b, 0x63, 0x39, 0xe7, 0xde, 0x76, 0xe8, 0x51,
0x12, 0xef, 0xe3, 0x2e, 0xd8, 0x7d, 0x46, 0xdd, 0xa4, 0xbd, 0xee, 0x06, 0xfe, 0x0b, 0x19, 0xf7,
0x0a, 0x99, 0xc0, 0x1d, 0x1f, 0x2a, 0x42, 0x55, 0x6b, 0x47, 0x28, 0xd7, 0x8e, 0x5a, 0x50, 0x75,
0x3d, 0x8f, 0xd1, 0x28, 0xa2, 0x51, 0xc3, 0x92, 0xf5, 0x9c, 0x01, 0xf8, 0x23, 0x98, 0xe3, 0xe3,
0xa1, 0xa2, 0x54, 0xef, 0xad, 0x4d, 0x50, 0x92, 0xb9, 0x8c, 0x65, 0x9c, 0x23, 0x38, 0x97, 0x64,
0x5a, 0x06, 0x8a, 0x1d, 0xa9, 0x44, 0xe4, 0x7b, 0xb2, 0xa1, 0xc4, 0x90, 0xb9, 0xc4, 0x66, 0xf7,
0xe2, 0xdf, 0x11, 0xac, 0x9b, 0xcf, 0x7b, 0x87, 0x5d, 0xb9, 0x05, 0x55, 0x9e, 0x3e, 0x85, 0x73,
0xf2, 0x29, 0xcc, 0x00, 0xe7, 0x36, 0xe0, 0x84, 0xf1, 0xbd, 0x70, 0x5f, 0xbb, 0xbb, 0xee, 0x1e,
0xd7, 0x72, 0x93, 0x2c, 0xb3, 0x66, 0x2a, 0xc8, 0x9e, 0x50, 0xcd, 0xd4, 0xf1, 0x61, 0x25, 0x67,
0x45, 0x95, 0xe1, 0x67, 0xf2, 0x29, 0x0d, 0x59, 0xda, 0x5b, 0xda, 0xc6, 0x4b, 0x28, 0x55, 0x84,
0x18, 0x49, 0xc4, 0x05, 0x81, 0x03, 0x37, 0xba, 0x1f, 0xaa, 0x28, 0x2f, 0x92, 0x64, 0xe9, 0xfc,
0x8c, 0x60, 0x79, 0x42, 0x11, 0xd7, 0xc1, 0xf2, 0x13, 0xae, 0x96, 0xef, 0x4d, 0x7f, 0x27, 0xf0,
0xe7, 0xe9, 0x4c, 0x51, 0x96, 0x7d, 0xe1, 0xfc, 0x6c, 0x4a, 0x85, 0xf9, 0x22, 0x17, 0xcc, 0x4a,
0x31, 0x98, 0x3f, 0x20, 0x35, 0xc6, 0x48, 0x33, 0xef, 0xae, 0x13, 0x3a, 0x5b, 0xb0, 0x92, 0xe3,
0xa1, 0xf2, 0xd1, 0x83, 0x55, 0x1e, 0xde, 0x52, 0xa8, 0x97, 0x0d, 0x48, 0x48, 0x3a, 0x62, 0xdc,
0x73, 0x02, 0x58, 0xbd, 0x19, 0xd7, 0x5b, 0xde, 0x29, 0x23, 0x75, 0xf4, 0x1f, 0xa8, 0x5b, 0x66,
0xea, 0xbf, 0x20, 0x38, 0xa3, 0x1f, 0x38, 0x79, 0x95, 0xa6, 0xf5, 0x0d, 0xc3, 0x85, 0xb1, 0x8e,
0x71, 0x61, 0xca, 0x33, 0x2f, 0xcc, 0x44, 0x8e, 0xef, 0xc0, 0x5a, 0x21, 0x1e, 0x2a, 0xb8, 0xc6,
0xd1, 0x13, 0x4d, 0x1b, 0x3d, 0xdb, 0xd0, 0x52, 0x66, 0x08, 0x7d, 0x46, 0x59, 0xea, 0x6b, 0x32,
0x10, 0x9f, 0x4d, 0xa3, 0x50, 0xdc, 0x8f, 0x8f, 0xeb, 0xfe, 0x84, 0x00, 0xee, 0x30, 0x16, 0xb2,
0x4d, 0xd9, 0x80, 0xeb, 0x00, 0xbb, 0x01, 0x7d, 0x31, 0xa4, 0x7d, 0x4e, 0x3d, 0xbb, 0x84, 0x6d,
0x35, 0x15, 0xaa, 0x7c, 0xda, 0x08, 0x37, 0x60, 0x35, 0x43, 0x44, 0xc0, 0x69, 0xe0, 0xf9, 0xc1,
0xbe, 0x6d, 0xa5, 0xb2, 0x9b, 0xa2, 0x53, 0x53, 0xcf, 0x2e, 0x63, 0x0c, 0x75, 0x89, 0x6c, 0x87,
0xfc, 0xce, 0x0b, 0x3f, 0xe2, 0x91, 0x5d, 0xc1, 0x6b, 0x6a, 0x58, 0x96, 0x13, 0x16, 0xa1, 0x6e,
0xff, 0x80, 0x7a, 0xf6, 0x1c, 0xb6, 0xa1, 0x26, 0x69, 0x3c, 0xd8, 0xdb, 0x8b, 0x28, 0xb7, 0x7f,
0xb3, 0xba, 0xdf, 0x43, 0x4d, 0x7b, 0xf9, 0xf0, 0x7a, 0x6e, 0xb4, 0x4f, 0xce, 0x28, 0xe1, 0x36,
0x34, 0xf5, 0x07, 0x32, 0x66, 0x93, 0x90, 0xb3, 0x51, 0x61, 0x3f, 0xd9, 0x78, 0xc8, 0x5d, 0x26,
0xf4, 0xad, 0x82, 0xdd, 0xc4, 0xcf, 0x72, 0xf7, 0x2e, 0x2c, 0x26, 0xcf, 0x00, 0xae, 0xc1, 0xc2,
0x23, 0x46, 0xe9, 0xcd, 0x9d, 0x2d, 0xbb, 0x24, 0x16, 0x62, 0x42, 0x14, 0x0b, 0x24, 0x3c, 0xdc,
0xcc, 0xee, 0xbd, 0xc0, 0x64, 0x1c, 0x36, 0x45, 0x6c, 0x83, 0x68, 0x14, 0x09, 0xa4, 0xdc, 0xbd,
0x96, 0xf5, 0x35, 0x6d, 0x28, 0xc0, 0x8b, 0x50, 0x11, 0x66, 0x63, 0x9b, 0xaa, 0x3a, 0x6d, 0x24,
0x16, 0x2a, 0x67, 0xb6, 0xd5, 0xbd, 0x01, 0xa7, 0xa6, 0x34, 0x13, 0x3c, 0x0f, 0xd6, 0x83, 0x43,
0xbb, 0x84, 0x97, 0xe1, 0x04, 0xa1, 0x47, 0xe1, 0x33, 0xba, 0xc3, 0xe8, 0xd0, 0x65, 0xd4, 0x46,
0x18, 0x60, 0x3e, 0x86, 0x6c, 0xab, 0xf7, 0xd7, 0x02, 0xd4, 0x34, 0x8e, 0xf8, 0x2e, 0x54, 0xd3,
0xaf, 0x15, 0x7c, 0xc6, 0x30, 0x69, 0x64, 0xdf, 0x7e, 0xcd, 0xf6, 0xb4, 0x6d, 0x55, 0xac, 0x5f,
0x43, 0x3d, 0x3f, 0x2d, 0x63, 0x27, 0xa7, 0x61, 0x9c, 0xd3, 0x9b, 0xe7, 0x66, 0xca, 0x28, 0xd3,
0xdf, 0x26, 0x9f, 0xa2, 0xd9, 0xc4, 0x89, 0xcf, 0x4f, 0x9b, 0x8b, 0x72, 0xe6, 0x3f, 0x78, 0x8b,
0x94, 0x3a, 0xe0, 0x50, 0x15, 0x72, 0x61, 0xa4, 0xc5, 0x9d, 0x99, 0xea, 0xda, 0xc0, 0xdc, 0xbc,
0x78, 0x0c, 0x49, 0x75, 0xd8, 0xd3, 0xe4, 0x13, 0x51, 0x9b, 0xff, 0xf0, 0x0c, 0xa2, 0xda, 0x04,
0xdc, 0xbc, 0xf0, 0x36, 0xb1, 0xcc, 0x21, 0xd3, 0x34, 0x57, 0x70, 0x68, 0xc6, 0xb8, 0x58, 0x70,
0x68, 0xe6, 0x68, 0xb8, 0x03, 0x35, 0xad, 0x2e, 0xf1, 0xd9, 0xe9, 0xcf, 0x5f, 0x6c, 0x7a, 0x63,
0xba, 0x40, 0x66, 0x51, 0x6b, 0x35, 0xd8, 0x30, 0x03, 0xe7, 0x5e, 0x8e, 0x82, 0x45, 0xd3, 0x3b,
0xf5, 0x18, 0x4e, 0xe4, 0x7a, 0x2c, 0x7e, 0x3f, 0xa7, 0x62, 0x7a, 0x8f, 0x9a, 0xce, 0x2c, 0x11,
0x65, 0x37, 0x48, 0x7b, 0x77, 0xbe, 0xa9, 0xe2, 0x8b, 0x26, 0x65, 0x63, 0x63, 0x6e, 0x76, 0x8f,
0x23, 0x1a, 0x9f, 0x77, 0xeb, 0xd3, 0xbf, 0x5f, 0xb7, 0xd1, 0xcb, 0xd7, 0x6d, 0xf4, 0xea, 0x75,
0x1b, 0xfd, 0xf8, 0xa6, 0x5d, 0x7a, 0xf9, 0xa6, 0x5d, 0xfa, 0xe7, 0x4d, 0xbb, 0xf4, 0x4d, 0x6b,
0xd6, 0x3f, 0x7d, 0x9e, 0xce, 0xcb, 0x5f, 0x57, 0xff, 0x0d, 0x00, 0x00, 0xff, 0xff, 0x70, 0x37,
0x0b, 0x83, 0x1b, 0x12, 0x00, 0x00,
}
func (m *SpaceSignRequest) Marshal() (dAtA []byte, err error) {
@ -2232,11 +2334,6 @@ func (m *SpaceStatusChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error
_ = i
var l int
_ = l
if m.DeletionDuration != 0 {
i = encodeVarintCoordinator(dAtA, i, uint64(m.DeletionDuration))
i--
dAtA[i] = 0x28
}
if m.DeletionPayloadType != 0 {
i = encodeVarintCoordinator(dAtA, i, uint64(m.DeletionPayloadType))
i--
@ -2666,6 +2763,78 @@ func (m *DeletionLogRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) {
return len(dAtA) - i, nil
}
func (m *SpaceDeleteRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *SpaceDeleteRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *SpaceDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.DeletionPayload) > 0 {
i -= len(m.DeletionPayload)
copy(dAtA[i:], m.DeletionPayload)
i = encodeVarintCoordinator(dAtA, i, uint64(len(m.DeletionPayload)))
i--
dAtA[i] = 0x1a
}
if len(m.DeletionPayloadId) > 0 {
i -= len(m.DeletionPayloadId)
copy(dAtA[i:], m.DeletionPayloadId)
i = encodeVarintCoordinator(dAtA, i, uint64(len(m.DeletionPayloadId)))
i--
dAtA[i] = 0x12
}
if len(m.SpaceId) > 0 {
i -= len(m.SpaceId)
copy(dAtA[i:], m.SpaceId)
i = encodeVarintCoordinator(dAtA, i, uint64(len(m.SpaceId)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *SpaceDeleteResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *SpaceDeleteResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *SpaceDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.ToBeDeletedTimestamp != 0 {
i = encodeVarintCoordinator(dAtA, i, uint64(m.ToBeDeletedTimestamp))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
}
func (m *AccountDeleteRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
@ -3048,9 +3217,6 @@ func (m *SpaceStatusChangeRequest) Size() (n int) {
if m.DeletionPayloadType != 0 {
n += 1 + sovCoordinator(uint64(m.DeletionPayloadType))
}
if m.DeletionDuration != 0 {
n += 1 + sovCoordinator(uint64(m.DeletionDuration))
}
return n
}
@ -3234,6 +3400,39 @@ func (m *DeletionLogRecord) Size() (n int) {
return n
}
func (m *SpaceDeleteRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.SpaceId)
if l > 0 {
n += 1 + l + sovCoordinator(uint64(l))
}
l = len(m.DeletionPayloadId)
if l > 0 {
n += 1 + l + sovCoordinator(uint64(l))
}
l = len(m.DeletionPayload)
if l > 0 {
n += 1 + l + sovCoordinator(uint64(l))
}
return n
}
func (m *SpaceDeleteResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.ToBeDeletedTimestamp != 0 {
n += 1 + sovCoordinator(uint64(m.ToBeDeletedTimestamp))
}
return n
}
func (m *AccountDeleteRequest) Size() (n int) {
if m == nil {
return 0
@ -4703,25 +4902,6 @@ func (m *SpaceStatusChangeRequest) Unmarshal(dAtA []byte) error {
break
}
}
case 5:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field DeletionDuration", wireType)
}
m.DeletionDuration = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.DeletionDuration |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipCoordinator(dAtA[iNdEx:])
@ -5935,6 +6115,223 @@ func (m *DeletionLogRecord) Unmarshal(dAtA []byte) error {
}
return nil
}
func (m *SpaceDeleteRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: SpaceDeleteRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: SpaceDeleteRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field SpaceId", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCoordinator
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthCoordinator
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.SpaceId = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field DeletionPayloadId", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCoordinator
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthCoordinator
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.DeletionPayloadId = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field DeletionPayload", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthCoordinator
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthCoordinator
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.DeletionPayload = append(m.DeletionPayload[:0], dAtA[iNdEx:postIndex]...)
if m.DeletionPayload == nil {
m.DeletionPayload = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipCoordinator(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCoordinator
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *SpaceDeleteResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: SpaceDeleteResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: SpaceDeleteResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ToBeDeletedTimestamp", wireType)
}
m.ToBeDeletedTimestamp = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCoordinator
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ToBeDeletedTimestamp |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipCoordinator(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCoordinator
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *AccountDeleteRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0

44
coordinator/coordinatorproto/coordinator_drpc.pb.go
View file

@ -47,6 +47,7 @@ type DRPCCoordinatorClient interface {
SpaceStatusChange(ctx context.Context, in *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, 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)
AccountDelete(ctx context.Context, in *AccountDeleteRequest) (*AccountDeleteResponse, error)
AccountRevertDeletion(ctx context.Context, in *AccountRevertDeletionRequest) (*AccountRevertDeletionResponse, error)
}
@ -124,6 +125,15 @@ func (c *drpcCoordinatorClient) DeletionLog(ctx context.Context, in *DeletionLog
return out, nil
}
func (c *drpcCoordinatorClient) SpaceDelete(ctx context.Context, in *SpaceDeleteRequest) (*SpaceDeleteResponse, error) {
out := new(SpaceDeleteResponse)
err := c.cc.Invoke(ctx, "/coordinator.Coordinator/SpaceDelete", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}, in, out)
if err != nil {
return nil, err
}
return out, nil
}
func (c *drpcCoordinatorClient) AccountDelete(ctx context.Context, in *AccountDeleteRequest) (*AccountDeleteResponse, error) {
out := new(AccountDeleteResponse)
err := c.cc.Invoke(ctx, "/coordinator.Coordinator/AccountDelete", drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}, in, out)
@ -150,6 +160,7 @@ type DRPCCoordinatorServer interface {
SpaceStatusChange(context.Context, *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
DeletionLog(context.Context, *DeletionLogRequest) (*DeletionLogResponse, error)
SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error)
AccountDelete(context.Context, *AccountDeleteRequest) (*AccountDeleteResponse, error)
AccountRevertDeletion(context.Context, *AccountRevertDeletionRequest) (*AccountRevertDeletionResponse, error)
}
@ -184,6 +195,10 @@ func (s *DRPCCoordinatorUnimplementedServer) DeletionLog(context.Context, *Delet
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
}
func (s *DRPCCoordinatorUnimplementedServer) SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error) {
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
}
func (s *DRPCCoordinatorUnimplementedServer) AccountDelete(context.Context, *AccountDeleteRequest) (*AccountDeleteResponse, error) {
return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
}
@ -194,7 +209,7 @@ func (s *DRPCCoordinatorUnimplementedServer) AccountRevertDeletion(context.Conte
type DRPCCoordinatorDescription struct{}
func (DRPCCoordinatorDescription) NumMethods() int { return 9 }
func (DRPCCoordinatorDescription) NumMethods() int { return 10 }
func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) {
switch n {
@ -262,6 +277,15 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
)
}, DRPCCoordinatorServer.DeletionLog, true
case 7:
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).
SpaceDelete(
ctx,
in1.(*SpaceDeleteRequest),
)
}, DRPCCoordinatorServer.SpaceDelete, true
case 8:
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).
@ -270,7 +294,7 @@ func (DRPCCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Rec
in1.(*AccountDeleteRequest),
)
}, DRPCCoordinatorServer.AccountDelete, true
case 8:
case 9:
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).
@ -400,6 +424,22 @@ func (x *drpcCoordinator_DeletionLogStream) SendAndClose(m *DeletionLogResponse)
return x.CloseSend()
}
type DRPCCoordinator_SpaceDeleteStream interface {
drpc.Stream
SendAndClose(*SpaceDeleteResponse) error
}
type drpcCoordinator_SpaceDeleteStream struct {
drpc.Stream
}
func (x *drpcCoordinator_SpaceDeleteStream) SendAndClose(m *SpaceDeleteResponse) error {
if err := x.MsgSend(m, drpcEncoding_File_coordinator_coordinatorproto_protos_coordinator_proto{}); err != nil {
return err
}
return x.CloseSend()
}
type DRPCCoordinator_AccountDeleteStream interface {
drpc.Stream
SendAndClose(*AccountDeleteResponse) error

18
coordinator/coordinatorproto/protos/coordinator.proto
View file

@ -19,7 +19,7 @@ service Coordinator {
// SpaceStatusCheckMany checks the statuses of spaces and tells if they are deleted or not
rpc SpaceStatusCheckMany(SpaceStatusCheckManyRequest) returns (SpaceStatusCheckManyResponse);
// SpaceStatusChange changes the status of space
// SpaceStatusChange changes the status of space - Deprecated
rpc SpaceStatusChange(SpaceStatusChangeRequest) returns (SpaceStatusChangeResponse);
// NetworkConfiguration retrieves the latest network configuration
@ -28,6 +28,9 @@ service Coordinator {
// DeletionLog gets the latest deletion log records
rpc DeletionLog(DeletionLogRequest) returns (DeletionLogResponse);
// SpaceDelete deletes a space
rpc SpaceDelete(SpaceDeleteRequest) returns (SpaceDeleteResponse);
// AccountDelete deletes an account
rpc AccountDelete(AccountDeleteRequest) returns (AccountDeleteResponse);
@ -135,7 +138,6 @@ message SpaceStatusChangeRequest {
string deletionPayloadId = 2;
bytes deletionPayload = 3;
DeletionPayloadType deletionPayloadType = 4;
int64 deletionDuration = 5;
}
// SpaceStatusChangeResponse contains changed status of space
@ -246,6 +248,18 @@ enum DeletionLogRecordStatus {
Remove = 2;
}
// SpaceDeleteRequest contains the deletion confirmation for the space to be deleted
message SpaceDeleteRequest {
string spaceId = 1;
string deletionPayloadId = 2;
bytes deletionPayload = 3;
}
// SpaceDeleteResponse contains timestamp when the space is finally deleted
message SpaceDeleteResponse {
int64 toBeDeletedTimestamp = 1;
}
// AccountDeleteRequest contains payload for account deletion
message AccountDeleteRequest {
string deletionPayloadId = 1;