syntax = "proto3"; package object; option go_package = "github.com/nspcc-dev/neofs-api-go/object"; option csharp_namespace = "NeoFS.API.Object"; import "refs/types.proto"; import "object/types.proto"; import "service/meta.proto"; import "service/verify.proto"; // Object service provides API for manipulating with the object. service Service { // Get the object from container. Response uses gRPC stream. First response // message carry object of requested address. Chunk messages are parts of // the object's payload if it is needed. All messages except first carry // chunks. Requested object can be restored by concatenation of object // message payload and all chunks keeping receiving order. rpc Get(GetRequest) returns (stream GetResponse); // Put the object into container. Request uses gRPC stream. First message // SHOULD BE type of PutHeader. Container id and Owner id of object SHOULD // BE set. Session token SHOULD BE obtained before put operation (see // session package). Chunk messages considered by server as part of object // payload. All messages except first SHOULD BE chunks. Chunk messages // SHOULD BE sent in direct order of fragmentation. rpc Put(stream PutRequest) returns (PutResponse); // Delete the object from a container rpc Delete(DeleteRequest) returns (DeleteResponse); // Head returns the object without data payload. Object in the // response has system header only. If full headers flag is set, extended // headers are also present. rpc Head(HeadRequest) returns (HeadResponse); // Search objects in container. Version of query language format SHOULD BE // set to 1. Search query represented in serialized format (see query // package). rpc Search(SearchRequest) returns (stream SearchResponse); // GetRange of data payload. Range is a pair (offset, length). // Requested range can be restored by concatenation of all chunks // keeping receiving order. rpc GetRange(GetRangeRequest) returns (stream GetRangeResponse); // GetRangeHash returns homomorphic hash of object payload range after XOR // operation. Ranges are set of pairs (offset, length). Hashes order in // response corresponds to ranges order in request. Homomorphic hash is // calculated for XORed data. rpc GetRangeHash(GetRangeHashRequest) returns (GetRangeHashResponse); } message GetRequest { // Carries the address of the requested object. refs.Address address = 1; // Carries the raw option flag of the request. // Raw request is sent to receive only the objects // that are physically stored on the server. bool raw = 2; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message GetResponse { // Carries the single message of the response stream. oneof ObjectPart { // Carries the object header. Header header = 1; // Carries part of the object payload. bytes chunk = 2; } } message PutRequest { // Groups initialization parameters of object placement in NeoFS. message Init { // Carries the header of the object to save in the system. Header header = 1; // Carries the number of the object copies to store // within the RPC call. Default zero value is processed according // to the container placement rules. uint32 copies_number = 2; } // Carries the single part of the query stream. oneof Part { // Carries the initialization parameters of the object stream. Init init = 1; // Carries part of the object payload. bytes chunk = 2; } // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message PutResponse { // Carries identifier of the saved object. // It is used to access an object in the container. refs.ObjectID object_id = 1; } message DeleteRequest { // Carries the address of the object to be deleted. refs.Address address = 1; // Carries identifier the object owner. refs.OwnerID owner_id = 2; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } // DeleteResponse is empty because we cannot guarantee permanent object removal // in distributed system. message DeleteResponse { } message HeadRequest { // Carries the address of the object with the requested header. refs.Address address = 1; // Carries the option to crop header to main part. bool main_only = 2; // Carries the raw option flag of the request. // Raw request is sent to receive only the headers of the objects // that are physically stored on the server. bool raw = 3; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message HeadResponse { // Carries the requested object header. Header header = 1; } message SearchRequest { // Carries search container identifier. refs.ContainerID container_id = 1; message Query { uint32 version = 1; message Filter { enum MatchType { MATCH_UNKNOWN = 0; STRING_EQUAL = 1; } MatchType match_type = 1; string name = 2; string value = 3; } repeated Filter filters = 2; } Query query = 2; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message SearchResponse { // Carries list of object identifiers that match the search query. repeated refs.ObjectID id_list = 1; } // Range groups the parameters of object payload range. message Range { // Carries the offset of the range from the object payload start. uint64 offset = 1; // Carries the length of the object payload range. uint64 length = 2; } message GetRangeRequest { // Address carries address of the object that contains the requested payload range. refs.Address address = 1; // Range carries the parameters of the requested payload range. Range range = 2; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message GetRangeResponse { // Carries part of the object payload. bytes chunk = 1; } message GetRangeHashRequest { // Carries address of the object that contains the requested payload range. refs.Address address = 1; // Carries the list of object payload range to calculate homomorphic hash. repeated Range ranges = 2; // Carries binary salt to XOR object payload ranges before hash calculation. bytes salt = 3; // Carries request meta information. Header data is used only to regulate message // transport and does not affect request execution. service.RequestMetaHeader meta_header = 98; // Carries request verification information. This header is used to authenticate // the nodes of the message route and check the correctness of transmission. service.RequestVerificationHeader verify_header = 99; } message GetRangeHashResponse { // Carries list of homomorphic hashes in a binary format. repeated bytes hash_list = 1; }