object

package
v2.16.0 Latest Latest
Warning

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

Go to latest
Published: Sep 14, 2023 License: Apache-2.0 Imports: 14 Imported by: 21

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"
)
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 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 (*GetRangeHashRequest) SetBody

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 (*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 (*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 (*GetRangeHashResponse) SetBody

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 (*GetRangeHashResponseBody) SetHashList

func (r *GetRangeHashResponseBody) SetHashList(v [][]byte)

func (*GetRangeHashResponseBody) SetType

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) 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) 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) 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 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 added in v2.16.0

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

func (*PutSingleRequest) FromGRPCMessage added in v2.16.0

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

func (*PutSingleRequest) GetBody added in v2.16.0

func (r *PutSingleRequest) GetBody() *PutSingleRequestBody

func (*PutSingleRequest) SetBody added in v2.16.0

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

func (*PutSingleRequest) ToGRPCMessage added in v2.16.0

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

type PutSingleRequestBody added in v2.16.0

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

func (*PutSingleRequestBody) FromGRPCMessage added in v2.16.0

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

func (*PutSingleRequestBody) GetCopiesNumber added in v2.16.0

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

func (*PutSingleRequestBody) GetObject added in v2.16.0

func (b *PutSingleRequestBody) GetObject() *Object

func (*PutSingleRequestBody) SetCopiesNumber added in v2.16.0

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

func (*PutSingleRequestBody) SetObject added in v2.16.0

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

func (*PutSingleRequestBody) StableMarshal added in v2.16.0

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

func (*PutSingleRequestBody) StableSize added in v2.16.0

func (r *PutSingleRequestBody) StableSize() int

func (*PutSingleRequestBody) ToGRPCMessage added in v2.16.0

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

func (*PutSingleRequestBody) Unmarshal added in v2.16.0

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

type PutSingleResponse added in v2.16.0

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

func (*PutSingleResponse) FromGRPCMessage added in v2.16.0

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

func (*PutSingleResponse) GetBody added in v2.16.0

func (*PutSingleResponse) SetBody added in v2.16.0

func (*PutSingleResponse) ToGRPCMessage added in v2.16.0

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

type PutSingleResponseBody added in v2.16.0

type PutSingleResponseBody struct {
}

func (*PutSingleResponseBody) FromGRPCMessage added in v2.16.0

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

func (*PutSingleResponseBody) StableMarshal added in v2.16.0

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

func (*PutSingleResponseBody) StableSize added in v2.16.0

func (r *PutSingleResponseBody) StableSize() int

func (*PutSingleResponseBody) ToGRPCMessage added in v2.16.0

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

func (*PutSingleResponseBody) Unmarshal added in v2.16.0

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL