object

package
v0.0.0-...-afdc2d8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 14 Imported by: 17

Documentation

Index

Constants

View Source 
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"
)
View Source 
const (
	// SysAttributeUploadIDNeoFS marks smaller parts of a split bigger object.
	// Deprecated: use SysAttributeUploadID.
	SysAttributeUploadIDNeoFS = SysAttributePrefixNeoFS + "UPLOAD_ID"

	// SysAttributeExpEpochNeoFS tells GC to delete object after that epoch.
	// Deprecated: use SysAttributeExpEpoch.
	SysAttributeExpEpochNeoFS = SysAttributePrefixNeoFS + "EXPIRATION_EPOCH"

	// SysAttributeTickEpochNeoFS defines what epoch must produce object
	// notification.
	// Deprecated: use SysAttributeTickEpoch.
	SysAttributeTickEpochNeoFS = SysAttributePrefixNeoFS + "TICK_EPOCH"

	// SysAttributeTickTopicNeoFS defines what topic object notification
	// must be sent to.
	// Deprecated: use SysAttributeTickTopic.
	SysAttributeTickTopicNeoFS = SysAttributePrefixNeoFS + "TICK_TOPIC"
)
View Source 
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"

	// FilterHeaderECParent is a filter key to "ec.parent" field of the object header.
	FilterHeaderECParent = ReservedFilterPrefix + "ec.parent"
)
View Source 
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"
)
View Source 
const (
	// BooleanPropertyValueTrue is a true value for boolean property filters.
	BooleanPropertyValueTrue = "true"

	// BooleanPropertyValueFalse is a false value for boolean property filters.
	BooleanPropertyValueFalse = ""
)
View Source 
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
)
View Source 
const ReservedFilterPrefix = "$Object:"

ReservedFilterPrefix is a prefix of key to object header value or property.

View Source 
const SysAttributePrefix = "__SYSTEM__"

SysAttributePrefix is a prefix of key to system attribute.

View Source 
const SysAttributePrefixNeoFS = "__NEOFS__"

SysAttributePrefixNeoFS is a prefix of key to system attribute. Deprecated: use SysAttributePrefix.

Variables

View Source 
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 GlobalizeFail 

func GlobalizeFail(c *status.Code)

GlobalizeFail globalizes local code of object failure.

Arg must not be nil.

func LocalizeFailStatus 

func LocalizeFailStatus(c *status.Code) bool

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 MatchTypeToGRPCField(t MatchType) object.MatchType

func RangesToGRPC 

func RangesToGRPC(rs []Range) (res []object.Range)

func ReadAccessDeniedDesc 

func ReadAccessDeniedDesc(st status.Status) (desc string)

ReadAccessDeniedDesc looks up for status detail with human-readable description of StatusAccessDenied. Returns empty string if detail is missing.

func ReadLock 

func ReadLock(lock *Lock, obj Object) error

ReadLock reads Lock from the Object payload content.

func SearchFiltersToGRPC 

func SearchFiltersToGRPC(fs []SearchFilter) (res []object.SearchRequest_Body_Filter)

func TypeToGRPCField 

func TypeToGRPCField(t Type) object.ObjectType

func WriteAccessDeniedDesc 

func WriteAccessDeniedDesc(st *status.Status, desc string)

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 WriteLock 

func WriteLock(obj *Object, lock Lock)

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) FromGRPCMessage 

func (a *Attribute) FromGRPCMessage(m grpc.Message) error

func (*Attribute) GetKey 

func (a *Attribute) GetKey() string

func (*Attribute) GetValue 

func (a *Attribute) GetValue() string

func (*Attribute) MarshalJSON 

func (a *Attribute) MarshalJSON() ([]byte, error)

func (*Attribute) SetKey 

func (a *Attribute) SetKey(v string)

func (*Attribute) SetValue 

func (a *Attribute) SetValue(v string)

func (*Attribute) StableMarshal 

func (a *Attribute) StableMarshal(buf []byte) []byte

func (*Attribute) StableSize 

func (a *Attribute) StableSize() (size int)

func (*Attribute) ToGRPCMessage 

func (a *Attribute) ToGRPCMessage() grpc.Message

func (*Attribute) Unmarshal 

