object

package
v1.20.3 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2020 License: Apache-2.0 Imports: 12 Imported by: 15

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

	// FilterPropertyChildfree is a filter key to check if an object has empty children list in `Split` header.
	FilterPropertyChildfree = ReservedFilterPrefix + "CHILDFREE"
)
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 ReservedFilterPrefix = "$Object:"

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

View Source 
const SysAttributePrefix = "__NEOFS__"

SysAttributePrefix is a prefix of key to system attribute.

Variables

This section is empty.

Functions

func AttributeToGRPCMessage 

func AttributeToGRPCMessage(a *Attribute) *object.Header_Attribute

func DeleteRequestBodyToGRPCMessage 

func DeleteRequestBodyToGRPCMessage(r *DeleteRequestBody) *object.DeleteRequest_Body

func DeleteRequestToGRPCMessage 

func DeleteRequestToGRPCMessage(r *DeleteRequest) *object.DeleteRequest

func DeleteResponseBodyToGRPCMessage 

func DeleteResponseBodyToGRPCMessage(r *DeleteResponseBody) *object.DeleteResponse_Body

func DeleteResponseToGRPCMessage 

func DeleteResponseToGRPCMessage(r *DeleteResponse) *object.DeleteResponse

func GetHeaderPartFullToGRPCMessage 

func GetHeaderPartFullToGRPCMessage(r *GetHeaderPartFull) *object.HeadResponse_Body_Header

func GetHeaderPartShortToGRPCMessage 

func GetHeaderPartShortToGRPCMessage(r *GetHeaderPartShort) *object.HeadResponse_Body_ShortHeader

func GetObjectPartChunkToGRPCMessage 

func GetObjectPartChunkToGRPCMessage(r *GetObjectPartChunk) *object.GetResponse_Body_Chunk

func GetObjectPartInitToGRPCMessage 

func GetObjectPartInitToGRPCMessage(r *GetObjectPartInit) *object.GetResponse_Body_Init

func GetRangeHashRequestBodyToGRPCMessage 

func GetRangeHashRequestBodyToGRPCMessage(r *GetRangeHashRequestBody) *object.GetRangeHashRequest_Body

func GetRangeHashRequestToGRPCMessage 

func GetRangeHashRequestToGRPCMessage(r *GetRangeHashRequest) *object.GetRangeHashRequest

func GetRangeHashResponseBodyToGRPCMessage 

func GetRangeHashResponseBodyToGRPCMessage(r *GetRangeHashResponseBody) *object.GetRangeHashResponse_Body

func GetRangeHashResponseToGRPCMessage 

func GetRangeHashResponseToGRPCMessage(r *GetRangeHashResponse) *object.GetRangeHashResponse

func GetRangeRequestBodyToGRPCMessage 

func GetRangeRequestBodyToGRPCMessage(r *GetRangeRequestBody) *object.GetRangeRequest_Body

func GetRangeRequestToGRPCMessage 

func GetRangeRequestToGRPCMessage(r *GetRangeRequest) *object.GetRangeRequest

func GetRangeResponseBodyToGRPCMessage 

func GetRangeResponseBodyToGRPCMessage(r *GetRangeResponseBody) *object.GetRangeResponse_Body

func GetRangeResponseToGRPCMessage 

func GetRangeResponseToGRPCMessage(r *GetRangeResponse) *object.GetRangeResponse

func GetRequestBodyToGRPCMessage 

func GetRequestBodyToGRPCMessage(r *GetRequestBody) *object.GetRequest_Body

func GetRequestToGRPCMessage 

func GetRequestToGRPCMessage(r *GetRequest) *object.GetRequest

func GetResponseBodyToGRPCMessage 

func GetResponseBodyToGRPCMessage(r *GetResponseBody) *object.GetResponse_Body

func GetResponseToGRPCMessage 

func GetResponseToGRPCMessage(r *GetResponse) *object.GetResponse

func HeadRequestBodyToGRPCMessage 

func HeadRequestBodyToGRPCMessage(r *HeadRequestBody) *object.HeadRequest_Body

func HeadRequestToGRPCMessage 

func HeadRequestToGRPCMessage(r *HeadRequest) *object.HeadRequest

func HeadResponseBodyToGRPCMessage 

func HeadResponseBodyToGRPCMessage(r *HeadResponseBody) *object.HeadResponse_Body

func HeadResponseToGRPCMessage 

