1// Code generated by protoc-gen-gogo. DO NOT EDIT. 2// source: piecestore2.proto 3 4package pb 5 6import ( 7 fmt "fmt" 8 math "math" 9 time "time" 10 11 proto "github.com/gogo/protobuf/proto" 12) 13 14// Reference imports to suppress errors if they are not otherwise used. 15var _ = proto.Marshal 16var _ = fmt.Errorf 17var _ = math.Inf 18var _ = time.Kitchen 19 20// This is a compile-time assertion to ensure that this generated file 21// is compatible with the proto package it is being compiled against. 22// A compilation error at this line likely means your copy of the 23// proto package needs to be updated. 24const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package 25 26type PieceHeader_FormatVersion int32 27 28const ( 29 PieceHeader_FORMAT_V0 PieceHeader_FormatVersion = 0 30 PieceHeader_FORMAT_V1 PieceHeader_FormatVersion = 1 31) 32 33var PieceHeader_FormatVersion_name = map[int32]string{ 34 0: "FORMAT_V0", 35 1: "FORMAT_V1", 36} 37 38var PieceHeader_FormatVersion_value = map[string]int32{ 39 "FORMAT_V0": 0, 40 "FORMAT_V1": 1, 41} 42 43func (x PieceHeader_FormatVersion) String() string { 44 return proto.EnumName(PieceHeader_FormatVersion_name, int32(x)) 45} 46 47func (PieceHeader_FormatVersion) EnumDescriptor() ([]byte, []int) { 48 return fileDescriptor_23ff32dd550c2439, []int{12, 0} 49} 50 51// Expected order of messages from uplink: 52// OrderLimit -> 53// repeated 54// Order -> 55// Chunk -> 56// PieceHash signed by uplink -> 57// <- PieceHash signed by storage node 58type PieceUploadRequest struct { 59 // first message to show that we are allowed to upload 60 Limit *OrderLimit `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"` 61 // order for uploading 62 Order *Order `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"` 63 Chunk *PieceUploadRequest_Chunk `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"` 64 // final message 65 Done *PieceHash `protobuf:"bytes,4,opt,name=done,proto3" json:"done,omitempty"` 66 XXX_NoUnkeyedLiteral struct{} `json:"-"` 67 XXX_unrecognized []byte `json:"-"` 68 XXX_sizecache int32 `json:"-"` 69} 70 71func (m *PieceUploadRequest) Reset() { *m = PieceUploadRequest{} } 72func (m *PieceUploadRequest) String() string { return proto.CompactTextString(m) } 73func (*PieceUploadRequest) ProtoMessage() {} 74func (*PieceUploadRequest) Descriptor() ([]byte, []int) { 75 return fileDescriptor_23ff32dd550c2439, []int{0} 76} 77func (m *PieceUploadRequest) XXX_Unmarshal(b []byte) error { 78 return xxx_messageInfo_PieceUploadRequest.Unmarshal(m, b) 79} 80func (m *PieceUploadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 81 return xxx_messageInfo_PieceUploadRequest.Marshal(b, m, deterministic) 82} 83func (m *PieceUploadRequest) XXX_Merge(src proto.Message) { 84 xxx_messageInfo_PieceUploadRequest.Merge(m, src) 85} 86func (m *PieceUploadRequest) XXX_Size() int { 87 return xxx_messageInfo_PieceUploadRequest.Size(m) 88} 89func (m *PieceUploadRequest) XXX_DiscardUnknown() { 90 xxx_messageInfo_PieceUploadRequest.DiscardUnknown(m) 91} 92 93var xxx_messageInfo_PieceUploadRequest proto.InternalMessageInfo 94 95func (m *PieceUploadRequest) GetLimit() *OrderLimit { 96 if m != nil { 97 return m.Limit 98 } 99 return nil 100} 101 102func (m *PieceUploadRequest) GetOrder() *Order { 103 if m != nil { 104 return m.Order 105 } 106 return nil 107} 108 109func (m *PieceUploadRequest) GetChunk() *PieceUploadRequest_Chunk { 110 if m != nil { 111 return m.Chunk 112 } 113 return nil 114} 115 116func (m *PieceUploadRequest) GetDone() *PieceHash { 117 if m != nil { 118 return m.Done 119 } 120 return nil 121} 122 123// data message 124type PieceUploadRequest_Chunk struct { 125 Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` 126 Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 127 XXX_NoUnkeyedLiteral struct{} `json:"-"` 128 XXX_unrecognized []byte `json:"-"` 129 XXX_sizecache int32 `json:"-"` 130} 131 132func (m *PieceUploadRequest_Chunk) Reset() { *m = PieceUploadRequest_Chunk{} } 133func (m *PieceUploadRequest_Chunk) String() string { return proto.CompactTextString(m) } 134func (*PieceUploadRequest_Chunk) ProtoMessage() {} 135func (*PieceUploadRequest_Chunk) Descriptor() ([]byte, []int) { 136 return fileDescriptor_23ff32dd550c2439, []int{0, 0} 137} 138func (m *PieceUploadRequest_Chunk) XXX_Unmarshal(b []byte) error { 139 return xxx_messageInfo_PieceUploadRequest_Chunk.Unmarshal(m, b) 140} 141func (m *PieceUploadRequest_Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 142 return xxx_messageInfo_PieceUploadRequest_Chunk.Marshal(b, m, deterministic) 143} 144func (m *PieceUploadRequest_Chunk) XXX_Merge(src proto.Message) { 145 xxx_messageInfo_PieceUploadRequest_Chunk.Merge(m, src) 146} 147func (m *PieceUploadRequest_Chunk) XXX_Size() int { 148 return xxx_messageInfo_PieceUploadRequest_Chunk.Size(m) 149} 150func (m *PieceUploadRequest_Chunk) XXX_DiscardUnknown() { 151 xxx_messageInfo_PieceUploadRequest_Chunk.DiscardUnknown(m) 152} 153 154var xxx_messageInfo_PieceUploadRequest_Chunk proto.InternalMessageInfo 155 156func (m *PieceUploadRequest_Chunk) GetOffset() int64 { 157 if m != nil { 158 return m.Offset 159 } 160 return 0 161} 162 163func (m *PieceUploadRequest_Chunk) GetData() []byte { 164 if m != nil { 165 return m.Data 166 } 167 return nil 168} 169 170type PieceUploadResponse struct { 171 Done *PieceHash `protobuf:"bytes,1,opt,name=done,proto3" json:"done,omitempty"` 172 XXX_NoUnkeyedLiteral struct{} `json:"-"` 173 XXX_unrecognized []byte `json:"-"` 174 XXX_sizecache int32 `json:"-"` 175} 176 177func (m *PieceUploadResponse) Reset() { *m = PieceUploadResponse{} } 178func (m *PieceUploadResponse) String() string { return proto.CompactTextString(m) } 179func (*PieceUploadResponse) ProtoMessage() {} 180func (*PieceUploadResponse) Descriptor() ([]byte, []int) { 181 return fileDescriptor_23ff32dd550c2439, []int{1} 182} 183func (m *PieceUploadResponse) XXX_Unmarshal(b []byte) error { 184 return xxx_messageInfo_PieceUploadResponse.Unmarshal(m, b) 185} 186func (m *PieceUploadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 187 return xxx_messageInfo_PieceUploadResponse.Marshal(b, m, deterministic) 188} 189func (m *PieceUploadResponse) XXX_Merge(src proto.Message) { 190 xxx_messageInfo_PieceUploadResponse.Merge(m, src) 191} 192func (m *PieceUploadResponse) XXX_Size() int { 193 return xxx_messageInfo_PieceUploadResponse.Size(m) 194} 195func (m *PieceUploadResponse) XXX_DiscardUnknown() { 196 xxx_messageInfo_PieceUploadResponse.DiscardUnknown(m) 197} 198 199var xxx_messageInfo_PieceUploadResponse proto.InternalMessageInfo 200 201func (m *PieceUploadResponse) GetDone() *PieceHash { 202 if m != nil { 203 return m.Done 204 } 205 return nil 206} 207 208// Expected order of messages from uplink: 209// {OrderLimit, Chunk} -> 210// go repeated 211// Order -> (async) 212// go repeated 213// <- PieceDownloadResponse.Chunk 214type PieceDownloadRequest struct { 215 // first message to show that we are allowed to upload 216 Limit *OrderLimit `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"` 217 // order for downloading 218 Order *Order `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"` 219 // request for the chunk 220 Chunk *PieceDownloadRequest_Chunk `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"` 221 XXX_NoUnkeyedLiteral struct{} `json:"-"` 222 XXX_unrecognized []byte `json:"-"` 223 XXX_sizecache int32 `json:"-"` 224} 225 226func (m *PieceDownloadRequest) Reset() { *m = PieceDownloadRequest{} } 227func (m *PieceDownloadRequest) String() string { return proto.CompactTextString(m) } 228func (*PieceDownloadRequest) ProtoMessage() {} 229func (*PieceDownloadRequest) Descriptor() ([]byte, []int) { 230 return fileDescriptor_23ff32dd550c2439, []int{2} 231} 232func (m *PieceDownloadRequest) XXX_Unmarshal(b []byte) error { 233 return xxx_messageInfo_PieceDownloadRequest.Unmarshal(m, b) 234} 235func (m *PieceDownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 236 return xxx_messageInfo_PieceDownloadRequest.Marshal(b, m, deterministic) 237} 238func (m *PieceDownloadRequest) XXX_Merge(src proto.Message) { 239 xxx_messageInfo_PieceDownloadRequest.Merge(m, src) 240} 241func (m *PieceDownloadRequest) XXX_Size() int { 242 return xxx_messageInfo_PieceDownloadRequest.Size(m) 243} 244func (m *PieceDownloadRequest) XXX_DiscardUnknown() { 245 xxx_messageInfo_PieceDownloadRequest.DiscardUnknown(m) 246} 247 248var xxx_messageInfo_PieceDownloadRequest proto.InternalMessageInfo 249 250func (m *PieceDownloadRequest) GetLimit() *OrderLimit { 251 if m != nil { 252 return m.Limit 253 } 254 return nil 255} 256 257func (m *PieceDownloadRequest) GetOrder() *Order { 258 if m != nil { 259 return m.Order 260 } 261 return nil 262} 263 264func (m *PieceDownloadRequest) GetChunk() *PieceDownloadRequest_Chunk { 265 if m != nil { 266 return m.Chunk 267 } 268 return nil 269} 270 271// Chunk that we wish to download 272type PieceDownloadRequest_Chunk struct { 273 Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` 274 ChunkSize int64 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"` 275 XXX_NoUnkeyedLiteral struct{} `json:"-"` 276 XXX_unrecognized []byte `json:"-"` 277 XXX_sizecache int32 `json:"-"` 278} 279 280func (m *PieceDownloadRequest_Chunk) Reset() { *m = PieceDownloadRequest_Chunk{} } 281func (m *PieceDownloadRequest_Chunk) String() string { return proto.CompactTextString(m) } 282func (*PieceDownloadRequest_Chunk) ProtoMessage() {} 283func (*PieceDownloadRequest_Chunk) Descriptor() ([]byte, []int) { 284 return fileDescriptor_23ff32dd550c2439, []int{2, 0} 285} 286func (m *PieceDownloadRequest_Chunk) XXX_Unmarshal(b []byte) error { 287 return xxx_messageInfo_PieceDownloadRequest_Chunk.Unmarshal(m, b) 288} 289func (m *PieceDownloadRequest_Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 290 return xxx_messageInfo_PieceDownloadRequest_Chunk.Marshal(b, m, deterministic) 291} 292func (m *PieceDownloadRequest_Chunk) XXX_Merge(src proto.Message) { 293 xxx_messageInfo_PieceDownloadRequest_Chunk.Merge(m, src) 294} 295func (m *PieceDownloadRequest_Chunk) XXX_Size() int { 296 return xxx_messageInfo_PieceDownloadRequest_Chunk.Size(m) 297} 298func (m *PieceDownloadRequest_Chunk) XXX_DiscardUnknown() { 299 xxx_messageInfo_PieceDownloadRequest_Chunk.DiscardUnknown(m) 300} 301 302var xxx_messageInfo_PieceDownloadRequest_Chunk proto.InternalMessageInfo 303 304func (m *PieceDownloadRequest_Chunk) GetOffset() int64 { 305 if m != nil { 306 return m.Offset 307 } 308 return 0 309} 310 311func (m *PieceDownloadRequest_Chunk) GetChunkSize() int64 { 312 if m != nil { 313 return m.ChunkSize 314 } 315 return 0 316} 317 318type PieceDownloadResponse struct { 319 Chunk *PieceDownloadResponse_Chunk `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` 320 Hash *PieceHash `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` 321 Limit *OrderLimit `protobuf:"bytes,3,opt,name=limit,proto3" json:"limit,omitempty"` 322 XXX_NoUnkeyedLiteral struct{} `json:"-"` 323 XXX_unrecognized []byte `json:"-"` 324 XXX_sizecache int32 `json:"-"` 325} 326 327func (m *PieceDownloadResponse) Reset() { *m = PieceDownloadResponse{} } 328func (m *PieceDownloadResponse) String() string { return proto.CompactTextString(m) } 329func (*PieceDownloadResponse) ProtoMessage() {} 330func (*PieceDownloadResponse) Descriptor() ([]byte, []int) { 331 return fileDescriptor_23ff32dd550c2439, []int{3} 332} 333func (m *PieceDownloadResponse) XXX_Unmarshal(b []byte) error { 334 return xxx_messageInfo_PieceDownloadResponse.Unmarshal(m, b) 335} 336func (m *PieceDownloadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 337 return xxx_messageInfo_PieceDownloadResponse.Marshal(b, m, deterministic) 338} 339func (m *PieceDownloadResponse) XXX_Merge(src proto.Message) { 340 xxx_messageInfo_PieceDownloadResponse.Merge(m, src) 341} 342func (m *PieceDownloadResponse) XXX_Size() int { 343 return xxx_messageInfo_PieceDownloadResponse.Size(m) 344} 345func (m *PieceDownloadResponse) XXX_DiscardUnknown() { 346 xxx_messageInfo_PieceDownloadResponse.DiscardUnknown(m) 347} 348 349var xxx_messageInfo_PieceDownloadResponse proto.InternalMessageInfo 350 351func (m *PieceDownloadResponse) GetChunk() *PieceDownloadResponse_Chunk { 352 if m != nil { 353 return m.Chunk 354 } 355 return nil 356} 357 358func (m *PieceDownloadResponse) GetHash() *PieceHash { 359 if m != nil { 360 return m.Hash 361 } 362 return nil 363} 364 365func (m *PieceDownloadResponse) GetLimit() *OrderLimit { 366 if m != nil { 367 return m.Limit 368 } 369 return nil 370} 371 372// Chunk response for download request 373type PieceDownloadResponse_Chunk struct { 374 Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` 375 Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` 376 XXX_NoUnkeyedLiteral struct{} `json:"-"` 377 XXX_unrecognized []byte `json:"-"` 378 XXX_sizecache int32 `json:"-"` 379} 380 381func (m *PieceDownloadResponse_Chunk) Reset() { *m = PieceDownloadResponse_Chunk{} } 382func (m *PieceDownloadResponse_Chunk) String() string { return proto.CompactTextString(m) } 383func (*PieceDownloadResponse_Chunk) ProtoMessage() {} 384func (*PieceDownloadResponse_Chunk) Descriptor() ([]byte, []int) { 385 return fileDescriptor_23ff32dd550c2439, []int{3, 0} 386} 387func (m *PieceDownloadResponse_Chunk) XXX_Unmarshal(b []byte) error { 388 return xxx_messageInfo_PieceDownloadResponse_Chunk.Unmarshal(m, b) 389} 390func (m *PieceDownloadResponse_Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 391 return xxx_messageInfo_PieceDownloadResponse_Chunk.Marshal(b, m, deterministic) 392} 393func (m *PieceDownloadResponse_Chunk) XXX_Merge(src proto.Message) { 394 xxx_messageInfo_PieceDownloadResponse_Chunk.Merge(m, src) 395} 396func (m *PieceDownloadResponse_Chunk) XXX_Size() int { 397 return xxx_messageInfo_PieceDownloadResponse_Chunk.Size(m) 398} 399func (m *PieceDownloadResponse_Chunk) XXX_DiscardUnknown() { 400 xxx_messageInfo_PieceDownloadResponse_Chunk.DiscardUnknown(m) 401} 402 403var xxx_messageInfo_PieceDownloadResponse_Chunk proto.InternalMessageInfo 404 405func (m *PieceDownloadResponse_Chunk) GetOffset() int64 { 406 if m != nil { 407 return m.Offset 408 } 409 return 0 410} 411 412func (m *PieceDownloadResponse_Chunk) GetData() []byte { 413 if m != nil { 414 return m.Data 415 } 416 return nil 417} 418 419type PieceDeleteRequest struct { 420 Limit *OrderLimit `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"` 421 XXX_NoUnkeyedLiteral struct{} `json:"-"` 422 XXX_unrecognized []byte `json:"-"` 423 XXX_sizecache int32 `json:"-"` 424} 425 426func (m *PieceDeleteRequest) Reset() { *m = PieceDeleteRequest{} } 427func (m *PieceDeleteRequest) String() string { return proto.CompactTextString(m) } 428func (*PieceDeleteRequest) ProtoMessage() {} 429func (*PieceDeleteRequest) Descriptor() ([]byte, []int) { 430 return fileDescriptor_23ff32dd550c2439, []int{4} 431} 432func (m *PieceDeleteRequest) XXX_Unmarshal(b []byte) error { 433 return xxx_messageInfo_PieceDeleteRequest.Unmarshal(m, b) 434} 435func (m *PieceDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 436 return xxx_messageInfo_PieceDeleteRequest.Marshal(b, m, deterministic) 437} 438func (m *PieceDeleteRequest) XXX_Merge(src proto.Message) { 439 xxx_messageInfo_PieceDeleteRequest.Merge(m, src) 440} 441func (m *PieceDeleteRequest) XXX_Size() int { 442 return xxx_messageInfo_PieceDeleteRequest.Size(m) 443} 444func (m *PieceDeleteRequest) XXX_DiscardUnknown() { 445 xxx_messageInfo_PieceDeleteRequest.DiscardUnknown(m) 446} 447 448var xxx_messageInfo_PieceDeleteRequest proto.InternalMessageInfo 449 450func (m *PieceDeleteRequest) GetLimit() *OrderLimit { 451 if m != nil { 452 return m.Limit 453 } 454 return nil 455} 456 457type PieceDeleteResponse struct { 458 XXX_NoUnkeyedLiteral struct{} `json:"-"` 459 XXX_unrecognized []byte `json:"-"` 460 XXX_sizecache int32 `json:"-"` 461} 462 463func (m *PieceDeleteResponse) Reset() { *m = PieceDeleteResponse{} } 464func (m *PieceDeleteResponse) String() string { return proto.CompactTextString(m) } 465func (*PieceDeleteResponse) ProtoMessage() {} 466func (*PieceDeleteResponse) Descriptor() ([]byte, []int) { 467 return fileDescriptor_23ff32dd550c2439, []int{5} 468} 469func (m *PieceDeleteResponse) XXX_Unmarshal(b []byte) error { 470 return xxx_messageInfo_PieceDeleteResponse.Unmarshal(m, b) 471} 472func (m *PieceDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 473 return xxx_messageInfo_PieceDeleteResponse.Marshal(b, m, deterministic) 474} 475func (m *PieceDeleteResponse) XXX_Merge(src proto.Message) { 476 xxx_messageInfo_PieceDeleteResponse.Merge(m, src) 477} 478func (m *PieceDeleteResponse) XXX_Size() int { 479 return xxx_messageInfo_PieceDeleteResponse.Size(m) 480} 481func (m *PieceDeleteResponse) XXX_DiscardUnknown() { 482 xxx_messageInfo_PieceDeleteResponse.DiscardUnknown(m) 483} 484 485var xxx_messageInfo_PieceDeleteResponse proto.InternalMessageInfo 486 487type DeletePiecesRequest struct { 488 PieceIds []PieceID `protobuf:"bytes,1,rep,name=piece_ids,json=pieceIds,proto3,customtype=PieceID" json:"piece_ids"` 489 XXX_NoUnkeyedLiteral struct{} `json:"-"` 490 XXX_unrecognized []byte `json:"-"` 491 XXX_sizecache int32 `json:"-"` 492} 493 494func (m *DeletePiecesRequest) Reset() { *m = DeletePiecesRequest{} } 495func (m *DeletePiecesRequest) String() string { return proto.CompactTextString(m) } 496func (*DeletePiecesRequest) ProtoMessage() {} 497func (*DeletePiecesRequest) Descriptor() ([]byte, []int) { 498 return fileDescriptor_23ff32dd550c2439, []int{6} 499} 500func (m *DeletePiecesRequest) XXX_Unmarshal(b []byte) error { 501 return xxx_messageInfo_DeletePiecesRequest.Unmarshal(m, b) 502} 503func (m *DeletePiecesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 504 return xxx_messageInfo_DeletePiecesRequest.Marshal(b, m, deterministic) 505} 506func (m *DeletePiecesRequest) XXX_Merge(src proto.Message) { 507 xxx_messageInfo_DeletePiecesRequest.Merge(m, src) 508} 509func (m *DeletePiecesRequest) XXX_Size() int { 510 return xxx_messageInfo_DeletePiecesRequest.Size(m) 511} 512func (m *DeletePiecesRequest) XXX_DiscardUnknown() { 513 xxx_messageInfo_DeletePiecesRequest.DiscardUnknown(m) 514} 515 516var xxx_messageInfo_DeletePiecesRequest proto.InternalMessageInfo 517 518type DeletePiecesResponse struct { 519 UnhandledCount int64 `protobuf:"varint,1,opt,name=unhandled_count,json=unhandledCount,proto3" json:"unhandled_count,omitempty"` 520 XXX_NoUnkeyedLiteral struct{} `json:"-"` 521 XXX_unrecognized []byte `json:"-"` 522 XXX_sizecache int32 `json:"-"` 523} 524 525func (m *DeletePiecesResponse) Reset() { *m = DeletePiecesResponse{} } 526func (m *DeletePiecesResponse) String() string { return proto.CompactTextString(m) } 527func (*DeletePiecesResponse) ProtoMessage() {} 528func (*DeletePiecesResponse) Descriptor() ([]byte, []int) { 529 return fileDescriptor_23ff32dd550c2439, []int{7} 530} 531func (m *DeletePiecesResponse) XXX_Unmarshal(b []byte) error { 532 return xxx_messageInfo_DeletePiecesResponse.Unmarshal(m, b) 533} 534func (m *DeletePiecesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 535 return xxx_messageInfo_DeletePiecesResponse.Marshal(b, m, deterministic) 536} 537func (m *DeletePiecesResponse) XXX_Merge(src proto.Message) { 538 xxx_messageInfo_DeletePiecesResponse.Merge(m, src) 539} 540func (m *DeletePiecesResponse) XXX_Size() int { 541 return xxx_messageInfo_DeletePiecesResponse.Size(m) 542} 543func (m *DeletePiecesResponse) XXX_DiscardUnknown() { 544 xxx_messageInfo_DeletePiecesResponse.DiscardUnknown(m) 545} 546 547var xxx_messageInfo_DeletePiecesResponse proto.InternalMessageInfo 548 549func (m *DeletePiecesResponse) GetUnhandledCount() int64 { 550 if m != nil { 551 return m.UnhandledCount 552 } 553 return 0 554} 555 556type RetainRequest struct { 557 CreationDate time.Time `protobuf:"bytes,1,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"` 558 Filter []byte `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` 559 XXX_NoUnkeyedLiteral struct{} `json:"-"` 560 XXX_unrecognized []byte `json:"-"` 561 XXX_sizecache int32 `json:"-"` 562} 563 564func (m *RetainRequest) Reset() { *m = RetainRequest{} } 565func (m *RetainRequest) String() string { return proto.CompactTextString(m) } 566func (*RetainRequest) ProtoMessage() {} 567func (*RetainRequest) Descriptor() ([]byte, []int) { 568 return fileDescriptor_23ff32dd550c2439, []int{8} 569} 570func (m *RetainRequest) XXX_Unmarshal(b []byte) error { 571 return xxx_messageInfo_RetainRequest.Unmarshal(m, b) 572} 573func (m *RetainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 574 return xxx_messageInfo_RetainRequest.Marshal(b, m, deterministic) 575} 576func (m *RetainRequest) XXX_Merge(src proto.Message) { 577 xxx_messageInfo_RetainRequest.Merge(m, src) 578} 579func (m *RetainRequest) XXX_Size() int { 580 return xxx_messageInfo_RetainRequest.Size(m) 581} 582func (m *RetainRequest) XXX_DiscardUnknown() { 583 xxx_messageInfo_RetainRequest.DiscardUnknown(m) 584} 585 586var xxx_messageInfo_RetainRequest proto.InternalMessageInfo 587 588func (m *RetainRequest) GetCreationDate() time.Time { 589 if m != nil { 590 return m.CreationDate 591 } 592 return time.Time{} 593} 594 595func (m *RetainRequest) GetFilter() []byte { 596 if m != nil { 597 return m.Filter 598 } 599 return nil 600} 601 602type RetainResponse struct { 603 XXX_NoUnkeyedLiteral struct{} `json:"-"` 604 XXX_unrecognized []byte `json:"-"` 605 XXX_sizecache int32 `json:"-"` 606} 607 608func (m *RetainResponse) Reset() { *m = RetainResponse{} } 609func (m *RetainResponse) String() string { return proto.CompactTextString(m) } 610func (*RetainResponse) ProtoMessage() {} 611func (*RetainResponse) Descriptor() ([]byte, []int) { 612 return fileDescriptor_23ff32dd550c2439, []int{9} 613} 614func (m *RetainResponse) XXX_Unmarshal(b []byte) error { 615 return xxx_messageInfo_RetainResponse.Unmarshal(m, b) 616} 617func (m *RetainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 618 return xxx_messageInfo_RetainResponse.Marshal(b, m, deterministic) 619} 620func (m *RetainResponse) XXX_Merge(src proto.Message) { 621 xxx_messageInfo_RetainResponse.Merge(m, src) 622} 623func (m *RetainResponse) XXX_Size() int { 624 return xxx_messageInfo_RetainResponse.Size(m) 625} 626func (m *RetainResponse) XXX_DiscardUnknown() { 627 xxx_messageInfo_RetainResponse.DiscardUnknown(m) 628} 629 630var xxx_messageInfo_RetainResponse proto.InternalMessageInfo 631 632type RestoreTrashRequest struct { 633 XXX_NoUnkeyedLiteral struct{} `json:"-"` 634 XXX_unrecognized []byte `json:"-"` 635 XXX_sizecache int32 `json:"-"` 636} 637 638func (m *RestoreTrashRequest) Reset() { *m = RestoreTrashRequest{} } 639func (m *RestoreTrashRequest) String() string { return proto.CompactTextString(m) } 640func (*RestoreTrashRequest) ProtoMessage() {} 641func (*RestoreTrashRequest) Descriptor() ([]byte, []int) { 642 return fileDescriptor_23ff32dd550c2439, []int{10} 643} 644func (m *RestoreTrashRequest) XXX_Unmarshal(b []byte) error { 645 return xxx_messageInfo_RestoreTrashRequest.Unmarshal(m, b) 646} 647func (m *RestoreTrashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 648 return xxx_messageInfo_RestoreTrashRequest.Marshal(b, m, deterministic) 649} 650func (m *RestoreTrashRequest) XXX_Merge(src proto.Message) { 651 xxx_messageInfo_RestoreTrashRequest.Merge(m, src) 652} 653func (m *RestoreTrashRequest) XXX_Size() int { 654 return xxx_messageInfo_RestoreTrashRequest.Size(m) 655} 656func (m *RestoreTrashRequest) XXX_DiscardUnknown() { 657 xxx_messageInfo_RestoreTrashRequest.DiscardUnknown(m) 658} 659 660var xxx_messageInfo_RestoreTrashRequest proto.InternalMessageInfo 661 662type RestoreTrashResponse struct { 663 XXX_NoUnkeyedLiteral struct{} `json:"-"` 664 XXX_unrecognized []byte `json:"-"` 665 XXX_sizecache int32 `json:"-"` 666} 667 668func (m *RestoreTrashResponse) Reset() { *m = RestoreTrashResponse{} } 669func (m *RestoreTrashResponse) String() string { return proto.CompactTextString(m) } 670func (*RestoreTrashResponse) ProtoMessage() {} 671func (*RestoreTrashResponse) Descriptor() ([]byte, []int) { 672 return fileDescriptor_23ff32dd550c2439, []int{11} 673} 674func (m *RestoreTrashResponse) XXX_Unmarshal(b []byte) error { 675 return xxx_messageInfo_RestoreTrashResponse.Unmarshal(m, b) 676} 677func (m *RestoreTrashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 678 return xxx_messageInfo_RestoreTrashResponse.Marshal(b, m, deterministic) 679} 680func (m *RestoreTrashResponse) XXX_Merge(src proto.Message) { 681 xxx_messageInfo_RestoreTrashResponse.Merge(m, src) 682} 683func (m *RestoreTrashResponse) XXX_Size() int { 684 return xxx_messageInfo_RestoreTrashResponse.Size(m) 685} 686func (m *RestoreTrashResponse) XXX_DiscardUnknown() { 687 xxx_messageInfo_RestoreTrashResponse.DiscardUnknown(m) 688} 689 690var xxx_messageInfo_RestoreTrashResponse proto.InternalMessageInfo 691 692// PieceHeader is used in piece storage to keep track of piece attributes. 693type PieceHeader struct { 694 // the storage format version being used for this piece. The piece filename should agree with this. 695 // The inclusion of this field is intended to aid repairability when filenames are damaged. 696 FormatVersion PieceHeader_FormatVersion `protobuf:"varint,1,opt,name=format_version,json=formatVersion,proto3,enum=piecestore.PieceHeader_FormatVersion" json:"format_version,omitempty"` 697 // content hash of the piece 698 Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` 699 // timestamp when upload occurred, as given by the "timestamp" field in the original orders.PieceHash 700 CreationTime time.Time `protobuf:"bytes,3,opt,name=creation_time,json=creationTime,proto3,stdtime" json:"creation_time"` 701 // signature from uplink over the original orders.PieceHash (the corresponding PieceHashSigning 702 // is reconstructable using the piece id from the piecestore, the piece size from the 703 // filesystem (minus the piece header size), and these (hash, upload_time, signature) fields). 704 Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"` 705 // the OrderLimit authorizing storage of this piece, as signed by the satellite and sent by 706 // the uplink 707 OrderLimit OrderLimit `protobuf:"bytes,5,opt,name=order_limit,json=orderLimit,proto3" json:"order_limit"` 708 XXX_NoUnkeyedLiteral struct{} `json:"-"` 709 XXX_unrecognized []byte `json:"-"` 710 XXX_sizecache int32 `json:"-"` 711} 712 713func (m *PieceHeader) Reset() { *m = PieceHeader{} } 714func (m *PieceHeader) String() string { return proto.CompactTextString(m) } 715func (*PieceHeader) ProtoMessage() {} 716func (*PieceHeader) Descriptor() ([]byte, []int) { 717 return fileDescriptor_23ff32dd550c2439, []int{12} 718} 719func (m *PieceHeader) XXX_Unmarshal(b []byte) error { 720 return xxx_messageInfo_PieceHeader.Unmarshal(m, b) 721} 722func (m *PieceHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { 723 return xxx_messageInfo_PieceHeader.Marshal(b, m, deterministic) 724} 725func (m *PieceHeader) XXX_Merge(src proto.Message) { 726 xxx_messageInfo_PieceHeader.Merge(m, src) 727} 728func (m *PieceHeader) XXX_Size() int { 729 return xxx_messageInfo_PieceHeader.Size(m) 730} 731func (m *PieceHeader) XXX_DiscardUnknown() { 732 xxx_messageInfo_PieceHeader.DiscardUnknown(m) 733} 734 735var xxx_messageInfo_PieceHeader proto.InternalMessageInfo 736 737func (m *PieceHeader) GetFormatVersion() PieceHeader_FormatVersion { 738 if m != nil { 739 return m.FormatVersion 740 } 741 return PieceHeader_FORMAT_V0 742} 743 744func (m *PieceHeader) GetHash() []byte { 745 if m != nil { 746 return m.Hash 747 } 748 return nil 749} 750 751func (m *PieceHeader) GetCreationTime() time.Time { 752 if m != nil { 753 return m.CreationTime 754 } 755 return time.Time{} 756} 757 758func (m *PieceHeader) GetSignature() []byte { 759 if m != nil { 760 return m.Signature 761 } 762 return nil 763} 764 765func (m *PieceHeader) GetOrderLimit() OrderLimit { 766 if m != nil { 767 return m.OrderLimit 768 } 769 return OrderLimit{} 770} 771 772func init() { 773 proto.RegisterEnum("piecestore.PieceHeader_FormatVersion", PieceHeader_FormatVersion_name, PieceHeader_FormatVersion_value) 774 proto.RegisterType((*PieceUploadRequest)(nil), "piecestore.PieceUploadRequest") 775 proto.RegisterType((*PieceUploadRequest_Chunk)(nil), "piecestore.PieceUploadRequest.Chunk") 776 proto.RegisterType((*PieceUploadResponse)(nil), "piecestore.PieceUploadResponse") 777 proto.RegisterType((*PieceDownloadRequest)(nil), "piecestore.PieceDownloadRequest") 778 proto.RegisterType((*PieceDownloadRequest_Chunk)(nil), "piecestore.PieceDownloadRequest.Chunk") 779 proto.RegisterType((*PieceDownloadResponse)(nil), "piecestore.PieceDownloadResponse") 780 proto.RegisterType((*PieceDownloadResponse_Chunk)(nil), "piecestore.PieceDownloadResponse.Chunk") 781 proto.RegisterType((*PieceDeleteRequest)(nil), "piecestore.PieceDeleteRequest") 782 proto.RegisterType((*PieceDeleteResponse)(nil), "piecestore.PieceDeleteResponse") 783 proto.RegisterType((*DeletePiecesRequest)(nil), "piecestore.DeletePiecesRequest") 784 proto.RegisterType((*DeletePiecesResponse)(nil), "piecestore.DeletePiecesResponse") 785 proto.RegisterType((*RetainRequest)(nil), "piecestore.RetainRequest") 786 proto.RegisterType((*RetainResponse)(nil), "piecestore.RetainResponse") 787 proto.RegisterType((*RestoreTrashRequest)(nil), "piecestore.RestoreTrashRequest") 788 proto.RegisterType((*RestoreTrashResponse)(nil), "piecestore.RestoreTrashResponse") 789 proto.RegisterType((*PieceHeader)(nil), "piecestore.PieceHeader") 790} 791 792func init() { proto.RegisterFile("piecestore2.proto", fileDescriptor_23ff32dd550c2439) } 793 794var fileDescriptor_23ff32dd550c2439 = []byte{ 795 // 786 bytes of a gzipped FileDescriptorProto 796 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x54, 0x4d, 0x4f, 0x13, 0x5d, 797 0x14, 0xee, 0xd0, 0x8f, 0x97, 0x1e, 0xa6, 0x05, 0x2e, 0x85, 0xf4, 0x9d, 0xbc, 0xaf, 0xad, 0xa3, 798 0x48, 0x17, 0x3a, 0xc5, 0xb2, 0xd2, 0x20, 0xc4, 0xd2, 0x10, 0x49, 0x40, 0xf0, 0xf2, 0xb1, 0x70, 799 0xd3, 0x0c, 0x9d, 0xdb, 0x76, 0xb4, 0x9d, 0x5b, 0x67, 0x6e, 0x35, 0xe1, 0x17, 0xb8, 0xf4, 0x37, 800 0xb9, 0xf2, 0x37, 0x18, 0x83, 0x0b, 0x97, 0xfe, 0x04, 0x37, 0xe6, 0x7e, 0x4c, 0xdb, 0xa1, 0x85, 801 0x06, 0x13, 0x57, 0xed, 0x3d, 0xe7, 0x39, 0xf7, 0x3c, 0xf7, 0x99, 0xe7, 0x1c, 0x58, 0xec, 0xb9, 802 0xa4, 0x41, 0x02, 0x46, 0x7d, 0x52, 0xb1, 0x7a, 0x3e, 0x65, 0x14, 0xc1, 0x30, 0x64, 0x40, 0x8b, 803 0xb6, 0xa8, 0x8c, 0x1b, 0x85, 0x16, 0xa5, 0xad, 0x0e, 0x29, 0x8b, 0xd3, 0x79, 0xbf, 0x59, 0x66, 804 0x6e, 0x97, 0x04, 0xcc, 0xee, 0xf6, 0x14, 0x40, 0xa7, 0xbe, 0x43, 0xfc, 0x40, 0x9e, 0xcc, 0x5f, 805 0x1a, 0xa0, 0x23, 0x7e, 0xd3, 0x69, 0xaf, 0x43, 0x6d, 0x07, 0x93, 0x77, 0x7d, 0x12, 0x30, 0x54, 806 0x82, 0x64, 0xc7, 0xed, 0xba, 0x2c, 0xaf, 0x15, 0xb5, 0xd2, 0x5c, 0x05, 0x59, 0xaa, 0xe8, 0x90, 807 0xff, 0xec, 0xf3, 0x0c, 0x96, 0x00, 0x74, 0x0f, 0x92, 0x22, 0x97, 0x9f, 0x11, 0xc8, 0x4c, 0x04, 808 0x89, 0x65, 0x0e, 0x3d, 0x85, 0x64, 0xa3, 0xdd, 0xf7, 0xde, 0xe6, 0xe3, 0x02, 0x74, 0xdf, 0x1a, 809 0x92, 0xb7, 0xc6, 0xbb, 0x5b, 0x3b, 0x1c, 0x8b, 0x65, 0x09, 0x5a, 0x85, 0x84, 0x43, 0x3d, 0x92, 810 0x4f, 0x88, 0xd2, 0xc5, 0xf0, 0x7e, 0x51, 0xf6, 0xc2, 0x0e, 0xda, 0x58, 0xa4, 0x8d, 0x0d, 0x48, 811 0x8a, 0x32, 0xb4, 0x02, 0x29, 0xda, 0x6c, 0x06, 0x44, 0x72, 0x8f, 0x63, 0x75, 0x42, 0x08, 0x12, 812 0x8e, 0xcd, 0x6c, 0xc1, 0x53, 0xc7, 0xe2, 0xbf, 0xb9, 0x09, 0x4b, 0x91, 0xf6, 0x41, 0x8f, 0x7a, 813 0x01, 0x19, 0xb4, 0xd4, 0x6e, 0x6c, 0x69, 0xfe, 0xd0, 0x20, 0x27, 0x62, 0x35, 0xfa, 0xc1, 0xfb, 814 0x8b, 0xea, 0x6d, 0x46, 0xd5, 0x7b, 0x30, 0xa6, 0xde, 0x95, 0xfe, 0x11, 0xfd, 0x8c, 0xad, 0x69, 815 0xc2, 0xfc, 0x0f, 0x20, 0x90, 0xf5, 0xc0, 0xbd, 0x20, 0x82, 0x48, 0x1c, 0xa7, 0x45, 0xe4, 0xd8, 816 0xbd, 0x20, 0xe6, 0x37, 0x0d, 0x96, 0xaf, 0x74, 0x51, 0x32, 0x3d, 0x0b, 0x79, 0xc9, 0x67, 0xae, 817 0xdd, 0xc0, 0x4b, 0x56, 0x8c, 0x7d, 0xd8, 0xb6, 0x1d, 0xb4, 0xd5, 0xd3, 0x27, 0xa9, 0xcc, 0xd3, 818 0x43, 0x31, 0xe3, 0x53, 0xc4, 0xfc, 0x33, 0x0b, 0x6c, 0x29, 0xff, 0xd7, 0x48, 0x87, 0x30, 0x72, 819 0xeb, 0x2f, 0x68, 0x2e, 0x2b, 0x0b, 0x85, 0xf5, 0xf2, 0xa5, 0xe6, 0x0e, 0x2c, 0xc9, 0x88, 0x48, 820 0x06, 0xe1, 0xbd, 0x0f, 0x21, 0x2d, 0x44, 0xaa, 0xbb, 0x4e, 0x90, 0xd7, 0x8a, 0xf1, 0x92, 0x5e, 821 0x9d, 0xff, 0x72, 0x59, 0x88, 0x7d, 0xbd, 0x2c, 0xfc, 0x23, 0x90, 0x7b, 0x35, 0x3c, 0x2b, 0x10, 822 0x7b, 0x4e, 0x60, 0x6e, 0x43, 0x2e, 0x7a, 0x89, 0x12, 0x7e, 0x0d, 0xe6, 0xfb, 0x5e, 0xdb, 0xf6, 823 0x9c, 0x0e, 0x71, 0xea, 0x0d, 0xda, 0xf7, 0xc2, 0x87, 0x66, 0x07, 0xe1, 0x1d, 0x1e, 0x35, 0x7d, 824 0xc8, 0x60, 0xc2, 0x6c, 0xd7, 0x0b, 0xfb, 0xef, 0x41, 0xa6, 0xe1, 0x13, 0x9b, 0xb9, 0xd4, 0xab, 825 0x3b, 0x36, 0x0b, 0x2d, 0x6e, 0x58, 0x72, 0x6b, 0x58, 0xe1, 0xd6, 0xb0, 0x4e, 0xc2, 0xad, 0x51, 826 0x9d, 0xe5, 0xfc, 0x3e, 0x7d, 0x2f, 0x68, 0x58, 0x0f, 0x4b, 0x6b, 0x36, 0x23, 0x5c, 0xe4, 0xa6, 827 0xdb, 0x61, 0xca, 0xbb, 0x3a, 0x56, 0x27, 0x73, 0x01, 0xb2, 0x61, 0x4f, 0xa5, 0xc5, 0x32, 0x2c, 828 0x61, 0x69, 0x8b, 0x13, 0x9f, 0x7f, 0x57, 0xc9, 0xc5, 0x5c, 0x81, 0x5c, 0x34, 0xac, 0xe0, 0x9f, 829 0x67, 0x60, 0x4e, 0x9a, 0x80, 0xd8, 0xdc, 0xfe, 0xfb, 0x90, 0x6d, 0x52, 0xbf, 0x6b, 0xb3, 0xfa, 830 0x7b, 0xe2, 0x07, 0x2e, 0xf5, 0x04, 0xe9, 0x6c, 0x65, 0x75, 0xcc, 0x6f, 0xb2, 0xc0, 0xda, 0x15, 831 0xe8, 0x33, 0x09, 0xc6, 0x99, 0xe6, 0xe8, 0x91, 0x7b, 0x60, 0xe0, 0x3a, 0x5d, 0x59, 0x6c, 0x54, 832 0x15, 0xbe, 0x2e, 0x95, 0xd5, 0x6e, 0xa9, 0x0a, 0x4f, 0xa2, 0xff, 0x20, 0x1d, 0xb8, 0x2d, 0xcf, 833 0x66, 0x7d, 0x5f, 0xae, 0x2c, 0x1d, 0x0f, 0x03, 0xe8, 0x09, 0xcc, 0x09, 0x23, 0xd5, 0xa5, 0xb9, 834 0x92, 0xd7, 0x99, 0xab, 0x9a, 0xe0, 0xd7, 0x63, 0xa0, 0x83, 0x88, 0xf9, 0x08, 0x32, 0x91, 0x77, 835 0xa1, 0x0c, 0xa4, 0x77, 0x0f, 0xf1, 0xc1, 0xf3, 0x93, 0xfa, 0xd9, 0xfa, 0x42, 0x6c, 0xf4, 0xf8, 836 0x78, 0x41, 0xab, 0xfc, 0x8c, 0x03, 0x1c, 0x0d, 0xe4, 0x41, 0x07, 0x90, 0x92, 0x3b, 0x0e, 0xdd, 837 0xb9, 0x79, 0xf7, 0x1a, 0x85, 0x6b, 0xf3, 0xea, 0xf3, 0xc4, 0x4a, 0x1a, 0x3a, 0x85, 0xd9, 0x70, 838 0xb6, 0x51, 0x71, 0xda, 0x3a, 0x32, 0xee, 0x4e, 0x5d, 0x0c, 0xfc, 0xd2, 0x75, 0x0d, 0xbd, 0x84, 839 0x94, 0xf4, 0xfb, 0x04, 0x96, 0x91, 0xf9, 0x9c, 0xc0, 0xf2, 0xca, 0xfc, 0xc5, 0x3f, 0xce, 0x68, 840 0xe8, 0x15, 0xe8, 0xa3, 0xf3, 0x83, 0x22, 0x55, 0x13, 0xc6, 0xd3, 0x28, 0x5e, 0x0f, 0x50, 0xa3, 841 0xb7, 0x0d, 0x29, 0xe9, 0x6e, 0xf4, 0xef, 0x28, 0x36, 0x32, 0x65, 0x86, 0x31, 0x29, 0xa5, 0x2e, 842 0x38, 0x06, 0x7d, 0xd4, 0xf5, 0x51, 0x4e, 0x13, 0xc6, 0x24, 0xca, 0x69, 0xe2, 0xc0, 0xc4, 0xaa, 843 0xb9, 0xd7, 0x88, 0xc7, 0xdf, 0x58, 0x2e, 0x2d, 0x37, 0x68, 0xb7, 0x4b, 0xbd, 0x72, 0xef, 0xfc, 844 0x3c, 0x25, 0x7c, 0xbb, 0xf1, 0x3b, 0x00, 0x00, 0xff, 0xff, 0x46, 0xf3, 0x6f, 0x64, 0x3e, 0x08, 845 0x00, 0x00, 846} 847