Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterObjectServiceServer(s grpc.ServiceRegistrar, srv ObjectServiceServer)
- type DeleteRequest
- func (x *DeleteRequest) ClearBody()
- func (x *DeleteRequest) ClearMetaHeader()
- func (x *DeleteRequest) ClearVerifyHeader()
- func (x *DeleteRequest) GetBody() *DeleteRequest_Body
- func (x *DeleteRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *DeleteRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *DeleteRequest) HasBody() bool
- func (x *DeleteRequest) HasMetaHeader() bool
- func (x *DeleteRequest) HasVerifyHeader() bool
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) SetBody(v *DeleteRequest_Body)
- func (x *DeleteRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *DeleteRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *DeleteRequest) String() string
- type DeleteRequest_Body
- func (x *DeleteRequest_Body) ClearAddress()
- func (x *DeleteRequest_Body) GetAddress() *grpc1.Address
- func (x *DeleteRequest_Body) HasAddress() bool
- func (*DeleteRequest_Body) ProtoMessage()
- func (x *DeleteRequest_Body) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest_Body) Reset()
- func (x *DeleteRequest_Body) SetAddress(v *grpc1.Address)
- func (x *DeleteRequest_Body) String() string
- type DeleteRequest_Body_builder
- type DeleteRequest_builder
- type DeleteResponse
- func (x *DeleteResponse) ClearBody()
- func (x *DeleteResponse) ClearMetaHeader()
- func (x *DeleteResponse) ClearVerifyHeader()
- func (x *DeleteResponse) GetBody() *DeleteResponse_Body
- func (x *DeleteResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *DeleteResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *DeleteResponse) HasBody() bool
- func (x *DeleteResponse) HasMetaHeader() bool
- func (x *DeleteResponse) HasVerifyHeader() bool
- func (*DeleteResponse) ProtoMessage()
- func (x *DeleteResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResponse) Reset()
- func (x *DeleteResponse) SetBody(v *DeleteResponse_Body)
- func (x *DeleteResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *DeleteResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *DeleteResponse) String() string
- type DeleteResponse_Body
- func (x *DeleteResponse_Body) ClearTombstone()
- func (x *DeleteResponse_Body) GetTombstone() *grpc1.Address
- func (x *DeleteResponse_Body) HasTombstone() bool
- func (*DeleteResponse_Body) ProtoMessage()
- func (x *DeleteResponse_Body) ProtoReflect() protoreflect.Message
- func (x *DeleteResponse_Body) Reset()
- func (x *DeleteResponse_Body) SetTombstone(v *grpc1.Address)
- func (x *DeleteResponse_Body) String() string
- type DeleteResponse_Body_builder
- type DeleteResponse_builder
- type ECInfo
- type ECInfo_Chunk
- func (x *ECInfo_Chunk) ClearId()
- func (x *ECInfo_Chunk) ClearIndex()
- func (x *ECInfo_Chunk) ClearTotal()
- func (x *ECInfo_Chunk) GetId() *grpc.ObjectID
- func (x *ECInfo_Chunk) GetIndex() uint32
- func (x *ECInfo_Chunk) GetTotal() uint32
- func (x *ECInfo_Chunk) HasId() bool
- func (x *ECInfo_Chunk) HasIndex() bool
- func (x *ECInfo_Chunk) HasTotal() bool
- func (*ECInfo_Chunk) ProtoMessage()
- func (x *ECInfo_Chunk) ProtoReflect() protoreflect.Message
- func (x *ECInfo_Chunk) Reset()
- func (x *ECInfo_Chunk) SetId(v *grpc.ObjectID)
- func (x *ECInfo_Chunk) SetIndex(v uint32)
- func (x *ECInfo_Chunk) SetTotal(v uint32)
- func (x *ECInfo_Chunk) String() string
- type ECInfo_Chunk_builder
- type ECInfo_builder
- type GetRangeHashRequest
- func (x *GetRangeHashRequest) ClearBody()
- func (x *GetRangeHashRequest) ClearMetaHeader()
- func (x *GetRangeHashRequest) ClearVerifyHeader()
- func (x *GetRangeHashRequest) GetBody() *GetRangeHashRequest_Body
- func (x *GetRangeHashRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *GetRangeHashRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *GetRangeHashRequest) HasBody() bool
- func (x *GetRangeHashRequest) HasMetaHeader() bool
- func (x *GetRangeHashRequest) HasVerifyHeader() bool
- func (*GetRangeHashRequest) ProtoMessage()
- func (x *GetRangeHashRequest) ProtoReflect() protoreflect.Message
- func (x *GetRangeHashRequest) Reset()
- func (x *GetRangeHashRequest) SetBody(v *GetRangeHashRequest_Body)
- func (x *GetRangeHashRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *GetRangeHashRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *GetRangeHashRequest) String() string
- type GetRangeHashRequest_Body
- func (x *GetRangeHashRequest_Body) ClearAddress()
- func (x *GetRangeHashRequest_Body) ClearSalt()
- func (x *GetRangeHashRequest_Body) ClearType()
- func (x *GetRangeHashRequest_Body) GetAddress() *grpc1.Address
- func (x *GetRangeHashRequest_Body) GetRanges() []*Range
- func (x *GetRangeHashRequest_Body) GetSalt() []byte
- func (x *GetRangeHashRequest_Body) GetType() grpc1.ChecksumType
- func (x *GetRangeHashRequest_Body) HasAddress() bool
- func (x *GetRangeHashRequest_Body) HasSalt() bool
- func (x *GetRangeHashRequest_Body) HasType() bool
- func (*GetRangeHashRequest_Body) ProtoMessage()
- func (x *GetRangeHashRequest_Body) ProtoReflect() protoreflect.Message
- func (x *GetRangeHashRequest_Body) Reset()
- func (x *GetRangeHashRequest_Body) SetAddress(v *grpc1.Address)
- func (x *GetRangeHashRequest_Body) SetRanges(v []*Range)
- func (x *GetRangeHashRequest_Body) SetSalt(v []byte)
- func (x *GetRangeHashRequest_Body) SetType(v grpc1.ChecksumType)
- func (x *GetRangeHashRequest_Body) String() string
- type GetRangeHashRequest_Body_builder
- type GetRangeHashRequest_builder
- type GetRangeHashResponse
- func (x *GetRangeHashResponse) ClearBody()
- func (x *GetRangeHashResponse) ClearMetaHeader()
- func (x *GetRangeHashResponse) ClearVerifyHeader()
- func (x *GetRangeHashResponse) GetBody() *GetRangeHashResponse_Body
- func (x *GetRangeHashResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *GetRangeHashResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *GetRangeHashResponse) HasBody() bool
- func (x *GetRangeHashResponse) HasMetaHeader() bool
- func (x *GetRangeHashResponse) HasVerifyHeader() bool
- func (*GetRangeHashResponse) ProtoMessage()
- func (x *GetRangeHashResponse) ProtoReflect() protoreflect.Message
- func (x *GetRangeHashResponse) Reset()
- func (x *GetRangeHashResponse) SetBody(v *GetRangeHashResponse_Body)
- func (x *GetRangeHashResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *GetRangeHashResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *GetRangeHashResponse) String() string
- type GetRangeHashResponse_Body
- func (x *GetRangeHashResponse_Body) ClearType()
- func (x *GetRangeHashResponse_Body) GetHashList() [][]byte
- func (x *GetRangeHashResponse_Body) GetType() grpc1.ChecksumType
- func (x *GetRangeHashResponse_Body) HasType() bool
- func (*GetRangeHashResponse_Body) ProtoMessage()
- func (x *GetRangeHashResponse_Body) ProtoReflect() protoreflect.Message
- func (x *GetRangeHashResponse_Body) Reset()
- func (x *GetRangeHashResponse_Body) SetHashList(v [][]byte)
- func (x *GetRangeHashResponse_Body) SetType(v grpc1.ChecksumType)
- func (x *GetRangeHashResponse_Body) String() string
- type GetRangeHashResponse_Body_builder
- type GetRangeHashResponse_builder
- type GetRangeRequest
- func (x *GetRangeRequest) ClearBody()
- func (x *GetRangeRequest) ClearMetaHeader()
- func (x *GetRangeRequest) ClearVerifyHeader()
- func (x *GetRangeRequest) GetBody() *GetRangeRequest_Body
- func (x *GetRangeRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *GetRangeRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *GetRangeRequest) HasBody() bool
- func (x *GetRangeRequest) HasMetaHeader() bool
- func (x *GetRangeRequest) HasVerifyHeader() bool
- func (*GetRangeRequest) ProtoMessage()
- func (x *GetRangeRequest) ProtoReflect() protoreflect.Message
- func (x *GetRangeRequest) Reset()
- func (x *GetRangeRequest) SetBody(v *GetRangeRequest_Body)
- func (x *GetRangeRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *GetRangeRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *GetRangeRequest) String() string
- type GetRangeRequest_Body
- func (x *GetRangeRequest_Body) ClearAddress()
- func (x *GetRangeRequest_Body) ClearRange()
- func (x *GetRangeRequest_Body) ClearRaw()
- func (x *GetRangeRequest_Body) GetAddress() *grpc1.Address
- func (x *GetRangeRequest_Body) GetRange() *Range
- func (x *GetRangeRequest_Body) GetRaw() bool
- func (x *GetRangeRequest_Body) HasAddress() bool
- func (x *GetRangeRequest_Body) HasRange() bool
- func (x *GetRangeRequest_Body) HasRaw() bool
- func (*GetRangeRequest_Body) ProtoMessage()
- func (x *GetRangeRequest_Body) ProtoReflect() protoreflect.Message
- func (x *GetRangeRequest_Body) Reset()
- func (x *GetRangeRequest_Body) SetAddress(v *grpc1.Address)
- func (x *GetRangeRequest_Body) SetRange(v *Range)
- func (x *GetRangeRequest_Body) SetRaw(v bool)
- func (x *GetRangeRequest_Body) String() string
- type GetRangeRequest_Body_builder
- type GetRangeRequest_builder
- type GetRangeResponse
- func (x *GetRangeResponse) ClearBody()
- func (x *GetRangeResponse) ClearMetaHeader()
- func (x *GetRangeResponse) ClearVerifyHeader()
- func (x *GetRangeResponse) GetBody() *GetRangeResponse_Body
- func (x *GetRangeResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *GetRangeResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *GetRangeResponse) HasBody() bool
- func (x *GetRangeResponse) HasMetaHeader() bool
- func (x *GetRangeResponse) HasVerifyHeader() bool
- func (*GetRangeResponse) ProtoMessage()
- func (x *GetRangeResponse) ProtoReflect() protoreflect.Message
- func (x *GetRangeResponse) Reset()
- func (x *GetRangeResponse) SetBody(v *GetRangeResponse_Body)
- func (x *GetRangeResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *GetRangeResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *GetRangeResponse) String() string
- type GetRangeResponse_Body
- func (x *GetRangeResponse_Body) ClearChunk()
- func (x *GetRangeResponse_Body) ClearEcInfo()
- func (x *GetRangeResponse_Body) ClearRangePart()
- func (x *GetRangeResponse_Body) ClearSplitInfo()
- func (x *GetRangeResponse_Body) GetChunk() []byte
- func (x *GetRangeResponse_Body) GetEcInfo() *ECInfo
- func (x *GetRangeResponse_Body) GetRangePart() isGetRangeResponse_Body_RangePart
- func (x *GetRangeResponse_Body) GetSplitInfo() *SplitInfo
- func (x *GetRangeResponse_Body) HasChunk() bool
- func (x *GetRangeResponse_Body) HasEcInfo() bool
- func (x *GetRangeResponse_Body) HasRangePart() bool
- func (x *GetRangeResponse_Body) HasSplitInfo() bool
- func (*GetRangeResponse_Body) ProtoMessage()
- func (x *GetRangeResponse_Body) ProtoReflect() protoreflect.Message
- func (x *GetRangeResponse_Body) Reset()
- func (x *GetRangeResponse_Body) SetChunk(v []byte)
- func (x *GetRangeResponse_Body) SetEcInfo(v *ECInfo)
- func (x *GetRangeResponse_Body) SetSplitInfo(v *SplitInfo)
- func (x *GetRangeResponse_Body) String() string
- func (x *GetRangeResponse_Body) WhichRangePart() case_GetRangeResponse_Body_RangePart
- type GetRangeResponse_Body_Chunk
- type GetRangeResponse_Body_EcInfo
- type GetRangeResponse_Body_SplitInfo
- type GetRangeResponse_Body_builder
- type GetRangeResponse_builder
- type GetRequest
- func (x *GetRequest) ClearBody()
- func (x *GetRequest) ClearMetaHeader()
- func (x *GetRequest) ClearVerifyHeader()
- func (x *GetRequest) GetBody() *GetRequest_Body
- func (x *GetRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *GetRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *GetRequest) HasBody() bool
- func (x *GetRequest) HasMetaHeader() bool
- func (x *GetRequest) HasVerifyHeader() bool
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (x *GetRequest) SetBody(v *GetRequest_Body)
- func (x *GetRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *GetRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *GetRequest) String() string
- type GetRequest_Body
- func (x *GetRequest_Body) ClearAddress()
- func (x *GetRequest_Body) ClearRaw()
- func (x *GetRequest_Body) GetAddress() *grpc1.Address
- func (x *GetRequest_Body) GetRaw() bool
- func (x *GetRequest_Body) HasAddress() bool
- func (x *GetRequest_Body) HasRaw() bool
- func (*GetRequest_Body) ProtoMessage()
- func (x *GetRequest_Body) ProtoReflect() protoreflect.Message
- func (x *GetRequest_Body) Reset()
- func (x *GetRequest_Body) SetAddress(v *grpc1.Address)
- func (x *GetRequest_Body) SetRaw(v bool)
- func (x *GetRequest_Body) String() string
- type GetRequest_Body_builder
- type GetRequest_builder
- type GetResponse
- func (x *GetResponse) ClearBody()
- func (x *GetResponse) ClearMetaHeader()
- func (x *GetResponse) ClearVerifyHeader()
- func (x *GetResponse) GetBody() *GetResponse_Body
- func (x *GetResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *GetResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *GetResponse) HasBody() bool
- func (x *GetResponse) HasMetaHeader() bool
- func (x *GetResponse) HasVerifyHeader() bool
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) SetBody(v *GetResponse_Body)
- func (x *GetResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *GetResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *GetResponse) String() string
- type GetResponse_Body
- func (x *GetResponse_Body) ClearChunk()
- func (x *GetResponse_Body) ClearEcInfo()
- func (x *GetResponse_Body) ClearInit()
- func (x *GetResponse_Body) ClearObjectPart()
- func (x *GetResponse_Body) ClearSplitInfo()
- func (x *GetResponse_Body) GetChunk() []byte
- func (x *GetResponse_Body) GetEcInfo() *ECInfo
- func (x *GetResponse_Body) GetInit() *GetResponse_Body_Init
- func (x *GetResponse_Body) GetObjectPart() isGetResponse_Body_ObjectPart
- func (x *GetResponse_Body) GetSplitInfo() *SplitInfo
- func (x *GetResponse_Body) HasChunk() bool
- func (x *GetResponse_Body) HasEcInfo() bool
- func (x *GetResponse_Body) HasInit() bool
- func (x *GetResponse_Body) HasObjectPart() bool
- func (x *GetResponse_Body) HasSplitInfo() bool
- func (*GetResponse_Body) ProtoMessage()
- func (x *GetResponse_Body) ProtoReflect() protoreflect.Message
- func (x *GetResponse_Body) Reset()
- func (x *GetResponse_Body) SetChunk(v []byte)
- func (x *GetResponse_Body) SetEcInfo(v *ECInfo)
- func (x *GetResponse_Body) SetInit(v *GetResponse_Body_Init)
- func (x *GetResponse_Body) SetSplitInfo(v *SplitInfo)
- func (x *GetResponse_Body) String() string
- func (x *GetResponse_Body) WhichObjectPart() case_GetResponse_Body_ObjectPart
- type GetResponse_Body_Chunk
- type GetResponse_Body_EcInfo
- type GetResponse_Body_Init
- func (x *GetResponse_Body_Init) ClearHeader()
- func (x *GetResponse_Body_Init) ClearObjectId()
- func (x *GetResponse_Body_Init) ClearSignature()
- func (x *GetResponse_Body_Init) GetHeader() *Header
- func (x *GetResponse_Body_Init) GetObjectId() *grpc1.ObjectID
- func (x *GetResponse_Body_Init) GetSignature() *grpc1.Signature
- func (x *GetResponse_Body_Init) HasHeader() bool
- func (x *GetResponse_Body_Init) HasObjectId() bool
- func (x *GetResponse_Body_Init) HasSignature() bool
- func (*GetResponse_Body_Init) ProtoMessage()
- func (x *GetResponse_Body_Init) ProtoReflect() protoreflect.Message
- func (x *GetResponse_Body_Init) Reset()
- func (x *GetResponse_Body_Init) SetHeader(v *Header)
- func (x *GetResponse_Body_Init) SetObjectId(v *grpc1.ObjectID)
- func (x *GetResponse_Body_Init) SetSignature(v *grpc1.Signature)
- func (x *GetResponse_Body_Init) String() string
- type GetResponse_Body_Init_
- type GetResponse_Body_Init_builder
- type GetResponse_Body_SplitInfo
- type GetResponse_Body_builder
- type GetResponse_builder
- type HeadRequest
- func (x *HeadRequest) ClearBody()
- func (x *HeadRequest) ClearMetaHeader()
- func (x *HeadRequest) ClearVerifyHeader()
- func (x *HeadRequest) GetBody() *HeadRequest_Body
- func (x *HeadRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *HeadRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *HeadRequest) HasBody() bool
- func (x *HeadRequest) HasMetaHeader() bool
- func (x *HeadRequest) HasVerifyHeader() bool
- func (*HeadRequest) ProtoMessage()
- func (x *HeadRequest) ProtoReflect() protoreflect.Message
- func (x *HeadRequest) Reset()
- func (x *HeadRequest) SetBody(v *HeadRequest_Body)
- func (x *HeadRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *HeadRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *HeadRequest) String() string
- type HeadRequest_Body
- func (x *HeadRequest_Body) ClearAddress()
- func (x *HeadRequest_Body) ClearMainOnly()
- func (x *HeadRequest_Body) ClearRaw()
- func (x *HeadRequest_Body) GetAddress() *grpc1.Address
- func (x *HeadRequest_Body) GetMainOnly() bool
- func (x *HeadRequest_Body) GetRaw() bool
- func (x *HeadRequest_Body) HasAddress() bool
- func (x *HeadRequest_Body) HasMainOnly() bool
- func (x *HeadRequest_Body) HasRaw() bool
- func (*HeadRequest_Body) ProtoMessage()
- func (x *HeadRequest_Body) ProtoReflect() protoreflect.Message
- func (x *HeadRequest_Body) Reset()
- func (x *HeadRequest_Body) SetAddress(v *grpc1.Address)
- func (x *HeadRequest_Body) SetMainOnly(v bool)
- func (x *HeadRequest_Body) SetRaw(v bool)
- func (x *HeadRequest_Body) String() string
- type HeadRequest_Body_builder
- type HeadRequest_builder
- type HeadResponse
- func (x *HeadResponse) ClearBody()
- func (x *HeadResponse) ClearMetaHeader()
- func (x *HeadResponse) ClearVerifyHeader()
- func (x *HeadResponse) GetBody() *HeadResponse_Body
- func (x *HeadResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *HeadResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *HeadResponse) HasBody() bool
- func (x *HeadResponse) HasMetaHeader() bool
- func (x *HeadResponse) HasVerifyHeader() bool
- func (*HeadResponse) ProtoMessage()
- func (x *HeadResponse) ProtoReflect() protoreflect.Message
- func (x *HeadResponse) Reset()
- func (x *HeadResponse) SetBody(v *HeadResponse_Body)
- func (x *HeadResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *HeadResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *HeadResponse) String() string
- type HeadResponse_Body
- func (x *HeadResponse_Body) ClearEcInfo()
- func (x *HeadResponse_Body) ClearHead()
- func (x *HeadResponse_Body) ClearHeader()
- func (x *HeadResponse_Body) ClearShortHeader()
- func (x *HeadResponse_Body) ClearSplitInfo()
- func (x *HeadResponse_Body) GetEcInfo() *ECInfo
- func (x *HeadResponse_Body) GetHead() isHeadResponse_Body_Head
- func (x *HeadResponse_Body) GetHeader() *HeaderWithSignature
- func (x *HeadResponse_Body) GetShortHeader() *ShortHeader
- func (x *HeadResponse_Body) GetSplitInfo() *SplitInfo
- func (x *HeadResponse_Body) HasEcInfo() bool
- func (x *HeadResponse_Body) HasHead() bool
- func (x *HeadResponse_Body) HasHeader() bool
- func (x *HeadResponse_Body) HasShortHeader() bool
- func (x *HeadResponse_Body) HasSplitInfo() bool
- func (*HeadResponse_Body) ProtoMessage()
- func (x *HeadResponse_Body) ProtoReflect() protoreflect.Message
- func (x *HeadResponse_Body) Reset()
- func (x *HeadResponse_Body) SetEcInfo(v *ECInfo)
- func (x *HeadResponse_Body) SetHeader(v *HeaderWithSignature)
- func (x *HeadResponse_Body) SetShortHeader(v *ShortHeader)
- func (x *HeadResponse_Body) SetSplitInfo(v *SplitInfo)
- func (x *HeadResponse_Body) String() string
- func (x *HeadResponse_Body) WhichHead() case_HeadResponse_Body_Head
- type HeadResponse_Body_EcInfo
- type HeadResponse_Body_Header
- type HeadResponse_Body_ShortHeader
- type HeadResponse_Body_SplitInfo
- type HeadResponse_Body_builder
- type HeadResponse_builder
- type Header
- func (x *Header) ClearContainerId()
- func (x *Header) ClearCreationEpoch()
- func (x *Header) ClearEc()
- func (x *Header) ClearHomomorphicHash()
- func (x *Header) ClearObjectType()
- func (x *Header) ClearOwnerId()
- func (x *Header) ClearPayloadHash()
- func (x *Header) ClearPayloadLength()
- func (x *Header) ClearSessionToken()
- func (x *Header) ClearSplit()
- func (x *Header) ClearVersion()
- func (x *Header) GetAttributes() []*Header_Attribute
- func (x *Header) GetContainerId() *grpc.ContainerID
- func (x *Header) GetCreationEpoch() uint64
- func (x *Header) GetEc() *Header_EC
- func (x *Header) GetHomomorphicHash() *grpc.Checksum
- func (x *Header) GetObjectType() ObjectType
- func (x *Header) GetOwnerId() *grpc.OwnerID
- func (x *Header) GetPayloadHash() *grpc.Checksum
- func (x *Header) GetPayloadLength() uint64
- func (x *Header) GetSessionToken() *grpc1.SessionToken
- func (x *Header) GetSplit() *Header_Split
- func (x *Header) GetVersion() *grpc.Version
- func (x *Header) HasContainerId() bool
- func (x *Header) HasCreationEpoch() bool
- func (x *Header) HasEc() bool
- func (x *Header) HasHomomorphicHash() bool
- func (x *Header) HasObjectType() bool
- func (x *Header) HasOwnerId() bool
- func (x *Header) HasPayloadHash() bool
- func (x *Header) HasPayloadLength() bool
- func (x *Header) HasSessionToken() bool
- func (x *Header) HasSplit() bool
- func (x *Header) HasVersion() bool
- func (*Header) ProtoMessage()
- func (x *Header) ProtoReflect() protoreflect.Message
- func (x *Header) Reset()
- func (x *Header) SetAttributes(v []*Header_Attribute)
- func (x *Header) SetContainerId(v *grpc.ContainerID)
- func (x *Header) SetCreationEpoch(v uint64)
- func (x *Header) SetEc(v *Header_EC)
- func (x *Header) SetHomomorphicHash(v *grpc.Checksum)
- func (x *Header) SetObjectType(v ObjectType)
- func (x *Header) SetOwnerId(v *grpc.OwnerID)
- func (x *Header) SetPayloadHash(v *grpc.Checksum)
- func (x *Header) SetPayloadLength(v uint64)
- func (x *Header) SetSessionToken(v *grpc1.SessionToken)
- func (x *Header) SetSplit(v *Header_Split)
- func (x *Header) SetVersion(v *grpc.Version)
- func (x *Header) String() string
- type HeaderWithSignature
- func (x *HeaderWithSignature) ClearHeader()
- func (x *HeaderWithSignature) ClearSignature()
- func (x *HeaderWithSignature) GetHeader() *Header
- func (x *HeaderWithSignature) GetSignature() *grpc1.Signature
- func (x *HeaderWithSignature) HasHeader() bool
- func (x *HeaderWithSignature) HasSignature() bool
- func (*HeaderWithSignature) ProtoMessage()
- func (x *HeaderWithSignature) ProtoReflect() protoreflect.Message
- func (x *HeaderWithSignature) Reset()
- func (x *HeaderWithSignature) SetHeader(v *Header)
- func (x *HeaderWithSignature) SetSignature(v *grpc1.Signature)
- func (x *HeaderWithSignature) String() string
- type HeaderWithSignature_builder
- type Header_Attribute
- func (x *Header_Attribute) ClearKey()
- func (x *Header_Attribute) ClearValue()
- func (x *Header_Attribute) GetKey() string
- func (x *Header_Attribute) GetValue() string
- func (x *Header_Attribute) HasKey() bool
- func (x *Header_Attribute) HasValue() bool
- func (*Header_Attribute) ProtoMessage()
- func (x *Header_Attribute) ProtoReflect() protoreflect.Message
- func (x *Header_Attribute) Reset()
- func (x *Header_Attribute) SetKey(v string)
- func (x *Header_Attribute) SetValue(v string)
- func (x *Header_Attribute) String() string
- type Header_Attribute_builder
- type Header_EC
- func (x *Header_EC) ClearHeader()
- func (x *Header_EC) ClearHeaderLength()
- func (x *Header_EC) ClearIndex()
- func (x *Header_EC) ClearParent()
- func (x *Header_EC) ClearParentSplitId()
- func (x *Header_EC) ClearParentSplitParentId()
- func (x *Header_EC) ClearTotal()
- func (x *Header_EC) GetHeader() []byte
- func (x *Header_EC) GetHeaderLength() uint32
- func (x *Header_EC) GetIndex() uint32
- func (x *Header_EC) GetParent() *grpc.ObjectID
- func (x *Header_EC) GetParentAttributes() []*Header_Attribute
- func (x *Header_EC) GetParentSplitId() []byte
- func (x *Header_EC) GetParentSplitParentId() *grpc.ObjectID
- func (x *Header_EC) GetTotal() uint32
- func (x *Header_EC) HasHeader() bool
- func (x *Header_EC) HasHeaderLength() bool
- func (x *Header_EC) HasIndex() bool
- func (x *Header_EC) HasParent() bool
- func (x *Header_EC) HasParentSplitId() bool
- func (x *Header_EC) HasParentSplitParentId() bool
- func (x *Header_EC) HasTotal() bool
- func (*Header_EC) ProtoMessage()
- func (x *Header_EC) ProtoReflect() protoreflect.Message
- func (x *Header_EC) Reset()
- func (x *Header_EC) SetHeader(v []byte)
- func (x *Header_EC) SetHeaderLength(v uint32)
- func (x *Header_EC) SetIndex(v uint32)
- func (x *Header_EC) SetParent(v *grpc.ObjectID)
- func (x *Header_EC) SetParentAttributes(v []*Header_Attribute)
- func (x *Header_EC) SetParentSplitId(v []byte)
- func (x *Header_EC) SetParentSplitParentId(v *grpc.ObjectID)
- func (x *Header_EC) SetTotal(v uint32)
- func (x *Header_EC) String() string
- type Header_EC_builder
- type Header_Split
- func (x *Header_Split) ClearParent()
- func (x *Header_Split) ClearParentHeader()
- func (x *Header_Split) ClearParentSignature()
- func (x *Header_Split) ClearPrevious()
- func (x *Header_Split) ClearSplitId()
- func (x *Header_Split) GetChildren() []*grpc.ObjectID
- func (x *Header_Split) GetParent() *grpc.ObjectID
- func (x *Header_Split) GetParentHeader() *Header
- func (x *Header_Split) GetParentSignature() *grpc.Signature
- func (x *Header_Split) GetPrevious() *grpc.ObjectID
- func (x *Header_Split) GetSplitId() []byte
- func (x *Header_Split) HasParent() bool
- func (x *Header_Split) HasParentHeader() bool
- func (x *Header_Split) HasParentSignature() bool
- func (x *Header_Split) HasPrevious() bool
- func (x *Header_Split) HasSplitId() bool
- func (*Header_Split) ProtoMessage()
- func (x *Header_Split) ProtoReflect() protoreflect.Message
- func (x *Header_Split) Reset()
- func (x *Header_Split) SetChildren(v []*grpc.ObjectID)
- func (x *Header_Split) SetParent(v *grpc.ObjectID)
- func (x *Header_Split) SetParentHeader(v *Header)
- func (x *Header_Split) SetParentSignature(v *grpc.Signature)
- func (x *Header_Split) SetPrevious(v *grpc.ObjectID)
- func (x *Header_Split) SetSplitId(v []byte)
- func (x *Header_Split) String() string
- type Header_Split_builder
- type Header_builder
- type MatchType
- type Object
- func (x *Object) ClearHeader()
- func (x *Object) ClearObjectId()
- func (x *Object) ClearPayload()
- func (x *Object) ClearSignature()
- func (x *Object) GetHeader() *Header
- func (x *Object) GetObjectId() *grpc.ObjectID
- func (x *Object) GetPayload() []byte
- func (x *Object) GetSignature() *grpc.Signature
- func (x *Object) HasHeader() bool
- func (x *Object) HasObjectId() bool
- func (x *Object) HasPayload() bool
- func (x *Object) HasSignature() bool
- func (*Object) ProtoMessage()
- func (x *Object) ProtoReflect() protoreflect.Message
- func (x *Object) Reset()
- func (x *Object) SetHeader(v *Header)
- func (x *Object) SetObjectId(v *grpc.ObjectID)
- func (x *Object) SetPayload(v []byte)
- func (x *Object) SetSignature(v *grpc.Signature)
- func (x *Object) String() string
- type ObjectServiceClient
- type ObjectServiceServer
- type ObjectService_GetClient
- type ObjectService_GetRangeClient
- type ObjectService_GetRangeServer
- type ObjectService_GetServer
- type ObjectService_PatchClient
- type ObjectService_PatchServer
- type ObjectService_PutClient
- type ObjectService_PutServer
- type ObjectService_SearchClient
- type ObjectService_SearchServer
- type ObjectType
- type Object_builder
- type PatchRequest
- func (x *PatchRequest) ClearBody()
- func (x *PatchRequest) ClearMetaHeader()
- func (x *PatchRequest) ClearVerifyHeader()
- func (x *PatchRequest) GetBody() *PatchRequest_Body
- func (x *PatchRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *PatchRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *PatchRequest) HasBody() bool
- func (x *PatchRequest) HasMetaHeader() bool
- func (x *PatchRequest) HasVerifyHeader() bool
- func (*PatchRequest) ProtoMessage()
- func (x *PatchRequest) ProtoReflect() protoreflect.Message
- func (x *PatchRequest) Reset()
- func (x *PatchRequest) SetBody(v *PatchRequest_Body)
- func (x *PatchRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *PatchRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *PatchRequest) String() string
- type PatchRequest_Body
- func (x *PatchRequest_Body) ClearAddress()
- func (x *PatchRequest_Body) ClearPatch()
- func (x *PatchRequest_Body) ClearReplaceAttributes()
- func (x *PatchRequest_Body) GetAddress() *grpc1.Address
- func (x *PatchRequest_Body) GetNewAttributes() []*Header_Attribute
- func (x *PatchRequest_Body) GetPatch() *PatchRequest_Body_Patch
- func (x *PatchRequest_Body) GetReplaceAttributes() bool
- func (x *PatchRequest_Body) HasAddress() bool
- func (x *PatchRequest_Body) HasPatch() bool
- func (x *PatchRequest_Body) HasReplaceAttributes() bool
- func (*PatchRequest_Body) ProtoMessage()
- func (x *PatchRequest_Body) ProtoReflect() protoreflect.Message
- func (x *PatchRequest_Body) Reset()
- func (x *PatchRequest_Body) SetAddress(v *grpc1.Address)
- func (x *PatchRequest_Body) SetNewAttributes(v []*Header_Attribute)
- func (x *PatchRequest_Body) SetPatch(v *PatchRequest_Body_Patch)
- func (x *PatchRequest_Body) SetReplaceAttributes(v bool)
- func (x *PatchRequest_Body) String() string
- type PatchRequest_Body_Patch
- func (x *PatchRequest_Body_Patch) ClearChunk()
- func (x *PatchRequest_Body_Patch) ClearSourceRange()
- func (x *PatchRequest_Body_Patch) GetChunk() []byte
- func (x *PatchRequest_Body_Patch) GetSourceRange() *Range
- func (x *PatchRequest_Body_Patch) HasChunk() bool
- func (x *PatchRequest_Body_Patch) HasSourceRange() bool
- func (*PatchRequest_Body_Patch) ProtoMessage()
- func (x *PatchRequest_Body_Patch) ProtoReflect() protoreflect.Message
- func (x *PatchRequest_Body_Patch) Reset()
- func (x *PatchRequest_Body_Patch) SetChunk(v []byte)
- func (x *PatchRequest_Body_Patch) SetSourceRange(v *Range)
- func (x *PatchRequest_Body_Patch) String() string
- type PatchRequest_Body_Patch_builder
- type PatchRequest_Body_builder
- type PatchRequest_builder
- type PatchResponse
- func (x *PatchResponse) ClearBody()
- func (x *PatchResponse) ClearMetaHeader()
- func (x *PatchResponse) ClearVerifyHeader()
- func (x *PatchResponse) GetBody() *PatchResponse_Body
- func (x *PatchResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *PatchResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *PatchResponse) HasBody() bool
- func (x *PatchResponse) HasMetaHeader() bool
- func (x *PatchResponse) HasVerifyHeader() bool
- func (*PatchResponse) ProtoMessage()
- func (x *PatchResponse) ProtoReflect() protoreflect.Message
- func (x *PatchResponse) Reset()
- func (x *PatchResponse) SetBody(v *PatchResponse_Body)
- func (x *PatchResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *PatchResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *PatchResponse) String() string
- type PatchResponse_Body
- func (x *PatchResponse_Body) ClearObjectId()
- func (x *PatchResponse_Body) GetObjectId() *grpc1.ObjectID
- func (x *PatchResponse_Body) HasObjectId() bool
- func (*PatchResponse_Body) ProtoMessage()
- func (x *PatchResponse_Body) ProtoReflect() protoreflect.Message
- func (x *PatchResponse_Body) Reset()
- func (x *PatchResponse_Body) SetObjectId(v *grpc1.ObjectID)
- func (x *PatchResponse_Body) String() string
- type PatchResponse_Body_builder
- type PatchResponse_builder
- type PutRequest
- func (x *PutRequest) ClearBody()
- func (x *PutRequest) ClearMetaHeader()
- func (x *PutRequest) ClearVerifyHeader()
- func (x *PutRequest) GetBody() *PutRequest_Body
- func (x *PutRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *PutRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *PutRequest) HasBody() bool
- func (x *PutRequest) HasMetaHeader() bool
- func (x *PutRequest) HasVerifyHeader() bool
- func (*PutRequest) ProtoMessage()
- func (x *PutRequest) ProtoReflect() protoreflect.Message
- func (x *PutRequest) Reset()
- func (x *PutRequest) SetBody(v *PutRequest_Body)
- func (x *PutRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *PutRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *PutRequest) String() string
- type PutRequest_Body
- func (x *PutRequest_Body) ClearChunk()
- func (x *PutRequest_Body) ClearInit()
- func (x *PutRequest_Body) ClearObjectPart()
- func (x *PutRequest_Body) GetChunk() []byte
- func (x *PutRequest_Body) GetInit() *PutRequest_Body_Init
- func (x *PutRequest_Body) GetObjectPart() isPutRequest_Body_ObjectPart
- func (x *PutRequest_Body) HasChunk() bool
- func (x *PutRequest_Body) HasInit() bool
- func (x *PutRequest_Body) HasObjectPart() bool
- func (*PutRequest_Body) ProtoMessage()
- func (x *PutRequest_Body) ProtoReflect() protoreflect.Message
- func (x *PutRequest_Body) Reset()
- func (x *PutRequest_Body) SetChunk(v []byte)
- func (x *PutRequest_Body) SetInit(v *PutRequest_Body_Init)
- func (x *PutRequest_Body) String() string
- func (x *PutRequest_Body) WhichObjectPart() case_PutRequest_Body_ObjectPart
- type PutRequest_Body_Chunk
- type PutRequest_Body_Init
- func (x *PutRequest_Body_Init) ClearHeader()
- func (x *PutRequest_Body_Init) ClearObjectId()
- func (x *PutRequest_Body_Init) ClearSignature()
- func (x *PutRequest_Body_Init) GetCopiesNumber() []uint32
- func (x *PutRequest_Body_Init) GetHeader() *Header
- func (x *PutRequest_Body_Init) GetObjectId() *grpc1.ObjectID
- func (x *PutRequest_Body_Init) GetSignature() *grpc1.Signature
- func (x *PutRequest_Body_Init) HasHeader() bool
- func (x *PutRequest_Body_Init) HasObjectId() bool
- func (x *PutRequest_Body_Init) HasSignature() bool
- func (*PutRequest_Body_Init) ProtoMessage()
- func (x *PutRequest_Body_Init) ProtoReflect() protoreflect.Message
- func (x *PutRequest_Body_Init) Reset()
- func (x *PutRequest_Body_Init) SetCopiesNumber(v []uint32)
- func (x *PutRequest_Body_Init) SetHeader(v *Header)
- func (x *PutRequest_Body_Init) SetObjectId(v *grpc1.ObjectID)
- func (x *PutRequest_Body_Init) SetSignature(v *grpc1.Signature)
- func (x *PutRequest_Body_Init) String() string
- type PutRequest_Body_Init_
- type PutRequest_Body_Init_builder
- type PutRequest_Body_builder
- type PutRequest_builder
- type PutResponse
- func (x *PutResponse) ClearBody()
- func (x *PutResponse) ClearMetaHeader()
- func (x *PutResponse) ClearVerifyHeader()
- func (x *PutResponse) GetBody() *PutResponse_Body
- func (x *PutResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *PutResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *PutResponse) HasBody() bool
- func (x *PutResponse) HasMetaHeader() bool
- func (x *PutResponse) HasVerifyHeader() bool
- func (*PutResponse) ProtoMessage()
- func (x *PutResponse) ProtoReflect() protoreflect.Message
- func (x *PutResponse) Reset()
- func (x *PutResponse) SetBody(v *PutResponse_Body)
- func (x *PutResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *PutResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *PutResponse) String() string
- type PutResponse_Body
- func (x *PutResponse_Body) ClearObjectId()
- func (x *PutResponse_Body) GetObjectId() *grpc1.ObjectID
- func (x *PutResponse_Body) HasObjectId() bool
- func (*PutResponse_Body) ProtoMessage()
- func (x *PutResponse_Body) ProtoReflect() protoreflect.Message
- func (x *PutResponse_Body) Reset()
- func (x *PutResponse_Body) SetObjectId(v *grpc1.ObjectID)
- func (x *PutResponse_Body) String() string
- type PutResponse_Body_builder
- type PutResponse_builder
- type PutSingleRequest
- func (x *PutSingleRequest) ClearBody()
- func (x *PutSingleRequest) ClearMetaHeader()
- func (x *PutSingleRequest) ClearVerifyHeader()
- func (x *PutSingleRequest) GetBody() *PutSingleRequest_Body
- func (x *PutSingleRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *PutSingleRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *PutSingleRequest) HasBody() bool
- func (x *PutSingleRequest) HasMetaHeader() bool
- func (x *PutSingleRequest) HasVerifyHeader() bool
- func (*PutSingleRequest) ProtoMessage()
- func (x *PutSingleRequest) ProtoReflect() protoreflect.Message
- func (x *PutSingleRequest) Reset()
- func (x *PutSingleRequest) SetBody(v *PutSingleRequest_Body)
- func (x *PutSingleRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *PutSingleRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *PutSingleRequest) String() string
- type PutSingleRequest_Body
- func (x *PutSingleRequest_Body) ClearObject()
- func (x *PutSingleRequest_Body) GetCopiesNumber() []uint32
- func (x *PutSingleRequest_Body) GetObject() *Object
- func (x *PutSingleRequest_Body) HasObject() bool
- func (*PutSingleRequest_Body) ProtoMessage()
- func (x *PutSingleRequest_Body) ProtoReflect() protoreflect.Message
- func (x *PutSingleRequest_Body) Reset()
- func (x *PutSingleRequest_Body) SetCopiesNumber(v []uint32)
- func (x *PutSingleRequest_Body) SetObject(v *Object)
- func (x *PutSingleRequest_Body) String() string
- type PutSingleRequest_Body_builder
- type PutSingleRequest_builder
- type PutSingleResponse
- func (x *PutSingleResponse) ClearBody()
- func (x *PutSingleResponse) ClearMetaHeader()
- func (x *PutSingleResponse) ClearVerifyHeader()
- func (x *PutSingleResponse) GetBody() *PutSingleResponse_Body
- func (x *PutSingleResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *PutSingleResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *PutSingleResponse) HasBody() bool
- func (x *PutSingleResponse) HasMetaHeader() bool
- func (x *PutSingleResponse) HasVerifyHeader() bool
- func (*PutSingleResponse) ProtoMessage()
- func (x *PutSingleResponse) ProtoReflect() protoreflect.Message
- func (x *PutSingleResponse) Reset()
- func (x *PutSingleResponse) SetBody(v *PutSingleResponse_Body)
- func (x *PutSingleResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *PutSingleResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *PutSingleResponse) String() string
- type PutSingleResponse_Body
- type PutSingleResponse_Body_builder
- type PutSingleResponse_builder
- type Range
- func (x *Range) ClearLength()
- func (x *Range) ClearOffset()
- func (x *Range) GetLength() uint64
- func (x *Range) GetOffset() uint64
- func (x *Range) HasLength() bool
- func (x *Range) HasOffset() bool
- func (*Range) ProtoMessage()
- func (x *Range) ProtoReflect() protoreflect.Message
- func (x *Range) Reset()
- func (x *Range) SetLength(v uint64)
- func (x *Range) SetOffset(v uint64)
- func (x *Range) String() string
- type Range_builder
- type SearchRequest
- func (x *SearchRequest) ClearBody()
- func (x *SearchRequest) ClearMetaHeader()
- func (x *SearchRequest) ClearVerifyHeader()
- func (x *SearchRequest) GetBody() *SearchRequest_Body
- func (x *SearchRequest) GetMetaHeader() *grpc.RequestMetaHeader
- func (x *SearchRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
- func (x *SearchRequest) HasBody() bool
- func (x *SearchRequest) HasMetaHeader() bool
- func (x *SearchRequest) HasVerifyHeader() bool
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) SetBody(v *SearchRequest_Body)
- func (x *SearchRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
- func (x *SearchRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
- func (x *SearchRequest) String() string
- type SearchRequest_Body
- func (x *SearchRequest_Body) ClearContainerId()
- func (x *SearchRequest_Body) ClearVersion()
- func (x *SearchRequest_Body) GetContainerId() *grpc1.ContainerID
- func (x *SearchRequest_Body) GetFilters() []*SearchRequest_Body_Filter
- func (x *SearchRequest_Body) GetVersion() uint32
- func (x *SearchRequest_Body) HasContainerId() bool
- func (x *SearchRequest_Body) HasVersion() bool
- func (*SearchRequest_Body) ProtoMessage()
- func (x *SearchRequest_Body) ProtoReflect() protoreflect.Message
- func (x *SearchRequest_Body) Reset()
- func (x *SearchRequest_Body) SetContainerId(v *grpc1.ContainerID)
- func (x *SearchRequest_Body) SetFilters(v []*SearchRequest_Body_Filter)
- func (x *SearchRequest_Body) SetVersion(v uint32)
- func (x *SearchRequest_Body) String() string
- type SearchRequest_Body_Filter
- func (x *SearchRequest_Body_Filter) ClearKey()
- func (x *SearchRequest_Body_Filter) ClearMatchType()
- func (x *SearchRequest_Body_Filter) ClearValue()
- func (x *SearchRequest_Body_Filter) GetKey() string
- func (x *SearchRequest_Body_Filter) GetMatchType() MatchType
- func (x *SearchRequest_Body_Filter) GetValue() string
- func (x *SearchRequest_Body_Filter) HasKey() bool
- func (x *SearchRequest_Body_Filter) HasMatchType() bool
- func (x *SearchRequest_Body_Filter) HasValue() bool
- func (*SearchRequest_Body_Filter) ProtoMessage()
- func (x *SearchRequest_Body_Filter) ProtoReflect() protoreflect.Message
- func (x *SearchRequest_Body_Filter) Reset()
- func (x *SearchRequest_Body_Filter) SetKey(v string)
- func (x *SearchRequest_Body_Filter) SetMatchType(v MatchType)
- func (x *SearchRequest_Body_Filter) SetValue(v string)
- func (x *SearchRequest_Body_Filter) String() string
- type SearchRequest_Body_Filter_builder
- type SearchRequest_Body_builder
- type SearchRequest_builder
- type SearchResponse
- func (x *SearchResponse) ClearBody()
- func (x *SearchResponse) ClearMetaHeader()
- func (x *SearchResponse) ClearVerifyHeader()
- func (x *SearchResponse) GetBody() *SearchResponse_Body
- func (x *SearchResponse) GetMetaHeader() *grpc.ResponseMetaHeader
- func (x *SearchResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
- func (x *SearchResponse) HasBody() bool
- func (x *SearchResponse) HasMetaHeader() bool
- func (x *SearchResponse) HasVerifyHeader() bool
- func (*SearchResponse) ProtoMessage()
- func (x *SearchResponse) ProtoReflect() protoreflect.Message
- func (x *SearchResponse) Reset()
- func (x *SearchResponse) SetBody(v *SearchResponse_Body)
- func (x *SearchResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
- func (x *SearchResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
- func (x *SearchResponse) String() string
- type SearchResponse_Body
- func (x *SearchResponse_Body) GetIdList() []*grpc1.ObjectID
- func (*SearchResponse_Body) ProtoMessage()
- func (x *SearchResponse_Body) ProtoReflect() protoreflect.Message
- func (x *SearchResponse_Body) Reset()
- func (x *SearchResponse_Body) SetIdList(v []*grpc1.ObjectID)
- func (x *SearchResponse_Body) String() string
- type SearchResponse_Body_builder
- type SearchResponse_builder
- type ShortHeader
- func (x *ShortHeader) ClearCreationEpoch()
- func (x *ShortHeader) ClearHomomorphicHash()
- func (x *ShortHeader) ClearObjectType()
- func (x *ShortHeader) ClearOwnerId()
- func (x *ShortHeader) ClearPayloadHash()
- func (x *ShortHeader) ClearPayloadLength()
- func (x *ShortHeader) ClearVersion()
- func (x *ShortHeader) GetCreationEpoch() uint64
- func (x *ShortHeader) GetHomomorphicHash() *grpc.Checksum
- func (x *ShortHeader) GetObjectType() ObjectType
- func (x *ShortHeader) GetOwnerId() *grpc.OwnerID
- func (x *ShortHeader) GetPayloadHash() *grpc.Checksum
- func (x *ShortHeader) GetPayloadLength() uint64
- func (x *ShortHeader) GetVersion() *grpc.Version
- func (x *ShortHeader) HasCreationEpoch() bool
- func (x *ShortHeader) HasHomomorphicHash() bool
- func (x *ShortHeader) HasObjectType() bool
- func (x *ShortHeader) HasOwnerId() bool
- func (x *ShortHeader) HasPayloadHash() bool
- func (x *ShortHeader) HasPayloadLength() bool
- func (x *ShortHeader) HasVersion() bool
- func (*ShortHeader) ProtoMessage()
- func (x *ShortHeader) ProtoReflect() protoreflect.Message
- func (x *ShortHeader) Reset()
- func (x *ShortHeader) SetCreationEpoch(v uint64)
- func (x *ShortHeader) SetHomomorphicHash(v *grpc.Checksum)
- func (x *ShortHeader) SetObjectType(v ObjectType)
- func (x *ShortHeader) SetOwnerId(v *grpc.OwnerID)
- func (x *ShortHeader) SetPayloadHash(v *grpc.Checksum)
- func (x *ShortHeader) SetPayloadLength(v uint64)
- func (x *ShortHeader) SetVersion(v *grpc.Version)
- func (x *ShortHeader) String() string
- type ShortHeader_builder
- type SplitInfo
- func (x *SplitInfo) ClearLastPart()
- func (x *SplitInfo) ClearLink()
- func (x *SplitInfo) ClearSplitId()
- func (x *SplitInfo) GetLastPart() *grpc.ObjectID
- func (x *SplitInfo) GetLink() *grpc.ObjectID
- func (x *SplitInfo) GetSplitId() []byte
- func (x *SplitInfo) HasLastPart() bool
- func (x *SplitInfo) HasLink() bool
- func (x *SplitInfo) HasSplitId() bool
- func (*SplitInfo) ProtoMessage()
- func (x *SplitInfo) ProtoReflect() protoreflect.Message
- func (x *SplitInfo) Reset()
- func (x *SplitInfo) SetLastPart(v *grpc.ObjectID)
- func (x *SplitInfo) SetLink(v *grpc.ObjectID)
- func (x *SplitInfo) SetSplitId(v []byte)
- func (x *SplitInfo) String() string
- type SplitInfo_builder
- type UnimplementedObjectServiceServer
- func (UnimplementedObjectServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedObjectServiceServer) Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) error
- func (UnimplementedObjectServiceServer) GetRange(*GetRangeRequest, grpc.ServerStreamingServer[GetRangeResponse]) error
- func (UnimplementedObjectServiceServer) GetRangeHash(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error)
- func (UnimplementedObjectServiceServer) Head(context.Context, *HeadRequest) (*HeadResponse, error)
- func (UnimplementedObjectServiceServer) Patch(grpc.ClientStreamingServer[PatchRequest, PatchResponse]) error
- func (UnimplementedObjectServiceServer) Put(grpc.ClientStreamingServer[PutRequest, PutResponse]) error
- func (UnimplementedObjectServiceServer) PutSingle(context.Context, *PutSingleRequest) (*PutSingleResponse, error)
- func (UnimplementedObjectServiceServer) Search(*SearchRequest, grpc.ServerStreamingServer[SearchResponse]) error
- type UnsafeObjectServiceServer
Constants ¶
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" ObjectService_PutSingle_FullMethodName = "/neo.fs.v2.object.ObjectService/PutSingle" ObjectService_Patch_FullMethodName = "/neo.fs.v2.object.ObjectService/Patch" )
const GetRangeResponse_Body_Chunk_case case_GetRangeResponse_Body_RangePart = 1
const GetRangeResponse_Body_EcInfo_case case_GetRangeResponse_Body_RangePart = 3
const GetRangeResponse_Body_RangePart_not_set_case case_GetRangeResponse_Body_RangePart = 0
const GetRangeResponse_Body_SplitInfo_case case_GetRangeResponse_Body_RangePart = 2
const GetResponse_Body_Chunk_case case_GetResponse_Body_ObjectPart = 2
const GetResponse_Body_EcInfo_case case_GetResponse_Body_ObjectPart = 4
const GetResponse_Body_Init_case case_GetResponse_Body_ObjectPart = 1
const GetResponse_Body_ObjectPart_not_set_case case_GetResponse_Body_ObjectPart = 0
const GetResponse_Body_SplitInfo_case case_GetResponse_Body_ObjectPart = 3
const HeadResponse_Body_EcInfo_case case_HeadResponse_Body_Head = 4
const HeadResponse_Body_Head_not_set_case case_HeadResponse_Body_Head = 0
const HeadResponse_Body_Header_case case_HeadResponse_Body_Head = 1
const HeadResponse_Body_ShortHeader_case case_HeadResponse_Body_Head = 2
const HeadResponse_Body_SplitInfo_case case_HeadResponse_Body_Head = 3
const PutRequest_Body_Chunk_case case_PutRequest_Body_ObjectPart = 2
const PutRequest_Body_Init_case case_PutRequest_Body_ObjectPart = 1
const PutRequest_Body_ObjectPart_not_set_case case_PutRequest_Body_ObjectPart = 0
Variables ¶
var ( ObjectType_name = map[int32]string{ 0: "REGULAR", 1: "TOMBSTONE", 3: "LOCK", } ObjectType_value = map[string]int32{ "REGULAR": 0, "TOMBSTONE": 1, "LOCK": 3, } )
Enum value maps for ObjectType.
var ( MatchType_name = map[int32]string{ 0: "MATCH_TYPE_UNSPECIFIED", 1: "STRING_EQUAL", 2: "STRING_NOT_EQUAL", 3: "NOT_PRESENT", 4: "COMMON_PREFIX", } MatchType_value = map[string]int32{ "MATCH_TYPE_UNSPECIFIED": 0, "STRING_EQUAL": 1, "STRING_NOT_EQUAL": 2, "NOT_PRESENT": 3, "COMMON_PREFIX": 4, } )
Enum value maps for MatchType.
var File_api_object_grpc_service_proto protoreflect.FileDescriptor
var File_api_object_grpc_types_proto protoreflect.FileDescriptor
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, }, { MethodName: "PutSingle", Handler: _ObjectService_PutSingle_Handler, }, }, 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, }, { StreamName: "Patch", Handler: _ObjectService_Patch_Handler, ClientStreams: true, }, }, Metadata: "api/object/grpc/service.proto", }
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)
Functions ¶
func RegisterObjectServiceServer ¶
func RegisterObjectServiceServer(s grpc.ServiceRegistrar, srv ObjectServiceServer)
Types ¶
type DeleteRequest ¶
type DeleteRequest struct { // Body of delete object request message. Body *DeleteRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object DELETE request
func (*DeleteRequest) ClearBody ¶
func (x *DeleteRequest) ClearBody()
func (*DeleteRequest) ClearMetaHeader ¶
func (x *DeleteRequest) ClearMetaHeader()
func (*DeleteRequest) ClearVerifyHeader ¶
func (x *DeleteRequest) ClearVerifyHeader()
func (*DeleteRequest) GetBody ¶
func (x *DeleteRequest) GetBody() *DeleteRequest_Body
func (*DeleteRequest) GetMetaHeader ¶
func (x *DeleteRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*DeleteRequest) GetVerifyHeader ¶
func (x *DeleteRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*DeleteRequest) HasBody ¶
func (x *DeleteRequest) HasBody() bool
func (*DeleteRequest) HasMetaHeader ¶
func (x *DeleteRequest) HasMetaHeader() bool
func (*DeleteRequest) HasVerifyHeader ¶
func (x *DeleteRequest) HasVerifyHeader() bool
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) SetBody ¶
func (x *DeleteRequest) SetBody(v *DeleteRequest_Body)
func (*DeleteRequest) SetMetaHeader ¶
func (x *DeleteRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*DeleteRequest) SetVerifyHeader ¶
func (x *DeleteRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteRequest_Body ¶
type DeleteRequest_Body struct { // Address of the object to be deleted Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // contains filtered or unexported fields }
Object DELETE request body
func (*DeleteRequest_Body) ClearAddress ¶
func (x *DeleteRequest_Body) ClearAddress()
func (*DeleteRequest_Body) GetAddress ¶
func (x *DeleteRequest_Body) GetAddress() *grpc1.Address
func (*DeleteRequest_Body) HasAddress ¶
func (x *DeleteRequest_Body) HasAddress() bool
func (*DeleteRequest_Body) ProtoMessage ¶
func (*DeleteRequest_Body) ProtoMessage()
func (*DeleteRequest_Body) ProtoReflect ¶
func (x *DeleteRequest_Body) ProtoReflect() protoreflect.Message
func (*DeleteRequest_Body) Reset ¶
func (x *DeleteRequest_Body) Reset()
func (*DeleteRequest_Body) SetAddress ¶
func (x *DeleteRequest_Body) SetAddress(v *grpc1.Address)
func (*DeleteRequest_Body) String ¶
func (x *DeleteRequest_Body) String() string
type DeleteRequest_Body_builder ¶
type DeleteRequest_Body_builder struct { // Address of the object to be deleted Address *grpc1.Address // contains filtered or unexported fields }
func (DeleteRequest_Body_builder) Build ¶
func (b0 DeleteRequest_Body_builder) Build() *DeleteRequest_Body
type DeleteRequest_builder ¶
type DeleteRequest_builder struct { // Body of delete object request message. Body *DeleteRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (DeleteRequest_builder) Build ¶
func (b0 DeleteRequest_builder) Build() *DeleteRequest
type DeleteResponse ¶
type DeleteResponse struct { // Body of delete object response message. Body *DeleteResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
DeleteResponse body is empty because we cannot guarantee permanent object removal in distributed system.
func (*DeleteResponse) ClearBody ¶
func (x *DeleteResponse) ClearBody()
func (*DeleteResponse) ClearMetaHeader ¶
func (x *DeleteResponse) ClearMetaHeader()
func (*DeleteResponse) ClearVerifyHeader ¶
func (x *DeleteResponse) ClearVerifyHeader()
func (*DeleteResponse) GetBody ¶
func (x *DeleteResponse) GetBody() *DeleteResponse_Body
func (*DeleteResponse) GetMetaHeader ¶
func (x *DeleteResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*DeleteResponse) GetVerifyHeader ¶
func (x *DeleteResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*DeleteResponse) HasBody ¶
func (x *DeleteResponse) HasBody() bool
func (*DeleteResponse) HasMetaHeader ¶
func (x *DeleteResponse) HasMetaHeader() bool
func (*DeleteResponse) HasVerifyHeader ¶
func (x *DeleteResponse) HasVerifyHeader() bool
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) SetBody ¶
func (x *DeleteResponse) SetBody(v *DeleteResponse_Body)
func (*DeleteResponse) SetMetaHeader ¶
func (x *DeleteResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*DeleteResponse) SetVerifyHeader ¶
func (x *DeleteResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type DeleteResponse_Body ¶
type DeleteResponse_Body struct { // Address of the tombstone created for the deleted object Tombstone *grpc1.Address `protobuf:"bytes,1,opt,name=tombstone" json:"tombstone,omitempty"` // contains filtered or unexported fields }
Object DELETE Response has an empty body.
func (*DeleteResponse_Body) ClearTombstone ¶
func (x *DeleteResponse_Body) ClearTombstone()
func (*DeleteResponse_Body) GetTombstone ¶
func (x *DeleteResponse_Body) GetTombstone() *grpc1.Address
func (*DeleteResponse_Body) HasTombstone ¶
func (x *DeleteResponse_Body) HasTombstone() bool
func (*DeleteResponse_Body) ProtoMessage ¶
func (*DeleteResponse_Body) ProtoMessage()
func (*DeleteResponse_Body) ProtoReflect ¶
func (x *DeleteResponse_Body) ProtoReflect() protoreflect.Message
func (*DeleteResponse_Body) Reset ¶
func (x *DeleteResponse_Body) Reset()
func (*DeleteResponse_Body) SetTombstone ¶
func (x *DeleteResponse_Body) SetTombstone(v *grpc1.Address)
func (*DeleteResponse_Body) String ¶
func (x *DeleteResponse_Body) String() string
type DeleteResponse_Body_builder ¶
type DeleteResponse_Body_builder struct { // Address of the tombstone created for the deleted object Tombstone *grpc1.Address // contains filtered or unexported fields }
func (DeleteResponse_Body_builder) Build ¶
func (b0 DeleteResponse_Body_builder) Build() *DeleteResponse_Body
type DeleteResponse_builder ¶
type DeleteResponse_builder struct { // Body of delete object response message. Body *DeleteResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (DeleteResponse_builder) Build ¶
func (b0 DeleteResponse_builder) Build() *DeleteResponse
type ECInfo ¶
type ECInfo struct { // Chunk stored on the node. Chunks []*ECInfo_Chunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"` // contains filtered or unexported fields }
Meta information for the erasure-encoded object.
func (*ECInfo) GetChunks ¶
func (x *ECInfo) GetChunks() []*ECInfo_Chunk
func (*ECInfo) ProtoMessage ¶
func (*ECInfo) ProtoMessage()
func (*ECInfo) ProtoReflect ¶
func (x *ECInfo) ProtoReflect() protoreflect.Message
func (*ECInfo) SetChunks ¶
func (x *ECInfo) SetChunks(v []*ECInfo_Chunk)
type ECInfo_Chunk ¶
type ECInfo_Chunk struct { // Object ID of the chunk. Id *grpc.ObjectID `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` // Index of the chunk. Index *uint32 `protobuf:"varint,2,opt,name=index" json:"index,omitempty"` // Total number of chunks in this split. Total *uint32 `protobuf:"varint,3,opt,name=total" json:"total,omitempty"` // contains filtered or unexported fields }
func (*ECInfo_Chunk) ClearId ¶
func (x *ECInfo_Chunk) ClearId()
func (*ECInfo_Chunk) ClearIndex ¶
func (x *ECInfo_Chunk) ClearIndex()
func (*ECInfo_Chunk) ClearTotal ¶
func (x *ECInfo_Chunk) ClearTotal()
func (*ECInfo_Chunk) GetId ¶
func (x *ECInfo_Chunk) GetId() *grpc.ObjectID
func (*ECInfo_Chunk) GetIndex ¶
func (x *ECInfo_Chunk) GetIndex() uint32
func (*ECInfo_Chunk) GetTotal ¶
func (x *ECInfo_Chunk) GetTotal() uint32
func (*ECInfo_Chunk) HasId ¶
func (x *ECInfo_Chunk) HasId() bool
func (*ECInfo_Chunk) HasIndex ¶
func (x *ECInfo_Chunk) HasIndex() bool
func (*ECInfo_Chunk) HasTotal ¶
func (x *ECInfo_Chunk) HasTotal() bool
func (*ECInfo_Chunk) ProtoMessage ¶
func (*ECInfo_Chunk) ProtoMessage()
func (*ECInfo_Chunk) ProtoReflect ¶
func (x *ECInfo_Chunk) ProtoReflect() protoreflect.Message
func (*ECInfo_Chunk) Reset ¶
func (x *ECInfo_Chunk) Reset()
func (*ECInfo_Chunk) SetId ¶
func (x *ECInfo_Chunk) SetId(v *grpc.ObjectID)
func (*ECInfo_Chunk) SetIndex ¶
func (x *ECInfo_Chunk) SetIndex(v uint32)
func (*ECInfo_Chunk) SetTotal ¶
func (x *ECInfo_Chunk) SetTotal(v uint32)
func (*ECInfo_Chunk) String ¶
func (x *ECInfo_Chunk) String() string
type ECInfo_Chunk_builder ¶
type ECInfo_Chunk_builder struct { // Object ID of the chunk. Id *grpc.ObjectID // Index of the chunk. Index *uint32 // Total number of chunks in this split. Total *uint32 // contains filtered or unexported fields }
func (ECInfo_Chunk_builder) Build ¶
func (b0 ECInfo_Chunk_builder) Build() *ECInfo_Chunk
type ECInfo_builder ¶
type ECInfo_builder struct { // Chunk stored on the node. Chunks []*ECInfo_Chunk // contains filtered or unexported fields }
func (ECInfo_builder) Build ¶
func (b0 ECInfo_builder) Build() *ECInfo
type GetRangeHashRequest ¶
type GetRangeHashRequest struct { // Body of get range hash object request message. Body *GetRangeHashRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Get hash of object's payload part
func (*GetRangeHashRequest) ClearBody ¶
func (x *GetRangeHashRequest) ClearBody()
func (*GetRangeHashRequest) ClearMetaHeader ¶
func (x *GetRangeHashRequest) ClearMetaHeader()
func (*GetRangeHashRequest) ClearVerifyHeader ¶
func (x *GetRangeHashRequest) ClearVerifyHeader()
func (*GetRangeHashRequest) GetBody ¶
func (x *GetRangeHashRequest) GetBody() *GetRangeHashRequest_Body
func (*GetRangeHashRequest) GetMetaHeader ¶
func (x *GetRangeHashRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*GetRangeHashRequest) GetVerifyHeader ¶
func (x *GetRangeHashRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*GetRangeHashRequest) HasBody ¶
func (x *GetRangeHashRequest) HasBody() bool
func (*GetRangeHashRequest) HasMetaHeader ¶
func (x *GetRangeHashRequest) HasMetaHeader() bool
func (*GetRangeHashRequest) HasVerifyHeader ¶
func (x *GetRangeHashRequest) HasVerifyHeader() bool
func (*GetRangeHashRequest) ProtoMessage ¶
func (*GetRangeHashRequest) ProtoMessage()
func (*GetRangeHashRequest) ProtoReflect ¶
func (x *GetRangeHashRequest) ProtoReflect() protoreflect.Message
func (*GetRangeHashRequest) Reset ¶
func (x *GetRangeHashRequest) Reset()
func (*GetRangeHashRequest) SetBody ¶
func (x *GetRangeHashRequest) SetBody(v *GetRangeHashRequest_Body)
func (*GetRangeHashRequest) SetMetaHeader ¶
func (x *GetRangeHashRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*GetRangeHashRequest) SetVerifyHeader ¶
func (x *GetRangeHashRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*GetRangeHashRequest) String ¶
func (x *GetRangeHashRequest) String() string
type GetRangeHashRequest_Body ¶
type GetRangeHashRequest_Body struct { // Address of the object that containing the requested payload range Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // List of object's payload ranges to calculate homomorphic hash Ranges []*Range `protobuf:"bytes,2,rep,name=ranges" json:"ranges,omitempty"` // Binary salt to XOR object's payload ranges before hash calculation Salt []byte `protobuf:"bytes,3,opt,name=salt" json:"salt,omitempty"` // Checksum algorithm type Type *grpc1.ChecksumType `protobuf:"varint,4,opt,name=type,enum=neo.fs.v2.refs.ChecksumType" json:"type,omitempty"` // contains filtered or unexported fields }
Get hash of object's payload part request body.
func (*GetRangeHashRequest_Body) ClearAddress ¶
func (x *GetRangeHashRequest_Body) ClearAddress()
func (*GetRangeHashRequest_Body) ClearSalt ¶
func (x *GetRangeHashRequest_Body) ClearSalt()
func (*GetRangeHashRequest_Body) ClearType ¶
func (x *GetRangeHashRequest_Body) ClearType()
func (*GetRangeHashRequest_Body) GetAddress ¶
func (x *GetRangeHashRequest_Body) GetAddress() *grpc1.Address
func (*GetRangeHashRequest_Body) GetRanges ¶
func (x *GetRangeHashRequest_Body) GetRanges() []*Range
func (*GetRangeHashRequest_Body) GetSalt ¶
func (x *GetRangeHashRequest_Body) GetSalt() []byte
func (*GetRangeHashRequest_Body) GetType ¶
func (x *GetRangeHashRequest_Body) GetType() grpc1.ChecksumType
func (*GetRangeHashRequest_Body) HasAddress ¶
func (x *GetRangeHashRequest_Body) HasAddress() bool
func (*GetRangeHashRequest_Body) HasSalt ¶
func (x *GetRangeHashRequest_Body) HasSalt() bool
func (*GetRangeHashRequest_Body) HasType ¶
func (x *GetRangeHashRequest_Body) HasType() bool
func (*GetRangeHashRequest_Body) ProtoMessage ¶
func (*GetRangeHashRequest_Body) ProtoMessage()
func (*GetRangeHashRequest_Body) ProtoReflect ¶
func (x *GetRangeHashRequest_Body) ProtoReflect() protoreflect.Message
func (*GetRangeHashRequest_Body) Reset ¶
func (x *GetRangeHashRequest_Body) Reset()
func (*GetRangeHashRequest_Body) SetAddress ¶
func (x *GetRangeHashRequest_Body) SetAddress(v *grpc1.Address)
func (*GetRangeHashRequest_Body) SetRanges ¶
func (x *GetRangeHashRequest_Body) SetRanges(v []*Range)
func (*GetRangeHashRequest_Body) SetSalt ¶
func (x *GetRangeHashRequest_Body) SetSalt(v []byte)
func (*GetRangeHashRequest_Body) SetType ¶
func (x *GetRangeHashRequest_Body) SetType(v grpc1.ChecksumType)
func (*GetRangeHashRequest_Body) String ¶
func (x *GetRangeHashRequest_Body) String() string
type GetRangeHashRequest_Body_builder ¶
type GetRangeHashRequest_Body_builder struct { // Address of the object that containing the requested payload range Address *grpc1.Address // List of object's payload ranges to calculate homomorphic hash Ranges []*Range // Binary salt to XOR object's payload ranges before hash calculation Salt []byte // Checksum algorithm type Type *grpc1.ChecksumType // contains filtered or unexported fields }
func (GetRangeHashRequest_Body_builder) Build ¶
func (b0 GetRangeHashRequest_Body_builder) Build() *GetRangeHashRequest_Body
type GetRangeHashRequest_builder ¶
type GetRangeHashRequest_builder struct { // Body of get range hash object request message. Body *GetRangeHashRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (GetRangeHashRequest_builder) Build ¶
func (b0 GetRangeHashRequest_builder) Build() *GetRangeHashRequest
type GetRangeHashResponse ¶
type GetRangeHashResponse struct { // Body of get range hash object response message. Body *GetRangeHashResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Get hash of object's payload part
func (*GetRangeHashResponse) ClearBody ¶
func (x *GetRangeHashResponse) ClearBody()
func (*GetRangeHashResponse) ClearMetaHeader ¶
func (x *GetRangeHashResponse) ClearMetaHeader()
func (*GetRangeHashResponse) ClearVerifyHeader ¶
func (x *GetRangeHashResponse) ClearVerifyHeader()
func (*GetRangeHashResponse) GetBody ¶
func (x *GetRangeHashResponse) GetBody() *GetRangeHashResponse_Body
func (*GetRangeHashResponse) GetMetaHeader ¶
func (x *GetRangeHashResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*GetRangeHashResponse) GetVerifyHeader ¶
func (x *GetRangeHashResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*GetRangeHashResponse) HasBody ¶
func (x *GetRangeHashResponse) HasBody() bool
func (*GetRangeHashResponse) HasMetaHeader ¶
func (x *GetRangeHashResponse) HasMetaHeader() bool
func (*GetRangeHashResponse) HasVerifyHeader ¶
func (x *GetRangeHashResponse) HasVerifyHeader() bool
func (*GetRangeHashResponse) ProtoMessage ¶
func (*GetRangeHashResponse) ProtoMessage()
func (*GetRangeHashResponse) ProtoReflect ¶
func (x *GetRangeHashResponse) ProtoReflect() protoreflect.Message
func (*GetRangeHashResponse) Reset ¶
func (x *GetRangeHashResponse) Reset()
func (*GetRangeHashResponse) SetBody ¶
func (x *GetRangeHashResponse) SetBody(v *GetRangeHashResponse_Body)
func (*GetRangeHashResponse) SetMetaHeader ¶
func (x *GetRangeHashResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*GetRangeHashResponse) SetVerifyHeader ¶
func (x *GetRangeHashResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*GetRangeHashResponse) String ¶
func (x *GetRangeHashResponse) String() string
type GetRangeHashResponse_Body ¶
type GetRangeHashResponse_Body struct { // Checksum algorithm type Type *grpc1.ChecksumType `protobuf:"varint,1,opt,name=type,enum=neo.fs.v2.refs.ChecksumType" json:"type,omitempty"` // List of range hashes in a binary format HashList [][]byte `protobuf:"bytes,2,rep,name=hash_list,json=hashList" json:"hash_list,omitempty"` // contains filtered or unexported fields }
Get hash of object's payload part response body.
func (*GetRangeHashResponse_Body) ClearType ¶
func (x *GetRangeHashResponse_Body) ClearType()
func (*GetRangeHashResponse_Body) GetHashList ¶
func (x *GetRangeHashResponse_Body) GetHashList() [][]byte
func (*GetRangeHashResponse_Body) GetType ¶
func (x *GetRangeHashResponse_Body) GetType() grpc1.ChecksumType
func (*GetRangeHashResponse_Body) HasType ¶
func (x *GetRangeHashResponse_Body) HasType() bool
func (*GetRangeHashResponse_Body) ProtoMessage ¶
func (*GetRangeHashResponse_Body) ProtoMessage()
func (*GetRangeHashResponse_Body) ProtoReflect ¶
func (x *GetRangeHashResponse_Body) ProtoReflect() protoreflect.Message
func (*GetRangeHashResponse_Body) Reset ¶
func (x *GetRangeHashResponse_Body) Reset()
func (*GetRangeHashResponse_Body) SetHashList ¶
func (x *GetRangeHashResponse_Body) SetHashList(v [][]byte)
func (*GetRangeHashResponse_Body) SetType ¶
func (x *GetRangeHashResponse_Body) SetType(v grpc1.ChecksumType)
func (*GetRangeHashResponse_Body) String ¶
func (x *GetRangeHashResponse_Body) String() string
type GetRangeHashResponse_Body_builder ¶
type GetRangeHashResponse_Body_builder struct { // Checksum algorithm type Type *grpc1.ChecksumType // List of range hashes in a binary format HashList [][]byte // contains filtered or unexported fields }
func (GetRangeHashResponse_Body_builder) Build ¶
func (b0 GetRangeHashResponse_Body_builder) Build() *GetRangeHashResponse_Body
type GetRangeHashResponse_builder ¶
type GetRangeHashResponse_builder struct { // Body of get range hash object response message. Body *GetRangeHashResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (GetRangeHashResponse_builder) Build ¶
func (b0 GetRangeHashResponse_builder) Build() *GetRangeHashResponse
type GetRangeRequest ¶
type GetRangeRequest struct { // Body of get range object request message. Body *GetRangeRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Request part of object's payload
func (*GetRangeRequest) ClearBody ¶
func (x *GetRangeRequest) ClearBody()
func (*GetRangeRequest) ClearMetaHeader ¶
func (x *GetRangeRequest) ClearMetaHeader()
func (*GetRangeRequest) ClearVerifyHeader ¶
func (x *GetRangeRequest) ClearVerifyHeader()
func (*GetRangeRequest) GetBody ¶
func (x *GetRangeRequest) GetBody() *GetRangeRequest_Body
func (*GetRangeRequest) GetMetaHeader ¶
func (x *GetRangeRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*GetRangeRequest) GetVerifyHeader ¶
func (x *GetRangeRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*GetRangeRequest) HasBody ¶
func (x *GetRangeRequest) HasBody() bool
func (*GetRangeRequest) HasMetaHeader ¶
func (x *GetRangeRequest) HasMetaHeader() bool
func (*GetRangeRequest) HasVerifyHeader ¶
func (x *GetRangeRequest) HasVerifyHeader() bool
func (*GetRangeRequest) ProtoMessage ¶
func (*GetRangeRequest) ProtoMessage()
func (*GetRangeRequest) ProtoReflect ¶
func (x *GetRangeRequest) ProtoReflect() protoreflect.Message
func (*GetRangeRequest) Reset ¶
func (x *GetRangeRequest) Reset()
func (*GetRangeRequest) SetBody ¶
func (x *GetRangeRequest) SetBody(v *GetRangeRequest_Body)
func (*GetRangeRequest) SetMetaHeader ¶
func (x *GetRangeRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*GetRangeRequest) SetVerifyHeader ¶
func (x *GetRangeRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*GetRangeRequest) String ¶
func (x *GetRangeRequest) String() string
type GetRangeRequest_Body ¶
type GetRangeRequest_Body struct { // Address of the object containing the requested payload range Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // Requested payload range Range *Range `protobuf:"bytes,2,opt,name=range" json:"range,omitempty"` // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node. Raw *bool `protobuf:"varint,3,opt,name=raw" json:"raw,omitempty"` // contains filtered or unexported fields }
Byte range of object's payload request body
func (*GetRangeRequest_Body) ClearAddress ¶
func (x *GetRangeRequest_Body) ClearAddress()
func (*GetRangeRequest_Body) ClearRange ¶
func (x *GetRangeRequest_Body) ClearRange()
func (*GetRangeRequest_Body) ClearRaw ¶
func (x *GetRangeRequest_Body) ClearRaw()
func (*GetRangeRequest_Body) GetAddress ¶
func (x *GetRangeRequest_Body) GetAddress() *grpc1.Address
func (*GetRangeRequest_Body) GetRange ¶
func (x *GetRangeRequest_Body) GetRange() *Range
func (*GetRangeRequest_Body) GetRaw ¶
func (x *GetRangeRequest_Body) GetRaw() bool
func (*GetRangeRequest_Body) HasAddress ¶
func (x *GetRangeRequest_Body) HasAddress() bool
func (*GetRangeRequest_Body) HasRange ¶
func (x *GetRangeRequest_Body) HasRange() bool
func (*GetRangeRequest_Body) HasRaw ¶
func (x *GetRangeRequest_Body) HasRaw() bool
func (*GetRangeRequest_Body) ProtoMessage ¶
func (*GetRangeRequest_Body) ProtoMessage()
func (*GetRangeRequest_Body) ProtoReflect ¶
func (x *GetRangeRequest_Body) ProtoReflect() protoreflect.Message
func (*GetRangeRequest_Body) Reset ¶
func (x *GetRangeRequest_Body) Reset()
func (*GetRangeRequest_Body) SetAddress ¶
func (x *GetRangeRequest_Body) SetAddress(v *grpc1.Address)
func (*GetRangeRequest_Body) SetRange ¶
func (x *GetRangeRequest_Body) SetRange(v *Range)
func (*GetRangeRequest_Body) SetRaw ¶
func (x *GetRangeRequest_Body) SetRaw(v bool)
func (*GetRangeRequest_Body) String ¶
func (x *GetRangeRequest_Body) String() string
type GetRangeRequest_Body_builder ¶
type GetRangeRequest_Body_builder struct { // Address of the object containing the requested payload range Address *grpc1.Address // Requested payload range Range *Range // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node. Raw *bool // contains filtered or unexported fields }
func (GetRangeRequest_Body_builder) Build ¶
func (b0 GetRangeRequest_Body_builder) Build() *GetRangeRequest_Body
type GetRangeRequest_builder ¶
type GetRangeRequest_builder struct { // Body of get range object request message. Body *GetRangeRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (GetRangeRequest_builder) Build ¶
func (b0 GetRangeRequest_builder) Build() *GetRangeRequest
type GetRangeResponse ¶
type GetRangeResponse struct { // Body of get range object response message. Body *GetRangeResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Get part of object's payload
func (*GetRangeResponse) ClearBody ¶
func (x *GetRangeResponse) ClearBody()
func (*GetRangeResponse) ClearMetaHeader ¶
func (x *GetRangeResponse) ClearMetaHeader()
func (*GetRangeResponse) ClearVerifyHeader ¶
func (x *GetRangeResponse) ClearVerifyHeader()
func (*GetRangeResponse) GetBody ¶
func (x *GetRangeResponse) GetBody() *GetRangeResponse_Body
func (*GetRangeResponse) GetMetaHeader ¶
func (x *GetRangeResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*GetRangeResponse) GetVerifyHeader ¶
func (x *GetRangeResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*GetRangeResponse) HasBody ¶
func (x *GetRangeResponse) HasBody() bool
func (*GetRangeResponse) HasMetaHeader ¶
func (x *GetRangeResponse) HasMetaHeader() bool
func (*GetRangeResponse) HasVerifyHeader ¶
func (x *GetRangeResponse) HasVerifyHeader() bool
func (*GetRangeResponse) ProtoMessage ¶
func (*GetRangeResponse) ProtoMessage()
func (*GetRangeResponse) ProtoReflect ¶
func (x *GetRangeResponse) ProtoReflect() protoreflect.Message
func (*GetRangeResponse) Reset ¶
func (x *GetRangeResponse) Reset()
func (*GetRangeResponse) SetBody ¶
func (x *GetRangeResponse) SetBody(v *GetRangeResponse_Body)
func (*GetRangeResponse) SetMetaHeader ¶
func (x *GetRangeResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*GetRangeResponse) SetVerifyHeader ¶
func (x *GetRangeResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*GetRangeResponse) String ¶
func (x *GetRangeResponse) String() string
type GetRangeResponse_Body ¶
type GetRangeResponse_Body struct { // Requested object range or meta information about split object. // // Types that are valid to be assigned to RangePart: // // *GetRangeResponse_Body_Chunk // *GetRangeResponse_Body_SplitInfo // *GetRangeResponse_Body_EcInfo RangePart isGetRangeResponse_Body_RangePart `protobuf_oneof:"range_part"` // contains filtered or unexported fields }
Get Range response body uses streams to transfer the response. Because object payload considered a byte sequence, there is no need to have some initial preamble message. The requested byte range is sent as a series chunks.
func (*GetRangeResponse_Body) ClearChunk ¶
func (x *GetRangeResponse_Body) ClearChunk()
func (*GetRangeResponse_Body) ClearEcInfo ¶
func (x *GetRangeResponse_Body) ClearEcInfo()
func (*GetRangeResponse_Body) ClearRangePart ¶
func (x *GetRangeResponse_Body) ClearRangePart()
func (*GetRangeResponse_Body) ClearSplitInfo ¶
func (x *GetRangeResponse_Body) ClearSplitInfo()
func (*GetRangeResponse_Body) GetChunk ¶
func (x *GetRangeResponse_Body) GetChunk() []byte
func (*GetRangeResponse_Body) GetEcInfo ¶
func (x *GetRangeResponse_Body) GetEcInfo() *ECInfo
func (*GetRangeResponse_Body) GetRangePart ¶
func (x *GetRangeResponse_Body) GetRangePart() isGetRangeResponse_Body_RangePart
func (*GetRangeResponse_Body) GetSplitInfo ¶
func (x *GetRangeResponse_Body) GetSplitInfo() *SplitInfo
func (*GetRangeResponse_Body) HasChunk ¶
func (x *GetRangeResponse_Body) HasChunk() bool
func (*GetRangeResponse_Body) HasEcInfo ¶
func (x *GetRangeResponse_Body) HasEcInfo() bool
func (*GetRangeResponse_Body) HasRangePart ¶
func (x *GetRangeResponse_Body) HasRangePart() bool
func (*GetRangeResponse_Body) HasSplitInfo ¶
func (x *GetRangeResponse_Body) HasSplitInfo() bool
func (*GetRangeResponse_Body) ProtoMessage ¶
func (*GetRangeResponse_Body) ProtoMessage()
func (*GetRangeResponse_Body) ProtoReflect ¶
func (x *GetRangeResponse_Body) ProtoReflect() protoreflect.Message
func (*GetRangeResponse_Body) Reset ¶
func (x *GetRangeResponse_Body) Reset()
func (*GetRangeResponse_Body) SetChunk ¶
func (x *GetRangeResponse_Body) SetChunk(v []byte)
func (*GetRangeResponse_Body) SetEcInfo ¶
func (x *GetRangeResponse_Body) SetEcInfo(v *ECInfo)
func (*GetRangeResponse_Body) SetSplitInfo ¶
func (x *GetRangeResponse_Body) SetSplitInfo(v *SplitInfo)
func (*GetRangeResponse_Body) String ¶
func (x *GetRangeResponse_Body) String() string
func (*GetRangeResponse_Body) WhichRangePart ¶
func (x *GetRangeResponse_Body) WhichRangePart() case_GetRangeResponse_Body_RangePart
type GetRangeResponse_Body_Chunk ¶
type GetRangeResponse_Body_Chunk struct { // Chunked object payload's range. Chunk []byte `protobuf:"bytes,1,opt,name=chunk,oneof"` }
type GetRangeResponse_Body_EcInfo ¶
type GetRangeResponse_Body_EcInfo struct { // Meta information for EC object assembly. EcInfo *ECInfo `protobuf:"bytes,3,opt,name=ec_info,json=ecInfo,oneof"` }
type GetRangeResponse_Body_SplitInfo ¶
type GetRangeResponse_Body_SplitInfo struct { // Meta information of split hierarchy. SplitInfo *SplitInfo `protobuf:"bytes,2,opt,name=split_info,json=splitInfo,oneof"` }
type GetRangeResponse_Body_builder ¶
type GetRangeResponse_Body_builder struct { // Fields of oneof RangePart: // Chunked object payload's range. Chunk []byte // Meta information of split hierarchy. SplitInfo *SplitInfo // Meta information for EC object assembly. EcInfo *ECInfo // contains filtered or unexported fields }
func (GetRangeResponse_Body_builder) Build ¶
func (b0 GetRangeResponse_Body_builder) Build() *GetRangeResponse_Body
type GetRangeResponse_builder ¶
type GetRangeResponse_builder struct { // Body of get range object response message. Body *GetRangeResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (GetRangeResponse_builder) Build ¶
func (b0 GetRangeResponse_builder) Build() *GetRangeResponse
type GetRequest ¶
type GetRequest struct { // Body of get object request message. Body *GetRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
GET object request
func (*GetRequest) ClearBody ¶
func (x *GetRequest) ClearBody()
func (*GetRequest) ClearMetaHeader ¶
func (x *GetRequest) ClearMetaHeader()
func (*GetRequest) ClearVerifyHeader ¶
func (x *GetRequest) ClearVerifyHeader()
func (*GetRequest) GetBody ¶
func (x *GetRequest) GetBody() *GetRequest_Body
func (*GetRequest) GetMetaHeader ¶
func (x *GetRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*GetRequest) GetVerifyHeader ¶
func (x *GetRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*GetRequest) HasBody ¶
func (x *GetRequest) HasBody() bool
func (*GetRequest) HasMetaHeader ¶
func (x *GetRequest) HasMetaHeader() bool
func (*GetRequest) HasVerifyHeader ¶
func (x *GetRequest) HasVerifyHeader() bool
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) SetBody ¶
func (x *GetRequest) SetBody(v *GetRequest_Body)
func (*GetRequest) SetMetaHeader ¶
func (x *GetRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*GetRequest) SetVerifyHeader ¶
func (x *GetRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetRequest_Body ¶
type GetRequest_Body struct { // Address of the requested object Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node Raw *bool `protobuf:"varint,2,opt,name=raw" json:"raw,omitempty"` // contains filtered or unexported fields }
GET Object request body
func (*GetRequest_Body) ClearAddress ¶
func (x *GetRequest_Body) ClearAddress()
func (*GetRequest_Body) ClearRaw ¶
func (x *GetRequest_Body) ClearRaw()
func (*GetRequest_Body) GetAddress ¶
func (x *GetRequest_Body) GetAddress() *grpc1.Address
func (*GetRequest_Body) GetRaw ¶
func (x *GetRequest_Body) GetRaw() bool
func (*GetRequest_Body) HasAddress ¶
func (x *GetRequest_Body) HasAddress() bool
func (*GetRequest_Body) HasRaw ¶
func (x *GetRequest_Body) HasRaw() bool
func (*GetRequest_Body) ProtoMessage ¶
func (*GetRequest_Body) ProtoMessage()
func (*GetRequest_Body) ProtoReflect ¶
func (x *GetRequest_Body) ProtoReflect() protoreflect.Message
func (*GetRequest_Body) Reset ¶
func (x *GetRequest_Body) Reset()
func (*GetRequest_Body) SetAddress ¶
func (x *GetRequest_Body) SetAddress(v *grpc1.Address)
func (*GetRequest_Body) SetRaw ¶
func (x *GetRequest_Body) SetRaw(v bool)
func (*GetRequest_Body) String ¶
func (x *GetRequest_Body) String() string
type GetRequest_Body_builder ¶
type GetRequest_Body_builder struct { // Address of the requested object Address *grpc1.Address // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node Raw *bool // contains filtered or unexported fields }
func (GetRequest_Body_builder) Build ¶
func (b0 GetRequest_Body_builder) Build() *GetRequest_Body
type GetRequest_builder ¶
type GetRequest_builder struct { // Body of get object request message. Body *GetRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (GetRequest_builder) Build ¶
func (b0 GetRequest_builder) Build() *GetRequest
type GetResponse ¶
type GetResponse struct { // Body of get object response message. Body *GetResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
GET object response
func (*GetResponse) ClearBody ¶
func (x *GetResponse) ClearBody()
func (*GetResponse) ClearMetaHeader ¶
func (x *GetResponse) ClearMetaHeader()
func (*GetResponse) ClearVerifyHeader ¶
func (x *GetResponse) ClearVerifyHeader()
func (*GetResponse) GetBody ¶
func (x *GetResponse) GetBody() *GetResponse_Body
func (*GetResponse) GetMetaHeader ¶
func (x *GetResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*GetResponse) GetVerifyHeader ¶
func (x *GetResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*GetResponse) HasBody ¶
func (x *GetResponse) HasBody() bool
func (*GetResponse) HasMetaHeader ¶
func (x *GetResponse) HasMetaHeader() bool
func (*GetResponse) HasVerifyHeader ¶
func (x *GetResponse) HasVerifyHeader() bool
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) SetBody ¶
func (x *GetResponse) SetBody(v *GetResponse_Body)
func (*GetResponse) SetMetaHeader ¶
func (x *GetResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*GetResponse) SetVerifyHeader ¶
func (x *GetResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type GetResponse_Body ¶
type GetResponse_Body struct { // Single message in the response stream. // // Types that are valid to be assigned to ObjectPart: // // *GetResponse_Body_Init_ // *GetResponse_Body_Chunk // *GetResponse_Body_SplitInfo // *GetResponse_Body_EcInfo ObjectPart isGetResponse_Body_ObjectPart `protobuf_oneof:"object_part"` // contains filtered or unexported fields }
GET Object Response body
func (*GetResponse_Body) ClearChunk ¶
func (x *GetResponse_Body) ClearChunk()
func (*GetResponse_Body) ClearEcInfo ¶
func (x *GetResponse_Body) ClearEcInfo()
func (*GetResponse_Body) ClearInit ¶
func (x *GetResponse_Body) ClearInit()
func (*GetResponse_Body) ClearObjectPart ¶
func (x *GetResponse_Body) ClearObjectPart()
func (*GetResponse_Body) ClearSplitInfo ¶
func (x *GetResponse_Body) ClearSplitInfo()
func (*GetResponse_Body) GetChunk ¶
func (x *GetResponse_Body) GetChunk() []byte
func (*GetResponse_Body) GetEcInfo ¶
func (x *GetResponse_Body) GetEcInfo() *ECInfo
func (*GetResponse_Body) GetInit ¶
func (x *GetResponse_Body) GetInit() *GetResponse_Body_Init
func (*GetResponse_Body) GetObjectPart ¶
func (x *GetResponse_Body) GetObjectPart() isGetResponse_Body_ObjectPart
func (*GetResponse_Body) GetSplitInfo ¶
func (x *GetResponse_Body) GetSplitInfo() *SplitInfo
func (*GetResponse_Body) HasChunk ¶
func (x *GetResponse_Body) HasChunk() bool
func (*GetResponse_Body) HasEcInfo ¶
func (x *GetResponse_Body) HasEcInfo() bool
func (*GetResponse_Body) HasInit ¶
func (x *GetResponse_Body) HasInit() bool
func (*GetResponse_Body) HasObjectPart ¶
func (x *GetResponse_Body) HasObjectPart() bool
func (*GetResponse_Body) HasSplitInfo ¶
func (x *GetResponse_Body) HasSplitInfo() bool
func (*GetResponse_Body) ProtoMessage ¶
func (*GetResponse_Body) ProtoMessage()
func (*GetResponse_Body) ProtoReflect ¶
func (x *GetResponse_Body) ProtoReflect() protoreflect.Message
func (*GetResponse_Body) Reset ¶
func (x *GetResponse_Body) Reset()
func (*GetResponse_Body) SetChunk ¶
func (x *GetResponse_Body) SetChunk(v []byte)
func (*GetResponse_Body) SetEcInfo ¶
func (x *GetResponse_Body) SetEcInfo(v *ECInfo)
func (*GetResponse_Body) SetInit ¶
func (x *GetResponse_Body) SetInit(v *GetResponse_Body_Init)
func (*GetResponse_Body) SetSplitInfo ¶
func (x *GetResponse_Body) SetSplitInfo(v *SplitInfo)
func (*GetResponse_Body) String ¶
func (x *GetResponse_Body) String() string
func (*GetResponse_Body) WhichObjectPart ¶
func (x *GetResponse_Body) WhichObjectPart() case_GetResponse_Body_ObjectPart
type GetResponse_Body_Chunk ¶
type GetResponse_Body_Chunk struct { // Chunked object payload Chunk []byte `protobuf:"bytes,2,opt,name=chunk,oneof"` }
type GetResponse_Body_EcInfo ¶
type GetResponse_Body_EcInfo struct { // Meta information for EC object assembly. EcInfo *ECInfo `protobuf:"bytes,4,opt,name=ec_info,json=ecInfo,oneof"` }
type GetResponse_Body_Init ¶
type GetResponse_Body_Init struct { // Object's unique identifier. ObjectId *grpc1.ObjectID `protobuf:"bytes,1,opt,name=object_id,json=objectId" json:"object_id,omitempty"` // Signed `ObjectID` Signature *grpc1.Signature `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"` // Object metadata headers Header *Header `protobuf:"bytes,3,opt,name=header" json:"header,omitempty"` // contains filtered or unexported fields }
Initial part of the `Object` structure stream. Technically it's a set of all `Object` structure's fields except `payload`.
func (*GetResponse_Body_Init) ClearHeader ¶
func (x *GetResponse_Body_Init) ClearHeader()
func (*GetResponse_Body_Init) ClearObjectId ¶
func (x *GetResponse_Body_Init) ClearObjectId()
func (*GetResponse_Body_Init) ClearSignature ¶
func (x *GetResponse_Body_Init) ClearSignature()
func (*GetResponse_Body_Init) GetHeader ¶
func (x *GetResponse_Body_Init) GetHeader() *Header
func (*GetResponse_Body_Init) GetObjectId ¶
func (x *GetResponse_Body_Init) GetObjectId() *grpc1.ObjectID
func (*GetResponse_Body_Init) GetSignature ¶
func (x *GetResponse_Body_Init) GetSignature() *grpc1.Signature
func (*GetResponse_Body_Init) HasHeader ¶
func (x *GetResponse_Body_Init) HasHeader() bool
func (*GetResponse_Body_Init) HasObjectId ¶
func (x *GetResponse_Body_Init) HasObjectId() bool
func (*GetResponse_Body_Init) HasSignature ¶
func (x *GetResponse_Body_Init) HasSignature() bool
func (*GetResponse_Body_Init) ProtoMessage ¶
func (*GetResponse_Body_Init) ProtoMessage()
func (*GetResponse_Body_Init) ProtoReflect ¶
func (x *GetResponse_Body_Init) ProtoReflect() protoreflect.Message
func (*GetResponse_Body_Init) Reset ¶
func (x *GetResponse_Body_Init) Reset()
func (*GetResponse_Body_Init) SetHeader ¶
func (x *GetResponse_Body_Init) SetHeader(v *Header)
func (*GetResponse_Body_Init) SetObjectId ¶
func (x *GetResponse_Body_Init) SetObjectId(v *grpc1.ObjectID)
func (*GetResponse_Body_Init) SetSignature ¶
func (x *GetResponse_Body_Init) SetSignature(v *grpc1.Signature)
func (*GetResponse_Body_Init) String ¶
func (x *GetResponse_Body_Init) String() string
type GetResponse_Body_Init_ ¶
type GetResponse_Body_Init_ struct { // Initial part of the object stream Init *GetResponse_Body_Init `protobuf:"bytes,1,opt,name=init,oneof"` }
type GetResponse_Body_Init_builder ¶
type GetResponse_Body_Init_builder struct { // Object's unique identifier. ObjectId *grpc1.ObjectID // Signed `ObjectID` Signature *grpc1.Signature // Object metadata headers Header *Header // contains filtered or unexported fields }
func (GetResponse_Body_Init_builder) Build ¶
func (b0 GetResponse_Body_Init_builder) Build() *GetResponse_Body_Init
type GetResponse_Body_SplitInfo ¶
type GetResponse_Body_SplitInfo struct { // Meta information of split hierarchy for object assembly. SplitInfo *SplitInfo `protobuf:"bytes,3,opt,name=split_info,json=splitInfo,oneof"` }
type GetResponse_Body_builder ¶
type GetResponse_Body_builder struct { // Fields of oneof ObjectPart: // Initial part of the object stream Init *GetResponse_Body_Init // Chunked object payload Chunk []byte // Meta information of split hierarchy for object assembly. SplitInfo *SplitInfo // Meta information for EC object assembly. EcInfo *ECInfo // contains filtered or unexported fields }
func (GetResponse_Body_builder) Build ¶
func (b0 GetResponse_Body_builder) Build() *GetResponse_Body
type GetResponse_builder ¶
type GetResponse_builder struct { // Body of get object response message. Body *GetResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (GetResponse_builder) Build ¶
func (b0 GetResponse_builder) Build() *GetResponse
type HeadRequest ¶
type HeadRequest struct { // Body of head object request message. Body *HeadRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object HEAD request
func (*HeadRequest) ClearBody ¶
func (x *HeadRequest) ClearBody()
func (*HeadRequest) ClearMetaHeader ¶
func (x *HeadRequest) ClearMetaHeader()
func (*HeadRequest) ClearVerifyHeader ¶
func (x *HeadRequest) ClearVerifyHeader()
func (*HeadRequest) GetBody ¶
func (x *HeadRequest) GetBody() *HeadRequest_Body
func (*HeadRequest) GetMetaHeader ¶
func (x *HeadRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*HeadRequest) GetVerifyHeader ¶
func (x *HeadRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*HeadRequest) HasBody ¶
func (x *HeadRequest) HasBody() bool
func (*HeadRequest) HasMetaHeader ¶
func (x *HeadRequest) HasMetaHeader() bool
func (*HeadRequest) HasVerifyHeader ¶
func (x *HeadRequest) HasVerifyHeader() bool
func (*HeadRequest) ProtoMessage ¶
func (*HeadRequest) ProtoMessage()
func (*HeadRequest) ProtoReflect ¶
func (x *HeadRequest) ProtoReflect() protoreflect.Message
func (*HeadRequest) Reset ¶
func (x *HeadRequest) Reset()
func (*HeadRequest) SetBody ¶
func (x *HeadRequest) SetBody(v *HeadRequest_Body)
func (*HeadRequest) SetMetaHeader ¶
func (x *HeadRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*HeadRequest) SetVerifyHeader ¶
func (x *HeadRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*HeadRequest) String ¶
func (x *HeadRequest) String() string
type HeadRequest_Body ¶
type HeadRequest_Body struct { // Address of the object with the requested Header Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // Return only minimal header subset MainOnly *bool `protobuf:"varint,2,opt,name=main_only,json=mainOnly" json:"main_only,omitempty"` // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node Raw *bool `protobuf:"varint,3,opt,name=raw" json:"raw,omitempty"` // contains filtered or unexported fields }
Object HEAD request body
func (*HeadRequest_Body) ClearAddress ¶
func (x *HeadRequest_Body) ClearAddress()
func (*HeadRequest_Body) ClearMainOnly ¶
func (x *HeadRequest_Body) ClearMainOnly()
func (*HeadRequest_Body) ClearRaw ¶
func (x *HeadRequest_Body) ClearRaw()
func (*HeadRequest_Body) GetAddress ¶
func (x *HeadRequest_Body) GetAddress() *grpc1.Address
func (*HeadRequest_Body) GetMainOnly ¶
func (x *HeadRequest_Body) GetMainOnly() bool
func (*HeadRequest_Body) GetRaw ¶
func (x *HeadRequest_Body) GetRaw() bool
func (*HeadRequest_Body) HasAddress ¶
func (x *HeadRequest_Body) HasAddress() bool
func (*HeadRequest_Body) HasMainOnly ¶
func (x *HeadRequest_Body) HasMainOnly() bool
func (*HeadRequest_Body) HasRaw ¶
func (x *HeadRequest_Body) HasRaw() bool
func (*HeadRequest_Body) ProtoMessage ¶
func (*HeadRequest_Body) ProtoMessage()
func (*HeadRequest_Body) ProtoReflect ¶
func (x *HeadRequest_Body) ProtoReflect() protoreflect.Message
func (*HeadRequest_Body) Reset ¶
func (x *HeadRequest_Body) Reset()
func (*HeadRequest_Body) SetAddress ¶
func (x *HeadRequest_Body) SetAddress(v *grpc1.Address)
func (*HeadRequest_Body) SetMainOnly ¶
func (x *HeadRequest_Body) SetMainOnly(v bool)
func (*HeadRequest_Body) SetRaw ¶
func (x *HeadRequest_Body) SetRaw(v bool)
func (*HeadRequest_Body) String ¶
func (x *HeadRequest_Body) String() string
type HeadRequest_Body_builder ¶
type HeadRequest_Body_builder struct { // Address of the object with the requested Header Address *grpc1.Address // Return only minimal header subset MainOnly *bool // If `raw` flag is set, request will work only with objects that are // physically stored on the peer node Raw *bool // contains filtered or unexported fields }
func (HeadRequest_Body_builder) Build ¶
func (b0 HeadRequest_Body_builder) Build() *HeadRequest_Body
type HeadRequest_builder ¶
type HeadRequest_builder struct { // Body of head object request message. Body *HeadRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (HeadRequest_builder) Build ¶
func (b0 HeadRequest_builder) Build() *HeadRequest
type HeadResponse ¶
type HeadResponse struct { // Body of head object response message. Body *HeadResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object HEAD response
func (*HeadResponse) ClearBody ¶
func (x *HeadResponse) ClearBody()
func (*HeadResponse) ClearMetaHeader ¶
func (x *HeadResponse) ClearMetaHeader()
func (*HeadResponse) ClearVerifyHeader ¶
func (x *HeadResponse) ClearVerifyHeader()
func (*HeadResponse) GetBody ¶
func (x *HeadResponse) GetBody() *HeadResponse_Body
func (*HeadResponse) GetMetaHeader ¶
func (x *HeadResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*HeadResponse) GetVerifyHeader ¶
func (x *HeadResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*HeadResponse) HasBody ¶
func (x *HeadResponse) HasBody() bool
func (*HeadResponse) HasMetaHeader ¶
func (x *HeadResponse) HasMetaHeader() bool
func (*HeadResponse) HasVerifyHeader ¶
func (x *HeadResponse) HasVerifyHeader() bool
func (*HeadResponse) ProtoMessage ¶
func (*HeadResponse) ProtoMessage()
func (*HeadResponse) ProtoReflect ¶
func (x *HeadResponse) ProtoReflect() protoreflect.Message
func (*HeadResponse) Reset ¶
func (x *HeadResponse) Reset()
func (*HeadResponse) SetBody ¶
func (x *HeadResponse) SetBody(v *HeadResponse_Body)
func (*HeadResponse) SetMetaHeader ¶
func (x *HeadResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*HeadResponse) SetVerifyHeader ¶
func (x *HeadResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*HeadResponse) String ¶
func (x *HeadResponse) String() string
type HeadResponse_Body ¶
type HeadResponse_Body struct { // Requested object header, it's part or meta information about split // object. // // Types that are valid to be assigned to Head: // // *HeadResponse_Body_Header // *HeadResponse_Body_ShortHeader // *HeadResponse_Body_SplitInfo // *HeadResponse_Body_EcInfo Head isHeadResponse_Body_Head `protobuf_oneof:"head"` // contains filtered or unexported fields }
Object HEAD response body
func (*HeadResponse_Body) ClearEcInfo ¶
func (x *HeadResponse_Body) ClearEcInfo()
func (*HeadResponse_Body) ClearHead ¶
func (x *HeadResponse_Body) ClearHead()
func (*HeadResponse_Body) ClearHeader ¶
func (x *HeadResponse_Body) ClearHeader()
func (*HeadResponse_Body) ClearShortHeader ¶
func (x *HeadResponse_Body) ClearShortHeader()
func (*HeadResponse_Body) ClearSplitInfo ¶
func (x *HeadResponse_Body) ClearSplitInfo()
func (*HeadResponse_Body) GetEcInfo ¶
func (x *HeadResponse_Body) GetEcInfo() *ECInfo
func (*HeadResponse_Body) GetHead ¶
func (x *HeadResponse_Body) GetHead() isHeadResponse_Body_Head
func (*HeadResponse_Body) GetHeader ¶
func (x *HeadResponse_Body) GetHeader() *HeaderWithSignature
func (*HeadResponse_Body) GetShortHeader ¶
func (x *HeadResponse_Body) GetShortHeader() *ShortHeader
func (*HeadResponse_Body) GetSplitInfo ¶
func (x *HeadResponse_Body) GetSplitInfo() *SplitInfo
func (*HeadResponse_Body) HasEcInfo ¶
func (x *HeadResponse_Body) HasEcInfo() bool
func (*HeadResponse_Body) HasHead ¶
func (x *HeadResponse_Body) HasHead() bool
func (*HeadResponse_Body) HasHeader ¶
func (x *HeadResponse_Body) HasHeader() bool
func (*HeadResponse_Body) HasShortHeader ¶
func (x *HeadResponse_Body) HasShortHeader() bool
func (*HeadResponse_Body) HasSplitInfo ¶
func (x *HeadResponse_Body) HasSplitInfo() bool
func (*HeadResponse_Body) ProtoMessage ¶
func (*HeadResponse_Body) ProtoMessage()
func (*HeadResponse_Body) ProtoReflect ¶
func (x *HeadResponse_Body) ProtoReflect() protoreflect.Message
func (*HeadResponse_Body) Reset ¶
func (x *HeadResponse_Body) Reset()
func (*HeadResponse_Body) SetEcInfo ¶
func (x *HeadResponse_Body) SetEcInfo(v *ECInfo)
func (*HeadResponse_Body) SetHeader ¶
func (x *HeadResponse_Body) SetHeader(v *HeaderWithSignature)
func (*HeadResponse_Body) SetShortHeader ¶
func (x *HeadResponse_Body) SetShortHeader(v *ShortHeader)
func (*HeadResponse_Body) SetSplitInfo ¶
func (x *HeadResponse_Body) SetSplitInfo(v *SplitInfo)
func (*HeadResponse_Body) String ¶
func (x *HeadResponse_Body) String() string
func (*HeadResponse_Body) WhichHead ¶
func (x *HeadResponse_Body) WhichHead() case_HeadResponse_Body_Head
type HeadResponse_Body_EcInfo ¶
type HeadResponse_Body_EcInfo struct { // Meta information for EC object assembly. EcInfo *ECInfo `protobuf:"bytes,4,opt,name=ec_info,json=ecInfo,oneof"` }
type HeadResponse_Body_Header ¶
type HeadResponse_Body_Header struct { // Full object's `Header` with `ObjectID` signature Header *HeaderWithSignature `protobuf:"bytes,1,opt,name=header,oneof"` }
type HeadResponse_Body_ShortHeader ¶
type HeadResponse_Body_ShortHeader struct { // Short object header ShortHeader *ShortHeader `protobuf:"bytes,2,opt,name=short_header,json=shortHeader,oneof"` }
type HeadResponse_Body_SplitInfo ¶
type HeadResponse_Body_SplitInfo struct { // Meta information of split hierarchy. SplitInfo *SplitInfo `protobuf:"bytes,3,opt,name=split_info,json=splitInfo,oneof"` }
type HeadResponse_Body_builder ¶
type HeadResponse_Body_builder struct { // Fields of oneof Head: // Full object's `Header` with `ObjectID` signature Header *HeaderWithSignature // Short object header ShortHeader *ShortHeader // Meta information of split hierarchy. SplitInfo *SplitInfo // Meta information for EC object assembly. EcInfo *ECInfo // contains filtered or unexported fields }
func (HeadResponse_Body_builder) Build ¶
func (b0 HeadResponse_Body_builder) Build() *HeadResponse_Body
type HeadResponse_builder ¶
type HeadResponse_builder struct { // Body of head object response message. Body *HeadResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (HeadResponse_builder) Build ¶
func (b0 HeadResponse_builder) Build() *HeadResponse
type Header ¶
type Header struct { // Object format version. Effectively, the version of API library used to // create particular object Version *grpc.Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"` // Object's container ContainerId *grpc.ContainerID `protobuf:"bytes,2,opt,name=container_id,json=containerID" json:"container_id,omitempty"` // Object's owner OwnerId *grpc.OwnerID `protobuf:"bytes,3,opt,name=owner_id,json=ownerID" json:"owner_id,omitempty"` // Object creation Epoch CreationEpoch *uint64 `protobuf:"varint,4,opt,name=creation_epoch,json=creationEpoch" json:"creation_epoch,omitempty"` // Size of payload in bytes. // `0xFFFFFFFFFFFFFFFF` means `payload_length` is unknown. PayloadLength *uint64 `protobuf:"varint,5,opt,name=payload_length,json=payloadLength" json:"payload_length,omitempty"` // Hash of payload bytes PayloadHash *grpc.Checksum `protobuf:"bytes,6,opt,name=payload_hash,json=payloadHash" json:"payload_hash,omitempty"` // Type of the object payload content ObjectType *ObjectType `protobuf:"varint,7,opt,name=object_type,json=objectType,enum=neo.fs.v2.object.ObjectType" json:"object_type,omitempty"` // Homomorphic hash of the object payload HomomorphicHash *grpc.Checksum `protobuf:"bytes,8,opt,name=homomorphic_hash,json=homomorphicHash" json:"homomorphic_hash,omitempty"` // Session token, if it was used during Object creation. Need it to verify // integrity and authenticity out of Request scope. SessionToken *grpc1.SessionToken `protobuf:"bytes,9,opt,name=session_token,json=sessionToken" json:"session_token,omitempty"` // User-defined object attributes Attributes []*Header_Attribute `protobuf:"bytes,10,rep,name=attributes" json:"attributes,omitempty"` // Position of the object in the split hierarchy Split *Header_Split `protobuf:"bytes,11,opt,name=split" json:"split,omitempty"` // Erasure code chunk information. Ec *Header_EC `protobuf:"bytes,12,opt,name=ec" json:"ec,omitempty"` // contains filtered or unexported fields }
Object Header
func (*Header) ClearContainerId ¶
func (x *Header) ClearContainerId()
func (*Header) ClearCreationEpoch ¶
func (x *Header) ClearCreationEpoch()
func (*Header) ClearHomomorphicHash ¶
func (x *Header) ClearHomomorphicHash()
func (*Header) ClearObjectType ¶
func (x *Header) ClearObjectType()
func (*Header) ClearOwnerId ¶
func (x *Header) ClearOwnerId()
func (*Header) ClearPayloadHash ¶
func (x *Header) ClearPayloadHash()
func (*Header) ClearPayloadLength ¶
func (x *Header) ClearPayloadLength()
func (*Header) ClearSessionToken ¶
func (x *Header) ClearSessionToken()
func (*Header) ClearSplit ¶
func (x *Header) ClearSplit()
func (*Header) ClearVersion ¶
func (x *Header) ClearVersion()
func (*Header) GetAttributes ¶
func (x *Header) GetAttributes() []*Header_Attribute
func (*Header) GetContainerId ¶
func (x *Header) GetContainerId() *grpc.ContainerID
func (*Header) GetCreationEpoch ¶
func (*Header) GetHomomorphicHash ¶
func (*Header) GetObjectType ¶
func (x *Header) GetObjectType() ObjectType
func (*Header) GetOwnerId ¶
func (*Header) GetPayloadHash ¶
func (*Header) GetPayloadLength ¶
func (*Header) GetSessionToken ¶
func (x *Header) GetSessionToken() *grpc1.SessionToken
func (*Header) GetSplit ¶
func (x *Header) GetSplit() *Header_Split
func (*Header) GetVersion ¶
func (*Header) HasContainerId ¶
func (*Header) HasCreationEpoch ¶
func (*Header) HasHomomorphicHash ¶
func (*Header) HasObjectType ¶
func (*Header) HasOwnerId ¶
func (*Header) HasPayloadHash ¶
func (*Header) HasPayloadLength ¶
func (*Header) HasSessionToken ¶
func (*Header) HasVersion ¶
func (*Header) ProtoMessage ¶
func (*Header) ProtoMessage()
func (*Header) ProtoReflect ¶
func (x *Header) ProtoReflect() protoreflect.Message
func (*Header) SetAttributes ¶
func (x *Header) SetAttributes(v []*Header_Attribute)
func (*Header) SetContainerId ¶
func (x *Header) SetContainerId(v *grpc.ContainerID)
func (*Header) SetCreationEpoch ¶
func (*Header) SetHomomorphicHash ¶
func (*Header) SetObjectType ¶
func (x *Header) SetObjectType(v ObjectType)
func (*Header) SetOwnerId ¶
func (*Header) SetPayloadHash ¶
func (*Header) SetPayloadLength ¶
func (*Header) SetSessionToken ¶
func (x *Header) SetSessionToken(v *grpc1.SessionToken)
func (*Header) SetSplit ¶
func (x *Header) SetSplit(v *Header_Split)
func (*Header) SetVersion ¶
type HeaderWithSignature ¶
type HeaderWithSignature struct { // Full object header Header *Header `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` // Signed `ObjectID` to verify full header's authenticity Signature *grpc1.Signature `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"` // contains filtered or unexported fields }
Tuple of a full object header and signature of an `ObjectID`. \ Signed `ObjectID` is present to verify full header's authenticity through the following steps:
1. Calculate `SHA-256` of the marshalled `Header` structure 2. Check if the resulting hash matches `ObjectID` 3. Check if `ObjectID` signature in `signature` field is correct
func (*HeaderWithSignature) ClearHeader ¶
func (x *HeaderWithSignature) ClearHeader()
func (*HeaderWithSignature) ClearSignature ¶
func (x *HeaderWithSignature) ClearSignature()
func (*HeaderWithSignature) GetHeader ¶
func (x *HeaderWithSignature) GetHeader() *Header
func (*HeaderWithSignature) GetSignature ¶
func (x *HeaderWithSignature) GetSignature() *grpc1.Signature
func (*HeaderWithSignature) HasHeader ¶
func (x *HeaderWithSignature) HasHeader() bool
func (*HeaderWithSignature) HasSignature ¶
func (x *HeaderWithSignature) HasSignature() bool
func (*HeaderWithSignature) ProtoMessage ¶
func (*HeaderWithSignature) ProtoMessage()
func (*HeaderWithSignature) ProtoReflect ¶
func (x *HeaderWithSignature) ProtoReflect() protoreflect.Message
func (*HeaderWithSignature) Reset ¶
func (x *HeaderWithSignature) Reset()
func (*HeaderWithSignature) SetHeader ¶
func (x *HeaderWithSignature) SetHeader(v *Header)
func (*HeaderWithSignature) SetSignature ¶
func (x *HeaderWithSignature) SetSignature(v *grpc1.Signature)
func (*HeaderWithSignature) String ¶
func (x *HeaderWithSignature) String() string
type HeaderWithSignature_builder ¶
type HeaderWithSignature_builder struct { // Full object header Header *Header // Signed `ObjectID` to verify full header's authenticity Signature *grpc1.Signature // contains filtered or unexported fields }
func (HeaderWithSignature_builder) Build ¶
func (b0 HeaderWithSignature_builder) Build() *HeaderWithSignature
type Header_Attribute ¶
type Header_Attribute struct { // string key to the object attribute Key *string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` // string value of the object attribute Value *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` // contains filtered or unexported fields }
`Attribute` is a user-defined Key-Value metadata pair attached to an object.
Key name must be an object-unique valid UTF-8 string. Value can't be empty. Objects with duplicated attribute names or attributes with empty values will be considered invalid.
There are some "well-known" attributes starting with `__SYSTEM__` (`__NEOFS__` is deprecated) prefix that affect system behaviour:
- [ __SYSTEM__UPLOAD_ID ] \ (`__NEOFS__UPLOAD_ID` is deprecated) \ Marks smaller parts of a split bigger object
- [ __SYSTEM__EXPIRATION_EPOCH ] \ (`__NEOFS__EXPIRATION_EPOCH` is deprecated) \ The epoch after which object with no LOCKs on it becomes unavailable. Locked object continues to be available until each of the LOCKs expire.
- [ __SYSTEM__TICK_EPOCH ] \ (`__NEOFS__TICK_EPOCH` is deprecated) \ Decimal number that defines what epoch must produce object notification with UTF-8 object address in a body (`0` value produces notification right after object put)
- [ __SYSTEM__TICK_TOPIC ] \ (`__NEOFS__TICK_TOPIC` is deprecated) \ UTF-8 string topic ID that is used for object notification
And some well-known attributes used by applications only:
- Name \ Human-friendly name
- FileName \ File name to be associated with the object on saving
- FilePath \ Full path to be associated with the object on saving. Should start with a '/' and use '/' as a delimiting symbol. Trailing '/' should be interpreted as a virtual directory marker. If an object has conflicting FilePath and FileName, FilePath should have higher priority, because it is used to construct the directory tree. FilePath with trailing '/' and non-empty FileName attribute should not be used together.
- Timestamp \ User-defined local time of object creation in Unix Timestamp format
- Content-Type \ MIME Content Type of object's payload
For detailed description of each well-known attribute please see the corresponding section in FrostFS Technical Specification.
func (*Header_Attribute) ClearKey ¶
func (x *Header_Attribute) ClearKey()
func (*Header_Attribute) ClearValue ¶
func (x *Header_Attribute) ClearValue()
func (*Header_Attribute) GetKey ¶
func (x *Header_Attribute) GetKey() string
func (*Header_Attribute) GetValue ¶
func (x *Header_Attribute) GetValue() string
func (*Header_Attribute) HasKey ¶
func (x *Header_Attribute) HasKey() bool
func (*Header_Attribute) HasValue ¶
func (x *Header_Attribute) HasValue() bool
func (*Header_Attribute) ProtoMessage ¶
func (*Header_Attribute) ProtoMessage()
func (*Header_Attribute) ProtoReflect ¶
func (x *Header_Attribute) ProtoReflect() protoreflect.Message
func (*Header_Attribute) Reset ¶
func (x *Header_Attribute) Reset()
func (*Header_Attribute) SetKey ¶
func (x *Header_Attribute) SetKey(v string)
func (*Header_Attribute) SetValue ¶
func (x *Header_Attribute) SetValue(v string)
func (*Header_Attribute) String ¶
func (x *Header_Attribute) String() string
type Header_Attribute_builder ¶
type Header_Attribute_builder struct { // string key to the object attribute Key *string // string value of the object attribute Value *string // contains filtered or unexported fields }
func (Header_Attribute_builder) Build ¶
func (b0 Header_Attribute_builder) Build() *Header_Attribute
type Header_EC ¶
type Header_EC struct { // Identifier of the origin object. Known to all chunks. Parent *grpc.ObjectID `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"` // Index of this chunk. Index *uint32 `protobuf:"varint,2,opt,name=index" json:"index,omitempty"` // Total number of chunks in this split. Total *uint32 `protobuf:"varint,3,opt,name=total" json:"total,omitempty"` // Total length of a parent header. Used to trim padding zeroes. HeaderLength *uint32 `protobuf:"varint,4,opt,name=header_length,json=headerLength" json:"header_length,omitempty"` // Chunk of a parent header. Header []byte `protobuf:"bytes,5,opt,name=header" json:"header,omitempty"` // As the origin object is EC-splitted its identifier is known to all // chunks as parent. But parent itself can be a part of Split (does not // relate to EC-split). In this case parent_split_id should be set. ParentSplitId []byte `protobuf:"bytes,6,opt,name=parent_split_id,json=parentSplitID" json:"parent_split_id,omitempty"` // EC-parent's parent ID. parent_split_parent_id is set if EC-parent, // itself, is a part of Split and if an object ID of its parent is // presented. The field allows to determine how EC-chunk is placed in Split // hierarchy. ParentSplitParentId *grpc.ObjectID `protobuf:"bytes,7,opt,name=parent_split_parent_id,json=parentSplitParentID" json:"parent_split_parent_id,omitempty"` // EC parent's attributes. ParentAttributes []*Header_Attribute `protobuf:"bytes,8,rep,name=parent_attributes,json=parentAttributes" json:"parent_attributes,omitempty"` // contains filtered or unexported fields }
Erasure code can be applied to any object. Information about encoded object structure is stored in `EC` header. All objects belonging to a single EC group have the same `parent` field.
func (*Header_EC) ClearHeader ¶
func (x *Header_EC) ClearHeader()
func (*Header_EC) ClearHeaderLength ¶
func (x *Header_EC) ClearHeaderLength()
func (*Header_EC) ClearIndex ¶
func (x *Header_EC) ClearIndex()
func (*Header_EC) ClearParent ¶
func (x *Header_EC) ClearParent()
func (*Header_EC) ClearParentSplitId ¶
func (x *Header_EC) ClearParentSplitId()
func (*Header_EC) ClearParentSplitParentId ¶
func (x *Header_EC) ClearParentSplitParentId()
func (*Header_EC) ClearTotal ¶
func (x *Header_EC) ClearTotal()
func (*Header_EC) GetHeaderLength ¶
func (*Header_EC) GetParentAttributes ¶
func (x *Header_EC) GetParentAttributes() []*Header_Attribute
func (*Header_EC) GetParentSplitId ¶
func (*Header_EC) GetParentSplitParentId ¶
func (*Header_EC) HasHeaderLength ¶
func (*Header_EC) HasParentSplitId ¶
func (*Header_EC) HasParentSplitParentId ¶
func (*Header_EC) ProtoMessage ¶
func (*Header_EC) ProtoMessage()
func (*Header_EC) ProtoReflect ¶
func (x *Header_EC) ProtoReflect() protoreflect.Message
func (*Header_EC) SetHeaderLength ¶
func (*Header_EC) SetParentAttributes ¶
func (x *Header_EC) SetParentAttributes(v []*Header_Attribute)
func (*Header_EC) SetParentSplitId ¶
func (*Header_EC) SetParentSplitParentId ¶
type Header_EC_builder ¶
type Header_EC_builder struct { // Identifier of the origin object. Known to all chunks. Parent *grpc.ObjectID // Index of this chunk. Index *uint32 // Total number of chunks in this split. Total *uint32 // Total length of a parent header. Used to trim padding zeroes. HeaderLength *uint32 // Chunk of a parent header. Header []byte // As the origin object is EC-splitted its identifier is known to all // chunks as parent. But parent itself can be a part of Split (does not // relate to EC-split). In this case parent_split_id should be set. ParentSplitId []byte // EC-parent's parent ID. parent_split_parent_id is set if EC-parent, // itself, is a part of Split and if an object ID of its parent is // presented. The field allows to determine how EC-chunk is placed in Split // hierarchy. ParentSplitParentId *grpc.ObjectID // EC parent's attributes. ParentAttributes []*Header_Attribute // contains filtered or unexported fields }
func (Header_EC_builder) Build ¶
func (b0 Header_EC_builder) Build() *Header_EC
type Header_Split ¶
type Header_Split struct { // Identifier of the origin object. Known only to the minor child. Parent *grpc.ObjectID `protobuf:"bytes,1,opt,name=parent" json:"parent,omitempty"` // Identifier of the left split neighbor Previous *grpc.ObjectID `protobuf:"bytes,2,opt,name=previous" json:"previous,omitempty"` // `signature` field of the parent object. Used to reconstruct parent. ParentSignature *grpc.Signature `protobuf:"bytes,3,opt,name=parent_signature,json=parentSignature" json:"parent_signature,omitempty"` // `header` field of the parent object. Used to reconstruct parent. ParentHeader *Header `protobuf:"bytes,4,opt,name=parent_header,json=parentHeader" json:"parent_header,omitempty"` // List of identifiers of the objects generated by splitting current one. Children []*grpc.ObjectID `protobuf:"bytes,5,rep,name=children" json:"children,omitempty"` // 16 byte UUIDv4 used to identify the split object hierarchy parts. Must be // unique inside container. All objects participating in the split must have // the same `split_id` value. SplitId []byte `protobuf:"bytes,6,opt,name=split_id,json=splitID" json:"split_id,omitempty"` // contains filtered or unexported fields }
Bigger objects can be split into a chain of smaller objects. Information about inter-dependencies between spawned objects and how to re-construct the original one is in the `Split` headers. Parent and children objects must be within the same container.
func (*Header_Split) ClearParent ¶
func (x *Header_Split) ClearParent()
func (*Header_Split) ClearParentHeader ¶
func (x *Header_Split) ClearParentHeader()
func (*Header_Split) ClearParentSignature ¶
func (x *Header_Split) ClearParentSignature()
func (*Header_Split) ClearPrevious ¶
func (x *Header_Split) ClearPrevious()
func (*Header_Split) ClearSplitId ¶
func (x *Header_Split) ClearSplitId()
func (*Header_Split) GetChildren ¶
func (x *Header_Split) GetChildren() []*grpc.ObjectID
func (*Header_Split) GetParent ¶
func (x *Header_Split) GetParent() *grpc.ObjectID
func (*Header_Split) GetParentHeader ¶
func (x *Header_Split) GetParentHeader() *Header
func (*Header_Split) GetParentSignature ¶
func (x *Header_Split) GetParentSignature() *grpc.Signature
func (*Header_Split) GetPrevious ¶
func (x *Header_Split) GetPrevious() *grpc.ObjectID
func (*Header_Split) GetSplitId ¶
func (x *Header_Split) GetSplitId() []byte
func (*Header_Split) HasParent ¶
func (x *Header_Split) HasParent() bool
func (*Header_Split) HasParentHeader ¶
func (x *Header_Split) HasParentHeader() bool
func (*Header_Split) HasParentSignature ¶
func (x *Header_Split) HasParentSignature() bool
func (*Header_Split) HasPrevious ¶
func (x *Header_Split) HasPrevious() bool
func (*Header_Split) HasSplitId ¶
func (x *Header_Split) HasSplitId() bool
func (*Header_Split) ProtoMessage ¶
func (*Header_Split) ProtoMessage()
func (*Header_Split) ProtoReflect ¶
func (x *Header_Split) ProtoReflect() protoreflect.Message
func (*Header_Split) Reset ¶
func (x *Header_Split) Reset()
func (*Header_Split) SetChildren ¶
func (x *Header_Split) SetChildren(v []*grpc.ObjectID)
func (*Header_Split) SetParent ¶
func (x *Header_Split) SetParent(v *grpc.ObjectID)
func (*Header_Split) SetParentHeader ¶
func (x *Header_Split) SetParentHeader(v *Header)
func (*Header_Split) SetParentSignature ¶
func (x *Header_Split) SetParentSignature(v *grpc.Signature)
func (*Header_Split) SetPrevious ¶
func (x *Header_Split) SetPrevious(v *grpc.ObjectID)
func (*Header_Split) SetSplitId ¶
func (x *Header_Split) SetSplitId(v []byte)
func (*Header_Split) String ¶
func (x *Header_Split) String() string
type Header_Split_builder ¶
type Header_Split_builder struct { // Identifier of the origin object. Known only to the minor child. Parent *grpc.ObjectID // Identifier of the left split neighbor Previous *grpc.ObjectID // `signature` field of the parent object. Used to reconstruct parent. ParentSignature *grpc.Signature // `header` field of the parent object. Used to reconstruct parent. ParentHeader *Header // List of identifiers of the objects generated by splitting current one. Children []*grpc.ObjectID // 16 byte UUIDv4 used to identify the split object hierarchy parts. Must be // unique inside container. All objects participating in the split must have // the same `split_id` value. SplitId []byte // contains filtered or unexported fields }
func (Header_Split_builder) Build ¶
func (b0 Header_Split_builder) Build() *Header_Split
type Header_builder ¶
type Header_builder struct { // Object format version. Effectively, the version of API library used to // create particular object Version *grpc.Version // Object's container ContainerId *grpc.ContainerID // Object's owner OwnerId *grpc.OwnerID // Object creation Epoch CreationEpoch *uint64 // Size of payload in bytes. // `0xFFFFFFFFFFFFFFFF` means `payload_length` is unknown. PayloadLength *uint64 // Hash of payload bytes PayloadHash *grpc.Checksum // Type of the object payload content ObjectType *ObjectType // Homomorphic hash of the object payload HomomorphicHash *grpc.Checksum // Session token, if it was used during Object creation. Need it to verify // integrity and authenticity out of Request scope. SessionToken *grpc1.SessionToken // User-defined object attributes Attributes []*Header_Attribute // Position of the object in the split hierarchy Split *Header_Split // Erasure code chunk information. Ec *Header_EC // contains filtered or unexported fields }
func (Header_builder) Build ¶
func (b0 Header_builder) Build() *Header
type MatchType ¶
type MatchType int32
Type of match expression
const ( // Unknown. Not used MatchType_MATCH_TYPE_UNSPECIFIED MatchType = 0 // Full string match MatchType_STRING_EQUAL MatchType = 1 // Full string mismatch MatchType_STRING_NOT_EQUAL MatchType = 2 // Lack of key MatchType_NOT_PRESENT MatchType = 3 // String prefix match MatchType_COMMON_PREFIX MatchType = 4 )
func (MatchType) Descriptor ¶
func (MatchType) Descriptor() protoreflect.EnumDescriptor
func (MatchType) Number ¶
func (x MatchType) Number() protoreflect.EnumNumber
func (MatchType) Type ¶
func (MatchType) Type() protoreflect.EnumType
type Object ¶
type Object struct { // Object's unique identifier. ObjectId *grpc.ObjectID `protobuf:"bytes,1,opt,name=object_id,json=objectID" json:"object_id,omitempty"` // Signed object_id Signature *grpc.Signature `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"` // Object metadata headers Header *Header `protobuf:"bytes,3,opt,name=header" json:"header,omitempty"` // Payload bytes Payload []byte `protobuf:"bytes,4,opt,name=payload" json:"payload,omitempty"` // contains filtered or unexported fields }
Object structure. Object is immutable and content-addressed. It means `ObjectID` will change if the header or the payload changes. It's calculated as a hash of header field which contains hash of the object's payload.
For non-regular object types payload format depends on object type specified in the header.
func (*Object) ClearHeader ¶
func (x *Object) ClearHeader()
func (*Object) ClearObjectId ¶
func (x *Object) ClearObjectId()
func (*Object) ClearPayload ¶
func (x *Object) ClearPayload()
func (*Object) ClearSignature ¶
func (x *Object) ClearSignature()
func (*Object) GetObjectId ¶
func (*Object) GetPayload ¶
func (*Object) GetSignature ¶
func (*Object) HasObjectId ¶
func (*Object) HasPayload ¶
func (*Object) HasSignature ¶
func (*Object) ProtoMessage ¶
func (*Object) ProtoMessage()
func (*Object) ProtoReflect ¶
func (x *Object) ProtoReflect() protoreflect.Message
func (*Object) SetObjectId ¶
func (*Object) SetPayload ¶
func (*Object) SetSignature ¶
type ObjectServiceClient ¶
type ObjectServiceClient interface { // Receive full object structure, including Headers and payload. Response uses // 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. // // Extended headers can change `Get` behaviour: // - [ __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) \ // 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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetResponse], 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. // Chunk messages SHOULD be sent in the direct order of fragmentation. // // Extended headers can change `Put` 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 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): \ // placement of an object of type TOMBSTONE that includes at least one // locked object is prohibited; // - **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; // - **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. Put(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PutRequest, PutResponse], error) // Delete the object from a container. There is no immediate removal // guarantee. Object will be marked for removal and deleted eventually. // // Extended headers can change `Delete` 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 marked to be removed from the container; // - Common failures (SECTION_FAILURE_COMMON); // - **ACCESS_DENIED** (2048, SECTION_OBJECT): \ // delete access to the object is denied; // - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \ // the object could not be deleted because it has not been \ // found within the container; // - **LOCKED** (2050, SECTION_OBJECT): \ // deleting a locked object is prohibited; // - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \ // object container not found; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. 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 // the very minimal information will be returned instead. // // Extended headers can change `Head` 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 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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Head(ctx context.Context, in *HeadRequest, opts ...grpc.CallOption) (*HeadResponse, error) // Search objects in container. Search query allows to match by Object // Header's filed values. Please see the corresponding FrostFS Technical // Specification section for more details. // // Extended headers can change `Search` 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): \ // 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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SearchResponse], 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 // restored by concatenation of all received payload chunks keeping the // receiving order. // // Extended headers can change `GetRange` behaviour: // - [ __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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. GetRange(ctx context.Context, in *GetRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GetRangeResponse], error) // Returns homomorphic or regular hash of object's payload range after // applying XOR operation with the provided `salt`. Ranges are set of (offset, // 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: // - [ __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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. GetRangeHash(ctx context.Context, in *GetRangeHashRequest, opts ...grpc.CallOption) (*GetRangeHashResponse, error) // Put the prepared object into container. // `ContainerID`, `ObjectID`, `OwnerID`, `PayloadHash` and `PayloadLength` of // an object MUST be set. // // 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): \ // placement of an object of type TOMBSTONE that includes at least one // locked object is prohibited; // - **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; // - **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. PutSingle(ctx context.Context, in *PutSingleRequest, opts ...grpc.CallOption) (*PutSingleResponse, error) // Patch the object. Request uses gRPC stream. First message must set // 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; // 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): \ // 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 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) (grpc.ClientStreamingClient[PatchRequest, PatchResponse], error) }
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.
`ObjectService` provides API for manipulating objects. Object operations do not affect the sidechain and are only served by nodes in p2p style.
func NewObjectServiceClient ¶
func NewObjectServiceClient(cc grpc.ClientConnInterface) ObjectServiceClient
type ObjectServiceServer ¶
type ObjectServiceServer interface { // Receive full object structure, including Headers and payload. Response uses // 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. // // Extended headers can change `Get` behaviour: // - [ __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) \ // 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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Get(*GetRequest, grpc.ServerStreamingServer[GetResponse]) 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. // Chunk messages SHOULD be sent in the direct order of fragmentation. // // Extended headers can change `Put` 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 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): \ // placement of an object of type TOMBSTONE that includes at least one // locked object is prohibited; // - **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; // - **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. Put(grpc.ClientStreamingServer[PutRequest, PutResponse]) error // Delete the object from a container. There is no immediate removal // guarantee. Object will be marked for removal and deleted eventually. // // Extended headers can change `Delete` 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 marked to be removed from the container; // - Common failures (SECTION_FAILURE_COMMON); // - **ACCESS_DENIED** (2048, SECTION_OBJECT): \ // delete access to the object is denied; // - **OBJECT_NOT_FOUND** (2049, SECTION_OBJECT): \ // the object could not be deleted because it has not been \ // found within the container; // - **LOCKED** (2050, SECTION_OBJECT): \ // deleting a locked object is prohibited; // - **CONTAINER_NOT_FOUND** (3072, SECTION_CONTAINER): \ // object container not found; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. 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 // the very minimal information will be returned instead. // // Extended headers can change `Head` 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 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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Head(context.Context, *HeadRequest) (*HeadResponse, error) // Search objects in container. Search query allows to match by Object // Header's filed values. Please see the corresponding FrostFS Technical // Specification section for more details. // // Extended headers can change `Search` 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): \ // 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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. Search(*SearchRequest, grpc.ServerStreamingServer[SearchResponse]) 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 // restored by concatenation of all received payload chunks keeping the // receiving order. // // Extended headers can change `GetRange` behaviour: // - [ __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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. GetRange(*GetRangeRequest, grpc.ServerStreamingServer[GetRangeResponse]) error // Returns homomorphic or regular hash of object's payload range after // applying XOR operation with the provided `salt`. Ranges are set of (offset, // 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: // - [ __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. // // Please refer to detailed `XHeader` description. // // Statuses: // - **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; // - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \ // access to container is denied; // - **TOKEN_EXPIRED** (4097, SECTION_SESSION): \ // provided session token has expired. GetRangeHash(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error) // Put the prepared object into container. // `ContainerID`, `ObjectID`, `OwnerID`, `PayloadHash` and `PayloadLength` of // an object MUST be set. // // 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): \ // placement of an object of type TOMBSTONE that includes at least one // locked object is prohibited; // - **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; // - **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. PutSingle(context.Context, *PutSingleRequest) (*PutSingleResponse, error) // Patch the object. Request uses gRPC stream. First message must set // 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; // 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): \ // 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 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(grpc.ClientStreamingServer[PatchRequest, PatchResponse]) error }
ObjectServiceServer is the server API for ObjectService service. All implementations should embed UnimplementedObjectServiceServer for forward compatibility.
`ObjectService` provides API for manipulating objects. Object operations do not affect the sidechain and are only served by nodes in p2p style.
type ObjectService_GetClient ¶
type ObjectService_GetClient = grpc.ServerStreamingClient[GetResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_GetRangeClient ¶
type ObjectService_GetRangeClient = grpc.ServerStreamingClient[GetRangeResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_GetRangeServer ¶
type ObjectService_GetRangeServer = grpc.ServerStreamingServer[GetRangeResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_GetServer ¶
type ObjectService_GetServer = grpc.ServerStreamingServer[GetResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_PatchClient ¶
type ObjectService_PatchClient = grpc.ClientStreamingClient[PatchRequest, PatchResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_PatchServer ¶
type ObjectService_PatchServer = grpc.ClientStreamingServer[PatchRequest, PatchResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_PutClient ¶
type ObjectService_PutClient = grpc.ClientStreamingClient[PutRequest, PutResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_PutServer ¶
type ObjectService_PutServer = grpc.ClientStreamingServer[PutRequest, PutResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_SearchClient ¶
type ObjectService_SearchClient = grpc.ServerStreamingClient[SearchResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectService_SearchServer ¶
type ObjectService_SearchServer = grpc.ServerStreamingServer[SearchResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ObjectType ¶
type ObjectType int32
Type of the object payload content. Only `REGULAR` type objects can be split, hence `TOMBSTONE` and `LOCK` payload is limited by the maximum object size.
String presentation of object type is the same as definition: * REGULAR * TOMBSTONE * LOCK
const ( // Just a normal object ObjectType_REGULAR ObjectType = 0 // Used internally to identify deleted objects ObjectType_TOMBSTONE ObjectType = 1 // Object lock ObjectType_LOCK ObjectType = 3 )
func (ObjectType) Descriptor ¶
func (ObjectType) Descriptor() protoreflect.EnumDescriptor
func (ObjectType) Enum ¶
func (x ObjectType) Enum() *ObjectType
func (ObjectType) Number ¶
func (x ObjectType) Number() protoreflect.EnumNumber
func (ObjectType) String ¶
func (x ObjectType) String() string
func (ObjectType) Type ¶
func (ObjectType) Type() protoreflect.EnumType
type Object_builder ¶
type Object_builder struct { // Object's unique identifier. ObjectId *grpc.ObjectID // Signed object_id Signature *grpc.Signature // Object metadata headers Header *Header // Payload bytes Payload []byte // contains filtered or unexported fields }
func (Object_builder) Build ¶
func (b0 Object_builder) Build() *Object
type PatchRequest ¶
type PatchRequest struct { // Body for patch request message. Body *PatchRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object PATCH request
func (*PatchRequest) ClearBody ¶
func (x *PatchRequest) ClearBody()
func (*PatchRequest) ClearMetaHeader ¶
func (x *PatchRequest) ClearMetaHeader()
func (*PatchRequest) ClearVerifyHeader ¶
func (x *PatchRequest) ClearVerifyHeader()
func (*PatchRequest) GetBody ¶
func (x *PatchRequest) GetBody() *PatchRequest_Body
func (*PatchRequest) GetMetaHeader ¶
func (x *PatchRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*PatchRequest) GetVerifyHeader ¶
func (x *PatchRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*PatchRequest) HasBody ¶
func (x *PatchRequest) HasBody() bool
func (*PatchRequest) HasMetaHeader ¶
func (x *PatchRequest) HasMetaHeader() bool
func (*PatchRequest) HasVerifyHeader ¶
func (x *PatchRequest) HasVerifyHeader() bool
func (*PatchRequest) ProtoMessage ¶
func (*PatchRequest) ProtoMessage()
func (*PatchRequest) ProtoReflect ¶
func (x *PatchRequest) ProtoReflect() protoreflect.Message
func (*PatchRequest) Reset ¶
func (x *PatchRequest) Reset()
func (*PatchRequest) SetBody ¶
func (x *PatchRequest) SetBody(v *PatchRequest_Body)
func (*PatchRequest) SetMetaHeader ¶
func (x *PatchRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*PatchRequest) SetVerifyHeader ¶
func (x *PatchRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*PatchRequest) String ¶
func (x *PatchRequest) String() string
type PatchRequest_Body ¶
type PatchRequest_Body struct { // The address of the object that is requested to get patched. Address *grpc1.Address `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"` // New attributes for the object. See `replace_attributes` flag usage to // define how new attributes should be set. NewAttributes []*Header_Attribute `protobuf:"bytes,2,rep,name=new_attributes,json=newAttributes" json:"new_attributes,omitempty"` // If this flag is set, then the object's attributes will be entirely // replaced by `new_attributes` list. The empty `new_attributes` list with // `replace_attributes = true` just resets attributes list for the object. // // Default `false` value for this flag means the attributes will be just // merged. If the incoming `new_attributes` list contains already existing // key, then it just replaces it while merging the lists. ReplaceAttributes *bool `protobuf:"varint,3,opt,name=replace_attributes,json=replaceAttributes" json:"replace_attributes,omitempty"` // The patch that is applied for the object. Patch *PatchRequest_Body_Patch `protobuf:"bytes,4,opt,name=patch" json:"patch,omitempty"` // contains filtered or unexported fields }
PATCH request body
func (*PatchRequest_Body) ClearAddress ¶
func (x *PatchRequest_Body) ClearAddress()
func (*PatchRequest_Body) ClearPatch ¶
func (x *PatchRequest_Body) ClearPatch()
func (*PatchRequest_Body) ClearReplaceAttributes ¶
func (x *PatchRequest_Body) ClearReplaceAttributes()
func (*PatchRequest_Body) GetAddress ¶
func (x *PatchRequest_Body) GetAddress() *grpc1.Address
func (*PatchRequest_Body) GetNewAttributes ¶
func (x *PatchRequest_Body) GetNewAttributes() []*Header_Attribute
func (*PatchRequest_Body) GetPatch ¶
func (x *PatchRequest_Body) GetPatch() *PatchRequest_Body_Patch
func (*PatchRequest_Body) GetReplaceAttributes ¶
func (x *PatchRequest_Body) GetReplaceAttributes() bool
func (*PatchRequest_Body) HasAddress ¶
func (x *PatchRequest_Body) HasAddress() bool
func (*PatchRequest_Body) HasPatch ¶
func (x *PatchRequest_Body) HasPatch() bool
func (*PatchRequest_Body) HasReplaceAttributes ¶
func (x *PatchRequest_Body) HasReplaceAttributes() bool
func (*PatchRequest_Body) ProtoMessage ¶
func (*PatchRequest_Body) ProtoMessage()
func (*PatchRequest_Body) ProtoReflect ¶
func (x *PatchRequest_Body) ProtoReflect() protoreflect.Message
func (*PatchRequest_Body) Reset ¶
func (x *PatchRequest_Body) Reset()
func (*PatchRequest_Body) SetAddress ¶
func (x *PatchRequest_Body) SetAddress(v *grpc1.Address)
func (*PatchRequest_Body) SetNewAttributes ¶
func (x *PatchRequest_Body) SetNewAttributes(v []*Header_Attribute)
func (*PatchRequest_Body) SetPatch ¶
func (x *PatchRequest_Body) SetPatch(v *PatchRequest_Body_Patch)
func (*PatchRequest_Body) SetReplaceAttributes ¶
func (x *PatchRequest_Body) SetReplaceAttributes(v bool)
func (*PatchRequest_Body) String ¶
func (x *PatchRequest_Body) String() string
type PatchRequest_Body_Patch ¶
type PatchRequest_Body_Patch struct { // The range of the source object for which the payload is replaced by the // patch's chunk. If the range's `length = 0`, then the patch's chunk is // just appended to the original payload starting from the `offest` // without any replace. SourceRange *Range `protobuf:"bytes,1,opt,name=source_range,json=sourceRange" json:"source_range,omitempty"` // The chunk that is being appended to or that replaces the original // payload on the given range. Chunk []byte `protobuf:"bytes,2,opt,name=chunk" json:"chunk,omitempty"` // contains filtered or unexported fields }
The patch for the object's payload.
func (*PatchRequest_Body_Patch) ClearChunk ¶
func (x *PatchRequest_Body_Patch) ClearChunk()
func (*PatchRequest_Body_Patch) ClearSourceRange ¶
func (x *PatchRequest_Body_Patch) ClearSourceRange()
func (*PatchRequest_Body_Patch) GetChunk ¶
func (x *PatchRequest_Body_Patch) GetChunk() []byte
func (*PatchRequest_Body_Patch) GetSourceRange ¶
func (x *PatchRequest_Body_Patch) GetSourceRange() *Range
func (*PatchRequest_Body_Patch) HasChunk ¶
func (x *PatchRequest_Body_Patch) HasChunk() bool
func (*PatchRequest_Body_Patch) HasSourceRange ¶
func (x *PatchRequest_Body_Patch) HasSourceRange() bool
func (*PatchRequest_Body_Patch) ProtoMessage ¶
func (*PatchRequest_Body_Patch) ProtoMessage()
func (*PatchRequest_Body_Patch) ProtoReflect ¶
func (x *PatchRequest_Body_Patch) ProtoReflect() protoreflect.Message
func (*PatchRequest_Body_Patch) Reset ¶
func (x *PatchRequest_Body_Patch) Reset()
func (*PatchRequest_Body_Patch) SetChunk ¶
func (x *PatchRequest_Body_Patch) SetChunk(v []byte)
func (*PatchRequest_Body_Patch) SetSourceRange ¶
func (x *PatchRequest_Body_Patch) SetSourceRange(v *Range)
func (*PatchRequest_Body_Patch) String ¶
func (x *PatchRequest_Body_Patch) String() string
type PatchRequest_Body_Patch_builder ¶
type PatchRequest_Body_Patch_builder struct { // The range of the source object for which the payload is replaced by the // patch's chunk. If the range's `length = 0`, then the patch's chunk is // just appended to the original payload starting from the `offest` // without any replace. SourceRange *Range // The chunk that is being appended to or that replaces the original // payload on the given range. Chunk []byte // contains filtered or unexported fields }
func (PatchRequest_Body_Patch_builder) Build ¶
func (b0 PatchRequest_Body_Patch_builder) Build() *PatchRequest_Body_Patch
type PatchRequest_Body_builder ¶
type PatchRequest_Body_builder struct { // The address of the object that is requested to get patched. Address *grpc1.Address // New attributes for the object. See `replace_attributes` flag usage to // define how new attributes should be set. NewAttributes []*Header_Attribute // If this flag is set, then the object's attributes will be entirely // replaced by `new_attributes` list. The empty `new_attributes` list with // `replace_attributes = true` just resets attributes list for the object. // // Default `false` value for this flag means the attributes will be just // merged. If the incoming `new_attributes` list contains already existing // key, then it just replaces it while merging the lists. ReplaceAttributes *bool // The patch that is applied for the object. Patch *PatchRequest_Body_Patch // contains filtered or unexported fields }
func (PatchRequest_Body_builder) Build ¶
func (b0 PatchRequest_Body_builder) Build() *PatchRequest_Body
type PatchRequest_builder ¶
type PatchRequest_builder struct { // Body for patch request message. Body *PatchRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (PatchRequest_builder) Build ¶
func (b0 PatchRequest_builder) Build() *PatchRequest
type PatchResponse ¶
type PatchResponse struct { // Body for patch response message. Body *PatchResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object PATCH response
func (*PatchResponse) ClearBody ¶
func (x *PatchResponse) ClearBody()
func (*PatchResponse) ClearMetaHeader ¶
func (x *PatchResponse) ClearMetaHeader()
func (*PatchResponse) ClearVerifyHeader ¶
func (x *PatchResponse) ClearVerifyHeader()
func (*PatchResponse) GetBody ¶
func (x *PatchResponse) GetBody() *PatchResponse_Body
func (*PatchResponse) GetMetaHeader ¶
func (x *PatchResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*PatchResponse) GetVerifyHeader ¶
func (x *PatchResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*PatchResponse) HasBody ¶
func (x *PatchResponse) HasBody() bool
func (*PatchResponse) HasMetaHeader ¶
func (x *PatchResponse) HasMetaHeader() bool
func (*PatchResponse) HasVerifyHeader ¶
func (x *PatchResponse) HasVerifyHeader() bool
func (*PatchResponse) ProtoMessage ¶
func (*PatchResponse) ProtoMessage()
func (*PatchResponse) ProtoReflect ¶
func (x *PatchResponse) ProtoReflect() protoreflect.Message
func (*PatchResponse) Reset ¶
func (x *PatchResponse) Reset()
func (*PatchResponse) SetBody ¶
func (x *PatchResponse) SetBody(v *PatchResponse_Body)
func (*PatchResponse) SetMetaHeader ¶
func (x *PatchResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*PatchResponse) SetVerifyHeader ¶
func (x *PatchResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*PatchResponse) String ¶
func (x *PatchResponse) String() string
type PatchResponse_Body ¶
type PatchResponse_Body struct { // The object ID of the saved patched object. ObjectId *grpc1.ObjectID `protobuf:"bytes,1,opt,name=object_id,json=objectId" json:"object_id,omitempty"` // contains filtered or unexported fields }
PATCH response body
func (*PatchResponse_Body) ClearObjectId ¶
func (x *PatchResponse_Body) ClearObjectId()
func (*PatchResponse_Body) GetObjectId ¶
func (x *PatchResponse_Body) GetObjectId() *grpc1.ObjectID
func (*PatchResponse_Body) HasObjectId ¶
func (x *PatchResponse_Body) HasObjectId() bool
func (*PatchResponse_Body) ProtoMessage ¶
func (*PatchResponse_Body) ProtoMessage()
func (*PatchResponse_Body) ProtoReflect ¶
func (x *PatchResponse_Body) ProtoReflect() protoreflect.Message
func (*PatchResponse_Body) Reset ¶
func (x *PatchResponse_Body) Reset()
func (*PatchResponse_Body) SetObjectId ¶
func (x *PatchResponse_Body) SetObjectId(v *grpc1.ObjectID)
func (*PatchResponse_Body) String ¶
func (x *PatchResponse_Body) String() string
type PatchResponse_Body_builder ¶
type PatchResponse_Body_builder struct { // The object ID of the saved patched object. ObjectId *grpc1.ObjectID // contains filtered or unexported fields }
func (PatchResponse_Body_builder) Build ¶
func (b0 PatchResponse_Body_builder) Build() *PatchResponse_Body
type PatchResponse_builder ¶
type PatchResponse_builder struct { // Body for patch response message. Body *PatchResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (PatchResponse_builder) Build ¶
func (b0 PatchResponse_builder) Build() *PatchResponse
type PutRequest ¶
type PutRequest struct { // Body of put object request message. Body *PutRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
PUT object request
func (*PutRequest) ClearBody ¶
func (x *PutRequest) ClearBody()
func (*PutRequest) ClearMetaHeader ¶
func (x *PutRequest) ClearMetaHeader()
func (*PutRequest) ClearVerifyHeader ¶
func (x *PutRequest) ClearVerifyHeader()
func (*PutRequest) GetBody ¶
func (x *PutRequest) GetBody() *PutRequest_Body
func (*PutRequest) GetMetaHeader ¶
func (x *PutRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*PutRequest) GetVerifyHeader ¶
func (x *PutRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*PutRequest) HasBody ¶
func (x *PutRequest) HasBody() bool
func (*PutRequest) HasMetaHeader ¶
func (x *PutRequest) HasMetaHeader() bool
func (*PutRequest) HasVerifyHeader ¶
func (x *PutRequest) HasVerifyHeader() bool
func (*PutRequest) ProtoMessage ¶
func (*PutRequest) ProtoMessage()
func (*PutRequest) ProtoReflect ¶
func (x *PutRequest) ProtoReflect() protoreflect.Message
func (*PutRequest) Reset ¶
func (x *PutRequest) Reset()
func (*PutRequest) SetBody ¶
func (x *PutRequest) SetBody(v *PutRequest_Body)
func (*PutRequest) SetMetaHeader ¶
func (x *PutRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*PutRequest) SetVerifyHeader ¶
func (x *PutRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*PutRequest) String ¶
func (x *PutRequest) String() string
type PutRequest_Body ¶
type PutRequest_Body struct { // Single message in the request stream. // // Types that are valid to be assigned to ObjectPart: // // *PutRequest_Body_Init_ // *PutRequest_Body_Chunk ObjectPart isPutRequest_Body_ObjectPart `protobuf_oneof:"object_part"` // contains filtered or unexported fields }
PUT request body
func (*PutRequest_Body) ClearChunk ¶
func (x *PutRequest_Body) ClearChunk()
func (*PutRequest_Body) ClearInit ¶
func (x *PutRequest_Body) ClearInit()
func (*PutRequest_Body) ClearObjectPart ¶
func (x *PutRequest_Body) ClearObjectPart()
func (*PutRequest_Body) GetChunk ¶
func (x *PutRequest_Body) GetChunk() []byte
func (*PutRequest_Body) GetInit ¶
func (x *PutRequest_Body) GetInit() *PutRequest_Body_Init
func (*PutRequest_Body) GetObjectPart ¶
func (x *PutRequest_Body) GetObjectPart() isPutRequest_Body_ObjectPart
func (*PutRequest_Body) HasChunk ¶
func (x *PutRequest_Body) HasChunk() bool
func (*PutRequest_Body) HasInit ¶
func (x *PutRequest_Body) HasInit() bool
func (*PutRequest_Body) HasObjectPart ¶
func (x *PutRequest_Body) HasObjectPart() bool
func (*PutRequest_Body) ProtoMessage ¶
func (*PutRequest_Body) ProtoMessage()
func (*PutRequest_Body) ProtoReflect ¶
func (x *PutRequest_Body) ProtoReflect() protoreflect.Message
func (*PutRequest_Body) Reset ¶
func (x *PutRequest_Body) Reset()
func (*PutRequest_Body) SetChunk ¶
func (x *PutRequest_Body) SetChunk(v []byte)
func (*PutRequest_Body) SetInit ¶
func (x *PutRequest_Body) SetInit(v *PutRequest_Body_Init)
func (*PutRequest_Body) String ¶
func (x *PutRequest_Body) String() string
func (*PutRequest_Body) WhichObjectPart ¶
func (x *PutRequest_Body) WhichObjectPart() case_PutRequest_Body_ObjectPart
type PutRequest_Body_Chunk ¶
type PutRequest_Body_Chunk struct { // Chunked object payload Chunk []byte `protobuf:"bytes,2,opt,name=chunk,oneof"` }
type PutRequest_Body_Init ¶
type PutRequest_Body_Init struct { // ObjectID if available. ObjectId *grpc1.ObjectID `protobuf:"bytes,1,opt,name=object_id,json=objectId" json:"object_id,omitempty"` // Object signature if available Signature *grpc1.Signature `protobuf:"bytes,2,opt,name=signature" json:"signature,omitempty"` // Object's Header Header *Header `protobuf:"bytes,3,opt,name=header" json:"header,omitempty"` // Number of copies of the object to store within the RPC call. By // default, object is processed according to the container's placement // policy. Can be one of: // 1. A single number; applied to the whole request and is treated as // a minimal number of nodes that must store an object to complete the // request successfully. // 2. An ordered array; every number is treated as a minimal number of // nodes in a corresponding placement vector that must store an object // to complete the request successfully. The length MUST equal the // placement vectors number, otherwise request is considered malformed. CopiesNumber []uint32 `protobuf:"varint,4,rep,packed,name=copies_number,json=copiesNumber" json:"copies_number,omitempty"` // contains filtered or unexported fields }
Newly created object structure parameters. If some optional parameters are not set, they will be calculated by a peer node.
func (*PutRequest_Body_Init) ClearHeader ¶
func (x *PutRequest_Body_Init) ClearHeader()
func (*PutRequest_Body_Init) ClearObjectId ¶
func (x *PutRequest_Body_Init) ClearObjectId()
func (*PutRequest_Body_Init) ClearSignature ¶
func (x *PutRequest_Body_Init) ClearSignature()
func (*PutRequest_Body_Init) GetCopiesNumber ¶
func (x *PutRequest_Body_Init) GetCopiesNumber() []uint32
func (*PutRequest_Body_Init) GetHeader ¶
func (x *PutRequest_Body_Init) GetHeader() *Header
func (*PutRequest_Body_Init) GetObjectId ¶
func (x *PutRequest_Body_Init) GetObjectId() *grpc1.ObjectID
func (*PutRequest_Body_Init) GetSignature ¶
func (x *PutRequest_Body_Init) GetSignature() *grpc1.Signature
func (*PutRequest_Body_Init) HasHeader ¶
func (x *PutRequest_Body_Init) HasHeader() bool
func (*PutRequest_Body_Init) HasObjectId ¶
func (x *PutRequest_Body_Init) HasObjectId() bool
func (*PutRequest_Body_Init) HasSignature ¶
func (x *PutRequest_Body_Init) HasSignature() bool
func (*PutRequest_Body_Init) ProtoMessage ¶
func (*PutRequest_Body_Init) ProtoMessage()
func (*PutRequest_Body_Init) ProtoReflect ¶
func (x *PutRequest_Body_Init) ProtoReflect() protoreflect.Message
func (*PutRequest_Body_Init) Reset ¶
func (x *PutRequest_Body_Init) Reset()
func (*PutRequest_Body_Init) SetCopiesNumber ¶
func (x *PutRequest_Body_Init) SetCopiesNumber(v []uint32)
func (*PutRequest_Body_Init) SetHeader ¶
func (x *PutRequest_Body_Init) SetHeader(v *Header)
func (*PutRequest_Body_Init) SetObjectId ¶
func (x *PutRequest_Body_Init) SetObjectId(v *grpc1.ObjectID)
func (*PutRequest_Body_Init) SetSignature ¶
func (x *PutRequest_Body_Init) SetSignature(v *grpc1.Signature)
func (*PutRequest_Body_Init) String ¶
func (x *PutRequest_Body_Init) String() string
type PutRequest_Body_Init_ ¶
type PutRequest_Body_Init_ struct { // Initial part of the object stream Init *PutRequest_Body_Init `protobuf:"bytes,1,opt,name=init,oneof"` }
type PutRequest_Body_Init_builder ¶
type PutRequest_Body_Init_builder struct { // ObjectID if available. ObjectId *grpc1.ObjectID // Object signature if available Signature *grpc1.Signature // Object's Header Header *Header // Number of copies of the object to store within the RPC call. By // default, object is processed according to the container's placement // policy. Can be one of: // 1. A single number; applied to the whole request and is treated as // a minimal number of nodes that must store an object to complete the // request successfully. // 2. An ordered array; every number is treated as a minimal number of // nodes in a corresponding placement vector that must store an object // to complete the request successfully. The length MUST equal the // placement vectors number, otherwise request is considered malformed. CopiesNumber []uint32 // contains filtered or unexported fields }
func (PutRequest_Body_Init_builder) Build ¶
func (b0 PutRequest_Body_Init_builder) Build() *PutRequest_Body_Init
type PutRequest_Body_builder ¶
type PutRequest_Body_builder struct { // Fields of oneof ObjectPart: // Initial part of the object stream Init *PutRequest_Body_Init // Chunked object payload Chunk []byte // contains filtered or unexported fields }
func (PutRequest_Body_builder) Build ¶
func (b0 PutRequest_Body_builder) Build() *PutRequest_Body
type PutRequest_builder ¶
type PutRequest_builder struct { // Body of put object request message. Body *PutRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (PutRequest_builder) Build ¶
func (b0 PutRequest_builder) Build() *PutRequest
type PutResponse ¶
type PutResponse struct { // Body of put object response message. Body *PutResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
PUT Object response
func (*PutResponse) ClearBody ¶
func (x *PutResponse) ClearBody()
func (*PutResponse) ClearMetaHeader ¶
func (x *PutResponse) ClearMetaHeader()
func (*PutResponse) ClearVerifyHeader ¶
func (x *PutResponse) ClearVerifyHeader()
func (*PutResponse) GetBody ¶
func (x *PutResponse) GetBody() *PutResponse_Body
func (*PutResponse) GetMetaHeader ¶
func (x *PutResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*PutResponse) GetVerifyHeader ¶
func (x *PutResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*PutResponse) HasBody ¶
func (x *PutResponse) HasBody() bool
func (*PutResponse) HasMetaHeader ¶
func (x *PutResponse) HasMetaHeader() bool
func (*PutResponse) HasVerifyHeader ¶
func (x *PutResponse) HasVerifyHeader() bool
func (*PutResponse) ProtoMessage ¶
func (*PutResponse) ProtoMessage()
func (*PutResponse) ProtoReflect ¶
func (x *PutResponse) ProtoReflect() protoreflect.Message
func (*PutResponse) Reset ¶
func (x *PutResponse) Reset()
func (*PutResponse) SetBody ¶
func (x *PutResponse) SetBody(v *PutResponse_Body)
func (*PutResponse) SetMetaHeader ¶
func (x *PutResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*PutResponse) SetVerifyHeader ¶
func (x *PutResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*PutResponse) String ¶
func (x *PutResponse) String() string
type PutResponse_Body ¶
type PutResponse_Body struct { // Identifier of the saved object ObjectId *grpc1.ObjectID `protobuf:"bytes,1,opt,name=object_id,json=objectId" json:"object_id,omitempty"` // contains filtered or unexported fields }
PUT Object response body
func (*PutResponse_Body) ClearObjectId ¶
func (x *PutResponse_Body) ClearObjectId()
func (*PutResponse_Body) GetObjectId ¶
func (x *PutResponse_Body) GetObjectId() *grpc1.ObjectID
func (*PutResponse_Body) HasObjectId ¶
func (x *PutResponse_Body) HasObjectId() bool
func (*PutResponse_Body) ProtoMessage ¶
func (*PutResponse_Body) ProtoMessage()
func (*PutResponse_Body) ProtoReflect ¶
func (x *PutResponse_Body) ProtoReflect() protoreflect.Message
func (*PutResponse_Body) Reset ¶
func (x *PutResponse_Body) Reset()
func (*PutResponse_Body) SetObjectId ¶
func (x *PutResponse_Body) SetObjectId(v *grpc1.ObjectID)
func (*PutResponse_Body) String ¶
func (x *PutResponse_Body) String() string
type PutResponse_Body_builder ¶
type PutResponse_Body_builder struct { // Identifier of the saved object ObjectId *grpc1.ObjectID // contains filtered or unexported fields }
func (PutResponse_Body_builder) Build ¶
func (b0 PutResponse_Body_builder) Build() *PutResponse_Body
type PutResponse_builder ¶
type PutResponse_builder struct { // Body of put object response message. Body *PutResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (PutResponse_builder) Build ¶
func (b0 PutResponse_builder) Build() *PutResponse
type PutSingleRequest ¶
type PutSingleRequest struct { // Body of put single object request message. Body *PutSingleRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object PUT Single request
func (*PutSingleRequest) ClearBody ¶
func (x *PutSingleRequest) ClearBody()
func (*PutSingleRequest) ClearMetaHeader ¶
func (x *PutSingleRequest) ClearMetaHeader()
func (*PutSingleRequest) ClearVerifyHeader ¶
func (x *PutSingleRequest) ClearVerifyHeader()
func (*PutSingleRequest) GetBody ¶
func (x *PutSingleRequest) GetBody() *PutSingleRequest_Body
func (*PutSingleRequest) GetMetaHeader ¶
func (x *PutSingleRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*PutSingleRequest) GetVerifyHeader ¶
func (x *PutSingleRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*PutSingleRequest) HasBody ¶
func (x *PutSingleRequest) HasBody() bool
func (*PutSingleRequest) HasMetaHeader ¶
func (x *PutSingleRequest) HasMetaHeader() bool
func (*PutSingleRequest) HasVerifyHeader ¶
func (x *PutSingleRequest) HasVerifyHeader() bool
func (*PutSingleRequest) ProtoMessage ¶
func (*PutSingleRequest) ProtoMessage()
func (*PutSingleRequest) ProtoReflect ¶
func (x *PutSingleRequest) ProtoReflect() protoreflect.Message
func (*PutSingleRequest) Reset ¶
func (x *PutSingleRequest) Reset()
func (*PutSingleRequest) SetBody ¶
func (x *PutSingleRequest) SetBody(v *PutSingleRequest_Body)
func (*PutSingleRequest) SetMetaHeader ¶
func (x *PutSingleRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*PutSingleRequest) SetVerifyHeader ¶
func (x *PutSingleRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*PutSingleRequest) String ¶
func (x *PutSingleRequest) String() string
type PutSingleRequest_Body ¶
type PutSingleRequest_Body struct { // Prepared object with payload. Object *Object `protobuf:"bytes,1,opt,name=object" json:"object,omitempty"` // Number of copies of the object to store within the RPC call. By default, // object is processed according to the container's placement policy. // Every number is treated as a minimal number of // nodes in a corresponding placement vector that must store an object // to complete the request successfully. The length MUST equal the placement // vectors number, otherwise request is considered malformed. CopiesNumber []uint32 `protobuf:"varint,2,rep,packed,name=copies_number,json=copiesNumber" json:"copies_number,omitempty"` // contains filtered or unexported fields }
PUT Single request body
func (*PutSingleRequest_Body) ClearObject ¶
func (x *PutSingleRequest_Body) ClearObject()
func (*PutSingleRequest_Body) GetCopiesNumber ¶
func (x *PutSingleRequest_Body) GetCopiesNumber() []uint32
func (*PutSingleRequest_Body) GetObject ¶
func (x *PutSingleRequest_Body) GetObject() *Object
func (*PutSingleRequest_Body) HasObject ¶
func (x *PutSingleRequest_Body) HasObject() bool
func (*PutSingleRequest_Body) ProtoMessage ¶
func (*PutSingleRequest_Body) ProtoMessage()
func (*PutSingleRequest_Body) ProtoReflect ¶
func (x *PutSingleRequest_Body) ProtoReflect() protoreflect.Message
func (*PutSingleRequest_Body) Reset ¶
func (x *PutSingleRequest_Body) Reset()
func (*PutSingleRequest_Body) SetCopiesNumber ¶
func (x *PutSingleRequest_Body) SetCopiesNumber(v []uint32)
func (*PutSingleRequest_Body) SetObject ¶
func (x *PutSingleRequest_Body) SetObject(v *Object)
func (*PutSingleRequest_Body) String ¶
func (x *PutSingleRequest_Body) String() string
type PutSingleRequest_Body_builder ¶
type PutSingleRequest_Body_builder struct { // Prepared object with payload. Object *Object // Number of copies of the object to store within the RPC call. By default, // object is processed according to the container's placement policy. // Every number is treated as a minimal number of // nodes in a corresponding placement vector that must store an object // to complete the request successfully. The length MUST equal the placement // vectors number, otherwise request is considered malformed. CopiesNumber []uint32 // contains filtered or unexported fields }
func (PutSingleRequest_Body_builder) Build ¶
func (b0 PutSingleRequest_Body_builder) Build() *PutSingleRequest_Body
type PutSingleRequest_builder ¶
type PutSingleRequest_builder struct { // Body of put single object request message. Body *PutSingleRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (PutSingleRequest_builder) Build ¶
func (b0 PutSingleRequest_builder) Build() *PutSingleRequest
type PutSingleResponse ¶
type PutSingleResponse struct { // Body of put single object response message. Body *PutSingleResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object PUT Single response
func (*PutSingleResponse) ClearBody ¶
func (x *PutSingleResponse) ClearBody()
func (*PutSingleResponse) ClearMetaHeader ¶
func (x *PutSingleResponse) ClearMetaHeader()
func (*PutSingleResponse) ClearVerifyHeader ¶
func (x *PutSingleResponse) ClearVerifyHeader()
func (*PutSingleResponse) GetBody ¶
func (x *PutSingleResponse) GetBody() *PutSingleResponse_Body
func (*PutSingleResponse) GetMetaHeader ¶
func (x *PutSingleResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*PutSingleResponse) GetVerifyHeader ¶
func (x *PutSingleResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*PutSingleResponse) HasBody ¶
func (x *PutSingleResponse) HasBody() bool
func (*PutSingleResponse) HasMetaHeader ¶
func (x *PutSingleResponse) HasMetaHeader() bool
func (*PutSingleResponse) HasVerifyHeader ¶
func (x *PutSingleResponse) HasVerifyHeader() bool
func (*PutSingleResponse) ProtoMessage ¶
func (*PutSingleResponse) ProtoMessage()
func (*PutSingleResponse) ProtoReflect ¶
func (x *PutSingleResponse) ProtoReflect() protoreflect.Message
func (*PutSingleResponse) Reset ¶
func (x *PutSingleResponse) Reset()
func (*PutSingleResponse) SetBody ¶
func (x *PutSingleResponse) SetBody(v *PutSingleResponse_Body)
func (*PutSingleResponse) SetMetaHeader ¶
func (x *PutSingleResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*PutSingleResponse) SetVerifyHeader ¶
func (x *PutSingleResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*PutSingleResponse) String ¶
func (x *PutSingleResponse) String() string
type PutSingleResponse_Body ¶
type PutSingleResponse_Body struct {
// contains filtered or unexported fields
}
PUT Single Object response body
func (*PutSingleResponse_Body) ProtoMessage ¶
func (*PutSingleResponse_Body) ProtoMessage()
func (*PutSingleResponse_Body) ProtoReflect ¶
func (x *PutSingleResponse_Body) ProtoReflect() protoreflect.Message
func (*PutSingleResponse_Body) Reset ¶
func (x *PutSingleResponse_Body) Reset()
func (*PutSingleResponse_Body) String ¶
func (x *PutSingleResponse_Body) String() string
type PutSingleResponse_Body_builder ¶
type PutSingleResponse_Body_builder struct {
// contains filtered or unexported fields
}
func (PutSingleResponse_Body_builder) Build ¶
func (b0 PutSingleResponse_Body_builder) Build() *PutSingleResponse_Body
type PutSingleResponse_builder ¶
type PutSingleResponse_builder struct { // Body of put single object response message. Body *PutSingleResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (PutSingleResponse_builder) Build ¶
func (b0 PutSingleResponse_builder) Build() *PutSingleResponse
type Range ¶
type Range struct { // Offset of the range from the object payload start Offset *uint64 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"` // Length in bytes of the object payload range Length *uint64 `protobuf:"varint,2,opt,name=length" json:"length,omitempty"` // contains filtered or unexported fields }
Object payload range.Ranges of zero length SHOULD be considered as invalid.
func (*Range) ClearLength ¶
func (x *Range) ClearLength()
func (*Range) ClearOffset ¶
func (x *Range) ClearOffset()
func (*Range) ProtoMessage ¶
func (*Range) ProtoMessage()
func (*Range) ProtoReflect ¶
func (x *Range) ProtoReflect() protoreflect.Message
type Range_builder ¶
type Range_builder struct { // Offset of the range from the object payload start Offset *uint64 // Length in bytes of the object payload range Length *uint64 // contains filtered or unexported fields }
func (Range_builder) Build ¶
func (b0 Range_builder) Build() *Range
type SearchRequest ¶
type SearchRequest struct { // Body of search object request message. Body *SearchRequest_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Object Search request
func (*SearchRequest) ClearBody ¶
func (x *SearchRequest) ClearBody()
func (*SearchRequest) ClearMetaHeader ¶
func (x *SearchRequest) ClearMetaHeader()
func (*SearchRequest) ClearVerifyHeader ¶
func (x *SearchRequest) ClearVerifyHeader()
func (*SearchRequest) GetBody ¶
func (x *SearchRequest) GetBody() *SearchRequest_Body
func (*SearchRequest) GetMetaHeader ¶
func (x *SearchRequest) GetMetaHeader() *grpc.RequestMetaHeader
func (*SearchRequest) GetVerifyHeader ¶
func (x *SearchRequest) GetVerifyHeader() *grpc.RequestVerificationHeader
func (*SearchRequest) HasBody ¶
func (x *SearchRequest) HasBody() bool
func (*SearchRequest) HasMetaHeader ¶
func (x *SearchRequest) HasMetaHeader() bool
func (*SearchRequest) HasVerifyHeader ¶
func (x *SearchRequest) HasVerifyHeader() bool
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) SetBody ¶
func (x *SearchRequest) SetBody(v *SearchRequest_Body)
func (*SearchRequest) SetMetaHeader ¶
func (x *SearchRequest) SetMetaHeader(v *grpc.RequestMetaHeader)
func (*SearchRequest) SetVerifyHeader ¶
func (x *SearchRequest) SetVerifyHeader(v *grpc.RequestVerificationHeader)
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
type SearchRequest_Body ¶
type SearchRequest_Body struct { // Container identifier were to search ContainerId *grpc1.ContainerID `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"` // Version of the Query Language used Version *uint32 `protobuf:"varint,2,opt,name=version" json:"version,omitempty"` // List of search expressions Filters []*SearchRequest_Body_Filter `protobuf:"bytes,3,rep,name=filters" json:"filters,omitempty"` // contains filtered or unexported fields }
Object Search request body
func (*SearchRequest_Body) ClearContainerId ¶
func (x *SearchRequest_Body) ClearContainerId()
func (*SearchRequest_Body) ClearVersion ¶
func (x *SearchRequest_Body) ClearVersion()
func (*SearchRequest_Body) GetContainerId ¶
func (x *SearchRequest_Body) GetContainerId() *grpc1.ContainerID
func (*SearchRequest_Body) GetFilters ¶
func (x *SearchRequest_Body) GetFilters() []*SearchRequest_Body_Filter
func (*SearchRequest_Body) GetVersion ¶
func (x *SearchRequest_Body) GetVersion() uint32
func (*SearchRequest_Body) HasContainerId ¶
func (x *SearchRequest_Body) HasContainerId() bool
func (*SearchRequest_Body) HasVersion ¶
func (x *SearchRequest_Body) HasVersion() bool
func (*SearchRequest_Body) ProtoMessage ¶
func (*SearchRequest_Body) ProtoMessage()
func (*SearchRequest_Body) ProtoReflect ¶
func (x *SearchRequest_Body) ProtoReflect() protoreflect.Message
func (*SearchRequest_Body) Reset ¶
func (x *SearchRequest_Body) Reset()
func (*SearchRequest_Body) SetContainerId ¶
func (x *SearchRequest_Body) SetContainerId(v *grpc1.ContainerID)
func (*SearchRequest_Body) SetFilters ¶
func (x *SearchRequest_Body) SetFilters(v []*SearchRequest_Body_Filter)
func (*SearchRequest_Body) SetVersion ¶
func (x *SearchRequest_Body) SetVersion(v uint32)
func (*SearchRequest_Body) String ¶
func (x *SearchRequest_Body) String() string
type SearchRequest_Body_Filter ¶
type SearchRequest_Body_Filter struct { // Match type to use MatchType *MatchType `protobuf:"varint,1,opt,name=match_type,json=matchType,enum=neo.fs.v2.object.MatchType" json:"match_type,omitempty"` // Attribute or Header fields to match Key *string `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"` // Value to match Value *string `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` // contains filtered or unexported fields }
Filter structure checks if the object header field or the attribute content matches a value.
If no filters are set, search request will return all objects of the container, including Regular object and Tombstone objects. Most human users expect to get only object they can directly work with. In that case, `$Object:ROOT` filter should be used.
By default `key` field refers to the corresponding object's `Attribute`. Some Object's header fields can also be accessed by adding `$Object:` prefix to the name. Here is the list of fields available via this prefix:
- $Object:version \ version
- $Object:objectID \ object_id
- $Object:containerID \ container_id
- $Object:ownerID \ owner_id
- $Object:creationEpoch \ creation_epoch
- $Object:payloadLength \ payload_length
- $Object:payloadHash \ payload_hash
- $Object:objectType \ object_type
- $Object:homomorphicHash \ homomorphic_hash
- $Object:split.parent \ object_id of parent
- $Object:split.splitID \ 16 byte UUIDv4 used to identify the split object hierarchy parts
- $Object:ec.parent \ If the object is stored according to EC policy, then ec_parent attribute is set to return an id list of all related EC chunks.
There are some well-known filter aliases to match objects by certain properties:
- $Object:ROOT \ Returns only `REGULAR` type objects that are not split or that are the top level root objects in a split hierarchy. This includes objects not present physically, like large objects split into smaller objects without a separate top-level root object. Objects of other types like Locks and Tombstones will not be shown. This filter may be useful for listing objects like `ls` command of some virtual file system. This filter is activated if the `key` exists, disregarding the value and matcher type.
- $Object:PHY \ Returns only objects physically stored in the system. This filter is activated if the `key` exists, disregarding the value and matcher type.
Note: using filters with a key with prefix `$Object:` and match type `NOT_PRESENT `is not recommended since this is not a cross-version approach. Behavior when processing this kind of filters is undefined.
func (*SearchRequest_Body_Filter) ClearKey ¶
func (x *SearchRequest_Body_Filter) ClearKey()
func (*SearchRequest_Body_Filter) ClearMatchType ¶
func (x *SearchRequest_Body_Filter) ClearMatchType()
func (*SearchRequest_Body_Filter) ClearValue ¶
func (x *SearchRequest_Body_Filter) ClearValue()
func (*SearchRequest_Body_Filter) GetKey ¶
func (x *SearchRequest_Body_Filter) GetKey() string
func (*SearchRequest_Body_Filter) GetMatchType ¶
func (x *SearchRequest_Body_Filter) GetMatchType() MatchType
func (*SearchRequest_Body_Filter) GetValue ¶
func (x *SearchRequest_Body_Filter) GetValue() string
func (*SearchRequest_Body_Filter) HasKey ¶
func (x *SearchRequest_Body_Filter) HasKey() bool
func (*SearchRequest_Body_Filter) HasMatchType ¶
func (x *SearchRequest_Body_Filter) HasMatchType() bool
func (*SearchRequest_Body_Filter) HasValue ¶
func (x *SearchRequest_Body_Filter) HasValue() bool
func (*SearchRequest_Body_Filter) ProtoMessage ¶
func (*SearchRequest_Body_Filter) ProtoMessage()
func (*SearchRequest_Body_Filter) ProtoReflect ¶
func (x *SearchRequest_Body_Filter) ProtoReflect() protoreflect.Message
func (*SearchRequest_Body_Filter) Reset ¶
func (x *SearchRequest_Body_Filter) Reset()
func (*SearchRequest_Body_Filter) SetKey ¶
func (x *SearchRequest_Body_Filter) SetKey(v string)
func (*SearchRequest_Body_Filter) SetMatchType ¶
func (x *SearchRequest_Body_Filter) SetMatchType(v MatchType)
func (*SearchRequest_Body_Filter) SetValue ¶
func (x *SearchRequest_Body_Filter) SetValue(v string)
func (*SearchRequest_Body_Filter) String ¶
func (x *SearchRequest_Body_Filter) String() string
type SearchRequest_Body_Filter_builder ¶
type SearchRequest_Body_Filter_builder struct { // Match type to use MatchType *MatchType // Attribute or Header fields to match Key *string // Value to match Value *string // contains filtered or unexported fields }
func (SearchRequest_Body_Filter_builder) Build ¶
func (b0 SearchRequest_Body_Filter_builder) Build() *SearchRequest_Body_Filter
type SearchRequest_Body_builder ¶
type SearchRequest_Body_builder struct { // Container identifier were to search ContainerId *grpc1.ContainerID // Version of the Query Language used Version *uint32 // List of search expressions Filters []*SearchRequest_Body_Filter // contains filtered or unexported fields }
func (SearchRequest_Body_builder) Build ¶
func (b0 SearchRequest_Body_builder) Build() *SearchRequest_Body
type SearchRequest_builder ¶
type SearchRequest_builder struct { // Body of search object request message. Body *SearchRequest_Body // Carries request meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.RequestMetaHeader // Carries request verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.RequestVerificationHeader // contains filtered or unexported fields }
func (SearchRequest_builder) Build ¶
func (b0 SearchRequest_builder) Build() *SearchRequest
type SearchResponse ¶
type SearchResponse struct { // Body of search object response message. Body *SearchResponse_Body `protobuf:"bytes,1,opt,name=body" json:"body,omitempty"` // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader `protobuf:"bytes,2,opt,name=meta_header,json=metaHeader" json:"meta_header,omitempty"` // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader `protobuf:"bytes,3,opt,name=verify_header,json=verifyHeader" json:"verify_header,omitempty"` // contains filtered or unexported fields }
Search response
func (*SearchResponse) ClearBody ¶
func (x *SearchResponse) ClearBody()
func (*SearchResponse) ClearMetaHeader ¶
func (x *SearchResponse) ClearMetaHeader()
func (*SearchResponse) ClearVerifyHeader ¶
func (x *SearchResponse) ClearVerifyHeader()
func (*SearchResponse) GetBody ¶
func (x *SearchResponse) GetBody() *SearchResponse_Body
func (*SearchResponse) GetMetaHeader ¶
func (x *SearchResponse) GetMetaHeader() *grpc.ResponseMetaHeader
func (*SearchResponse) GetVerifyHeader ¶
func (x *SearchResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader
func (*SearchResponse) HasBody ¶
func (x *SearchResponse) HasBody() bool
func (*SearchResponse) HasMetaHeader ¶
func (x *SearchResponse) HasMetaHeader() bool
func (*SearchResponse) HasVerifyHeader ¶
func (x *SearchResponse) HasVerifyHeader() bool
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶
func (x *SearchResponse) Reset()
func (*SearchResponse) SetBody ¶
func (x *SearchResponse) SetBody(v *SearchResponse_Body)
func (*SearchResponse) SetMetaHeader ¶
func (x *SearchResponse) SetMetaHeader(v *grpc.ResponseMetaHeader)
func (*SearchResponse) SetVerifyHeader ¶
func (x *SearchResponse) SetVerifyHeader(v *grpc.ResponseVerificationHeader)
func (*SearchResponse) String ¶
func (x *SearchResponse) String() string
type SearchResponse_Body ¶
type SearchResponse_Body struct { // List of `ObjectID`s that match the search query IdList []*grpc1.ObjectID `protobuf:"bytes,1,rep,name=id_list,json=idList" json:"id_list,omitempty"` // contains filtered or unexported fields }
Object Search response body
func (*SearchResponse_Body) GetIdList ¶
func (x *SearchResponse_Body) GetIdList() []*grpc1.ObjectID
func (*SearchResponse_Body) ProtoMessage ¶
func (*SearchResponse_Body) ProtoMessage()
func (*SearchResponse_Body) ProtoReflect ¶
func (x *SearchResponse_Body) ProtoReflect() protoreflect.Message
func (*SearchResponse_Body) Reset ¶
func (x *SearchResponse_Body) Reset()
func (*SearchResponse_Body) SetIdList ¶
func (x *SearchResponse_Body) SetIdList(v []*grpc1.ObjectID)
func (*SearchResponse_Body) String ¶
func (x *SearchResponse_Body) String() string
type SearchResponse_Body_builder ¶
type SearchResponse_Body_builder struct { // List of `ObjectID`s that match the search query IdList []*grpc1.ObjectID // contains filtered or unexported fields }
func (SearchResponse_Body_builder) Build ¶
func (b0 SearchResponse_Body_builder) Build() *SearchResponse_Body
type SearchResponse_builder ¶
type SearchResponse_builder struct { // Body of search object response message. Body *SearchResponse_Body // Carries response meta information. Header data is used only to regulate // message transport and does not affect request execution. MetaHeader *grpc.ResponseMetaHeader // Carries response verification information. This header is used to // authenticate the nodes of the message route and check the correctness of // transmission. VerifyHeader *grpc.ResponseVerificationHeader // contains filtered or unexported fields }
func (SearchResponse_builder) Build ¶
func (b0 SearchResponse_builder) Build() *SearchResponse
type ShortHeader ¶
type ShortHeader struct { // Object format version. Effectively, the version of API library used to // create particular object. Version *grpc.Version `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"` // Epoch when the object was created CreationEpoch *uint64 `protobuf:"varint,2,opt,name=creation_epoch,json=creationEpoch" json:"creation_epoch,omitempty"` // Object's owner OwnerId *grpc.OwnerID `protobuf:"bytes,3,opt,name=owner_id,json=ownerID" json:"owner_id,omitempty"` // Type of the object payload content ObjectType *ObjectType `protobuf:"varint,4,opt,name=object_type,json=objectType,enum=neo.fs.v2.object.ObjectType" json:"object_type,omitempty"` // Size of payload in bytes. // `0xFFFFFFFFFFFFFFFF` means `payload_length` is unknown PayloadLength *uint64 `protobuf:"varint,5,opt,name=payload_length,json=payloadLength" json:"payload_length,omitempty"` // Hash of payload bytes PayloadHash *grpc.Checksum `protobuf:"bytes,6,opt,name=payload_hash,json=payloadHash" json:"payload_hash,omitempty"` // Homomorphic hash of the object payload HomomorphicHash *grpc.Checksum `protobuf:"bytes,7,opt,name=homomorphic_hash,json=homomorphicHash" json:"homomorphic_hash,omitempty"` // contains filtered or unexported fields }
Short header fields
func (*ShortHeader) ClearCreationEpoch ¶
func (x *ShortHeader) ClearCreationEpoch()
func (*ShortHeader) ClearHomomorphicHash ¶
func (x *ShortHeader) ClearHomomorphicHash()
func (*ShortHeader) ClearObjectType ¶
func (x *ShortHeader) ClearObjectType()
func (*ShortHeader) ClearOwnerId ¶
func (x *ShortHeader) ClearOwnerId()
func (*ShortHeader) ClearPayloadHash ¶
func (x *ShortHeader) ClearPayloadHash()
func (*ShortHeader) ClearPayloadLength ¶
func (x *ShortHeader) ClearPayloadLength()
func (*ShortHeader) ClearVersion ¶
func (x *ShortHeader) ClearVersion()
func (*ShortHeader) GetCreationEpoch ¶
func (x *ShortHeader) GetCreationEpoch() uint64
func (*ShortHeader) GetHomomorphicHash ¶
func (x *ShortHeader) GetHomomorphicHash() *grpc.Checksum
func (*ShortHeader) GetObjectType ¶
func (x *ShortHeader) GetObjectType() ObjectType
func (*ShortHeader) GetOwnerId ¶
func (x *ShortHeader) GetOwnerId() *grpc.OwnerID
func (*ShortHeader) GetPayloadHash ¶
func (x *ShortHeader) GetPayloadHash() *grpc.Checksum
func (*ShortHeader) GetPayloadLength ¶
func (x *ShortHeader) GetPayloadLength() uint64
func (*ShortHeader) GetVersion ¶
func (x *ShortHeader) GetVersion() *grpc.Version
func (*ShortHeader) HasCreationEpoch ¶
func (x *ShortHeader) HasCreationEpoch() bool
func (*ShortHeader) HasHomomorphicHash ¶
func (x *ShortHeader) HasHomomorphicHash() bool
func (*ShortHeader) HasObjectType ¶
func (x *ShortHeader) HasObjectType() bool
func (*ShortHeader) HasOwnerId ¶
func (x *ShortHeader) HasOwnerId() bool
func (*ShortHeader) HasPayloadHash ¶
func (x *ShortHeader) HasPayloadHash() bool
func (*ShortHeader) HasPayloadLength ¶
func (x *ShortHeader) HasPayloadLength() bool
func (*ShortHeader) HasVersion ¶
func (x *ShortHeader) HasVersion() bool
func (*ShortHeader) ProtoMessage ¶
func (*ShortHeader) ProtoMessage()
func (*ShortHeader) ProtoReflect ¶
func (x *ShortHeader) ProtoReflect() protoreflect.Message
func (*ShortHeader) Reset ¶
func (x *ShortHeader) Reset()
func (*ShortHeader) SetCreationEpoch ¶
func (x *ShortHeader) SetCreationEpoch(v uint64)
func (*ShortHeader) SetHomomorphicHash ¶
func (x *ShortHeader) SetHomomorphicHash(v *grpc.Checksum)
func (*ShortHeader) SetObjectType ¶
func (x *ShortHeader) SetObjectType(v ObjectType)
func (*ShortHeader) SetOwnerId ¶
func (x *ShortHeader) SetOwnerId(v *grpc.OwnerID)
func (*ShortHeader) SetPayloadHash ¶
func (x *ShortHeader) SetPayloadHash(v *grpc.Checksum)
func (*ShortHeader) SetPayloadLength ¶
func (x *ShortHeader) SetPayloadLength(v uint64)
func (*ShortHeader) SetVersion ¶
func (x *ShortHeader) SetVersion(v *grpc.Version)
func (*ShortHeader) String ¶
func (x *ShortHeader) String() string
type ShortHeader_builder ¶
type ShortHeader_builder struct { // Object format version. Effectively, the version of API library used to // create particular object. Version *grpc.Version // Epoch when the object was created CreationEpoch *uint64 // Object's owner OwnerId *grpc.OwnerID // Type of the object payload content ObjectType *ObjectType // Size of payload in bytes. // `0xFFFFFFFFFFFFFFFF` means `payload_length` is unknown PayloadLength *uint64 // Hash of payload bytes PayloadHash *grpc.Checksum // Homomorphic hash of the object payload HomomorphicHash *grpc.Checksum // contains filtered or unexported fields }
func (ShortHeader_builder) Build ¶
func (b0 ShortHeader_builder) Build() *ShortHeader
type SplitInfo ¶
type SplitInfo struct { // 16 byte UUID used to identify the split object hierarchy parts. SplitId []byte `protobuf:"bytes,1,opt,name=split_id,json=splitId" json:"split_id,omitempty"` // The identifier of the last object in split hierarchy parts. It contains // split header with the original object header. LastPart *grpc.ObjectID `protobuf:"bytes,2,opt,name=last_part,json=lastPart" json:"last_part,omitempty"` // The identifier of a linking object for split hierarchy parts. It contains // split header with the original object header and a sorted list of // object parts. Link *grpc.ObjectID `protobuf:"bytes,3,opt,name=link" json:"link,omitempty"` // contains filtered or unexported fields }
Meta information of split hierarchy for object assembly. With the last part one can traverse linked list of split hierarchy back to the first part and assemble the original object. With a linking object one can assemble an object right from the object parts.
func (*SplitInfo) ClearLastPart ¶
func (x *SplitInfo) ClearLastPart()
func (*SplitInfo) ClearSplitId ¶
func (x *SplitInfo) ClearSplitId()
func (*SplitInfo) GetLastPart ¶
func (*SplitInfo) GetSplitId ¶
func (*SplitInfo) HasLastPart ¶
func (*SplitInfo) HasSplitId ¶
func (*SplitInfo) ProtoMessage ¶
func (*SplitInfo) ProtoMessage()
func (*SplitInfo) ProtoReflect ¶
func (x *SplitInfo) ProtoReflect() protoreflect.Message
func (*SplitInfo) SetLastPart ¶
func (*SplitInfo) SetSplitId ¶
type SplitInfo_builder ¶
type SplitInfo_builder struct { // 16 byte UUID used to identify the split object hierarchy parts. SplitId []byte // The identifier of the last object in split hierarchy parts. It contains // split header with the original object header. LastPart *grpc.ObjectID // The identifier of a linking object for split hierarchy parts. It contains // split header with the original object header and a sorted list of // object parts. Link *grpc.ObjectID // contains filtered or unexported fields }
func (SplitInfo_builder) Build ¶
func (b0 SplitInfo_builder) Build() *SplitInfo
type UnimplementedObjectServiceServer ¶
type UnimplementedObjectServiceServer struct{}
UnimplementedObjectServiceServer should be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedObjectServiceServer) Delete ¶
func (UnimplementedObjectServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedObjectServiceServer) GetRange ¶
func (UnimplementedObjectServiceServer) GetRange(*GetRangeRequest, grpc.ServerStreamingServer[GetRangeResponse]) error
func (UnimplementedObjectServiceServer) GetRangeHash ¶
func (UnimplementedObjectServiceServer) GetRangeHash(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error)
func (UnimplementedObjectServiceServer) Head ¶
func (UnimplementedObjectServiceServer) Head(context.Context, *HeadRequest) (*HeadResponse, error)
func (UnimplementedObjectServiceServer) PutSingle ¶
func (UnimplementedObjectServiceServer) PutSingle(context.Context, *PutSingleRequest) (*PutSingleResponse, error)
func (UnimplementedObjectServiceServer) Search ¶
func (UnimplementedObjectServiceServer) Search(*SearchRequest, grpc.ServerStreamingServer[SearchResponse]) error
type UnsafeObjectServiceServer ¶
type UnsafeObjectServiceServer interface {
// contains filtered or unexported methods
}
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.