func HeadResponseToGRPCMessage(r *HeadResponse) *object.HeadResponse

func HeaderToGRPCMessage 

func HeaderToGRPCMessage(h *Header) *object.Header

func HeaderWithSignatureToGRPCMessage 

func HeaderWithSignatureToGRPCMessage(h *HeaderWithSignature) *object.HeaderWithSignature

func MatchTypeToGRPCField 

func MatchTypeToGRPCField(t MatchType) object.MatchType

func ObjectToGRPCMessage 

func ObjectToGRPCMessage(o *Object) *object.Object

func PutObjectPartChunkToGRPCMessage 

func PutObjectPartChunkToGRPCMessage(r *PutObjectPartChunk) *object.PutRequest_Body_Chunk

func PutObjectPartInitToGRPCMessage 

func PutObjectPartInitToGRPCMessage(r *PutObjectPartInit) *object.PutRequest_Body_Init

func PutRequestBodyToGRPCMessage 

func PutRequestBodyToGRPCMessage(r *PutRequestBody) *object.PutRequest_Body

func PutRequestToGRPCMessage 

func PutRequestToGRPCMessage(r *PutRequest) *object.PutRequest

func PutResponseBodyToGRPCMessage 

func PutResponseBodyToGRPCMessage(r *PutResponseBody) *object.PutResponse_Body

func PutResponseToGRPCMessage 

func PutResponseToGRPCMessage(r *PutResponse) *object.PutResponse

func RangeToGRPCMessage 

func RangeToGRPCMessage(r *Range) *object.Range

func SearchFilterToGRPCMessage 

func SearchFilterToGRPCMessage(f *SearchFilter) *object.SearchRequest_Body_Filter

func SearchRequestBodyToGRPCMessage 

func SearchRequestBodyToGRPCMessage(r *SearchRequestBody) *object.SearchRequest_Body

func SearchRequestToGRPCMessage 

func SearchRequestToGRPCMessage(r *SearchRequest) *object.SearchRequest

func SearchResponseBodyToGRPCMessage 

func SearchResponseBodyToGRPCMessage(r *SearchResponseBody) *object.SearchResponse_Body

func SearchResponseToGRPCMessage 

func SearchResponseToGRPCMessage(r *SearchResponse) *object.SearchResponse

func ShortHeaderToGRPCMessage 

func ShortHeaderToGRPCMessage(h *ShortHeader) *object.ShortHeader

func SplitHeaderToGRPCMessage 

func SplitHeaderToGRPCMessage(h *SplitHeader) *object.Header_Split

func TypeToGRPCField 

func TypeToGRPCField(t Type) object.ObjectType

Types

type Attribute 

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

func AttributeFromGRPCMessage 

func AttributeFromGRPCMessage(m *object.Header_Attribute) *Attribute

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, error)

func (*Attribute) StableSize 

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

func (*Attribute) Unmarshal 

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

func (*Attribute) UnmarshalJSON 

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

type Client 

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

Client represents universal object transport client.

func NewClient 

func NewClient(opts ...Option) (*Client, error)

func (*Client) Delete 

func (c *Client) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*Client) Get 

func (c *Client) Get(ctx context.Context, req *GetRequest) (GetObjectStreamer, error)

func (*Client) GetRange 

func (c *Client) GetRange(ctx context.Context, req *GetRangeRequest) (GetRangeObjectStreamer, error)

func (*Client) GetRangeHash 

func (c *Client) GetRangeHash(ctx context.Context, req *GetRangeHashRequest) (*GetRangeHashResponse, error)

func (*Client) Head 

func (c *Client) Head(ctx context.Context, req *HeadRequest) (*HeadResponse, error)

func (*Client) Put 

func (c *Client) Put(ctx context.Context) (PutObjectStreamer, error)

func (*Client) Search 

func (c *Client) Search(ctx context.Context, req *SearchRequest) (SearchObjectStreamer, error)

type DeleteRequest 

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

func DeleteRequestFromGRPCMessage 

func DeleteRequestFromGRPCMessage(m *object.DeleteRequest) *DeleteRequest

func (*DeleteRequest) GetBody 

func (r *DeleteRequest) GetBody() *DeleteRequestBody

func (*DeleteRequest) GetMetaHeader 

func (r *DeleteRequest) GetMetaHeader() *session.RequestMetaHeader

func (*DeleteRequest) GetVerificationHeader 

