Documentation ¶
Index ¶
- Constants
- Variables
- func AttributesToGRPC(xs []Attribute) (res []*object.Header_Attribute)
- func GlobalizeFail(c *status.Code)
- func LocalizeFailStatus(c *status.Code) bool
- func MatchTypeToGRPCField(t MatchType) object.MatchType
- func RangesToGRPC(rs []Range) (res []*object.Range)
- func ReadAccessDeniedDesc(st status.Status) (desc string)
- func ReadLink(link *Link, obj Object) error
- func ReadLock(lock *Lock, obj Object) error
- func SearchFiltersToGRPC(fs []SearchFilter) (res []*object.SearchRequest_Body_Filter)
- func TypeToGRPCField(t Type) object.ObjectType
- func WriteAccessDeniedDesc(st *status.Status, desc string)
- func WriteLink(obj *Object, link Link)
- func WriteLock(obj *Object, lock Lock)
- func WriteNotificationInfo(o *Object, ni NotificationInfo)
- type Attribute
- func (a *Attribute) FromGRPCMessage(m grpc.Message) error
- func (a *Attribute) GetKey() string
- func (a *Attribute) GetValue() string
- func (a *Attribute) MarshalJSON() ([]byte, error)
- func (a *Attribute) SetKey(v string)
- func (a *Attribute) SetValue(v string)
- func (a *Attribute) StableMarshal(buf []byte) []byte
- func (a *Attribute) StableSize() (size int)
- func (a *Attribute) ToGRPCMessage() grpc.Message
- func (a *Attribute) Unmarshal(data []byte) error
- func (a *Attribute) UnmarshalJSON(data []byte) error
- type DeleteRequest
- type DeleteRequestBody
- func (r *DeleteRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *DeleteRequestBody) GetAddress() *refs.Address
- func (r *DeleteRequestBody) SetAddress(v *refs.Address)
- func (r *DeleteRequestBody) StableMarshal(buf []byte) []byte
- func (r *DeleteRequestBody) StableSize() (size int)
- func (r *DeleteRequestBody) ToGRPCMessage() grpc.Message
- func (r *DeleteRequestBody) Unmarshal(data []byte) error
- type DeleteResponse
- type DeleteResponseBody
- func (r *DeleteResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *DeleteResponseBody) GetTombstone() *refs.Address
- func (r *DeleteResponseBody) SetTombstone(v *refs.Address)
- func (r *DeleteResponseBody) StableMarshal(buf []byte) []byte
- func (r *DeleteResponseBody) StableSize() (size int)
- func (r *DeleteResponseBody) ToGRPCMessage() grpc.Message
- func (r *DeleteResponseBody) Unmarshal(data []byte) error
- type GetHeaderPart
- type GetObjectPart
- type GetObjectPartChunk
- type GetObjectPartInit
- func (r *GetObjectPartInit) FromGRPCMessage(m grpc.Message) error
- func (r *GetObjectPartInit) GetHeader() *Header
- func (r *GetObjectPartInit) GetObjectID() *refs.ObjectID
- func (r *GetObjectPartInit) GetSignature() *refs.Signature
- func (r *GetObjectPartInit) SetHeader(v *Header)
- func (r *GetObjectPartInit) SetObjectID(v *refs.ObjectID)
- func (r *GetObjectPartInit) SetSignature(v *refs.Signature)
- func (r *GetObjectPartInit) StableMarshal(buf []byte) []byte
- func (r *GetObjectPartInit) StableSize() (size int)
- func (r *GetObjectPartInit) ToGRPCMessage() grpc.Message
- func (r *GetObjectPartInit) Unmarshal(data []byte) error
- type GetRangeHashRequest
- type GetRangeHashRequestBody
- func (r *GetRangeHashRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetRangeHashRequestBody) GetAddress() *refs.Address
- func (r *GetRangeHashRequestBody) GetRanges() []Range
- func (r *GetRangeHashRequestBody) GetSalt() []byte
- func (r *GetRangeHashRequestBody) GetType() refs.ChecksumType
- func (r *GetRangeHashRequestBody) SetAddress(v *refs.Address)
- func (r *GetRangeHashRequestBody) SetRanges(v []Range)
- func (r *GetRangeHashRequestBody) SetSalt(v []byte)
- func (r *GetRangeHashRequestBody) SetType(v refs.ChecksumType)
- func (r *GetRangeHashRequestBody) StableMarshal(buf []byte) []byte
- func (r *GetRangeHashRequestBody) StableSize() (size int)
- func (r *GetRangeHashRequestBody) ToGRPCMessage() grpc.Message
- func (r *GetRangeHashRequestBody) Unmarshal(data []byte) error
- type GetRangeHashResponse
- type GetRangeHashResponseBody
- func (r *GetRangeHashResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetRangeHashResponseBody) GetHashList() [][]byte
- func (r *GetRangeHashResponseBody) GetType() refs.ChecksumType
- func (r *GetRangeHashResponseBody) SetHashList(v [][]byte)
- func (r *GetRangeHashResponseBody) SetType(v refs.ChecksumType)
- func (r *GetRangeHashResponseBody) StableMarshal(buf []byte) []byte
- func (r *GetRangeHashResponseBody) StableSize() (size int)
- func (r *GetRangeHashResponseBody) ToGRPCMessage() grpc.Message
- func (r *GetRangeHashResponseBody) Unmarshal(data []byte) error
- type GetRangePart
- type GetRangePartChunk
- type GetRangeRequest
- type GetRangeRequestBody
- func (r *GetRangeRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetRangeRequestBody) GetAddress() *refs.Address
- func (r *GetRangeRequestBody) GetRange() *Range
- func (r *GetRangeRequestBody) GetRaw() bool
- func (r *GetRangeRequestBody) SetAddress(v *refs.Address)
- func (r *GetRangeRequestBody) SetRange(v *Range)
- func (r *GetRangeRequestBody) SetRaw(v bool)
- func (r *GetRangeRequestBody) StableMarshal(buf []byte) []byte
- func (r *GetRangeRequestBody) StableSize() (size int)
- func (r *GetRangeRequestBody) ToGRPCMessage() grpc.Message
- func (r *GetRangeRequestBody) Unmarshal(data []byte) error
- type GetRangeResponse
- type GetRangeResponseBody
- func (r *GetRangeResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetRangeResponseBody) GetRangePart() GetRangePart
- func (r *GetRangeResponseBody) SetRangePart(v GetRangePart)
- func (r *GetRangeResponseBody) StableMarshal(buf []byte) []byte
- func (r *GetRangeResponseBody) StableSize() (size int)
- func (r *GetRangeResponseBody) ToGRPCMessage() grpc.Message
- func (r *GetRangeResponseBody) Unmarshal(data []byte) error
- type GetRequest
- type GetRequestBody
- func (r *GetRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetRequestBody) GetAddress() *refs.Address
- func (r *GetRequestBody) GetRaw() bool
- func (r *GetRequestBody) SetAddress(v *refs.Address)
- func (r *GetRequestBody) SetRaw(v bool)
- func (r *GetRequestBody) StableMarshal(buf []byte) []byte
- func (r *GetRequestBody) StableSize() (size int)
- func (r *GetRequestBody) ToGRPCMessage() grpc.Message
- func (r *GetRequestBody) Unmarshal(data []byte) error
- type GetResponse
- type GetResponseBody
- func (r *GetResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *GetResponseBody) GetObjectPart() GetObjectPart
- func (r *GetResponseBody) SetObjectPart(v GetObjectPart)
- func (r *GetResponseBody) StableMarshal(buf []byte) []byte
- func (r *GetResponseBody) StableSize() (size int)
- func (r *GetResponseBody) ToGRPCMessage() grpc.Message
- func (r *GetResponseBody) Unmarshal(data []byte) error
- type HeadRequest
- type HeadRequestBody
- func (r *HeadRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *HeadRequestBody) GetAddress() *refs.Address
- func (r *HeadRequestBody) GetMainOnly() bool
- func (r *HeadRequestBody) GetRaw() bool
- func (r *HeadRequestBody) SetAddress(v *refs.Address)
- func (r *HeadRequestBody) SetMainOnly(v bool)
- func (r *HeadRequestBody) SetRaw(v bool)
- func (r *HeadRequestBody) StableMarshal(buf []byte) []byte
- func (r *HeadRequestBody) StableSize() (size int)
- func (r *HeadRequestBody) ToGRPCMessage() grpc.Message
- func (r *HeadRequestBody) Unmarshal(data []byte) error
- type HeadResponse
- type HeadResponseBody
- func (r *HeadResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *HeadResponseBody) GetHeaderPart() GetHeaderPart
- func (r *HeadResponseBody) SetHeaderPart(v GetHeaderPart)
- func (r *HeadResponseBody) StableMarshal(buf []byte) []byte
- func (r *HeadResponseBody) StableSize() (size int)
- func (r *HeadResponseBody) ToGRPCMessage() grpc.Message
- func (r *HeadResponseBody) Unmarshal(data []byte) error
- type Header
- func (h *Header) FromGRPCMessage(m grpc.Message) error
- func (h *Header) GetAttributes() []Attribute
- func (h *Header) GetContainerID() *refs.ContainerID
- func (h *Header) GetCreationEpoch() uint64
- func (h *Header) GetHomomorphicHash() *refs.Checksum
- func (h *Header) GetObjectType() Type
- func (h *Header) GetOwnerID() *refs.OwnerID
- func (h *Header) GetPayloadHash() *refs.Checksum
- func (h *Header) GetPayloadLength() uint64
- func (h *Header) GetSessionToken() *session.Token
- func (h *Header) GetSplit() *SplitHeader
- func (h *Header) GetVersion() *refs.Version
- func (h *Header) MarshalJSON() ([]byte, error)
- func (h *Header) SetAttributes(v []Attribute)
- func (h *Header) SetContainerID(v *refs.ContainerID)
- func (h *Header) SetCreationEpoch(v uint64)
- func (h *Header) SetHomomorphicHash(v *refs.Checksum)
- func (h *Header) SetObjectType(v Type)
- func (h *Header) SetOwnerID(v *refs.OwnerID)
- func (h *Header) SetPayloadHash(v *refs.Checksum)
- func (h *Header) SetPayloadLength(v uint64)
- func (h *Header) SetSessionToken(v *session.Token)
- func (h *Header) SetSplit(v *SplitHeader)
- func (h *Header) SetVersion(v *refs.Version)
- func (h *Header) StableMarshal(buf []byte) []byte
- func (h *Header) StableSize() (size int)
- func (h *Header) ToGRPCMessage() grpc.Message
- func (h *Header) Unmarshal(data []byte) error
- func (h *Header) UnmarshalJSON(data []byte) error
- type HeaderWithSignature
- func (h *HeaderWithSignature) FromGRPCMessage(m grpc.Message) error
- func (h *HeaderWithSignature) GetHeader() *Header
- func (h *HeaderWithSignature) GetSignature() *refs.Signature
- func (h *HeaderWithSignature) MarshalJSON() ([]byte, error)
- func (h *HeaderWithSignature) SetHeader(v *Header)
- func (h *HeaderWithSignature) SetSignature(v *refs.Signature)
- func (h *HeaderWithSignature) StableMarshal(buf []byte) []byte
- func (h *HeaderWithSignature) StableSize() (size int)
- func (h *HeaderWithSignature) ToGRPCMessage() grpc.Message
- func (h *HeaderWithSignature) Unmarshal(data []byte) error
- func (h *HeaderWithSignature) UnmarshalJSON(data []byte) error
- type Link
- func (x *Link) FromGRPCMessage(m grpc.Message) error
- func (x *Link) IterateChildren(f func(MeasuredObject))
- func (x *Link) NumberOfChildren() int
- func (x *Link) SetChildren(chs []MeasuredObject)
- func (x *Link) StableMarshal(buf []byte) []byte
- func (x *Link) StableSize() int
- func (x *Link) ToGRPCMessage() grpc.Message
- func (x *Link) Unmarshal(data []byte) error
- type Lock
- func (x *Lock) FromGRPCMessage(m grpc.Message) error
- func (x *Lock) IterateMembers(f func(refs.ObjectID))
- func (x *Lock) NumberOfMembers() int
- func (x *Lock) SetMembers(ids []refs.ObjectID)
- func (x *Lock) StableMarshal(buf []byte) []byte
- func (x *Lock) StableSize() (sz int)
- func (x *Lock) ToGRPCMessage() grpc.Message
- func (x *Lock) Unmarshal(data []byte) error
- type MatchType
- type MeasuredObject
- type NotificationInfo
- type Object
- func (o *Object) FromGRPCMessage(m grpc.Message) error
- func (o *Object) GetHeader() *Header
- func (o *Object) GetObjectID() *refs.ObjectID
- func (o *Object) GetPayload() []byte
- func (o *Object) GetSignature() *refs.Signature
- func (o *Object) MarshalJSON() ([]byte, error)
- func (o *Object) SetHeader(v *Header)
- func (o *Object) SetObjectID(v *refs.ObjectID)
- func (o *Object) SetPayload(v []byte)
- func (o *Object) SetSignature(v *refs.Signature)
- func (o *Object) StableMarshal(buf []byte) []byte
- func (o *Object) StableSize() (size int)
- func (o *Object) ToGRPCMessage() grpc.Message
- func (o *Object) Unmarshal(data []byte) error
- func (o *Object) UnmarshalJSON(data []byte) error
- type PutObjectPart
- type PutObjectPartChunk
- type PutObjectPartInit
- func (r *PutObjectPartInit) FromGRPCMessage(m grpc.Message) error
- func (r *PutObjectPartInit) GetCopiesNumber() uint32
- func (r *PutObjectPartInit) GetHeader() *Header
- func (r *PutObjectPartInit) GetObjectID() *refs.ObjectID
- func (r *PutObjectPartInit) GetSignature() *refs.Signature
- func (r *PutObjectPartInit) SetCopiesNumber(v uint32)
- func (r *PutObjectPartInit) SetHeader(v *Header)
- func (r *PutObjectPartInit) SetObjectID(v *refs.ObjectID)
- func (r *PutObjectPartInit) SetSignature(v *refs.Signature)
- func (r *PutObjectPartInit) StableMarshal(buf []byte) []byte
- func (r *PutObjectPartInit) StableSize() (size int)
- func (r *PutObjectPartInit) ToGRPCMessage() grpc.Message
- func (r *PutObjectPartInit) Unmarshal(data []byte) error
- type PutRequest
- type PutRequestBody
- func (r *PutRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *PutRequestBody) GetObjectPart() PutObjectPart
- func (r *PutRequestBody) SetObjectPart(v PutObjectPart)
- func (r *PutRequestBody) StableMarshal(buf []byte) []byte
- func (r *PutRequestBody) StableSize() (size int)
- func (r *PutRequestBody) ToGRPCMessage() grpc.Message
- func (r *PutRequestBody) Unmarshal(data []byte) error
- type PutResponse
- type PutResponseBody
- func (r *PutResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *PutResponseBody) GetObjectID() *refs.ObjectID
- func (r *PutResponseBody) SetObjectID(v *refs.ObjectID)
- func (r *PutResponseBody) StableMarshal(buf []byte) []byte
- func (r *PutResponseBody) StableSize() (size int)
- func (r *PutResponseBody) ToGRPCMessage() grpc.Message
- func (r *PutResponseBody) Unmarshal(data []byte) error
- type Range
- func (r *Range) FromGRPCMessage(m grpc.Message) error
- func (r *Range) GetLength() uint64
- func (r *Range) GetOffset() uint64
- func (r *Range) MarshalJSON() ([]byte, error)
- func (r *Range) SetLength(v uint64)
- func (r *Range) SetOffset(v uint64)
- func (r *Range) StableMarshal(buf []byte) []byte
- func (r *Range) StableSize() (size int)
- func (r *Range) ToGRPCMessage() grpc.Message
- func (r *Range) Unmarshal(data []byte) error
- func (r *Range) UnmarshalJSON(data []byte) error
- type SearchFilter
- func (f *SearchFilter) FromGRPCMessage(m grpc.Message) error
- func (f *SearchFilter) GetKey() string
- func (f *SearchFilter) GetMatchType() MatchType
- func (f *SearchFilter) GetValue() string
- func (f *SearchFilter) MarshalJSON() ([]byte, error)
- func (f *SearchFilter) SetKey(v string)
- func (f *SearchFilter) SetMatchType(v MatchType)
- func (f *SearchFilter) SetValue(v string)
- func (f *SearchFilter) StableMarshal(buf []byte) []byte
- func (f *SearchFilter) StableSize() (size int)
- func (f *SearchFilter) ToGRPCMessage() grpc.Message
- func (f *SearchFilter) Unmarshal(data []byte) error
- func (f *SearchFilter) UnmarshalJSON(data []byte) error
- type SearchRequest
- type SearchRequestBody
- func (r *SearchRequestBody) FromGRPCMessage(m grpc.Message) error
- func (r *SearchRequestBody) GetContainerID() *refs.ContainerID
- func (r *SearchRequestBody) GetFilters() []SearchFilter
- func (r *SearchRequestBody) GetVersion() uint32
- func (r *SearchRequestBody) SetContainerID(v *refs.ContainerID)
- func (r *SearchRequestBody) SetFilters(v []SearchFilter)
- func (r *SearchRequestBody) SetVersion(v uint32)
- func (r *SearchRequestBody) StableMarshal(buf []byte) []byte
- func (r *SearchRequestBody) StableSize() (size int)
- func (r *SearchRequestBody) ToGRPCMessage() grpc.Message
- func (r *SearchRequestBody) Unmarshal(data []byte) error
- type SearchResponse
- type SearchResponseBody
- func (r *SearchResponseBody) FromGRPCMessage(m grpc.Message) error
- func (r *SearchResponseBody) GetIDList() []refs.ObjectID
- func (r *SearchResponseBody) SetIDList(v []refs.ObjectID)
- func (r *SearchResponseBody) StableMarshal(buf []byte) []byte
- func (r *SearchResponseBody) StableSize() (size int)
- func (r *SearchResponseBody) ToGRPCMessage() grpc.Message
- func (r *SearchResponseBody) Unmarshal(data []byte) error
- type ShortHeader
- func (h *ShortHeader) FromGRPCMessage(m grpc.Message) error
- func (h *ShortHeader) GetCreationEpoch() uint64
- func (h *ShortHeader) GetHomomorphicHash() *refs.Checksum
- func (h *ShortHeader) GetObjectType() Type
- func (h *ShortHeader) GetOwnerID() *refs.OwnerID
- func (h *ShortHeader) GetPayloadHash() *refs.Checksum
- func (h *ShortHeader) GetPayloadLength() uint64
- func (h *ShortHeader) GetVersion() *refs.Version
- func (h *ShortHeader) MarshalJSON() ([]byte, error)
- func (h *ShortHeader) SetCreationEpoch(v uint64)
- func (h *ShortHeader) SetHomomorphicHash(v *refs.Checksum)
- func (h *ShortHeader) SetObjectType(v Type)
- func (h *ShortHeader) SetOwnerID(v *refs.OwnerID)
- func (h *ShortHeader) SetPayloadHash(v *refs.Checksum)
- func (h *ShortHeader) SetPayloadLength(v uint64)
- func (h *ShortHeader) SetVersion(v *refs.Version)
- func (h *ShortHeader) StableMarshal(buf []byte) []byte
- func (h *ShortHeader) StableSize() (size int)
- func (h *ShortHeader) ToGRPCMessage() grpc.Message
- func (h *ShortHeader) Unmarshal(data []byte) error
- func (h *ShortHeader) UnmarshalJSON(data []byte) error
- type SplitHeader
- func (h *SplitHeader) FromGRPCMessage(m grpc.Message) error
- func (h *SplitHeader) GetChildren() []refs.ObjectID
- func (h *SplitHeader) GetFirst() *refs.ObjectID
- func (h *SplitHeader) GetParent() *refs.ObjectID
- func (h *SplitHeader) GetParentHeader() *Header
- func (h *SplitHeader) GetParentSignature() *refs.Signature
- func (h *SplitHeader) GetPrevious() *refs.ObjectID
- func (h *SplitHeader) GetSplitID() []byte
- func (h *SplitHeader) MarshalJSON() ([]byte, error)
- func (h *SplitHeader) SetChildren(v []refs.ObjectID)
- func (h *SplitHeader) SetFirst(v *refs.ObjectID)
- func (h *SplitHeader) SetParent(v *refs.ObjectID)
- func (h *SplitHeader) SetParentHeader(v *Header)
- func (h *SplitHeader) SetParentSignature(v *refs.Signature)
- func (h *SplitHeader) SetPrevious(v *refs.ObjectID)
- func (h *SplitHeader) SetSplitID(v []byte)
- func (h *SplitHeader) StableMarshal(buf []byte) []byte
- func (h *SplitHeader) StableSize() (size int)
- func (h *SplitHeader) ToGRPCMessage() grpc.Message
- func (h *SplitHeader) Unmarshal(data []byte) error
- func (h *SplitHeader) UnmarshalJSON(data []byte) error
- type SplitInfo
- func (s *SplitInfo) FromGRPCMessage(m grpc.Message) error
- func (s *SplitInfo) GetFirstPart() *refs.ObjectID
- func (s *SplitInfo) GetLastPart() *refs.ObjectID
- func (s *SplitInfo) GetLink() *refs.ObjectID
- func (s *SplitInfo) GetSplitID() []byte
- func (s *SplitInfo) MarshalJSON() ([]byte, error)
- func (s *SplitInfo) SetFirstPart(v *refs.ObjectID)
- func (s *SplitInfo) SetLastPart(v *refs.ObjectID)
- func (s *SplitInfo) SetLink(v *refs.ObjectID)
- func (s *SplitInfo) SetSplitID(v []byte)
- func (s *SplitInfo) StableMarshal(buf []byte) []byte
- func (s *SplitInfo) StableSize() (size int)
- func (s *SplitInfo) ToGRPCMessage() grpc.Message
- func (s *SplitInfo) Unmarshal(data []byte) error
- func (s *SplitInfo) UnmarshalJSON(data []byte) error
- type Type
Constants ¶
const ( // SysAttributeUploadID marks smaller parts of a split bigger object. SysAttributeUploadID = SysAttributePrefix + "UPLOAD_ID" // SysAttributeExpEpoch tells GC to delete object after that epoch. SysAttributeExpEpoch = SysAttributePrefix + "EXPIRATION_EPOCH" // SysAttributeTickEpoch defines what epoch must produce object // notification. SysAttributeTickEpoch = SysAttributePrefix + "TICK_EPOCH" // SysAttributeTickTopic defines what topic object notification // must be sent to. SysAttributeTickTopic = SysAttributePrefix + "TICK_TOPIC" )
const ( // FilterHeaderVersion is a filter key to "version" field of the object header. FilterHeaderVersion = ReservedFilterPrefix + "version" // FilterHeaderObjectID is a filter key to "object_id" field of the object. FilterHeaderObjectID = ReservedFilterPrefix + "objectID" // FilterHeaderContainerID is a filter key to "container_id" field of the object header. FilterHeaderContainerID = ReservedFilterPrefix + "containerID" // FilterHeaderOwnerID is a filter key to "owner_id" field of the object header. FilterHeaderOwnerID = ReservedFilterPrefix + "ownerID" // FilterHeaderCreationEpoch is a filter key to "creation_epoch" field of the object header. FilterHeaderCreationEpoch = ReservedFilterPrefix + "creationEpoch" // FilterHeaderPayloadLength is a filter key to "payload_length" field of the object header. FilterHeaderPayloadLength = ReservedFilterPrefix + "payloadLength" // FilterHeaderPayloadHash is a filter key to "payload_hash" field of the object header. FilterHeaderPayloadHash = ReservedFilterPrefix + "payloadHash" // FilterHeaderObjectType is a filter key to "object_type" field of the object header. FilterHeaderObjectType = ReservedFilterPrefix + "objectType" // FilterHeaderHomomorphicHash is a filter key to "homomorphic_hash" field of the object header. FilterHeaderHomomorphicHash = ReservedFilterPrefix + "homomorphicHash" // FilterHeaderParent is a filter key to "split.parent" field of the object header. FilterHeaderParent = ReservedFilterPrefix + "split.parent" // FilterHeaderSplitID is a filter key to "split.splitID" field of the object header. FilterHeaderSplitID = ReservedFilterPrefix + "split.splitID" )
const ( // FilterPropertyRoot is a filter key to check if regular object is on top of split hierarchy. FilterPropertyRoot = ReservedFilterPrefix + "ROOT" // FilterPropertyPhy is a filter key to check if an object physically stored on a node. FilterPropertyPhy = ReservedFilterPrefix + "PHY" )
const ( // BooleanPropertyValueTrue is a true value for boolean property filters. BooleanPropertyValueTrue = "true" // BooleanPropertyValueFalse is a false value for boolean property filters. BooleanPropertyValueFalse = "" )
const ( // StatusAccessDenied is a local status.Code value for // ACCESS_DENIED object failure. StatusAccessDenied status.Code = iota // StatusNotFound is a local status.Code value for // OBJECT_NOT_FOUND object failure. StatusNotFound // StatusLocked is a local status.Code value for // LOCKED object failure. StatusLocked // StatusLockNonRegularObject is a local status.Code value for // LOCK_NON_REGULAR_OBJECT object failure. StatusLockNonRegularObject // StatusAlreadyRemoved is a local status.Code value for // OBJECT_ALREADY_REMOVED object failure. StatusAlreadyRemoved // StatusOutOfRange is a local status.Code value for // OUT_OF_RANGE object failure. StatusOutOfRange )
const ReservedFilterPrefix = "$Object:"
ReservedFilterPrefix is a prefix of key to object header value or property.
const SysAttributePrefix = "__NEOFS__"
SysAttributePrefix is a prefix of key to system attribute.
Variables ¶
var ErrNotificationNotSet = errors.New("notification for object is not set")
ErrNotificationNotSet means that object does not have notification.
Functions ¶
func AttributesToGRPC ¶
func AttributesToGRPC(xs []Attribute) (res []*object.Header_Attribute)
func LocalizeFailStatus ¶
LocalizeFailStatus checks if passed global status.Code is related to object failure and:
then localizes the code and returns true, else leaves the code unchanged and returns false.
Arg must not be nil.
func MatchTypeToGRPCField ¶
func RangesToGRPC ¶
func ReadAccessDeniedDesc ¶
ReadAccessDeniedDesc looks up for status detail with human-readable description of StatusAccessDenied. Returns empty string if detail is missing.
func SearchFiltersToGRPC ¶
func SearchFiltersToGRPC(fs []SearchFilter) (res []*object.SearchRequest_Body_Filter)
func TypeToGRPCField ¶
func TypeToGRPCField(t Type) object.ObjectType
func WriteAccessDeniedDesc ¶
WriteAccessDeniedDesc writes human-readable description of StatusAccessDenied into status.Status as a detail. The status must not be nil.
Existing details are expected to be ID-unique, otherwise undefined behavior.
func WriteLink ¶
WriteLink writes Link to the Object as a payload content. The object must not be nil.
func WriteLock ¶
WriteLock writes Lock to the Object as a payload content. The object must not be nil.
func WriteNotificationInfo ¶
func WriteNotificationInfo(o *Object, ni NotificationInfo)
WriteNotificationInfo writes NotificationInfo to the Object via attributes. Object must not be nil.
Existing notification attributes are expected to be key-unique, otherwise undefined behavior.
Types ¶
type Attribute ¶
type Attribute struct {
// contains filtered or unexported fields
}
func AttributesFromGRPC ¶
func AttributesFromGRPC(xs []*object.Header_Attribute) (res []Attribute, err error)
func (*Attribute) MarshalJSON ¶
func (*Attribute) StableMarshal ¶
func (*Attribute) StableSize ¶
func (*Attribute) ToGRPCMessage ¶
func (*Attribute) UnmarshalJSON ¶
type DeleteRequest ¶
type DeleteRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*DeleteRequest) FromGRPCMessage ¶
func (r *DeleteRequest) FromGRPCMessage(m grpc.Message) error
func (*DeleteRequest) GetBody ¶
func (r *DeleteRequest) GetBody() *DeleteRequestBody
func (*DeleteRequest) SetBody ¶
func (r *DeleteRequest) SetBody(v *DeleteRequestBody)
func (*DeleteRequest) ToGRPCMessage ¶
func (r *DeleteRequest) ToGRPCMessage() grpc.Message
type DeleteRequestBody ¶
type DeleteRequestBody struct {
// contains filtered or unexported fields
}
func (*DeleteRequestBody) FromGRPCMessage ¶
func (r *DeleteRequestBody) FromGRPCMessage(m grpc.Message) error
func (*DeleteRequestBody) GetAddress ¶
func (r *DeleteRequestBody) GetAddress() *refs.Address
func (*DeleteRequestBody) SetAddress ¶
func (r *DeleteRequestBody) SetAddress(v *refs.Address)
func (*DeleteRequestBody) StableMarshal ¶
func (r *DeleteRequestBody) StableMarshal(buf []byte) []byte
func (*DeleteRequestBody) StableSize ¶
func (r *DeleteRequestBody) StableSize() (size int)
func (*DeleteRequestBody) ToGRPCMessage ¶
func (r *DeleteRequestBody) ToGRPCMessage() grpc.Message
func (*DeleteRequestBody) Unmarshal ¶
func (r *DeleteRequestBody) Unmarshal(data []byte) error
type DeleteResponse ¶
type DeleteResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*DeleteResponse) FromGRPCMessage ¶
func (r *DeleteResponse) FromGRPCMessage(m grpc.Message) error
func (*DeleteResponse) GetBody ¶
func (r *DeleteResponse) GetBody() *DeleteResponseBody
func (*DeleteResponse) SetBody ¶
func (r *DeleteResponse) SetBody(v *DeleteResponseBody)
func (*DeleteResponse) ToGRPCMessage ¶
func (r *DeleteResponse) ToGRPCMessage() grpc.Message
type DeleteResponseBody ¶
type DeleteResponseBody struct {
// contains filtered or unexported fields
}
func (*DeleteResponseBody) FromGRPCMessage ¶
func (r *DeleteResponseBody) FromGRPCMessage(m grpc.Message) error
func (*DeleteResponseBody) GetTombstone ¶
func (r *DeleteResponseBody) GetTombstone() *refs.Address
GetTombstone returns tombstone address.
func (*DeleteResponseBody) SetTombstone ¶
func (r *DeleteResponseBody) SetTombstone(v *refs.Address)
SetTombstone sets tombstone address.
func (*DeleteResponseBody) StableMarshal ¶
func (r *DeleteResponseBody) StableMarshal(buf []byte) []byte
func (*DeleteResponseBody) StableSize ¶
func (r *DeleteResponseBody) StableSize() (size int)
func (*DeleteResponseBody) ToGRPCMessage ¶
func (r *DeleteResponseBody) ToGRPCMessage() grpc.Message
func (*DeleteResponseBody) Unmarshal ¶
func (r *DeleteResponseBody) Unmarshal(data []byte) error
type GetHeaderPart ¶
type GetHeaderPart interface {
// contains filtered or unexported methods
}
type GetObjectPart ¶
type GetObjectPart interface {
// contains filtered or unexported methods
}
type GetObjectPartChunk ¶
type GetObjectPartChunk struct {
// contains filtered or unexported fields
}
func (*GetObjectPartChunk) FromGRPCMessage ¶
func (r *GetObjectPartChunk) FromGRPCMessage(m grpc.Message) error
func (*GetObjectPartChunk) GetChunk ¶
func (r *GetObjectPartChunk) GetChunk() []byte
func (*GetObjectPartChunk) SetChunk ¶
func (r *GetObjectPartChunk) SetChunk(v []byte)
func (*GetObjectPartChunk) ToGRPCMessage ¶
func (r *GetObjectPartChunk) ToGRPCMessage() grpc.Message
type GetObjectPartInit ¶
type GetObjectPartInit struct {
// contains filtered or unexported fields
}
func (*GetObjectPartInit) FromGRPCMessage ¶
func (r *GetObjectPartInit) FromGRPCMessage(m grpc.Message) error
func (*GetObjectPartInit) GetHeader ¶
func (r *GetObjectPartInit) GetHeader() *Header
func (*GetObjectPartInit) GetObjectID ¶
func (r *GetObjectPartInit) GetObjectID() *refs.ObjectID
func (*GetObjectPartInit) GetSignature ¶
func (r *GetObjectPartInit) GetSignature() *refs.Signature
func (*GetObjectPartInit) SetHeader ¶
func (r *GetObjectPartInit) SetHeader(v *Header)
func (*GetObjectPartInit) SetObjectID ¶
func (r *GetObjectPartInit) SetObjectID(v *refs.ObjectID)
func (*GetObjectPartInit) SetSignature ¶
func (r *GetObjectPartInit) SetSignature(v *refs.Signature)
func (*GetObjectPartInit) StableMarshal ¶
func (r *GetObjectPartInit) StableMarshal(buf []byte) []byte
func (*GetObjectPartInit) StableSize ¶
func (r *GetObjectPartInit) StableSize() (size int)
func (*GetObjectPartInit) ToGRPCMessage ¶
func (r *GetObjectPartInit) ToGRPCMessage() grpc.Message
func (*GetObjectPartInit) Unmarshal ¶
func (r *GetObjectPartInit) Unmarshal(data []byte) error
type GetRangeHashRequest ¶
type GetRangeHashRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*GetRangeHashRequest) FromGRPCMessage ¶
func (r *GetRangeHashRequest) FromGRPCMessage(m grpc.Message) error
func (*GetRangeHashRequest) GetBody ¶
func (r *GetRangeHashRequest) GetBody() *GetRangeHashRequestBody
func (*GetRangeHashRequest) SetBody ¶
func (r *GetRangeHashRequest) SetBody(v *GetRangeHashRequestBody)
func (*GetRangeHashRequest) ToGRPCMessage ¶
func (r *GetRangeHashRequest) ToGRPCMessage() grpc.Message
type GetRangeHashRequestBody ¶
type GetRangeHashRequestBody struct {
// contains filtered or unexported fields
}
func (*GetRangeHashRequestBody) FromGRPCMessage ¶
func (r *GetRangeHashRequestBody) FromGRPCMessage(m grpc.Message) error
func (*GetRangeHashRequestBody) GetAddress ¶
func (r *GetRangeHashRequestBody) GetAddress() *refs.Address
func (*GetRangeHashRequestBody) GetRanges ¶
func (r *GetRangeHashRequestBody) GetRanges() []Range
func (*GetRangeHashRequestBody) GetSalt ¶
func (r *GetRangeHashRequestBody) GetSalt() []byte
func (*GetRangeHashRequestBody) GetType ¶
func (r *GetRangeHashRequestBody) GetType() refs.ChecksumType
func (*GetRangeHashRequestBody) SetAddress ¶
func (r *GetRangeHashRequestBody) SetAddress(v *refs.Address)
func (*GetRangeHashRequestBody) SetRanges ¶
func (r *GetRangeHashRequestBody) SetRanges(v []Range)
func (*GetRangeHashRequestBody) SetSalt ¶
func (r *GetRangeHashRequestBody) SetSalt(v []byte)
func (*GetRangeHashRequestBody) SetType ¶
func (r *GetRangeHashRequestBody) SetType(v refs.ChecksumType)
func (*GetRangeHashRequestBody) StableMarshal ¶
func (r *GetRangeHashRequestBody) StableMarshal(buf []byte) []byte
func (*GetRangeHashRequestBody) StableSize ¶
func (r *GetRangeHashRequestBody) StableSize() (size int)
func (*GetRangeHashRequestBody) ToGRPCMessage ¶
func (r *GetRangeHashRequestBody) ToGRPCMessage() grpc.Message
func (*GetRangeHashRequestBody) Unmarshal ¶
func (r *GetRangeHashRequestBody) Unmarshal(data []byte) error
type GetRangeHashResponse ¶
type GetRangeHashResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*GetRangeHashResponse) FromGRPCMessage ¶
func (r *GetRangeHashResponse) FromGRPCMessage(m grpc.Message) error
func (*GetRangeHashResponse) GetBody ¶
func (r *GetRangeHashResponse) GetBody() *GetRangeHashResponseBody
func (*GetRangeHashResponse) SetBody ¶
func (r *GetRangeHashResponse) SetBody(v *GetRangeHashResponseBody)
func (*GetRangeHashResponse) ToGRPCMessage ¶
func (r *GetRangeHashResponse) ToGRPCMessage() grpc.Message
type GetRangeHashResponseBody ¶
type GetRangeHashResponseBody struct {
// contains filtered or unexported fields
}
func (*GetRangeHashResponseBody) FromGRPCMessage ¶
func (r *GetRangeHashResponseBody) FromGRPCMessage(m grpc.Message) error
func (*GetRangeHashResponseBody) GetHashList ¶
func (r *GetRangeHashResponseBody) GetHashList() [][]byte
func (*GetRangeHashResponseBody) GetType ¶
func (r *GetRangeHashResponseBody) GetType() refs.ChecksumType
func (*GetRangeHashResponseBody) SetHashList ¶
func (r *GetRangeHashResponseBody) SetHashList(v [][]byte)
func (*GetRangeHashResponseBody) SetType ¶
func (r *GetRangeHashResponseBody) SetType(v refs.ChecksumType)
func (*GetRangeHashResponseBody) StableMarshal ¶
func (r *GetRangeHashResponseBody) StableMarshal(buf []byte) []byte
func (*GetRangeHashResponseBody) StableSize ¶
func (r *GetRangeHashResponseBody) StableSize() (size int)
func (*GetRangeHashResponseBody) ToGRPCMessage ¶
func (r *GetRangeHashResponseBody) ToGRPCMessage() grpc.Message
func (*GetRangeHashResponseBody) Unmarshal ¶
func (r *GetRangeHashResponseBody) Unmarshal(data []byte) error
type GetRangePart ¶
type GetRangePart interface {
// contains filtered or unexported methods
}
type GetRangePartChunk ¶
type GetRangePartChunk struct {
// contains filtered or unexported fields
}
func (*GetRangePartChunk) FromGRPCMessage ¶
func (r *GetRangePartChunk) FromGRPCMessage(m grpc.Message) error
func (*GetRangePartChunk) GetChunk ¶
func (r *GetRangePartChunk) GetChunk() []byte
func (*GetRangePartChunk) SetChunk ¶
func (r *GetRangePartChunk) SetChunk(v []byte)
func (*GetRangePartChunk) ToGRPCMessage ¶
func (r *GetRangePartChunk) ToGRPCMessage() grpc.Message
type GetRangeRequest ¶
type GetRangeRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*GetRangeRequest) FromGRPCMessage ¶
func (r *GetRangeRequest) FromGRPCMessage(m grpc.Message) error
func (*GetRangeRequest) GetBody ¶
func (r *GetRangeRequest) GetBody() *GetRangeRequestBody
func (*GetRangeRequest) SetBody ¶
func (r *GetRangeRequest) SetBody(v *GetRangeRequestBody)
func (*GetRangeRequest) ToGRPCMessage ¶
func (r *GetRangeRequest) ToGRPCMessage() grpc.Message
type GetRangeRequestBody ¶
type GetRangeRequestBody struct {
// contains filtered or unexported fields
}
func (*GetRangeRequestBody) FromGRPCMessage ¶
func (r *GetRangeRequestBody) FromGRPCMessage(m grpc.Message) error
func (*GetRangeRequestBody) GetAddress ¶
func (r *GetRangeRequestBody) GetAddress() *refs.Address
func (*GetRangeRequestBody) GetRange ¶
func (r *GetRangeRequestBody) GetRange() *Range
func (*GetRangeRequestBody) GetRaw ¶
func (r *GetRangeRequestBody) GetRaw() bool
func (*GetRangeRequestBody) SetAddress ¶
func (r *GetRangeRequestBody) SetAddress(v *refs.Address)
func (*GetRangeRequestBody) SetRange ¶
func (r *GetRangeRequestBody) SetRange(v *Range)
func (*GetRangeRequestBody) SetRaw ¶
func (r *GetRangeRequestBody) SetRaw(v bool)
func (*GetRangeRequestBody) StableMarshal ¶
func (r *GetRangeRequestBody) StableMarshal(buf []byte) []byte
func (*GetRangeRequestBody) StableSize ¶
func (r *GetRangeRequestBody) StableSize() (size int)
func (*GetRangeRequestBody) ToGRPCMessage ¶
func (r *GetRangeRequestBody) ToGRPCMessage() grpc.Message
func (*GetRangeRequestBody) Unmarshal ¶
func (r *GetRangeRequestBody) Unmarshal(data []byte) error
type GetRangeResponse ¶
type GetRangeResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*GetRangeResponse) FromGRPCMessage ¶
func (r *GetRangeResponse) FromGRPCMessage(m grpc.Message) error
func (*GetRangeResponse) GetBody ¶
func (r *GetRangeResponse) GetBody() *GetRangeResponseBody
func (*GetRangeResponse) SetBody ¶
func (r *GetRangeResponse) SetBody(v *GetRangeResponseBody)
func (*GetRangeResponse) ToGRPCMessage ¶
func (r *GetRangeResponse) ToGRPCMessage() grpc.Message
type GetRangeResponseBody ¶
type GetRangeResponseBody struct {
// contains filtered or unexported fields
}
func (*GetRangeResponseBody) FromGRPCMessage ¶
func (r *GetRangeResponseBody) FromGRPCMessage(m grpc.Message) error
func (*GetRangeResponseBody) GetRangePart ¶
func (r *GetRangeResponseBody) GetRangePart() GetRangePart
func (*GetRangeResponseBody) SetRangePart ¶
func (r *GetRangeResponseBody) SetRangePart(v GetRangePart)
func (*GetRangeResponseBody) StableMarshal ¶
func (r *GetRangeResponseBody) StableMarshal(buf []byte) []byte
func (*GetRangeResponseBody) StableSize ¶
func (r *GetRangeResponseBody) StableSize() (size int)
func (*GetRangeResponseBody) ToGRPCMessage ¶
func (r *GetRangeResponseBody) ToGRPCMessage() grpc.Message
func (*GetRangeResponseBody) Unmarshal ¶
func (r *GetRangeResponseBody) Unmarshal(data []byte) error
type GetRequest ¶
type GetRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*GetRequest) FromGRPCMessage ¶
func (r *GetRequest) FromGRPCMessage(m grpc.Message) error
func (*GetRequest) GetBody ¶
func (r *GetRequest) GetBody() *GetRequestBody
func (*GetRequest) SetBody ¶
func (r *GetRequest) SetBody(v *GetRequestBody)
func (*GetRequest) ToGRPCMessage ¶
func (r *GetRequest) ToGRPCMessage() grpc.Message
type GetRequestBody ¶
type GetRequestBody struct {
// contains filtered or unexported fields
}
func (*GetRequestBody) FromGRPCMessage ¶
func (r *GetRequestBody) FromGRPCMessage(m grpc.Message) error
func (*GetRequestBody) GetAddress ¶
func (r *GetRequestBody) GetAddress() *refs.Address
func (*GetRequestBody) GetRaw ¶
func (r *GetRequestBody) GetRaw() bool
func (*GetRequestBody) SetAddress ¶
func (r *GetRequestBody) SetAddress(v *refs.Address)
func (*GetRequestBody) SetRaw ¶
func (r *GetRequestBody) SetRaw(v bool)
func (*GetRequestBody) StableMarshal ¶
func (r *GetRequestBody) StableMarshal(buf []byte) []byte
func (*GetRequestBody) StableSize ¶
func (r *GetRequestBody) StableSize() (size int)
func (*GetRequestBody) ToGRPCMessage ¶
func (r *GetRequestBody) ToGRPCMessage() grpc.Message
func (*GetRequestBody) Unmarshal ¶
func (r *GetRequestBody) Unmarshal(data []byte) error
type GetResponse ¶
type GetResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*GetResponse) FromGRPCMessage ¶
func (r *GetResponse) FromGRPCMessage(m grpc.Message) error
func (*GetResponse) GetBody ¶
func (r *GetResponse) GetBody() *GetResponseBody
func (*GetResponse) SetBody ¶
func (r *GetResponse) SetBody(v *GetResponseBody)
func (*GetResponse) ToGRPCMessage ¶
func (r *GetResponse) ToGRPCMessage() grpc.Message
type GetResponseBody ¶
type GetResponseBody struct {
// contains filtered or unexported fields
}
func (*GetResponseBody) FromGRPCMessage ¶
func (r *GetResponseBody) FromGRPCMessage(m grpc.Message) error
func (*GetResponseBody) GetObjectPart ¶
func (r *GetResponseBody) GetObjectPart() GetObjectPart
func (*GetResponseBody) SetObjectPart ¶
func (r *GetResponseBody) SetObjectPart(v GetObjectPart)
func (*GetResponseBody) StableMarshal ¶
func (r *GetResponseBody) StableMarshal(buf []byte) []byte
func (*GetResponseBody) StableSize ¶
func (r *GetResponseBody) StableSize() (size int)
func (*GetResponseBody) ToGRPCMessage ¶
func (r *GetResponseBody) ToGRPCMessage() grpc.Message
func (*GetResponseBody) Unmarshal ¶
func (r *GetResponseBody) Unmarshal(data []byte) error
type HeadRequest ¶
type HeadRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*HeadRequest) FromGRPCMessage ¶
func (r *HeadRequest) FromGRPCMessage(m grpc.Message) error
func (*HeadRequest) GetBody ¶
func (r *HeadRequest) GetBody() *HeadRequestBody
func (*HeadRequest) SetBody ¶
func (r *HeadRequest) SetBody(v *HeadRequestBody)
func (*HeadRequest) ToGRPCMessage ¶
func (r *HeadRequest) ToGRPCMessage() grpc.Message
type HeadRequestBody ¶
type HeadRequestBody struct {
// contains filtered or unexported fields
}
func (*HeadRequestBody) FromGRPCMessage ¶
func (r *HeadRequestBody) FromGRPCMessage(m grpc.Message) error
func (*HeadRequestBody) GetAddress ¶
func (r *HeadRequestBody) GetAddress() *refs.Address
func (*HeadRequestBody) GetMainOnly ¶
func (r *HeadRequestBody) GetMainOnly() bool
func (*HeadRequestBody) GetRaw ¶
func (r *HeadRequestBody) GetRaw() bool
func (*HeadRequestBody) SetAddress ¶
func (r *HeadRequestBody) SetAddress(v *refs.Address)
func (*HeadRequestBody) SetMainOnly ¶
func (r *HeadRequestBody) SetMainOnly(v bool)
func (*HeadRequestBody) SetRaw ¶
func (r *HeadRequestBody) SetRaw(v bool)
func (*HeadRequestBody) StableMarshal ¶
func (r *HeadRequestBody) StableMarshal(buf []byte) []byte
func (*HeadRequestBody) StableSize ¶
func (r *HeadRequestBody) StableSize() (size int)
func (*HeadRequestBody) ToGRPCMessage ¶
func (r *HeadRequestBody) ToGRPCMessage() grpc.Message
func (*HeadRequestBody) Unmarshal ¶
func (r *HeadRequestBody) Unmarshal(data []byte) error
type HeadResponse ¶
type HeadResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*HeadResponse) FromGRPCMessage ¶
func (r *HeadResponse) FromGRPCMessage(m grpc.Message) error
func (*HeadResponse) GetBody ¶
func (r *HeadResponse) GetBody() *HeadResponseBody
func (*HeadResponse) SetBody ¶
func (r *HeadResponse) SetBody(v *HeadResponseBody)
func (*HeadResponse) ToGRPCMessage ¶
func (r *HeadResponse) ToGRPCMessage() grpc.Message
type HeadResponseBody ¶
type HeadResponseBody struct {
// contains filtered or unexported fields
}
func (*HeadResponseBody) FromGRPCMessage ¶
func (r *HeadResponseBody) FromGRPCMessage(m grpc.Message) error
func (*HeadResponseBody) GetHeaderPart ¶
func (r *HeadResponseBody) GetHeaderPart() GetHeaderPart
func (*HeadResponseBody) SetHeaderPart ¶
func (r *HeadResponseBody) SetHeaderPart(v GetHeaderPart)
func (*HeadResponseBody) StableMarshal ¶
func (r *HeadResponseBody) StableMarshal(buf []byte) []byte
func (*HeadResponseBody) StableSize ¶
func (r *HeadResponseBody) StableSize() (size int)
func (*HeadResponseBody) ToGRPCMessage ¶
func (r *HeadResponseBody) ToGRPCMessage() grpc.Message
func (*HeadResponseBody) Unmarshal ¶
func (r *HeadResponseBody) Unmarshal(data []byte) error
type Header ¶
type Header struct {
// contains filtered or unexported fields
}
func (*Header) GetAttributes ¶
func (*Header) GetContainerID ¶
func (h *Header) GetContainerID() *refs.ContainerID
func (*Header) GetCreationEpoch ¶
func (*Header) GetHomomorphicHash ¶
func (*Header) GetObjectType ¶
func (*Header) GetOwnerID ¶
func (*Header) GetPayloadHash ¶
func (*Header) GetPayloadLength ¶
func (*Header) GetSessionToken ¶
func (*Header) GetSplit ¶
func (h *Header) GetSplit() *SplitHeader
func (*Header) GetVersion ¶
func (*Header) MarshalJSON ¶
func (*Header) SetAttributes ¶
func (*Header) SetContainerID ¶
func (h *Header) SetContainerID(v *refs.ContainerID)
func (*Header) SetCreationEpoch ¶
func (*Header) SetHomomorphicHash ¶
func (*Header) SetObjectType ¶
func (*Header) SetOwnerID ¶
func (*Header) SetPayloadHash ¶
func (*Header) SetPayloadLength ¶
func (*Header) SetSessionToken ¶
func (*Header) SetSplit ¶
func (h *Header) SetSplit(v *SplitHeader)
func (*Header) SetVersion ¶
func (*Header) StableMarshal ¶
func (*Header) StableSize ¶
func (*Header) ToGRPCMessage ¶
func (*Header) UnmarshalJSON ¶
type HeaderWithSignature ¶
type HeaderWithSignature struct {
// contains filtered or unexported fields
}
func (*HeaderWithSignature) FromGRPCMessage ¶
func (h *HeaderWithSignature) FromGRPCMessage(m grpc.Message) error
func (*HeaderWithSignature) GetHeader ¶
func (h *HeaderWithSignature) GetHeader() *Header
func (*HeaderWithSignature) GetSignature ¶
func (h *HeaderWithSignature) GetSignature() *refs.Signature
func (*HeaderWithSignature) MarshalJSON ¶
func (h *HeaderWithSignature) MarshalJSON() ([]byte, error)
func (*HeaderWithSignature) SetHeader ¶
func (h *HeaderWithSignature) SetHeader(v *Header)
func (*HeaderWithSignature) SetSignature ¶
func (h *HeaderWithSignature) SetSignature(v *refs.Signature)
func (*HeaderWithSignature) StableMarshal ¶
func (h *HeaderWithSignature) StableMarshal(buf []byte) []byte
func (*HeaderWithSignature) StableSize ¶
func (h *HeaderWithSignature) StableSize() (size int)
func (*HeaderWithSignature) ToGRPCMessage ¶
func (h *HeaderWithSignature) ToGRPCMessage() grpc.Message
func (*HeaderWithSignature) Unmarshal ¶
func (h *HeaderWithSignature) Unmarshal(data []byte) error
func (*HeaderWithSignature) UnmarshalJSON ¶
func (h *HeaderWithSignature) UnmarshalJSON(data []byte) error
type Link ¶
type Link struct {
// contains filtered or unexported fields
}
Link represents object Link message from NeoFS API V2 protocol.
func (*Link) IterateChildren ¶
func (x *Link) IterateChildren(f func(MeasuredObject))
IterateChildren passes members of the link list to f.
func (*Link) NumberOfChildren ¶
NumberOfChildren returns length of children list.
func (*Link) SetChildren ¶
func (x *Link) SetChildren(chs []MeasuredObject)
SetChildren sets a list of the child objects. Arg must not be mutated for the duration of the Link.
func (*Link) StableMarshal ¶
StableMarshal encodes the Link into Protocol Buffers binary format with direct field order.
func (*Link) StableSize ¶
StableSize size of the buffer required to write the Link in Protocol Buffers binary format.
func (*Link) ToGRPCMessage ¶
type Lock ¶
type Lock struct {
// contains filtered or unexported fields
}
Lock represents object Lock message from NeoFS API V2 protocol.
func (*Lock) IterateMembers ¶
IterateMembers passes members of the lock list to f.
func (*Lock) NumberOfMembers ¶
NumberOfMembers returns length of lock list.
func (*Lock) SetMembers ¶
SetMembers sets list of locked members. Arg must not be mutated for the duration of the Lock.
func (*Lock) StableMarshal ¶
StableMarshal encodes the Lock into Protocol Buffers binary format with direct field order.
func (*Lock) StableSize ¶
StableSize size of the buffer required to write the Lock in Protocol Buffers binary format.
func (*Lock) ToGRPCMessage ¶
type MatchType ¶
type MatchType uint32
func MatchTypeFromGRPCField ¶
func (*MatchType) FromString ¶
FromString parses MatchType from a string representation. It is a reverse action to String().
Returns true if s was parsed successfully.
type MeasuredObject ¶
MeasuredObject groups object descriptor and object's length.
func (*MeasuredObject) FromGRPCMessage ¶
func (x *MeasuredObject) FromGRPCMessage(m grpc.Message) error
func (*MeasuredObject) StableMarshal ¶
func (x *MeasuredObject) StableMarshal(buf []byte) []byte
StableMarshal encodes the MeasuredObject into Protocol Buffers binary format with direct field order.
func (*MeasuredObject) StableSize ¶
func (x *MeasuredObject) StableSize() int
StableSize size of the buffer required to write the MeasuredObject in Protocol Buffers binary format.
func (*MeasuredObject) ToGRPCMessage ¶
func (x *MeasuredObject) ToGRPCMessage() grpc.Message
func (*MeasuredObject) Unmarshal ¶
func (x *MeasuredObject) Unmarshal(data []byte) error
Unmarshal decodes the Link from its Protocol Buffers binary format.
type NotificationInfo ¶
type NotificationInfo struct {
// contains filtered or unexported fields
}
NotificationInfo groups information about object notification that can be written to object.
Topic is an optional field.
func GetNotificationInfo ¶
func GetNotificationInfo(o *Object) (*NotificationInfo, error)
GetNotificationInfo looks for object notification attributes. Object must not be nil. Returns ErrNotificationNotSet if no corresponding attributes were found.
Existing notification attributes are expected to be key-unique, otherwise undefined behavior.
func (NotificationInfo) Epoch ¶
func (n NotificationInfo) Epoch() uint64
Epoch returns object notification tick epoch.
func (*NotificationInfo) SetEpoch ¶
func (n *NotificationInfo) SetEpoch(epoch uint64)
SetEpoch sets object notification tick epoch.
func (*NotificationInfo) SetTopic ¶
func (n *NotificationInfo) SetTopic(topic string)
SetTopic sets optional object notification topic.
func (NotificationInfo) Topic ¶
func (n NotificationInfo) Topic() string
Topic return optional object notification topic.
type Object ¶
type Object struct {
// contains filtered or unexported fields
}
func (*Object) GetObjectID ¶
func (*Object) GetPayload ¶
func (*Object) GetSignature ¶
func (*Object) MarshalJSON ¶
func (*Object) SetObjectID ¶
func (*Object) SetPayload ¶
func (*Object) SetSignature ¶
func (*Object) StableMarshal ¶
func (*Object) StableSize ¶
func (*Object) ToGRPCMessage ¶
func (*Object) UnmarshalJSON ¶
type PutObjectPart ¶
type PutObjectPart interface {
// contains filtered or unexported methods
}
type PutObjectPartChunk ¶
type PutObjectPartChunk struct {
// contains filtered or unexported fields
}
func (*PutObjectPartChunk) FromGRPCMessage ¶
func (r *PutObjectPartChunk) FromGRPCMessage(m grpc.Message) error
func (*PutObjectPartChunk) GetChunk ¶
func (r *PutObjectPartChunk) GetChunk() []byte
func (*PutObjectPartChunk) SetChunk ¶
func (r *PutObjectPartChunk) SetChunk(v []byte)
func (*PutObjectPartChunk) ToGRPCMessage ¶
func (r *PutObjectPartChunk) ToGRPCMessage() grpc.Message
type PutObjectPartInit ¶
type PutObjectPartInit struct {
// contains filtered or unexported fields
}
func (*PutObjectPartInit) FromGRPCMessage ¶
func (r *PutObjectPartInit) FromGRPCMessage(m grpc.Message) error
func (*PutObjectPartInit) GetCopiesNumber ¶
func (r *PutObjectPartInit) GetCopiesNumber() uint32
func (*PutObjectPartInit) GetHeader ¶
func (r *PutObjectPartInit) GetHeader() *Header
func (*PutObjectPartInit) GetObjectID ¶
func (r *PutObjectPartInit) GetObjectID() *refs.ObjectID
func (*PutObjectPartInit) GetSignature ¶
func (r *PutObjectPartInit) GetSignature() *refs.Signature
func (*PutObjectPartInit) SetCopiesNumber ¶
func (r *PutObjectPartInit) SetCopiesNumber(v uint32)
func (*PutObjectPartInit) SetHeader ¶
func (r *PutObjectPartInit) SetHeader(v *Header)
func (*PutObjectPartInit) SetObjectID ¶
func (r *PutObjectPartInit) SetObjectID(v *refs.ObjectID)
func (*PutObjectPartInit) SetSignature ¶
func (r *PutObjectPartInit) SetSignature(v *refs.Signature)
func (*PutObjectPartInit) StableMarshal ¶
func (r *PutObjectPartInit) StableMarshal(buf []byte) []byte
func (*PutObjectPartInit) StableSize ¶
func (r *PutObjectPartInit) StableSize() (size int)
func (*PutObjectPartInit) ToGRPCMessage ¶
func (r *PutObjectPartInit) ToGRPCMessage() grpc.Message
func (*PutObjectPartInit) Unmarshal ¶
func (r *PutObjectPartInit) Unmarshal(data []byte) error
type PutRequest ¶
type PutRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*PutRequest) FromGRPCMessage ¶
func (r *PutRequest) FromGRPCMessage(m grpc.Message) error
func (*PutRequest) GetBody ¶
func (r *PutRequest) GetBody() *PutRequestBody
func (*PutRequest) SetBody ¶
func (r *PutRequest) SetBody(v *PutRequestBody)
func (*PutRequest) ToGRPCMessage ¶
func (r *PutRequest) ToGRPCMessage() grpc.Message
type PutRequestBody ¶
type PutRequestBody struct {
// contains filtered or unexported fields
}
func (*PutRequestBody) FromGRPCMessage ¶
func (r *PutRequestBody) FromGRPCMessage(m grpc.Message) error
func (*PutRequestBody) GetObjectPart ¶
func (r *PutRequestBody) GetObjectPart() PutObjectPart
func (*PutRequestBody) SetObjectPart ¶
func (r *PutRequestBody) SetObjectPart(v PutObjectPart)
func (*PutRequestBody) StableMarshal ¶
func (r *PutRequestBody) StableMarshal(buf []byte) []byte
func (*PutRequestBody) StableSize ¶
func (r *PutRequestBody) StableSize() (size int)
func (*PutRequestBody) ToGRPCMessage ¶
func (r *PutRequestBody) ToGRPCMessage() grpc.Message
func (*PutRequestBody) Unmarshal ¶
func (r *PutRequestBody) Unmarshal(data []byte) error
type PutResponse ¶
type PutResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*PutResponse) FromGRPCMessage ¶
func (r *PutResponse) FromGRPCMessage(m grpc.Message) error
func (*PutResponse) GetBody ¶
func (r *PutResponse) GetBody() *PutResponseBody
func (*PutResponse) SetBody ¶
func (r *PutResponse) SetBody(v *PutResponseBody)
func (*PutResponse) ToGRPCMessage ¶
func (r *PutResponse) ToGRPCMessage() grpc.Message
type PutResponseBody ¶
type PutResponseBody struct {
// contains filtered or unexported fields
}
func (*PutResponseBody) FromGRPCMessage ¶
func (r *PutResponseBody) FromGRPCMessage(m grpc.Message) error
func (*PutResponseBody) GetObjectID ¶
func (r *PutResponseBody) GetObjectID() *refs.ObjectID
func (*PutResponseBody) SetObjectID ¶
func (r *PutResponseBody) SetObjectID(v *refs.ObjectID)
func (*PutResponseBody) StableMarshal ¶
func (r *PutResponseBody) StableMarshal(buf []byte) []byte
func (*PutResponseBody) StableSize ¶
func (r *PutResponseBody) StableSize() (size int)
func (*PutResponseBody) ToGRPCMessage ¶
func (r *PutResponseBody) ToGRPCMessage() grpc.Message
func (*PutResponseBody) Unmarshal ¶
func (r *PutResponseBody) Unmarshal(data []byte) error
type Range ¶
type Range struct {
// contains filtered or unexported fields
}
func (*Range) MarshalJSON ¶
func (*Range) StableMarshal ¶
func (*Range) StableSize ¶
func (*Range) ToGRPCMessage ¶
func (*Range) UnmarshalJSON ¶
type SearchFilter ¶
type SearchFilter struct {
// contains filtered or unexported fields
}
func SearchFiltersFromGRPC ¶
func SearchFiltersFromGRPC(fs []*object.SearchRequest_Body_Filter) (res []SearchFilter, err error)
func (*SearchFilter) FromGRPCMessage ¶
func (f *SearchFilter) FromGRPCMessage(m grpc.Message) error
func (*SearchFilter) GetKey ¶
func (f *SearchFilter) GetKey() string
func (*SearchFilter) GetMatchType ¶
func (f *SearchFilter) GetMatchType() MatchType
func (*SearchFilter) GetValue ¶
func (f *SearchFilter) GetValue() string
func (*SearchFilter) MarshalJSON ¶
func (f *SearchFilter) MarshalJSON() ([]byte, error)
func (*SearchFilter) SetKey ¶
func (f *SearchFilter) SetKey(v string)
func (*SearchFilter) SetMatchType ¶
func (f *SearchFilter) SetMatchType(v MatchType)
func (*SearchFilter) SetValue ¶
func (f *SearchFilter) SetValue(v string)
func (*SearchFilter) StableMarshal ¶
func (f *SearchFilter) StableMarshal(buf []byte) []byte
func (*SearchFilter) StableSize ¶
func (f *SearchFilter) StableSize() (size int)
func (*SearchFilter) ToGRPCMessage ¶
func (f *SearchFilter) ToGRPCMessage() grpc.Message
func (*SearchFilter) Unmarshal ¶
func (f *SearchFilter) Unmarshal(data []byte) error
func (*SearchFilter) UnmarshalJSON ¶
func (f *SearchFilter) UnmarshalJSON(data []byte) error
type SearchRequest ¶
type SearchRequest struct { session.RequestHeaders // contains filtered or unexported fields }
func (*SearchRequest) FromGRPCMessage ¶
func (r *SearchRequest) FromGRPCMessage(m grpc.Message) error
func (*SearchRequest) GetBody ¶
func (r *SearchRequest) GetBody() *SearchRequestBody
func (*SearchRequest) SetBody ¶
func (r *SearchRequest) SetBody(v *SearchRequestBody)
func (*SearchRequest) ToGRPCMessage ¶
func (r *SearchRequest) ToGRPCMessage() grpc.Message
type SearchRequestBody ¶
type SearchRequestBody struct {
// contains filtered or unexported fields
}
func (*SearchRequestBody) FromGRPCMessage ¶
func (r *SearchRequestBody) FromGRPCMessage(m grpc.Message) error
func (*SearchRequestBody) GetContainerID ¶
func (r *SearchRequestBody) GetContainerID() *refs.ContainerID
func (*SearchRequestBody) GetFilters ¶
func (r *SearchRequestBody) GetFilters() []SearchFilter
func (*SearchRequestBody) GetVersion ¶
func (r *SearchRequestBody) GetVersion() uint32
func (*SearchRequestBody) SetContainerID ¶
func (r *SearchRequestBody) SetContainerID(v *refs.ContainerID)
func (*SearchRequestBody) SetFilters ¶
func (r *SearchRequestBody) SetFilters(v []SearchFilter)
func (*SearchRequestBody) SetVersion ¶
func (r *SearchRequestBody) SetVersion(v uint32)
func (*SearchRequestBody) StableMarshal ¶
func (r *SearchRequestBody) StableMarshal(buf []byte) []byte
func (*SearchRequestBody) StableSize ¶
func (r *SearchRequestBody) StableSize() (size int)
func (*SearchRequestBody) ToGRPCMessage ¶
func (r *SearchRequestBody) ToGRPCMessage() grpc.Message
func (*SearchRequestBody) Unmarshal ¶
func (r *SearchRequestBody) Unmarshal(data []byte) error
type SearchResponse ¶
type SearchResponse struct { session.ResponseHeaders // contains filtered or unexported fields }
func (*SearchResponse) FromGRPCMessage ¶
func (r *SearchResponse) FromGRPCMessage(m grpc.Message) error
func (*SearchResponse) GetBody ¶
func (r *SearchResponse) GetBody() *SearchResponseBody
func (*SearchResponse) SetBody ¶
func (r *SearchResponse) SetBody(v *SearchResponseBody)
func (*SearchResponse) ToGRPCMessage ¶
func (r *SearchResponse) ToGRPCMessage() grpc.Message
type SearchResponseBody ¶
type SearchResponseBody struct {
// contains filtered or unexported fields
}
func (*SearchResponseBody) FromGRPCMessage ¶
func (r *SearchResponseBody) FromGRPCMessage(m grpc.Message) error
func (*SearchResponseBody) GetIDList ¶
func (r *SearchResponseBody) GetIDList() []refs.ObjectID
func (*SearchResponseBody) SetIDList ¶
func (r *SearchResponseBody) SetIDList(v []refs.ObjectID)
func (*SearchResponseBody) StableMarshal ¶
func (r *SearchResponseBody) StableMarshal(buf []byte) []byte
func (*SearchResponseBody) StableSize ¶
func (r *SearchResponseBody) StableSize() (size int)
func (*SearchResponseBody) ToGRPCMessage ¶
func (r *SearchResponseBody) ToGRPCMessage() grpc.Message
func (*SearchResponseBody) Unmarshal ¶
func (r *SearchResponseBody) Unmarshal(data []byte) error
type ShortHeader ¶
type ShortHeader struct {
// contains filtered or unexported fields
}
func (*ShortHeader) FromGRPCMessage ¶
func (h *ShortHeader) FromGRPCMessage(m grpc.Message) error
func (*ShortHeader) GetCreationEpoch ¶
func (h *ShortHeader) GetCreationEpoch() uint64
func (*ShortHeader) GetHomomorphicHash ¶
func (h *ShortHeader) GetHomomorphicHash() *refs.Checksum
func (*ShortHeader) GetObjectType ¶
func (h *ShortHeader) GetObjectType() Type
func (*ShortHeader) GetOwnerID ¶
func (h *ShortHeader) GetOwnerID() *refs.OwnerID
func (*ShortHeader) GetPayloadHash ¶
func (h *ShortHeader) GetPayloadHash() *refs.Checksum
func (*ShortHeader) GetPayloadLength ¶
func (h *ShortHeader) GetPayloadLength() uint64
func (*ShortHeader) GetVersion ¶
func (h *ShortHeader) GetVersion() *refs.Version
func (*ShortHeader) MarshalJSON ¶
func (h *ShortHeader) MarshalJSON() ([]byte, error)
func (*ShortHeader) SetCreationEpoch ¶
func (h *ShortHeader) SetCreationEpoch(v uint64)
func (*ShortHeader) SetHomomorphicHash ¶
func (h *ShortHeader) SetHomomorphicHash(v *refs.Checksum)
func (*ShortHeader) SetObjectType ¶
func (h *ShortHeader) SetObjectType(v Type)
func (*ShortHeader) SetOwnerID ¶
func (h *ShortHeader) SetOwnerID(v *refs.OwnerID)
func (*ShortHeader) SetPayloadHash ¶
func (h *ShortHeader) SetPayloadHash(v *refs.Checksum)
func (*ShortHeader) SetPayloadLength ¶
func (h *ShortHeader) SetPayloadLength(v uint64)
func (*ShortHeader) SetVersion ¶
func (h *ShortHeader) SetVersion(v *refs.Version)
func (*ShortHeader) StableMarshal ¶
func (h *ShortHeader) StableMarshal(buf []byte) []byte
func (*ShortHeader) StableSize ¶
func (h *ShortHeader) StableSize() (size int)
func (*ShortHeader) ToGRPCMessage ¶
func (h *ShortHeader) ToGRPCMessage() grpc.Message
func (*ShortHeader) Unmarshal ¶
func (h *ShortHeader) Unmarshal(data []byte) error
func (*ShortHeader) UnmarshalJSON ¶
func (h *ShortHeader) UnmarshalJSON(data []byte) error
type SplitHeader ¶
type SplitHeader struct {
// contains filtered or unexported fields
}
func (*SplitHeader) FromGRPCMessage ¶
func (h *SplitHeader) FromGRPCMessage(m grpc.Message) error
func (*SplitHeader) GetChildren ¶
func (h *SplitHeader) GetChildren() []refs.ObjectID
func (*SplitHeader) GetFirst ¶
func (h *SplitHeader) GetFirst() *refs.ObjectID
func (*SplitHeader) GetParent ¶
func (h *SplitHeader) GetParent() *refs.ObjectID
func (*SplitHeader) GetParentHeader ¶
func (h *SplitHeader) GetParentHeader() *Header
func (*SplitHeader) GetParentSignature ¶
func (h *SplitHeader) GetParentSignature() *refs.Signature
func (*SplitHeader) GetPrevious ¶
func (h *SplitHeader) GetPrevious() *refs.ObjectID
func (*SplitHeader) GetSplitID ¶
func (h *SplitHeader) GetSplitID() []byte
func (*SplitHeader) MarshalJSON ¶
func (h *SplitHeader) MarshalJSON() ([]byte, error)
func (*SplitHeader) SetChildren ¶
func (h *SplitHeader) SetChildren(v []refs.ObjectID)
func (*SplitHeader) SetFirst ¶
func (h *SplitHeader) SetFirst(v *refs.ObjectID)
func (*SplitHeader) SetParent ¶
func (h *SplitHeader) SetParent(v *refs.ObjectID)
func (*SplitHeader) SetParentHeader ¶
func (h *SplitHeader) SetParentHeader(v *Header)
func (*SplitHeader) SetParentSignature ¶
func (h *SplitHeader) SetParentSignature(v *refs.Signature)
func (*SplitHeader) SetPrevious ¶
func (h *SplitHeader) SetPrevious(v *refs.ObjectID)
func (*SplitHeader) SetSplitID ¶
func (h *SplitHeader) SetSplitID(v []byte)
func (*SplitHeader) StableMarshal ¶
func (h *SplitHeader) StableMarshal(buf []byte) []byte
func (*SplitHeader) StableSize ¶
func (h *SplitHeader) StableSize() (size int)
func (*SplitHeader) ToGRPCMessage ¶
func (h *SplitHeader) ToGRPCMessage() grpc.Message
func (*SplitHeader) Unmarshal ¶
func (h *SplitHeader) Unmarshal(data []byte) error
func (*SplitHeader) UnmarshalJSON ¶
func (h *SplitHeader) UnmarshalJSON(data []byte) error
type SplitInfo ¶
type SplitInfo struct {
// contains filtered or unexported fields
}
func (*SplitInfo) GetFirstPart ¶
func (*SplitInfo) GetLastPart ¶
func (*SplitInfo) GetSplitID ¶
func (*SplitInfo) MarshalJSON ¶
func (*SplitInfo) SetFirstPart ¶
func (*SplitInfo) SetLastPart ¶
func (*SplitInfo) SetSplitID ¶
func (*SplitInfo) StableMarshal ¶
func (*SplitInfo) StableSize ¶
func (*SplitInfo) ToGRPCMessage ¶
func (*SplitInfo) UnmarshalJSON ¶
type Type ¶
type Type uint32
func TypeFromGRPCField ¶
func TypeFromGRPCField(t object.ObjectType) Type
func TypeFromString
deprecated
func (*Type) FromString ¶
FromString parses Type from a string representation. It is a reverse action to String().
Returns true if s was parsed successfully.