func (a *Attribute) Unmarshal(data []byte) error

func (*Attribute) UnmarshalJSON 

func (a *Attribute) UnmarshalJSON(data []byte) error

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 ECChunk 

type ECChunk struct {
	ID    refs.ObjectID
	Index uint32
	Total uint32
}

func (*ECChunk) FromGRPCMessage 

func (c *ECChunk) FromGRPCMessage(m grpc.Message) error

func (*ECChunk) MarshalJSON 

func (e *ECChunk) MarshalJSON() ([]byte, error)

func (*ECChunk) StableMarshal 

func (c *ECChunk) StableMarshal(buf []byte) []byte

func (*ECChunk) StableSize 

func (c *ECChunk) StableSize() (size int)

func (*ECChunk) ToGRPCMessage 

func (c *ECChunk) ToGRPCMessage() grpc.Message

func (*ECChunk) Unmarshal 

func (c *ECChunk) Unmarshal(data []byte) error

func (*ECChunk) UnmarshalJSON 

func (e *ECChunk) UnmarshalJSON(data []byte) error

type ECHeader 

type ECHeader struct {
	Parent              *refs.ObjectID
	ParentSplitID       []byte
	ParentSplitParentID *refs.ObjectID
	ParentAttributes    []Attribute
	Index               uint32
	Total               uint32
	Header              []byte
	HeaderLength        uint32
}

func (*ECHeader) FromGRPCMessage 

func (h *ECHeader) FromGRPCMessage(m grpc.Message) error

func (*ECHeader) StableMarshal 

func (h *ECHeader) StableMarshal(buf []byte) []byte

func (*ECHeader) StableSize 

func (h *ECHeader) StableSize() (size int)

func (*ECHeader) ToGRPCMessage 

func (h *ECHeader) ToGRPCMessage() grpc.Message

func (*ECHeader) Unmarshal 

func (h *ECHeader) Unmarshal(data []byte) error

type ECInfo 

type ECInfo struct {
	Chunks []ECChunk
}

func (*ECInfo) FromGRPCMessage 

func (s *ECInfo) FromGRPCMessage(m grpc.Message) error

func (*ECInfo) MarshalJSON 

func (e *ECInfo) MarshalJSON() ([]byte, error)

func (*ECInfo) StableMarshal 

func (e *ECInfo) StableMarshal(buf []byte) []byte

func (*ECInfo) StableSize 

func (e *ECInfo) StableSize() (size int)

func (*ECInfo) ToGRPCMessage 

func (s *ECInfo) ToGRPCMessage() grpc.Message

func (*ECInfo) Unmarshal 

func (e *ECInfo) Unmarshal(data []byte) error

func (*ECInfo) UnmarshalJSON 