func (r *DeleteRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*DeleteRequest) SetBody 

func (r *DeleteRequest) SetBody(v *DeleteRequestBody)

func (*DeleteRequest) SetMetaHeader 

func (r *DeleteRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*DeleteRequest) SetVerificationHeader 

func (r *DeleteRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type DeleteRequestBody 

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

func DeleteRequestBodyFromGRPCMessage 

func DeleteRequestBodyFromGRPCMessage(m *object.DeleteRequest_Body) *DeleteRequestBody

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, error)

func (*DeleteRequestBody) StableSize 

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

type DeleteResponse 

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

func DeleteResponseFromGRPCMessage 

func DeleteResponseFromGRPCMessage(m *object.DeleteResponse) *DeleteResponse

func (*DeleteResponse) GetBody 

func (r *DeleteResponse) GetBody() *DeleteResponseBody

func (*DeleteResponse) GetMetaHeader 

func (r *DeleteResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*DeleteResponse) GetVerificationHeader 

func (r *DeleteResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*DeleteResponse) SetBody 

func (r *DeleteResponse) SetBody(v *DeleteResponseBody)

func (*DeleteResponse) SetMetaHeader 

func (r *DeleteResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*DeleteResponse) SetVerificationHeader 

func (r *DeleteResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type DeleteResponseBody 

type DeleteResponseBody struct{}

func DeleteResponseBodyFromGRPCMessage 

func DeleteResponseBodyFromGRPCMessage(m *object.DeleteResponse_Body) *DeleteResponseBody

func (*DeleteResponseBody) StableMarshal 

func (r *DeleteResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*DeleteResponseBody) StableSize 

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

type GetHeaderPart 

type GetHeaderPart interface {
	// contains filtered or unexported methods
}

type GetHeaderPartFull 

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

func GetHeaderPartFullFromGRPCMessage 

func GetHeaderPartFullFromGRPCMessage(m *object.HeadResponse_Body_Header) *GetHeaderPartFull

func (*GetHeaderPartFull) GetHeaderWithSignature 

func (h *GetHeaderPartFull) GetHeaderWithSignature() *HeaderWithSignature

func (*GetHeaderPartFull) SetHeaderWithSignature 

func (h *GetHeaderPartFull) SetHeaderWithSignature(v *HeaderWithSignature)

type GetHeaderPartShort 

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

func GetHeaderPartShortFromGRPCMessage 

func GetHeaderPartShortFromGRPCMessage(m *object.HeadResponse_Body_ShortHeader) *GetHeaderPartShort

func (*GetHeaderPartShort) GetShortHeader 

func (h *GetHeaderPartShort) GetShortHeader() *ShortHeader

func (*GetHeaderPartShort) SetShortHeader 

func (h *GetHeaderPartShort) SetShortHeader(v *ShortHeader)

type GetObjectPart 

type GetObjectPart interface {
	// contains filtered or unexported methods
}

type GetObjectPartChunk 

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

func GetObjectPartChunkFromGRPCMessage 

func GetObjectPartChunkFromGRPCMessage(m *object.GetResponse_Body_Chunk) *GetObjectPartChunk

func (*GetObjectPartChunk) GetChunk 

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

func (*GetObjectPartChunk) SetChunk 

func (r *GetObjectPartChunk) SetChunk(v []byte)

type GetObjectPartInit 

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

func GetObjectPartInitFromGRPCMessage 

func GetObjectPartInitFromGRPCMessage(m *object.GetResponse_Body_Init) *GetObjectPartInit

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, error)

func (*GetObjectPartInit) StableSize 

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

type GetObjectStreamer 

type GetObjectStreamer interface {
	Recv() (*GetResponse, error)
}

type GetRangeHashRequest 

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

func GetRangeHashRequestFromGRPCMessage 

func GetRangeHashRequestFromGRPCMessage(m *object.GetRangeHashRequest) *GetRangeHashRequest

func (*GetRangeHashRequest) GetBody 

func (r *GetRangeHashRequest) GetBody() *GetRangeHashRequestBody

func (*GetRangeHashRequest) GetMetaHeader 

func (r *GetRangeHashRequest) GetMetaHeader() *session.RequestMetaHeader

func (*GetRangeHashRequest) GetVerificationHeader 

func (r *GetRangeHashRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*GetRangeHashRequest) SetBody 

