object

package
v2.0.0-...-d29d931 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

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"

	// FilterHeaderParent 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 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 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 GetRangePartChunkToGRPCMessage 

func GetRangePartChunkToGRPCMessage(r *GetRangePartChunk) *object.GetRangeResponse_Body_Chunk

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 SplitInfoToGRPCMessage 

func SplitInfoToGRPCMessage(s *SplitInfo) *object.SplitInfo

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 {
	// contains filtered or unexported fields
}

func DeleteResponseBodyFromGRPCMessage 

func DeleteResponseBodyFromGRPCMessage(m *object.DeleteResponse_Body) *DeleteResponseBody

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

func (*DeleteResponseBody) StableSize 

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

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 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 GetRangePart 

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

type GetRangePartChunk 

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

func GetRangePartChunkFromGRPCMessage 

func GetRangePartChunkFromGRPCMessage(m *object.GetRangeResponse_Body_Chunk) *GetRangePartChunk

func (*GetRangePartChunk) GetChunk 

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

func (*GetRangePartChunk) SetChunk 

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

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) 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, 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) 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, 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
	MatchStringNotEqual
	MatchNotPresent
)

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

func (*SearchFilter) StableSize 

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

func (*SearchFilter) UnmarshalJSON 

func (f *SearchFilter) UnmarshalJSON(data []byte) error

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

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

func SplitInfoFromGRPCMessage 

func SplitInfoFromGRPCMessage(m *object.SplitInfo) *SplitInfo

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

func (*SplitInfo) StableSize 

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

func (*SplitInfo) Unmarshal 

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

type Type 

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

func TypeFromGRPCField 

func TypeFromGRPCField(t object.ObjectType) Type

func TypeFromString 

func TypeFromString(s string) Type

func (Type) String 

func (t Type) String() string

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.