func (e *ECInfo) UnmarshalJSON(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 struct {
	// contains filtered or unexported fields
}

func (*Header) FromGRPCMessage 

func (h *Header) FromGRPCMessage(m grpc.Message) error

func (*Header) GetAttributes 

func (h *Header) GetAttributes() []Attribute

func (*Header) GetContainerID 

func (h *Header) GetContainerID() *refs.ContainerID

func (*Header) GetCreationEpoch 

func (h *Header) GetCreationEpoch() uint64

func (*Header) GetEC 

func (h *Header) GetEC() *ECHeader

func (*Header) GetHomomorphicHash 

func (h *Header) GetHomomorphicHash() *refs.Checksum

func (*Header) GetObjectType 

func (h *Header) GetObjectType() Type

func (*Header) GetOwnerID 

func (h *Header) GetOwnerID() *refs.OwnerID

func (*Header) GetPayloadHash 

func (h *Header) GetPayloadHash() *refs.Checksum

func (*Header) GetPayloadLength 

func (h *Header) GetPayloadLength() uint64

func (*Header) GetSessionToken 

func (h *Header) GetSessionToken() *session.Token

func (*Header) GetSplit 

func (h *Header) GetSplit() *SplitHeader

func (*Header) GetVersion 

func (h *Header) GetVersion() *refs.Version

func (*Header) MarshalJSON 

func (h *Header) MarshalJSON() ([]byte, error)

func (*Header) SetAttributes 

func (h *Header) SetAttributes(v []Attribute)

func (*Header) SetContainerID 

func (h *Header) SetContainerID(v *refs.ContainerID)

func (*Header) SetCreationEpoch 

func (h *Header) SetCreationEpoch(v uint64)

func (*Header) SetEC 

func (h *Header) SetEC(v *ECHeader)

func (*Header) SetHomomorphicHash 

func (h *Header) SetHomomorphicHash(v *refs.Checksum)

func (*Header) SetObjectType 

func (h *Header) SetObjectType(v Type)

func (*Header) SetOwnerID 

func (h *Header) SetOwnerID(v *refs.OwnerID)

func (*Header) SetPayloadHash 

func (h *Header) SetPayloadHash(v *refs.Checksum)

func (*Header) SetPayloadLength 

func (h *Header) SetPayloadLength(v uint64)

func (*Header) SetSessionToken 

func (h *Header) SetSessionToken(v *session.Token)

func (*Header) SetSplit 

func (h *Header) SetSplit(v *SplitHeader)

func (*Header) SetVersion 

func (h *Header) SetVersion(v *refs.Version)

func (*Header) StableMarshal 

func (h *Header) StableMarshal(buf []byte) []byte

func (*Header) StableSize 

func (h *Header) StableSize() (size int)

func (*Header) ToGRPCMessage 

func (h *Header) ToGRPCMessage() grpc.Message

func (*Header) Unmarshal 

func (h *Header) Unmarshal(data []byte) error

func (*Header) UnmarshalJSON 

func (h *Header) UnmarshalJSON(data []byte) error

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 Lock 

type Lock struct {
	// contains filtered or unexported fields
}

Lock represents object Lock message from NeoFS API V2 protocol.

func (*Lock) FromGRPCMessage 

func (x *Lock) FromGRPCMessage(m grpc.Message) error

func (*Lock) IterateMembers 

func (x *Lock) IterateMembers(f func(refs.ObjectID))

IterateMembers passes members of the lock list to f.

func (*Lock) NumberOfMembers 

func (x *Lock) NumberOfMembers() int

NumberOfMembers returns length of lock list.

func (*Lock) SetMembers 

func (x *Lock) SetMembers(ids []refs.ObjectID)

SetMembers sets list of locked members. Arg must not be mutated for the duration of the Lock.

func (*Lock) StableMarshal 

func (x *Lock) StableMarshal(buf []byte) []byte

StableMarshal encodes the Lock into Protocol Buffers binary format with direct field order.

func (*Lock) StableSize 

func (x *Lock) StableSize() (sz int)

StableSize size of the buffer required to write the Lock in Protocol Buffers binary format.

func (*Lock) ToGRPCMessage 

func (x *Lock) ToGRPCMessage() grpc.Message

func (*Lock) Unmarshal 

func (x *Lock) Unmarshal(data []byte) error

Unmarshal decodes the Lock from its Protocol Buffers binary format.

type MatchType 

type MatchType uint32
const (
	MatchUnknown MatchType = iota
	MatchStringEqual
	MatchStringNotEqual
	MatchNotPresent
	MatchCommonPrefix
)

func MatchTypeFromGRPCField 

func MatchTypeFromGRPCField(t object.MatchType) MatchType

func (*MatchType) FromString 

func (t *MatchType) FromString(s string) bool

FromString parses MatchType from a string representation. It is a reverse action to String().

Returns true if s was parsed successfully.

func (MatchType) String 

func (t MatchType) String() string

String returns string representation of MatchType.

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) FromGRPCMessage 

func (o *Object) FromGRPCMessage(m grpc.Message) error

func (*Object) GetHeader 

func (o *Object) GetHeader() *Header

func (*Object) GetObjectID 

func (o *Object) GetObjectID() *refs.ObjectID

func (*Object) GetPayload 

func (o *Object) GetPayload() []byte

func (*Object) GetSignature 

func (o *Object) GetSignature() *refs.Signature

func (*Object) MarshalJSON 

func (o *Object) MarshalJSON() ([]byte, error)

func (*Object) SetHeader 

func (o *Object) SetHeader(v *Header)

func (*Object) SetMarshalData 

func (o *Object) SetMarshalData(data []byte)