func (r *GetRangeHashRequest) SetBody(v *GetRangeHashRequestBody)

func (*GetRangeHashRequest) SetMetaHeader 

func (r *GetRangeHashRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*GetRangeHashRequest) SetVerificationHeader 

func (r *GetRangeHashRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type GetRangeHashRequestBody 

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

func GetRangeHashRequestBodyFromGRPCMessage 

func GetRangeHashRequestBodyFromGRPCMessage(m *object.GetRangeHashRequest_Body) *GetRangeHashRequestBody

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, error)

func (*GetRangeHashRequestBody) StableSize 

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

type GetRangeHashResponse 

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

func GetRangeHashResponseFromGRPCMessage 

func GetRangeHashResponseFromGRPCMessage(m *object.GetRangeHashResponse) *GetRangeHashResponse

func (*GetRangeHashResponse) GetBody 

func (r *GetRangeHashResponse) GetBody() *GetRangeHashResponseBody

func (*GetRangeHashResponse) GetMetaHeader 

func (r *GetRangeHashResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*GetRangeHashResponse) GetVerificationHeader 

func (r *GetRangeHashResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*GetRangeHashResponse) SetBody 

func (r *GetRangeHashResponse) SetBody(v *GetRangeHashResponseBody)

func (*GetRangeHashResponse) SetMetaHeader 

func (r *GetRangeHashResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*GetRangeHashResponse) SetVerificationHeader 

func (r *GetRangeHashResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type GetRangeHashResponseBody 

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

func GetRangeHashResponseBodyFromGRPCMessage 

func GetRangeHashResponseBodyFromGRPCMessage(m *object.GetRangeHashResponse_Body) *GetRangeHashResponseBody

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, error)

func (*GetRangeHashResponseBody) StableSize 

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

type GetRangeObjectStreamer 

type GetRangeObjectStreamer interface {
	Recv() (*GetRangeResponse, error)
}

type GetRangeRequest 

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

func GetRangeRequestFromGRPCMessage 

func GetRangeRequestFromGRPCMessage(m *object.GetRangeRequest) *GetRangeRequest

func (*GetRangeRequest) GetBody 

func (r *GetRangeRequest) GetBody() *GetRangeRequestBody

func (*GetRangeRequest) GetMetaHeader 

func (r *GetRangeRequest) GetMetaHeader() *session.RequestMetaHeader

func (*GetRangeRequest) GetVerificationHeader 

func (r *GetRangeRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*GetRangeRequest) SetBody 

func (r *GetRangeRequest) SetBody(v *GetRangeRequestBody)

func (*GetRangeRequest) SetMetaHeader 

func (r *GetRangeRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*GetRangeRequest) SetVerificationHeader 

