2021-09-28 15:11:33 +00:00
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2022-07-04 09:07:35 +00:00
// versions:
2023-04-17 12:44:35 +00:00
// - protoc-gen-go-grpc v1.3.0
2024-07-26 07:15:06 +00:00
// - protoc v5.27.2
2022-07-04 09:07:35 +00:00
// source: object/grpc/service.proto
2021-09-28 15:11:33 +00:00
package object
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc . SupportPackageIsVersion7
2023-04-17 12:44:35 +00:00
const (
ObjectService_Get_FullMethodName = "/neo.fs.v2.object.ObjectService/Get"
ObjectService_Put_FullMethodName = "/neo.fs.v2.object.ObjectService/Put"
ObjectService_Delete_FullMethodName = "/neo.fs.v2.object.ObjectService/Delete"
ObjectService_Head_FullMethodName = "/neo.fs.v2.object.ObjectService/Head"
ObjectService_Search_FullMethodName = "/neo.fs.v2.object.ObjectService/Search"
ObjectService_GetRange_FullMethodName = "/neo.fs.v2.object.ObjectService/GetRange"
ObjectService_GetRangeHash_FullMethodName = "/neo.fs.v2.object.ObjectService/GetRangeHash"
2023-06-30 10:25:01 +00:00
ObjectService_PutSingle_FullMethodName = "/neo.fs.v2.object.ObjectService/PutSingle"
2024-07-24 14:40:47 +00:00
ObjectService_Patch_FullMethodName = "/neo.fs.v2.object.ObjectService/Patch"
2023-04-17 12:44:35 +00:00
)
2021-09-28 15:11:33 +00:00
// ObjectServiceClient is the client API for ObjectService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type ObjectServiceClient interface {
// Receive full object structure, including Headers and payload. Response uses
2023-08-17 08:08:14 +00:00
// gRPC stream. First response message carries the object with the requested
// address. Chunk messages are parts of the object's payload if it is needed.
// All messages, except the first one, carry payload chunks. The requested
// object can be restored by concatenation of object message payload and all
// chunks keeping the receiving order.
2022-06-15 17:30:22 +00:00
//
// Extended headers can change `Get` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
2023-08-17 08:08:14 +00:00
// Will try older versions (starting from `__SYSTEM__NETMAP_EPOCH`
// (`__NEOFS__NETMAP_EPOCH` is deprecated) if specified or the latest one
// otherwise) of Network Map to find an object until the depth limit is
// reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// read access to the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Get ( ctx context . Context , in * GetRequest , opts ... grpc . CallOption ) ( ObjectService_GetClient , error )
// Put the object into container. Request uses gRPC stream. First message
// SHOULD be of PutHeader type. `ContainerID` and `OwnerID` of an object
// SHOULD be set. Session token SHOULD be obtained before `PUT` operation (see
// session package). Chunk messages are considered by server as a part of an
// object payload. All messages, except first one, SHOULD be payload chunks.
2022-06-15 17:30:22 +00:00
// Chunk messages SHOULD be sent in the direct order of fragmentation.
//
// Extended headers can change `Put` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **LOCKED** (2050, SECTION_OBJECT): \
2023-08-17 08:08:14 +00:00
// placement of an object of type TOMBSTONE that includes at least one
// locked object is prohibited;
2023-04-17 12:44:35 +00:00
// - **LOCK_NON_REGULAR_OBJECT** (2051, SECTION_OBJECT): \
// placement of an object of type LOCK that includes at least one object of
// type other than REGULAR is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
2023-08-17 08:08:14 +00:00
// (for trusted object preparation) session private key does not exist or
// has
2023-04-17 12:44:35 +00:00
//
2022-02-21 17:57:27 +00:00
// been deleted;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Put ( ctx context . Context , opts ... grpc . CallOption ) ( ObjectService_PutClient , error )
// Delete the object from a container. There is no immediate removal
// guarantee. Object will be marked for removal and deleted eventually.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `Delete` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully marked to be removed from the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// delete access to the object is denied;
2023-08-17 08:08:14 +00:00
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// the object could not be deleted because it has not been \
// found within the container;
2023-04-17 12:44:35 +00:00
// - **LOCKED** (2050, SECTION_OBJECT): \
// deleting a locked object is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Delete ( ctx context . Context , in * DeleteRequest , opts ... grpc . CallOption ) ( * DeleteResponse , error )
// Returns the object Headers without data payload. By default full header is
// returned. If `main_only` request field is set, the short header with only
2022-06-15 17:30:22 +00:00
// the very minimal information will be returned instead.
//
// Extended headers can change `Head` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object header has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation HEAD of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Head ( ctx context . Context , in * HeadRequest , opts ... grpc . CallOption ) ( * HeadResponse , error )
// Search objects in container. Search query allows to match by Object
2024-10-01 10:52:57 +00:00
// Header's filed values. Please see the corresponding FrostFS Technical
2021-09-28 15:11:33 +00:00
// Specification section for more details.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `Search` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// objects have been successfully selected;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation SEARCH of the object is denied;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// search container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Search ( ctx context . Context , in * SearchRequest , opts ... grpc . CallOption ) ( ObjectService_SearchClient , error )
// Get byte range of data payload. Range is set as an (offset, length) tuple.
// Like in `Get` method, the response uses gRPC stream. Requested range can be
2023-08-17 08:08:14 +00:00
// restored by concatenation of all received payload chunks keeping the
// receiving order.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `GetRange` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
// Will try older versions of Network Map to find an object until the depth
// limit is reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// data range of the object payload has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation RANGE of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted.
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
GetRange ( ctx context . Context , in * GetRangeRequest , opts ... grpc . CallOption ) ( ObjectService_GetRangeClient , error )
// Returns homomorphic or regular hash of object's payload range after
// applying XOR operation with the provided `salt`. Ranges are set of (offset,
2022-06-15 17:30:22 +00:00
// length) tuples. Hashes order in response corresponds to the ranges order in
// the request. Note that hash is calculated for XORed data.
//
// Extended headers can change `GetRangeHash` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
// Will try older versions of Network Map to find an object until the depth
// limit is reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// data range of the object payload has been successfully hashed;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation RANGEHASH of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
GetRangeHash ( ctx context . Context , in * GetRangeHashRequest , opts ... grpc . CallOption ) ( * GetRangeHashResponse , error )
2023-06-30 10:25:01 +00:00
// Put the prepared object into container.
2023-08-17 08:08:14 +00:00
// `ContainerID`, `ObjectID`, `OwnerID`, `PayloadHash` and `PayloadLength` of
// an object MUST be set.
2023-06-30 10:25:01 +00:00
//
// Extended headers can change `Put` behaviour:
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
//
// Please refer to detailed `XHeader` description.
//
// Statuses:
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **LOCKED** (2050, SECTION_OBJECT): \
2023-08-17 08:08:14 +00:00
// placement of an object of type TOMBSTONE that includes at least one
// locked object is prohibited;
2023-06-30 10:25:01 +00:00
// - **LOCK_NON_REGULAR_OBJECT** (2051, SECTION_OBJECT): \
// placement of an object of type LOCK that includes at least one object of
// type other than REGULAR is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-06-30 10:25:01 +00:00
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
2023-08-17 08:08:14 +00:00
// (for trusted object preparation) session private key does not exist or
// has
2023-06-30 10:25:01 +00:00
//
// been deleted;
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
PutSingle ( ctx context . Context , in * PutSingleRequest , opts ... grpc . CallOption ) ( * PutSingleResponse , error )
2024-07-24 14:40:47 +00:00
// Patch the object. Request uses gRPC stream. First message must set
2024-10-01 10:52:57 +00:00
// the address of the object that is going to get patched. If the object's
// attributes are patched, then these attrubutes must be set only within the
// first stream message.
//
// If the patch request is performed by NOT the object's owner but if the
// actor has the permission to perform the patch, then `OwnerID` of the object
// is changed. In this case the object's owner loses the object's ownership
// after the patch request is successfully done.
//
// As objects are content-addressable the patching causes new object ID
// generation for the patched object. This object id is set witihn
// `PatchResponse`. But the object id may remain unchanged in such cases:
// 1. The chunk of the applying patch contains the same value as the object's
// payload within the same range;
2024-07-24 14:40:47 +00:00
// 2. The patch that reverts the changes applied by preceding patch;
// 3. The application of the same patches for the object a few times.
//
// Extended headers can change `Patch` behaviour:
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
//
// Please refer to detailed `XHeader` description.
//
// Statuses:
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully patched and saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
2024-04-25 12:13:10 +00:00
// the requested object has been marked as deleted.
2024-07-24 14:40:47 +00:00
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
// (for trusted object preparation) session private key does not exist or
// has been deleted;
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
Patch ( ctx context . Context , opts ... grpc . CallOption ) ( ObjectService_PatchClient , error )
2021-09-28 15:11:33 +00:00
}
type objectServiceClient struct {
cc grpc . ClientConnInterface
}
func NewObjectServiceClient ( cc grpc . ClientConnInterface ) ObjectServiceClient {
return & objectServiceClient { cc }
}
func ( c * objectServiceClient ) Get ( ctx context . Context , in * GetRequest , opts ... grpc . CallOption ) ( ObjectService_GetClient , error ) {
2023-04-17 12:44:35 +00:00
stream , err := c . cc . NewStream ( ctx , & ObjectService_ServiceDesc . Streams [ 0 ] , ObjectService_Get_FullMethodName , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
x := & objectServiceGetClient { stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
return x , nil
}
type ObjectService_GetClient interface {
Recv ( ) ( * GetResponse , error )
grpc . ClientStream
}
type objectServiceGetClient struct {
grpc . ClientStream
}
func ( x * objectServiceGetClient ) Recv ( ) ( * GetResponse , error ) {
m := new ( GetResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func ( c * objectServiceClient ) Put ( ctx context . Context , opts ... grpc . CallOption ) ( ObjectService_PutClient , error ) {
2023-04-17 12:44:35 +00:00
stream , err := c . cc . NewStream ( ctx , & ObjectService_ServiceDesc . Streams [ 1 ] , ObjectService_Put_FullMethodName , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
x := & objectServicePutClient { stream }
return x , nil
}
type ObjectService_PutClient interface {
Send ( * PutRequest ) error
CloseAndRecv ( ) ( * PutResponse , error )
grpc . ClientStream
}
type objectServicePutClient struct {
grpc . ClientStream
}
func ( x * objectServicePutClient ) Send ( m * PutRequest ) error {
return x . ClientStream . SendMsg ( m )
}
func ( x * objectServicePutClient ) CloseAndRecv ( ) ( * PutResponse , error ) {
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
m := new ( PutResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func ( c * objectServiceClient ) Delete ( ctx context . Context , in * DeleteRequest , opts ... grpc . CallOption ) ( * DeleteResponse , error ) {
out := new ( DeleteResponse )
2023-04-17 12:44:35 +00:00
err := c . cc . Invoke ( ctx , ObjectService_Delete_FullMethodName , in , out , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
return out , nil
}
func ( c * objectServiceClient ) Head ( ctx context . Context , in * HeadRequest , opts ... grpc . CallOption ) ( * HeadResponse , error ) {
out := new ( HeadResponse )
2023-04-17 12:44:35 +00:00
err := c . cc . Invoke ( ctx , ObjectService_Head_FullMethodName , in , out , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
return out , nil
}
func ( c * objectServiceClient ) Search ( ctx context . Context , in * SearchRequest , opts ... grpc . CallOption ) ( ObjectService_SearchClient , error ) {
2023-04-17 12:44:35 +00:00
stream , err := c . cc . NewStream ( ctx , & ObjectService_ServiceDesc . Streams [ 2 ] , ObjectService_Search_FullMethodName , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
x := & objectServiceSearchClient { stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
return x , nil
}
type ObjectService_SearchClient interface {
Recv ( ) ( * SearchResponse , error )
grpc . ClientStream
}
type objectServiceSearchClient struct {
grpc . ClientStream
}
func ( x * objectServiceSearchClient ) Recv ( ) ( * SearchResponse , error ) {
m := new ( SearchResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func ( c * objectServiceClient ) GetRange ( ctx context . Context , in * GetRangeRequest , opts ... grpc . CallOption ) ( ObjectService_GetRangeClient , error ) {
2023-04-17 12:44:35 +00:00
stream , err := c . cc . NewStream ( ctx , & ObjectService_ServiceDesc . Streams [ 3 ] , ObjectService_GetRange_FullMethodName , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
x := & objectServiceGetRangeClient { stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
return x , nil
}
type ObjectService_GetRangeClient interface {
Recv ( ) ( * GetRangeResponse , error )
grpc . ClientStream
}
type objectServiceGetRangeClient struct {
grpc . ClientStream
}
func ( x * objectServiceGetRangeClient ) Recv ( ) ( * GetRangeResponse , error ) {
m := new ( GetRangeResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func ( c * objectServiceClient ) GetRangeHash ( ctx context . Context , in * GetRangeHashRequest , opts ... grpc . CallOption ) ( * GetRangeHashResponse , error ) {
out := new ( GetRangeHashResponse )
2023-04-17 12:44:35 +00:00
err := c . cc . Invoke ( ctx , ObjectService_GetRangeHash_FullMethodName , in , out , opts ... )
2021-09-28 15:11:33 +00:00
if err != nil {
return nil , err
}
return out , nil
}
2023-06-30 10:25:01 +00:00
func ( c * objectServiceClient ) PutSingle ( ctx context . Context , in * PutSingleRequest , opts ... grpc . CallOption ) ( * PutSingleResponse , error ) {
out := new ( PutSingleResponse )
err := c . cc . Invoke ( ctx , ObjectService_PutSingle_FullMethodName , in , out , opts ... )
if err != nil {
return nil , err
}
return out , nil
}
2024-07-24 14:40:47 +00:00
func ( c * objectServiceClient ) Patch ( ctx context . Context , opts ... grpc . CallOption ) ( ObjectService_PatchClient , error ) {
stream , err := c . cc . NewStream ( ctx , & ObjectService_ServiceDesc . Streams [ 4 ] , ObjectService_Patch_FullMethodName , opts ... )
if err != nil {
return nil , err
}
x := & objectServicePatchClient { stream }
return x , nil
}
type ObjectService_PatchClient interface {
Send ( * PatchRequest ) error
CloseAndRecv ( ) ( * PatchResponse , error )
grpc . ClientStream
}
type objectServicePatchClient struct {
grpc . ClientStream
}
func ( x * objectServicePatchClient ) Send ( m * PatchRequest ) error {
return x . ClientStream . SendMsg ( m )
}
func ( x * objectServicePatchClient ) CloseAndRecv ( ) ( * PatchResponse , error ) {
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
m := new ( PatchResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
2021-09-28 15:11:33 +00:00
// ObjectServiceServer is the server API for ObjectService service.
// All implementations should embed UnimplementedObjectServiceServer
// for forward compatibility
type ObjectServiceServer interface {
// Receive full object structure, including Headers and payload. Response uses
2023-08-17 08:08:14 +00:00
// gRPC stream. First response message carries the object with the requested
// address. Chunk messages are parts of the object's payload if it is needed.
// All messages, except the first one, carry payload chunks. The requested
// object can be restored by concatenation of object message payload and all
// chunks keeping the receiving order.
2022-06-15 17:30:22 +00:00
//
// Extended headers can change `Get` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
2023-08-17 08:08:14 +00:00
// Will try older versions (starting from `__SYSTEM__NETMAP_EPOCH`
// (`__NEOFS__NETMAP_EPOCH` is deprecated) if specified or the latest one
// otherwise) of Network Map to find an object until the depth limit is
// reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// read access to the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Get ( * GetRequest , ObjectService_GetServer ) error
// Put the object into container. Request uses gRPC stream. First message
// SHOULD be of PutHeader type. `ContainerID` and `OwnerID` of an object
// SHOULD be set. Session token SHOULD be obtained before `PUT` operation (see
// session package). Chunk messages are considered by server as a part of an
// object payload. All messages, except first one, SHOULD be payload chunks.
2022-06-15 17:30:22 +00:00
// Chunk messages SHOULD be sent in the direct order of fragmentation.
//
// Extended headers can change `Put` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **LOCKED** (2050, SECTION_OBJECT): \
2023-08-17 08:08:14 +00:00
// placement of an object of type TOMBSTONE that includes at least one
// locked object is prohibited;
2023-04-17 12:44:35 +00:00
// - **LOCK_NON_REGULAR_OBJECT** (2051, SECTION_OBJECT): \
// placement of an object of type LOCK that includes at least one object of
// type other than REGULAR is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
2023-08-17 08:08:14 +00:00
// (for trusted object preparation) session private key does not exist or
// has
2023-04-17 12:44:35 +00:00
//
2022-02-21 17:57:27 +00:00
// been deleted;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Put ( ObjectService_PutServer ) error
// Delete the object from a container. There is no immediate removal
// guarantee. Object will be marked for removal and deleted eventually.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `Delete` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully marked to be removed from the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// delete access to the object is denied;
2023-08-17 08:08:14 +00:00
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// the object could not be deleted because it has not been \
// found within the container;
2023-04-17 12:44:35 +00:00
// - **LOCKED** (2050, SECTION_OBJECT): \
// deleting a locked object is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Delete ( context . Context , * DeleteRequest ) ( * DeleteResponse , error )
// Returns the object Headers without data payload. By default full header is
// returned. If `main_only` request field is set, the short header with only
2022-06-15 17:30:22 +00:00
// the very minimal information will be returned instead.
//
// Extended headers can change `Head` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// object header has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation HEAD of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Head ( context . Context , * HeadRequest ) ( * HeadResponse , error )
// Search objects in container. Search query allows to match by Object
2024-10-01 10:52:57 +00:00
// Header's filed values. Please see the corresponding FrostFS Technical
2021-09-28 15:11:33 +00:00
// Specification section for more details.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `Search` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// objects have been successfully selected;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation SEARCH of the object is denied;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// search container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
Search ( * SearchRequest , ObjectService_SearchServer ) error
// Get byte range of data payload. Range is set as an (offset, length) tuple.
// Like in `Get` method, the response uses gRPC stream. Requested range can be
2023-08-17 08:08:14 +00:00
// restored by concatenation of all received payload chunks keeping the
// receiving order.
2021-10-04 12:32:16 +00:00
//
2022-06-15 17:30:22 +00:00
// Extended headers can change `GetRange` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
// Will try older versions of Network Map to find an object until the depth
// limit is reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
//
2021-10-04 12:32:16 +00:00
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// data range of the object payload has been successfully read;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation RANGE of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
// the requested object has been marked as deleted.
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
GetRange ( * GetRangeRequest , ObjectService_GetRangeServer ) error
// Returns homomorphic or regular hash of object's payload range after
// applying XOR operation with the provided `salt`. Ranges are set of (offset,
2022-06-15 17:30:22 +00:00
// length) tuples. Hashes order in response corresponds to the ranges order in
// the request. Note that hash is calculated for XORed data.
//
// Extended headers can change `GetRangeHash` behaviour:
2023-04-17 12:44:35 +00:00
// - [ __SYSTEM__NETMAP_EPOCH ] \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
// - [ __SYSTEM__NETMAP_LOOKUP_DEPTH ] \
// (`__NEOFS__NETMAP_LOOKUP_DEPTH` is deprecated) \
// Will try older versions of Network Map to find an object until the depth
// limit is reached.
2022-06-15 17:30:22 +00:00
//
// Please refer to detailed `XHeader` description.
2021-10-04 12:32:16 +00:00
//
// Statuses:
2023-04-17 12:44:35 +00:00
// - **OK** (0, SECTION_SUCCESS): \
// data range of the object payload has been successfully hashed;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// access to operation RANGEHASH of the object is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-04-17 12:44:35 +00:00
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
2021-09-28 15:11:33 +00:00
GetRangeHash ( context . Context , * GetRangeHashRequest ) ( * GetRangeHashResponse , error )
2023-06-30 10:25:01 +00:00
// Put the prepared object into container.
2023-08-17 08:08:14 +00:00
// `ContainerID`, `ObjectID`, `OwnerID`, `PayloadHash` and `PayloadLength` of
// an object MUST be set.
2023-06-30 10:25:01 +00:00
//
// Extended headers can change `Put` behaviour:
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requested version of Network Map for object placement
// calculation.
//
// Please refer to detailed `XHeader` description.
//
// Statuses:
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **LOCKED** (2050, SECTION_OBJECT): \
2023-08-17 08:08:14 +00:00
// placement of an object of type TOMBSTONE that includes at least one
// locked object is prohibited;
2023-06-30 10:25:01 +00:00
// - **LOCK_NON_REGULAR_OBJECT** (2051, SECTION_OBJECT): \
// placement of an object of type LOCK that includes at least one object of
// type other than REGULAR is prohibited;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
2024-03-26 15:52:20 +00:00
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
2023-06-30 10:25:01 +00:00
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
2023-08-17 08:08:14 +00:00
// (for trusted object preparation) session private key does not exist or
// has
2023-06-30 10:25:01 +00:00
//
// been deleted;
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
PutSingle ( context . Context , * PutSingleRequest ) ( * PutSingleResponse , error )
2024-07-24 14:40:47 +00:00
// Patch the object. Request uses gRPC stream. First message must set
2024-10-01 10:52:57 +00:00
// the address of the object that is going to get patched. If the object's
// attributes are patched, then these attrubutes must be set only within the
// first stream message.
//
// If the patch request is performed by NOT the object's owner but if the
// actor has the permission to perform the patch, then `OwnerID` of the object
// is changed. In this case the object's owner loses the object's ownership
// after the patch request is successfully done.
//
// As objects are content-addressable the patching causes new object ID
// generation for the patched object. This object id is set witihn
// `PatchResponse`. But the object id may remain unchanged in such cases:
// 1. The chunk of the applying patch contains the same value as the object's
// payload within the same range;
2024-07-24 14:40:47 +00:00
// 2. The patch that reverts the changes applied by preceding patch;
// 3. The application of the same patches for the object a few times.
//
// Extended headers can change `Patch` behaviour:
// - [ __SYSTEM__NETMAP_EPOCH \
// (`__NEOFS__NETMAP_EPOCH` is deprecated) \
// Will use the requsted version of Network Map for object placement
// calculation.
//
// Please refer to detailed `XHeader` description.
//
// Statuses:
// - **OK** (0, SECTION_SUCCESS): \
// object has been successfully patched and saved in the container;
// - Common failures (SECTION_FAILURE_COMMON);
// - **ACCESS_DENIED** (2048, SECTION_OBJECT): \
// write access to the container is denied;
// - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \
// object not found in container;
// - **OBJECT_ALREADY_REMOVED** (2052, SECTION_OBJECT): \
2024-04-25 12:13:10 +00:00
// the requested object has been marked as deleted.
2024-07-24 14:40:47 +00:00
// - **OUT_OF_RANGE** (2053, SECTION_OBJECT): \
// the requested range is out of bounds;
// - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \
// object storage container not found;
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
// access to container is denied;
// - **TOKEN_NOT_FOUND** (4096, SECTION_SESSION): \
// (for trusted object preparation) session private key does not exist or
// has been deleted;
// - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \
// provided session token has expired.
Patch ( ObjectService_PatchServer ) error
2021-09-28 15:11:33 +00:00
}
// UnimplementedObjectServiceServer should be embedded to have forward compatible implementations.
type UnimplementedObjectServiceServer struct {
}
func ( UnimplementedObjectServiceServer ) Get ( * GetRequest , ObjectService_GetServer ) error {
return status . Errorf ( codes . Unimplemented , "method Get not implemented" )
}
func ( UnimplementedObjectServiceServer ) Put ( ObjectService_PutServer ) error {
return status . Errorf ( codes . Unimplemented , "method Put not implemented" )
}
func ( UnimplementedObjectServiceServer ) Delete ( context . Context , * DeleteRequest ) ( * DeleteResponse , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method Delete not implemented" )
}
func ( UnimplementedObjectServiceServer ) Head ( context . Context , * HeadRequest ) ( * HeadResponse , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method Head not implemented" )
}
func ( UnimplementedObjectServiceServer ) Search ( * SearchRequest , ObjectService_SearchServer ) error {
return status . Errorf ( codes . Unimplemented , "method Search not implemented" )
}
func ( UnimplementedObjectServiceServer ) GetRange ( * GetRangeRequest , ObjectService_GetRangeServer ) error {
return status . Errorf ( codes . Unimplemented , "method GetRange not implemented" )
}
func ( UnimplementedObjectServiceServer ) GetRangeHash ( context . Context , * GetRangeHashRequest ) ( * GetRangeHashResponse , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method GetRangeHash not implemented" )
}
2023-06-30 10:25:01 +00:00
func ( UnimplementedObjectServiceServer ) PutSingle ( context . Context , * PutSingleRequest ) ( * PutSingleResponse , error ) {
return nil , status . Errorf ( codes . Unimplemented , "method PutSingle not implemented" )
}
2024-07-24 14:40:47 +00:00
func ( UnimplementedObjectServiceServer ) Patch ( ObjectService_PatchServer ) error {
return status . Errorf ( codes . Unimplemented , "method Patch not implemented" )
}
2021-09-28 15:11:33 +00:00
// UnsafeObjectServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ObjectServiceServer will
// result in compilation errors.
type UnsafeObjectServiceServer interface {
mustEmbedUnimplementedObjectServiceServer ( )
}
func RegisterObjectServiceServer ( s grpc . ServiceRegistrar , srv ObjectServiceServer ) {
s . RegisterService ( & ObjectService_ServiceDesc , srv )
}
func _ObjectService_Get_Handler ( srv interface { } , stream grpc . ServerStream ) error {
m := new ( GetRequest )
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ObjectServiceServer ) . Get ( m , & objectServiceGetServer { stream } )
}
type ObjectService_GetServer interface {
Send ( * GetResponse ) error
grpc . ServerStream
}
type objectServiceGetServer struct {
grpc . ServerStream
}
func ( x * objectServiceGetServer ) Send ( m * GetResponse ) error {
return x . ServerStream . SendMsg ( m )
}
func _ObjectService_Put_Handler ( srv interface { } , stream grpc . ServerStream ) error {
return srv . ( ObjectServiceServer ) . Put ( & objectServicePutServer { stream } )
}
type ObjectService_PutServer interface {
SendAndClose ( * PutResponse ) error
Recv ( ) ( * PutRequest , error )
grpc . ServerStream
}
type objectServicePutServer struct {
grpc . ServerStream
}
func ( x * objectServicePutServer ) SendAndClose ( m * PutResponse ) error {
return x . ServerStream . SendMsg ( m )
}
func ( x * objectServicePutServer ) Recv ( ) ( * PutRequest , error ) {
m := new ( PutRequest )
if err := x . ServerStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
func _ObjectService_Delete_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( DeleteRequest )
if err := dec ( in ) ; err != nil {
return nil , err
}
if interceptor == nil {
return srv . ( ObjectServiceServer ) . Delete ( ctx , in )
}
info := & grpc . UnaryServerInfo {
Server : srv ,
2023-04-17 12:44:35 +00:00
FullMethod : ObjectService_Delete_FullMethodName ,
2021-09-28 15:11:33 +00:00
}
handler := func ( ctx context . Context , req interface { } ) ( interface { } , error ) {
return srv . ( ObjectServiceServer ) . Delete ( ctx , req . ( * DeleteRequest ) )
}
return interceptor ( ctx , in , info , handler )
}
func _ObjectService_Head_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( HeadRequest )
if err := dec ( in ) ; err != nil {
return nil , err
}
if interceptor == nil {
return srv . ( ObjectServiceServer ) . Head ( ctx , in )
}
info := & grpc . UnaryServerInfo {
Server : srv ,
2023-04-17 12:44:35 +00:00
FullMethod : ObjectService_Head_FullMethodName ,
2021-09-28 15:11:33 +00:00
}
handler := func ( ctx context . Context , req interface { } ) ( interface { } , error ) {
return srv . ( ObjectServiceServer ) . Head ( ctx , req . ( * HeadRequest ) )
}
return interceptor ( ctx , in , info , handler )
}
func _ObjectService_Search_Handler ( srv interface { } , stream grpc . ServerStream ) error {
m := new ( SearchRequest )
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ObjectServiceServer ) . Search ( m , & objectServiceSearchServer { stream } )
}
type ObjectService_SearchServer interface {
Send ( * SearchResponse ) error
grpc . ServerStream
}
type objectServiceSearchServer struct {
grpc . ServerStream
}
func ( x * objectServiceSearchServer ) Send ( m * SearchResponse ) error {
return x . ServerStream . SendMsg ( m )
}
func _ObjectService_GetRange_Handler ( srv interface { } , stream grpc . ServerStream ) error {
m := new ( GetRangeRequest )
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( ObjectServiceServer ) . GetRange ( m , & objectServiceGetRangeServer { stream } )
}
type ObjectService_GetRangeServer interface {
Send ( * GetRangeResponse ) error
grpc . ServerStream
}
type objectServiceGetRangeServer struct {
grpc . ServerStream
}
func ( x * objectServiceGetRangeServer ) Send ( m * GetRangeResponse ) error {
return x . ServerStream . SendMsg ( m )
}
func _ObjectService_GetRangeHash_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( GetRangeHashRequest )
if err := dec ( in ) ; err != nil {
return nil , err
}
if interceptor == nil {
return srv . ( ObjectServiceServer ) . GetRangeHash ( ctx , in )
}
info := & grpc . UnaryServerInfo {
Server : srv ,
2023-04-17 12:44:35 +00:00
FullMethod : ObjectService_GetRangeHash_FullMethodName ,
2021-09-28 15:11:33 +00:00
}
handler := func ( ctx context . Context , req interface { } ) ( interface { } , error ) {
return srv . ( ObjectServiceServer ) . GetRangeHash ( ctx , req . ( * GetRangeHashRequest ) )
}
return interceptor ( ctx , in , info , handler )
}
2023-06-30 10:25:01 +00:00
func _ObjectService_PutSingle_Handler ( srv interface { } , ctx context . Context , dec func ( interface { } ) error , interceptor grpc . UnaryServerInterceptor ) ( interface { } , error ) {
in := new ( PutSingleRequest )
if err := dec ( in ) ; err != nil {
return nil , err
}
if interceptor == nil {
return srv . ( ObjectServiceServer ) . PutSingle ( ctx , in )
}
info := & grpc . UnaryServerInfo {
Server : srv ,
FullMethod : ObjectService_PutSingle_FullMethodName ,
}
handler := func ( ctx context . Context , req interface { } ) ( interface { } , error ) {
return srv . ( ObjectServiceServer ) . PutSingle ( ctx , req . ( * PutSingleRequest ) )
}
return interceptor ( ctx , in , info , handler )
}
2024-07-24 14:40:47 +00:00
func _ObjectService_Patch_Handler ( srv interface { } , stream grpc . ServerStream ) error {
return srv . ( ObjectServiceServer ) . Patch ( & objectServicePatchServer { stream } )
}
type ObjectService_PatchServer interface {
SendAndClose ( * PatchResponse ) error
Recv ( ) ( * PatchRequest , error )
grpc . ServerStream
}
type objectServicePatchServer struct {
grpc . ServerStream
}
func ( x * objectServicePatchServer ) SendAndClose ( m * PatchResponse ) error {
return x . ServerStream . SendMsg ( m )
}
func ( x * objectServicePatchServer ) Recv ( ) ( * PatchRequest , error ) {
m := new ( PatchRequest )
if err := x . ServerStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
2021-09-28 15:11:33 +00:00
// ObjectService_ServiceDesc is the grpc.ServiceDesc for ObjectService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ObjectService_ServiceDesc = grpc . ServiceDesc {
ServiceName : "neo.fs.v2.object.ObjectService" ,
HandlerType : ( * ObjectServiceServer ) ( nil ) ,
Methods : [ ] grpc . MethodDesc {
{
MethodName : "Delete" ,
Handler : _ObjectService_Delete_Handler ,
} ,
{
MethodName : "Head" ,
Handler : _ObjectService_Head_Handler ,
} ,
{
MethodName : "GetRangeHash" ,
Handler : _ObjectService_GetRangeHash_Handler ,
} ,
2023-06-30 10:25:01 +00:00
{
MethodName : "PutSingle" ,
Handler : _ObjectService_PutSingle_Handler ,
} ,
2021-09-28 15:11:33 +00:00
} ,
Streams : [ ] grpc . StreamDesc {
{
StreamName : "Get" ,
Handler : _ObjectService_Get_Handler ,
ServerStreams : true ,
} ,
{
StreamName : "Put" ,
Handler : _ObjectService_Put_Handler ,
ClientStreams : true ,
} ,
{
StreamName : "Search" ,
Handler : _ObjectService_Search_Handler ,
ServerStreams : true ,
} ,
{
StreamName : "GetRange" ,
Handler : _ObjectService_GetRange_Handler ,
ServerStreams : true ,
} ,
2024-07-24 14:40:47 +00:00
{
StreamName : "Patch" ,
Handler : _ObjectService_Patch_Handler ,
ClientStreams : true ,
} ,
2021-09-28 15:11:33 +00:00
} ,
2021-11-17 09:35:56 +00:00
Metadata : "object/grpc/service.proto" ,
2021-09-28 15:11:33 +00:00
}