SetMarshalData sets marshal data to reduce memory allocations.

It is unsafe to modify/copy object data after setting marshal data.

func (*Object) SetObjectID 

func (o *Object) SetObjectID(v *refs.ObjectID)

func (*Object) SetPayload 

func (o *Object) SetPayload(v []byte)

func (*Object) SetSignature 

func (o *Object) SetSignature(v *refs.Signature)

func (*Object) StableMarshal 

func (o *Object) StableMarshal(buf []byte) []byte

func (*Object) StableSize 

func (o *Object) StableSize() (size int)

func (*Object) ToGRPCMessage 

func (o *Object) ToGRPCMessage() grpc.Message

func (*Object) Unmarshal 

func (o *Object) Unmarshal(data []byte) error

func (*Object) UnmarshalJSON 

func (o *Object) UnmarshalJSON(data []byte) error

type PatchRequest 

type PatchRequest struct {
	session.RequestHeaders
	// contains filtered or unexported fields
}

func (*PatchRequest) FromGRPCMessage 

func (r *PatchRequest) FromGRPCMessage(m grpc.Message) error

func (*PatchRequest) GetBody 

func (r *PatchRequest) GetBody() *PatchRequestBody

func (*PatchRequest) SetBody 

func (r *PatchRequest) SetBody(v *PatchRequestBody)

func (*PatchRequest) ToGRPCMessage 

func (r *PatchRequest) ToGRPCMessage() grpc.Message

type PatchRequestBody 

type PatchRequestBody struct {
	// contains filtered or unexported fields
}

func (*PatchRequestBody) FromGRPCMessage 

func (r *PatchRequestBody) FromGRPCMessage(m grpc.Message) error

func (*PatchRequestBody) GetAddress 

func (r *PatchRequestBody) GetAddress() *refs.Address

func (*PatchRequestBody) GetNewAttributes 

func (r *PatchRequestBody) GetNewAttributes() []Attribute

func (*PatchRequestBody) GetPatch 

func (r *PatchRequestBody) GetPatch() *PatchRequestBodyPatch

func (*PatchRequestBody) GetReplaceAttributes 

func (r *PatchRequestBody) GetReplaceAttributes() bool

func (*PatchRequestBody) SetAddress 

func (r *PatchRequestBody) SetAddress(addr *refs.Address)

func (*PatchRequestBody) SetNewAttributes 

func (r *PatchRequestBody) SetNewAttributes(attrs []Attribute)

func (*PatchRequestBody) SetPatch 

func (r *PatchRequestBody) SetPatch(patch *PatchRequestBodyPatch)

func (*PatchRequestBody) SetReplaceAttributes 

func (r *PatchRequestBody) SetReplaceAttributes(replace bool)

func (*PatchRequestBody) StableMarshal 

func (r *PatchRequestBody) StableMarshal(buf []byte) []byte

func (*PatchRequestBody) StableSize 

func (r *PatchRequestBody) StableSize() int

func (*PatchRequestBody) ToGRPCMessage 

func (r *PatchRequestBody) ToGRPCMessage() grpc.Message

func (*PatchRequestBody) Unmarshal 

func (r *PatchRequestBody) Unmarshal(data []byte) error

type PatchRequestBodyPatch 

type PatchRequestBodyPatch struct {
	Range *Range

	Chunk []byte
}

func (*PatchRequestBodyPatch) FromGRPCMessage 

func (r *PatchRequestBodyPatch) FromGRPCMessage(m grpc.Message) error

func (*PatchRequestBodyPatch) GetChunk 

func (r *PatchRequestBodyPatch) GetChunk() []byte

func (*PatchRequestBodyPatch) GetRange 

func (r *PatchRequestBodyPatch) GetRange() *Range

func (*PatchRequestBodyPatch) StableMarshal 

func (r *PatchRequestBodyPatch) StableMarshal(buf []byte) []byte

func (*PatchRequestBodyPatch) StableSize 

func (r *PatchRequestBodyPatch) StableSize() int

func (*PatchRequestBodyPatch) ToGRPCMessage 

func (r *PatchRequestBodyPatch) ToGRPCMessage() grpc.Message

func (*PatchRequestBodyPatch) Unmarshal 