func (r *GetRangeRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type GetRangeRequestBody 

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

func GetRangeRequestBodyFromGRPCMessage 

func GetRangeRequestBodyFromGRPCMessage(m *object.GetRangeRequest_Body) *GetRangeRequestBody

func (*GetRangeRequestBody) GetAddress 

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

func (*GetRangeRequestBody) GetRange 

func (r *GetRangeRequestBody) GetRange() *Range

func (*GetRangeRequestBody) SetAddress 

func (r *GetRangeRequestBody) SetAddress(v *refs.Address)

func (*GetRangeRequestBody) SetRange 

func (r *GetRangeRequestBody) SetRange(v *Range)

func (*GetRangeRequestBody) StableMarshal 

func (r *GetRangeRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetRangeRequestBody) StableSize 

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

type GetRangeResponse 

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

func GetRangeResponseFromGRPCMessage 

func GetRangeResponseFromGRPCMessage(m *object.GetRangeResponse) *GetRangeResponse

func (*GetRangeResponse) GetBody 

func (r *GetRangeResponse) GetBody() *GetRangeResponseBody

func (*GetRangeResponse) GetMetaHeader 

func (r *GetRangeResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*GetRangeResponse) GetVerificationHeader 

func (r *GetRangeResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*GetRangeResponse) SetBody 

func (r *GetRangeResponse) SetBody(v *GetRangeResponseBody)

func (*GetRangeResponse) SetMetaHeader 

func (r *GetRangeResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*GetRangeResponse) SetVerificationHeader 

func (r *GetRangeResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type GetRangeResponseBody 

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

func GetRangeResponseBodyFromGRPCMessage 

func GetRangeResponseBodyFromGRPCMessage(m *object.GetRangeResponse_Body) *GetRangeResponseBody

func (*GetRangeResponseBody) GetChunk 

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

func (*GetRangeResponseBody) SetChunk 

func (r *GetRangeResponseBody) SetChunk(v []byte)

func (*GetRangeResponseBody) StableMarshal 

func (r *GetRangeResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*GetRangeResponseBody) StableSize 

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

type GetRequest 

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

func GetRequestFromGRPCMessage 

func GetRequestFromGRPCMessage(m *object.GetRequest) *GetRequest

func (*GetRequest) GetBody 

func (r *GetRequest) GetBody() *GetRequestBody

func (*GetRequest) GetMetaHeader 

func (r *GetRequest) GetMetaHeader() *session.RequestMetaHeader

func (*GetRequest) GetVerificationHeader 

func (r *GetRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*GetRequest) SetBody 

func (r *GetRequest) SetBody(v *GetRequestBody)

func (*GetRequest) SetMetaHeader 

func (r *GetRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*GetRequest) SetVerificationHeader 

func (r *GetRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type GetRequestBody 

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

func GetRequestBodyFromGRPCMessage 

func GetRequestBodyFromGRPCMessage(m *object.GetRequest_Body) *GetRequestBody

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, error)

func (*GetRequestBody) StableSize 

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

type GetResponse 

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

func GetResponseFromGRPCMessage 

func GetResponseFromGRPCMessage(m *object.GetResponse) *GetResponse

func (*GetResponse) GetBody 

func (r *GetResponse) GetBody() *GetResponseBody

func (*GetResponse) GetMetaHeader 

func (r *GetResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*GetResponse) GetVerificationHeader 

func (r *GetResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*GetResponse) SetBody 

func (r *GetResponse) SetBody(v *GetResponseBody)

func (*GetResponse) SetMetaHeader 

func (r *GetResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*GetResponse) SetVerificationHeader 

func (r *GetResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type GetResponseBody 

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

func GetResponseBodyFromGRPCMessage 

func GetResponseBodyFromGRPCMessage(m *object.GetResponse_Body) *GetResponseBody

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, error)

func (*GetResponseBody) StableSize 

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

type HeadRequest 

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

func HeadRequestFromGRPCMessage 

func HeadRequestFromGRPCMessage(m *object.HeadRequest) *HeadRequest

func (*HeadRequest) GetBody 

func (r *HeadRequest) GetBody() *HeadRequestBody

func (*HeadRequest) GetMetaHeader 

func (r *HeadRequest) GetMetaHeader() *session.RequestMetaHeader

func (*HeadRequest) GetVerificationHeader 

func (r *HeadRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*HeadRequest) SetBody 

func (r *HeadRequest) SetBody(v *HeadRequestBody)

func (*HeadRequest) SetMetaHeader 

func (r *HeadRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*HeadRequest) SetVerificationHeader 

func (r *HeadRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type HeadRequestBody 

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

func HeadRequestBodyFromGRPCMessage 

func HeadRequestBodyFromGRPCMessage(m *object.HeadRequest_Body) *HeadRequestBody

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, error)

func (*HeadRequestBody) StableSize 

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

type HeadResponse 

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

func HeadResponseFromGRPCMessage 

func HeadResponseFromGRPCMessage(m *object.HeadResponse) *HeadResponse

func (*HeadResponse) GetBody 

func (r *HeadResponse) GetBody() *HeadResponseBody

func (*HeadResponse) GetMetaHeader 

func (r *HeadResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*HeadResponse) GetVerificationHeader 

func (r *HeadResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*HeadResponse) SetBody 

func (r *HeadResponse) SetBody(v *HeadResponseBody)

func (*HeadResponse) SetMetaHeader 

func (r *HeadResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*HeadResponse) SetVerificationHeader 

func (r *HeadResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type HeadResponseBody 

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

func HeadResponseBodyFromGRPCMessage 

func HeadResponseBodyFromGRPCMessage(m *object.HeadResponse_Body) *HeadResponseBody

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, error)

func (*HeadResponseBody) StableSize 

func (r *HeadResponseBody) StableSize() (size int)
type Header struct {
	// contains filtered or unexported fields
}

func HeaderFromGRPCMessage 

func HeaderFromGRPCMessage(m *object.Header) *Header

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.SessionToken

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.SessionToken)

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, error)

func (*Header) StableSize 

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

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 HeaderWithSignatureFromGRPCMessage 

func HeaderWithSignatureFromGRPCMessage(m *object.HeaderWithSignature) *HeaderWithSignature

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, error)

func (*HeaderWithSignature) StableSize 

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

func (*HeaderWithSignature) Unmarshal 

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

func (*HeaderWithSignature) UnmarshalJSON 

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

type MatchType 

type MatchType uint32
const (
	MatchUnknown MatchType = iota
	MatchStringEqual
)

func MatchTypeFromGRPCField 

func MatchTypeFromGRPCField(t object.MatchType) MatchType

type Object 

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

func ObjectFromGRPCMessage 

func ObjectFromGRPCMessage(m *object.Object) *Object

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, error)

func (*Object) StableSize 

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

func (*Object) StableUnmarshal 

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

func (*Object) Unmarshal 

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

func (*Object) UnmarshalJSON 

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

type Option 

type Option func(*cfg)

Option represents Client option.

func WithGRPCCallOpts 

func WithGRPCCallOpts(v []grpc.CallOption) Option

func WithGRPCClient 

func WithGRPCClient(v *object.Client) Option

func WithGRPCClientOpts 

func WithGRPCClientOpts(v []object.Option) Option

func WithGRPCServiceClient 

func WithGRPCServiceClient(v object.ObjectServiceClient) Option

func WithGlobalOpts 

func WithGlobalOpts(v ...client.Option) Option

type PutObjectPart 

type PutObjectPart interface {
	// contains filtered or unexported methods
}

type PutObjectPartChunk 

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

func PutObjectPartChunkFromGRPCMessage 

func PutObjectPartChunkFromGRPCMessage(m *object.PutRequest_Body_Chunk) *PutObjectPartChunk

func (*PutObjectPartChunk) GetChunk 

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

func (*PutObjectPartChunk) SetChunk 

func (r *PutObjectPartChunk) SetChunk(v []byte)

type PutObjectPartInit 

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

func PutObjectPartInitFromGRPCMessage 

func PutObjectPartInitFromGRPCMessage(m *object.PutRequest_Body_Init) *PutObjectPartInit

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, error)

func (*PutObjectPartInit) StableSize 

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

type PutObjectStreamer 

type PutObjectStreamer interface {
	Send(*PutRequest) error
	CloseAndRecv() (*PutResponse, error)
}

type PutRequest 

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

func PutRequestFromGRPCMessage 

func PutRequestFromGRPCMessage(m *object.PutRequest) *PutRequest

func (*PutRequest) GetBody 

func (r *PutRequest) GetBody() *PutRequestBody

func (*PutRequest) GetMetaHeader 

func (r *PutRequest) GetMetaHeader() *session.RequestMetaHeader

func (*PutRequest) GetVerificationHeader 

func (r *PutRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*PutRequest) SetBody 

func (r *PutRequest) SetBody(v *PutRequestBody)

func (*PutRequest) SetMetaHeader 

func (r *PutRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*PutRequest) SetVerificationHeader 

func (r *PutRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type PutRequestBody 

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

func PutRequestBodyFromGRPCMessage 

func PutRequestBodyFromGRPCMessage(m *object.PutRequest_Body) *PutRequestBody

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, error)

func (*PutRequestBody) StableSize 

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

type PutResponse 

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

func PutResponseFromGRPCMessage 

func PutResponseFromGRPCMessage(m *object.PutResponse) *PutResponse

func (*PutResponse) GetBody 

func (r *PutResponse) GetBody() *PutResponseBody

func (*PutResponse) GetMetaHeader 

func (r *PutResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*PutResponse) GetVerificationHeader 

func (r *PutResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*PutResponse) SetBody 

func (r *PutResponse) SetBody(v *PutResponseBody)

func (*PutResponse) SetMetaHeader 

func (r *PutResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*PutResponse) SetVerificationHeader 

func (r *PutResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type PutResponseBody 

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

func PutResponseBodyFromGRPCMessage 

func PutResponseBodyFromGRPCMessage(m *object.PutResponse_Body) *PutResponseBody

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, error)

func (*PutResponseBody) StableSize 

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

type Range 

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

func RangeFromGRPCMessage 

func RangeFromGRPCMessage(m *object.Range) *Range

func (*Range) GetLength 

func (r *Range) GetLength() uint64