func (r *PatchRequestBodyPatch) Unmarshal(data []byte) error

type PatchResponse 

type PatchResponse struct {
	Body *PatchResponseBody

	session.ResponseHeaders
}

func (*PatchResponse) FromGRPCMessage 

func (r *PatchResponse) FromGRPCMessage(m grpc.Message) error

func (*PatchResponse) GetBody 

func (r *PatchResponse) GetBody() *PatchResponseBody

func (*PatchResponse) SetBody 

func (r *PatchResponse) SetBody(v *PatchResponseBody)

func (*PatchResponse) ToGRPCMessage 

func (r *PatchResponse) ToGRPCMessage() grpc.Message

type PatchResponseBody 

type PatchResponseBody struct {
	ObjectID *refs.ObjectID
}

func (*PatchResponseBody) FromGRPCMessage 

func (r *PatchResponseBody) FromGRPCMessage(m grpc.Message) error

func (*PatchResponseBody) GetObjectID 

func (r *PatchResponseBody) GetObjectID() *refs.ObjectID

func (*PatchResponseBody) SetObjectID 

func (r *PatchResponseBody) SetObjectID(objectID *refs.ObjectID)

func (*PatchResponseBody) StableMarshal 

func (r *PatchResponseBody) StableMarshal(buf []byte) []byte

func (*PatchResponseBody) StableSize 

func (r *PatchResponseBody) StableSize() int

func (*PatchResponseBody) ToGRPCMessage 

func (r *PatchResponseBody) ToGRPCMessage() grpc.Message

func (*PatchResponseBody) Unmarshal 

func (r *PatchResponseBody) Unmarshal(data []byte) error

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 PutSingleRequest 

type PutSingleRequest struct {
	session.RequestHeaders
	// contains filtered or unexported fields
}

func (*PutSingleRequest) FromGRPCMessage 

func (r *PutSingleRequest) FromGRPCMessage(m grpc.Message) error

func (*PutSingleRequest) GetBody 

func (r *PutSingleRequest) GetBody() *PutSingleRequestBody

func (*PutSingleRequest) SetBody 

func (r *PutSingleRequest) SetBody(v *PutSingleRequestBody)

func (*PutSingleRequest) ToGRPCMessage 

func (r *PutSingleRequest) ToGRPCMessage() grpc.Message

type PutSingleRequestBody 

type PutSingleRequestBody struct {
	// contains filtered or unexported fields
}

func (*PutSingleRequestBody) FromGRPCMessage 

func (r *PutSingleRequestBody) FromGRPCMessage(m grpc.Message) error

func (*PutSingleRequestBody) GetCopiesNumber 

func (b *PutSingleRequestBody) GetCopiesNumber() []uint32

func (*PutSingleRequestBody) GetObject 

func (b *PutSingleRequestBody) GetObject() *Object

func (*PutSingleRequestBody) SetCopiesNumber 

func (b *PutSingleRequestBody) SetCopiesNumber(v []uint32)

func (*PutSingleRequestBody) SetMarshalData 

func (r *PutSingleRequestBody) SetMarshalData(data []byte)

SetMarshalData sets marshal data to reduce memory allocations.

It is unsafe to modify/copy request data after setting marshal data.

func (*PutSingleRequestBody) SetObject 

func (b *PutSingleRequestBody) SetObject(o *Object)

func (*PutSingleRequestBody) StableMarshal 

func (r *PutSingleRequestBody) StableMarshal(buf []byte) []byte

func (*PutSingleRequestBody) StableSize 

func (r *PutSingleRequestBody) StableSize() int

func (*PutSingleRequestBody) ToGRPCMessage 

func (r *PutSingleRequestBody) ToGRPCMessage() grpc.Message

func (*PutSingleRequestBody) Unmarshal 

func (r *PutSingleRequestBody) Unmarshal(data []byte) error

type PutSingleResponse 

type PutSingleResponse struct {
	session.ResponseHeaders
	// contains filtered or unexported fields
}

func (*PutSingleResponse) FromGRPCMessage 

func (r *PutSingleResponse) FromGRPCMessage(m grpc.Message) error

func (*PutSingleResponse) GetBody 