func (*Range) GetOffset 

func (r *Range) GetOffset() uint64

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, error)

func (*Range) StableSize 

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

type SearchFilter 

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

func SearchFilterFromGRPCMessage 

func SearchFilterFromGRPCMessage(m *object.SearchRequest_Body_Filter) *SearchFilter

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) 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, error)

func (*SearchFilter) StableSize 

func (f *SearchFilter) StableSize() (size int)

type SearchObjectStreamer 

type SearchObjectStreamer interface {
	Recv() (*SearchResponse, error)
}

type SearchRequest 

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

func SearchRequestFromGRPCMessage 

func SearchRequestFromGRPCMessage(m *object.SearchRequest) *SearchRequest

func (*SearchRequest) GetBody 

func (r *SearchRequest) GetBody() *SearchRequestBody

func (*SearchRequest) GetMetaHeader 

func (r *SearchRequest) GetMetaHeader() *session.RequestMetaHeader

func (*SearchRequest) GetVerificationHeader 

func (r *SearchRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*SearchRequest) SetBody 

func (r *SearchRequest) SetBody(v *SearchRequestBody)

func (*SearchRequest) SetMetaHeader 

func (r *SearchRequest) SetMetaHeader(v *session.RequestMetaHeader)

func (*SearchRequest) SetVerificationHeader 

func (r *SearchRequest) SetVerificationHeader(v *session.RequestVerificationHeader)

type SearchRequestBody 

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

func SearchRequestBodyFromGRPCMessage 

func SearchRequestBodyFromGRPCMessage(m *object.SearchRequest_Body) *SearchRequestBody

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, error)

func (*SearchRequestBody) StableSize 

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

type SearchResponse 

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

func SearchResponseFromGRPCMessage 

func SearchResponseFromGRPCMessage(m *object.SearchResponse) *SearchResponse

func (*SearchResponse) GetBody 

func (r *SearchResponse) GetBody() *SearchResponseBody

func (*SearchResponse) GetMetaHeader 

func (r *SearchResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*SearchResponse) GetVerificationHeader 

func (r *SearchResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*SearchResponse) SetBody 

func (r *SearchResponse) SetBody(v *SearchResponseBody)

func (*SearchResponse) SetMetaHeader 

func (r *SearchResponse) SetMetaHeader(v *session.ResponseMetaHeader)

func (*SearchResponse) SetVerificationHeader 

func (r *SearchResponse) SetVerificationHeader(v *session.ResponseVerificationHeader)

type SearchResponseBody 

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

func SearchResponseBodyFromGRPCMessage 

func SearchResponseBodyFromGRPCMessage(m *object.SearchResponse_Body) *SearchResponseBody

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, error)

func (*SearchResponseBody) StableSize 

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

type Service 

type Service interface {
	Get(context.Context, *GetRequest) (GetObjectStreamer, error)
	Put(context.Context) (PutObjectStreamer, error)
	Head(context.Context, *HeadRequest) (*HeadResponse, error)
	Search(context.Context, *SearchRequest) (SearchObjectStreamer, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	GetRange(context.Context, *GetRangeRequest) (GetRangeObjectStreamer, error)
	GetRangeHash(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error)
}

type ShortHeader 

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

func ShortHeaderFromGRPCMessage 

func ShortHeaderFromGRPCMessage(m *object.ShortHeader) *ShortHeader

func (*ShortHeader) GetCreationEpoch 

func (h *ShortHeader) GetCreationEpoch() uint64

func (*ShortHeader) GetObjectType 

func (h *ShortHeader) GetObjectType() Type

func (*ShortHeader) GetOwnerID 

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

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

func (h *ShortHeader) SetObjectType(v Type)

func (*ShortHeader) SetOwnerID 

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

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, error)

func (*ShortHeader) StableSize 

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

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 SplitHeaderFromGRPCMessage 

func SplitHeaderFromGRPCMessage(m *object.Header_Split) *SplitHeader

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

func (h *SplitHeader) StableMarshal(buf []byte) ([]byte, error)

func (*SplitHeader) StableSize 

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

func (*SplitHeader) Unmarshal 

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

func (*SplitHeader) UnmarshalJSON 

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

type Type 

type Type uint32
const (
	TypeRegular Type = iota
	TypeTombstone
	TypeStorageGroup
)

func TypeFromGRPCField 

func TypeFromGRPCField(t object.ObjectType) 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.