func (r *PutSingleResponse) GetBody() *PutSingleResponseBody

func (*PutSingleResponse) SetBody 

func (r *PutSingleResponse) SetBody(v *PutSingleResponseBody)

func (*PutSingleResponse) ToGRPCMessage 

func (r *PutSingleResponse) ToGRPCMessage() grpc.Message

type PutSingleResponseBody 

type PutSingleResponseBody struct{}

func (*PutSingleResponseBody) FromGRPCMessage 

func (r *PutSingleResponseBody) FromGRPCMessage(m grpc.Message) error

func (*PutSingleResponseBody) StableMarshal 

func (r *PutSingleResponseBody) StableMarshal(buf []byte) []byte

func (*PutSingleResponseBody) StableSize 

func (r *PutSingleResponseBody) StableSize() int

func (*PutSingleResponseBody) ToGRPCMessage 

func (r *PutSingleResponseBody) ToGRPCMessage() grpc.Message

func (*PutSingleResponseBody) Unmarshal 

func (r *PutSingleResponseBody) Unmarshal(data []byte) error

type Range 

type Range struct {
	// contains filtered or unexported fields
}

func RangesFromGRPC 

func RangesFromGRPC(rs []object.Range) (res []Range, err error)

func (*Range) FromGRPCMessage 

func (r *Range) FromGRPCMessage(m grpc.Message) error

func (*Range) GetLength 

func (r *Range) GetLength() uint64

func (*Range) GetOffset 

func (r *Range) GetOffset() uint64

func (*Range) MarshalJSON 

func (r *Range) MarshalJSON() ([]byte, error)

func (*Range) SetLength 

func (r *Range) SetLength(v uint64)

func (*Range) SetOffset 

func (r *Range) SetOffset(v uint64)

func (*Range) StableMarshal 

func (r *Range) StableMarshal(buf []byte) []byte

func (*Range) StableSize 

func (r *Range) StableSize() (size int)

func (*Range) ToGRPCMessage 

func (r *Range) ToGRPCMessage() grpc.Message

func (*Range) Unmarshal 

func (r *Range) Unmarshal(data []byte) error

func (*Range) UnmarshalJSON 

func (r *Range) UnmarshalJSON(data []byte) error

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) 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) 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) FromGRPCMessage 

func (s *SplitInfo) FromGRPCMessage(m grpc.Message) error

func (*SplitInfo) GetLastPart 

func (s *SplitInfo) GetLastPart() *refs.ObjectID
func (s *SplitInfo) GetLink() *refs.ObjectID

func (*SplitInfo) GetSplitID 

func (s *SplitInfo) GetSplitID() []byte

func (*SplitInfo) MarshalJSON 

func (s *SplitInfo) MarshalJSON() ([]byte, error)

func (*SplitInfo) SetLastPart 

func (s *SplitInfo) SetLastPart(v *refs.ObjectID)
func (s *SplitInfo) SetLink(v *refs.ObjectID)

func (*SplitInfo) SetSplitID 

func (s *SplitInfo) SetSplitID(v []byte)

func (*SplitInfo) StableMarshal 

func (s *SplitInfo) StableMarshal(buf []byte) []byte

func (*SplitInfo) StableSize 

func (s *SplitInfo) StableSize() (size int)

func (*SplitInfo) ToGRPCMessage 

func (s *SplitInfo) ToGRPCMessage() grpc.Message

func (*SplitInfo) Unmarshal 

func (s *SplitInfo) Unmarshal(data []byte) error

func (*SplitInfo) UnmarshalJSON 

func (s *SplitInfo) UnmarshalJSON(data []byte) error

type Type 

type Type uint32
const (
	TypeRegular Type = iota
	TypeTombstone

	TypeLock
)

func TypeFromGRPCField 

func TypeFromGRPCField(t object.ObjectType) Type

func TypeFromString deprecated 

func TypeFromString(s string) (t Type)

TypeFromString converts string to Type.

Deprecated: use FromString method.

func (*Type) FromString 

func (t *Type) FromString(s string) bool

FromString parses Type from a string representation. It is a reverse action to String().

Returns true if s was parsed successfully.

func (Type) String 

func (t Type) String() string

String returns string representation of Type.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.