Versions in this module Expand all Collapse all v2 v2.14.0 Oct 17, 2022 v2.13.1 Aug 1, 2022 v2.13.0 Jul 4, 2022 v2.12.2 Jun 3, 2022 v2.12.1 Mar 15, 2022 v2.12.0 Feb 25, 2022retracted Changes in this version type ObjectType + const ObjectType_LOCK v2.11.1 Dec 28, 2021 v2.11.0 Dec 2, 2021 Changes in this version + var ErrNilObjectServiceClient = errors.New("object gRPC client is nil") + var File_object_grpc_service_proto protoreflect.FileDescriptor + var File_object_grpc_types_proto protoreflect.FileDescriptor + var File_v2_object_grpc_status_proto protoreflect.FileDescriptor + var MatchType_name = map[int32]string + var MatchType_value = map[string]int32 + var ObjectService_ServiceDesc = grpc.ServiceDesc + var ObjectType_name = map[int32]string + var ObjectType_value = map[string]int32 + var StatusCommon_name = map[int32]string + var StatusCommon_value = map[string]int32 + var StatusPut_name = map[int32]string + var StatusPut_value = map[string]int32 + func RegisterObjectServiceServer(s grpc.ServiceRegistrar, srv ObjectServiceServer) + type Client struct + func NewClient(c ObjectServiceClient, opts ...Option) (*Client, error) + func (c *Client) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error) + func (c *Client) Get(ctx context.Context, req *GetRequest) (ObjectService_GetClient, error) + func (c *Client) GetRange(ctx context.Context, req *GetRangeRequest) (ObjectService_GetRangeClient, error) + func (c *Client) GetRangeHash(ctx context.Context, req *GetRangeHashRequest) (*GetRangeHashResponse, error) + func (c *Client) Head(ctx context.Context, req *HeadRequest) (*HeadResponse, error) + func (c *Client) Put(ctx context.Context) (ObjectService_PutClient, error) + func (c *Client) Search(ctx context.Context, req *SearchRequest) (ObjectService_SearchClient, error) + type DeleteRequest struct + Body *DeleteRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) SetBody(v *DeleteRequest_Body) + func (m *DeleteRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *DeleteRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *DeleteRequest) GetBody() *DeleteRequest_Body + func (x *DeleteRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *DeleteRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *DeleteRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRequest) Reset() + func (x *DeleteRequest) String() string + type DeleteRequest_Body struct + Address *grpc1.Address + func (*DeleteRequest_Body) Descriptor() ([]byte, []int) + func (*DeleteRequest_Body) ProtoMessage() + func (m *DeleteRequest_Body) SetAddress(v *refs.Address) + func (x *DeleteRequest_Body) GetAddress() *grpc1.Address + func (x *DeleteRequest_Body) ProtoReflect() protoreflect.Message + func (x *DeleteRequest_Body) Reset() + func (x *DeleteRequest_Body) String() string + type DeleteResponse struct + Body *DeleteResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) SetBody(v *DeleteResponse_Body) + func (m *DeleteResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *DeleteResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *DeleteResponse) GetBody() *DeleteResponse_Body + func (x *DeleteResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *DeleteResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) String() string + type DeleteResponse_Body struct + Tombstone *grpc1.Address + func (*DeleteResponse_Body) Descriptor() ([]byte, []int) + func (*DeleteResponse_Body) ProtoMessage() + func (x *DeleteResponse_Body) GetTombstone() *grpc1.Address + func (x *DeleteResponse_Body) ProtoReflect() protoreflect.Message + func (x *DeleteResponse_Body) Reset() + func (x *DeleteResponse_Body) SetTombstone(v *refs.Address) + func (x *DeleteResponse_Body) String() string + type GetRangeHashRequest struct + Body *GetRangeHashRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*GetRangeHashRequest) Descriptor() ([]byte, []int) + func (*GetRangeHashRequest) ProtoMessage() + func (m *GetRangeHashRequest) SetBody(v *GetRangeHashRequest_Body) + func (m *GetRangeHashRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *GetRangeHashRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *GetRangeHashRequest) GetBody() *GetRangeHashRequest_Body + func (x *GetRangeHashRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *GetRangeHashRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *GetRangeHashRequest) ProtoReflect() protoreflect.Message + func (x *GetRangeHashRequest) Reset() + func (x *GetRangeHashRequest) String() string + type GetRangeHashRequest_Body struct + Address *grpc1.Address + Ranges []*Range + Salt []byte + Type grpc1.ChecksumType + func (*GetRangeHashRequest_Body) Descriptor() ([]byte, []int) + func (*GetRangeHashRequest_Body) ProtoMessage() + func (m *GetRangeHashRequest_Body) SetAddress(v *refs.Address) + func (m *GetRangeHashRequest_Body) SetRanges(v []*Range) + func (m *GetRangeHashRequest_Body) SetSalt(v []byte) + func (m *GetRangeHashRequest_Body) SetType(v refs.ChecksumType) + func (x *GetRangeHashRequest_Body) GetAddress() *grpc1.Address + func (x *GetRangeHashRequest_Body) GetRanges() []*Range + func (x *GetRangeHashRequest_Body) GetSalt() []byte + func (x *GetRangeHashRequest_Body) GetType() grpc1.ChecksumType + func (x *GetRangeHashRequest_Body) ProtoReflect() protoreflect.Message + func (x *GetRangeHashRequest_Body) Reset() + func (x *GetRangeHashRequest_Body) String() string + type GetRangeHashResponse struct + Body *GetRangeHashResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*GetRangeHashResponse) Descriptor() ([]byte, []int) + func (*GetRangeHashResponse) ProtoMessage() + func (m *GetRangeHashResponse) SetBody(v *GetRangeHashResponse_Body) + func (m *GetRangeHashResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *GetRangeHashResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *GetRangeHashResponse) GetBody() *GetRangeHashResponse_Body + func (x *GetRangeHashResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *GetRangeHashResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *GetRangeHashResponse) ProtoReflect() protoreflect.Message + func (x *GetRangeHashResponse) Reset() + func (x *GetRangeHashResponse) String() string + type GetRangeHashResponse_Body struct + HashList [][]byte + Type grpc1.ChecksumType + func (*GetRangeHashResponse_Body) Descriptor() ([]byte, []int) + func (*GetRangeHashResponse_Body) ProtoMessage() + func (m *GetRangeHashResponse_Body) SetHashList(v [][]byte) + func (m *GetRangeHashResponse_Body) SetType(v refs.ChecksumType) + func (x *GetRangeHashResponse_Body) GetHashList() [][]byte + func (x *GetRangeHashResponse_Body) GetType() grpc1.ChecksumType + func (x *GetRangeHashResponse_Body) ProtoReflect() protoreflect.Message + func (x *GetRangeHashResponse_Body) Reset() + func (x *GetRangeHashResponse_Body) String() string + type GetRangeRequest struct + Body *GetRangeRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*GetRangeRequest) Descriptor() ([]byte, []int) + func (*GetRangeRequest) ProtoMessage() + func (m *GetRangeRequest) SetBody(v *GetRangeRequest_Body) + func (m *GetRangeRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *GetRangeRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *GetRangeRequest) GetBody() *GetRangeRequest_Body + func (x *GetRangeRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *GetRangeRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *GetRangeRequest) ProtoReflect() protoreflect.Message + func (x *GetRangeRequest) Reset() + func (x *GetRangeRequest) String() string + type GetRangeRequest_Body struct + Address *grpc1.Address + Range *Range + Raw bool + func (*GetRangeRequest_Body) Descriptor() ([]byte, []int) + func (*GetRangeRequest_Body) ProtoMessage() + func (m *GetRangeRequest_Body) SetAddress(v *refs.Address) + func (m *GetRangeRequest_Body) SetRange(v *Range) + func (m *GetRangeRequest_Body) SetRaw(v bool) + func (x *GetRangeRequest_Body) GetAddress() *grpc1.Address + func (x *GetRangeRequest_Body) GetRange() *Range + func (x *GetRangeRequest_Body) GetRaw() bool + func (x *GetRangeRequest_Body) ProtoReflect() protoreflect.Message + func (x *GetRangeRequest_Body) Reset() + func (x *GetRangeRequest_Body) String() string + type GetRangeResponse struct + Body *GetRangeResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*GetRangeResponse) Descriptor() ([]byte, []int) + func (*GetRangeResponse) ProtoMessage() + func (m *GetRangeResponse) SetBody(v *GetRangeResponse_Body) + func (m *GetRangeResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *GetRangeResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *GetRangeResponse) GetBody() *GetRangeResponse_Body + func (x *GetRangeResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *GetRangeResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *GetRangeResponse) ProtoReflect() protoreflect.Message + func (x *GetRangeResponse) Reset() + func (x *GetRangeResponse) String() string + type GetRangeResponse_Body struct + RangePart isGetRangeResponse_Body_RangePart + func (*GetRangeResponse_Body) Descriptor() ([]byte, []int) + func (*GetRangeResponse_Body) ProtoMessage() + func (m *GetRangeResponse_Body) GetRangePart() isGetRangeResponse_Body_RangePart + func (m *GetRangeResponse_Body) SetChunk(v *GetRangeResponse_Body_Chunk) + func (m *GetRangeResponse_Body) SetSplitInfo(v *SplitInfo) + func (x *GetRangeResponse_Body) GetChunk() []byte + func (x *GetRangeResponse_Body) GetSplitInfo() *SplitInfo + func (x *GetRangeResponse_Body) ProtoReflect() protoreflect.Message + func (x *GetRangeResponse_Body) Reset() + func (x *GetRangeResponse_Body) String() string + type GetRangeResponse_Body_Chunk struct + Chunk []byte + func (m *GetRangeResponse_Body_Chunk) GetChunk() []byte + func (m *GetRangeResponse_Body_Chunk) SetChunk(v []byte) + type GetRangeResponse_Body_SplitInfo struct + SplitInfo *SplitInfo + type GetRequest struct + Body *GetRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) SetBody(v *GetRequest_Body) + func (m *GetRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *GetRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *GetRequest) GetBody() *GetRequest_Body + func (x *GetRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *GetRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type GetRequest_Body struct + Address *grpc1.Address + Raw bool + func (*GetRequest_Body) Descriptor() ([]byte, []int) + func (*GetRequest_Body) ProtoMessage() + func (m *GetRequest_Body) SetAddress(v *refs.Address) + func (m *GetRequest_Body) SetRaw(v bool) + func (x *GetRequest_Body) GetAddress() *grpc1.Address + func (x *GetRequest_Body) GetRaw() bool + func (x *GetRequest_Body) ProtoReflect() protoreflect.Message + func (x *GetRequest_Body) Reset() + func (x *GetRequest_Body) String() string + type GetResponse struct + Body *GetResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) SetBody(v *GetResponse_Body) + func (m *GetResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *GetResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *GetResponse) GetBody() *GetResponse_Body + func (x *GetResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *GetResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *GetResponse) ProtoReflect() protoreflect.Message + func (x *GetResponse) Reset() + func (x *GetResponse) String() string + type GetResponse_Body struct + ObjectPart isGetResponse_Body_ObjectPart + func (*GetResponse_Body) Descriptor() ([]byte, []int) + func (*GetResponse_Body) ProtoMessage() + func (m *GetResponse_Body) GetObjectPart() isGetResponse_Body_ObjectPart + func (m *GetResponse_Body) SetChunk(v *GetResponse_Body_Chunk) + func (m *GetResponse_Body) SetInit(v *GetResponse_Body_Init) + func (m *GetResponse_Body) SetSplitInfo(v *SplitInfo) + func (x *GetResponse_Body) GetChunk() []byte + func (x *GetResponse_Body) GetInit() *GetResponse_Body_Init + func (x *GetResponse_Body) GetSplitInfo() *SplitInfo + func (x *GetResponse_Body) ProtoReflect() protoreflect.Message + func (x *GetResponse_Body) Reset() + func (x *GetResponse_Body) String() string + type GetResponse_Body_Chunk struct + Chunk []byte + func (m *GetResponse_Body_Chunk) GetChunk() []byte + func (m *GetResponse_Body_Chunk) SetChunk(v []byte) + type GetResponse_Body_Init struct + Header *Header + ObjectId *grpc1.ObjectID + Signature *grpc1.Signature + func (*GetResponse_Body_Init) Descriptor() ([]byte, []int) + func (*GetResponse_Body_Init) ProtoMessage() + func (m *GetResponse_Body_Init) SetHeader(v *Header) + func (m *GetResponse_Body_Init) SetObjectId(v *refs.ObjectID) + func (m *GetResponse_Body_Init) SetSignature(v *refs.Signature) + func (x *GetResponse_Body_Init) GetHeader() *Header + func (x *GetResponse_Body_Init) GetObjectId() *grpc1.ObjectID + func (x *GetResponse_Body_Init) GetSignature() *grpc1.Signature + func (x *GetResponse_Body_Init) ProtoReflect() protoreflect.Message + func (x *GetResponse_Body_Init) Reset() + func (x *GetResponse_Body_Init) String() string + type GetResponse_Body_Init_ struct + Init *GetResponse_Body_Init + type GetResponse_Body_SplitInfo struct + SplitInfo *SplitInfo + type HeadRequest struct + Body *HeadRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*HeadRequest) Descriptor() ([]byte, []int) + func (*HeadRequest) ProtoMessage() + func (m *HeadRequest) SetBody(v *HeadRequest_Body) + func (m *HeadRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *HeadRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *HeadRequest) GetBody() *HeadRequest_Body + func (x *HeadRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *HeadRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *HeadRequest) ProtoReflect() protoreflect.Message + func (x *HeadRequest) Reset() + func (x *HeadRequest) String() string + type HeadRequest_Body struct + Address *grpc1.Address + MainOnly bool + Raw bool + func (*HeadRequest_Body) Descriptor() ([]byte, []int) + func (*HeadRequest_Body) ProtoMessage() + func (m *HeadRequest_Body) SetAddress(v *refs.Address) + func (m *HeadRequest_Body) SetMainOnly(v bool) + func (m *HeadRequest_Body) SetRaw(v bool) + func (x *HeadRequest_Body) GetAddress() *grpc1.Address + func (x *HeadRequest_Body) GetMainOnly() bool + func (x *HeadRequest_Body) GetRaw() bool + func (x *HeadRequest_Body) ProtoReflect() protoreflect.Message + func (x *HeadRequest_Body) Reset() + func (x *HeadRequest_Body) String() string + type HeadResponse struct + Body *HeadResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*HeadResponse) Descriptor() ([]byte, []int) + func (*HeadResponse) ProtoMessage() + func (m *HeadResponse) SetBody(v *HeadResponse_Body) + func (m *HeadResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *HeadResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *HeadResponse) GetBody() *HeadResponse_Body + func (x *HeadResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *HeadResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *HeadResponse) ProtoReflect() protoreflect.Message + func (x *HeadResponse) Reset() + func (x *HeadResponse) String() string + type HeadResponse_Body struct + Head isHeadResponse_Body_Head + func (*HeadResponse_Body) Descriptor() ([]byte, []int) + func (*HeadResponse_Body) ProtoMessage() + func (m *HeadResponse_Body) GetHead() isHeadResponse_Body_Head + func (m *HeadResponse_Body) SetHeader(v *HeaderWithSignature) + func (m *HeadResponse_Body) SetShortHeader(v *ShortHeader) + func (m *HeadResponse_Body) SetSplitInfo(v *SplitInfo) + func (x *HeadResponse_Body) GetHeader() *HeaderWithSignature + func (x *HeadResponse_Body) GetShortHeader() *ShortHeader + func (x *HeadResponse_Body) GetSplitInfo() *SplitInfo + func (x *HeadResponse_Body) ProtoReflect() protoreflect.Message + func (x *HeadResponse_Body) Reset() + func (x *HeadResponse_Body) String() string + type HeadResponse_Body_Header struct + Header *HeaderWithSignature + type HeadResponse_Body_ShortHeader struct + ShortHeader *ShortHeader + type HeadResponse_Body_SplitInfo struct + SplitInfo *SplitInfo + type Header struct + Attributes []*Header_Attribute + ContainerId *grpc.ContainerID + CreationEpoch uint64 + HomomorphicHash *grpc.Checksum + ObjectType ObjectType + OwnerId *grpc.OwnerID + PayloadHash *grpc.Checksum + PayloadLength uint64 + SessionToken *grpc1.SessionToken + Split *Header_Split + Version *grpc.Version + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (m *Header) SetAttributes(v []*Header_Attribute) + func (m *Header) SetContainerId(v *refs.ContainerID) + func (m *Header) SetCreationEpoch(v uint64) + func (m *Header) SetHomomorphicHash(v *refs.Checksum) + func (m *Header) SetObjectType(v ObjectType) + func (m *Header) SetOwnerId(v *refs.OwnerID) + func (m *Header) SetPayloadHash(v *refs.Checksum) + func (m *Header) SetPayloadLength(v uint64) + func (m *Header) SetSessionToken(v *session.SessionToken) + func (m *Header) SetSplit(v *Header_Split) + func (m *Header) SetVersion(v *refs.Version) + func (x *Header) GetAttributes() []*Header_Attribute + func (x *Header) GetContainerId() *grpc.ContainerID + func (x *Header) GetCreationEpoch() uint64 + func (x *Header) GetHomomorphicHash() *grpc.Checksum + func (x *Header) GetObjectType() ObjectType + func (x *Header) GetOwnerId() *grpc.OwnerID + func (x *Header) GetPayloadHash() *grpc.Checksum + func (x *Header) GetPayloadLength() uint64 + func (x *Header) GetSessionToken() *grpc1.SessionToken + func (x *Header) GetSplit() *Header_Split + func (x *Header) GetVersion() *grpc.Version + func (x *Header) ProtoReflect() protoreflect.Message + func (x *Header) Reset() + func (x *Header) String() string + type HeaderWithSignature struct + Header *Header + Signature *grpc1.Signature + func (*HeaderWithSignature) Descriptor() ([]byte, []int) + func (*HeaderWithSignature) ProtoMessage() + func (m *HeaderWithSignature) SetHeader(v *Header) + func (m *HeaderWithSignature) SetSignature(v *refs.Signature) + func (x *HeaderWithSignature) GetHeader() *Header + func (x *HeaderWithSignature) GetSignature() *grpc1.Signature + func (x *HeaderWithSignature) ProtoReflect() protoreflect.Message + func (x *HeaderWithSignature) Reset() + func (x *HeaderWithSignature) String() string + type Header_Attribute struct + Key string + Value string + func (*Header_Attribute) Descriptor() ([]byte, []int) + func (*Header_Attribute) ProtoMessage() + func (m *Header_Attribute) SetKey(v string) + func (m *Header_Attribute) SetValue(v string) + func (x *Header_Attribute) GetKey() string + func (x *Header_Attribute) GetValue() string + func (x *Header_Attribute) ProtoReflect() protoreflect.Message + func (x *Header_Attribute) Reset() + func (x *Header_Attribute) String() string + type Header_Split struct + Children []*grpc.ObjectID + Parent *grpc.ObjectID + ParentHeader *Header + ParentSignature *grpc.Signature + Previous *grpc.ObjectID + SplitId []byte + func (*Header_Split) Descriptor() ([]byte, []int) + func (*Header_Split) ProtoMessage() + func (m *Header_Split) SetChildren(v []*refs.ObjectID) + func (m *Header_Split) SetParent(v *refs.ObjectID) + func (m *Header_Split) SetParentHeader(v *Header) + func (m *Header_Split) SetParentSignature(v *refs.Signature) + func (m *Header_Split) SetPrevious(v *refs.ObjectID) + func (m *Header_Split) SetSplitId(v []byte) + func (x *Header_Split) GetChildren() []*grpc.ObjectID + func (x *Header_Split) GetParent() *grpc.ObjectID + func (x *Header_Split) GetParentHeader() *Header + func (x *Header_Split) GetParentSignature() *grpc.Signature + func (x *Header_Split) GetPrevious() *grpc.ObjectID + func (x *Header_Split) GetSplitId() []byte + func (x *Header_Split) ProtoReflect() protoreflect.Message + func (x *Header_Split) Reset() + func (x *Header_Split) String() string + type MatchType int32 + const MatchType_COMMON_PREFIX + const MatchType_MATCH_TYPE_UNSPECIFIED + const MatchType_NOT_PRESENT + const MatchType_STRING_EQUAL + const MatchType_STRING_NOT_EQUAL + func (MatchType) Descriptor() protoreflect.EnumDescriptor + func (MatchType) EnumDescriptor() ([]byte, []int) + func (MatchType) Type() protoreflect.EnumType + func (x *MatchType) FromString(s string) bool + func (x MatchType) Enum() *MatchType + func (x MatchType) Number() protoreflect.EnumNumber + func (x MatchType) String() string + type Object struct + Header *Header + ObjectId *grpc.ObjectID + Payload []byte + Signature *grpc.Signature + func (*Object) Descriptor() ([]byte, []int) + func (*Object) ProtoMessage() + func (m *Object) SetHeader(v *Header) + func (m *Object) SetObjectId(v *refs.ObjectID) + func (m *Object) SetPayload(v []byte) + func (m *Object) SetSignature(v *refs.Signature) + func (x *Object) GetHeader() *Header + func (x *Object) GetObjectId() *grpc.ObjectID + func (x *Object) GetPayload() []byte + func (x *Object) GetSignature() *grpc.Signature + func (x *Object) ProtoReflect() protoreflect.Message + func (x *Object) Reset() + func (x *Object) String() string + type ObjectServiceClient interface + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (ObjectService_GetClient, error) + GetRange func(ctx context.Context, in *GetRangeRequest, opts ...grpc.CallOption) (ObjectService_GetRangeClient, error) + GetRangeHash func(ctx context.Context, in *GetRangeHashRequest, opts ...grpc.CallOption) (*GetRangeHashResponse, error) + Head func(ctx context.Context, in *HeadRequest, opts ...grpc.CallOption) (*HeadResponse, error) + Put func(ctx context.Context, opts ...grpc.CallOption) (ObjectService_PutClient, error) + Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (ObjectService_SearchClient, error) + func NewObjectServiceClient(cc grpc.ClientConnInterface) ObjectServiceClient + type ObjectServiceServer interface + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Get func(*GetRequest, ObjectService_GetServer) error + GetRange func(*GetRangeRequest, ObjectService_GetRangeServer) error + GetRangeHash func(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error) + Head func(context.Context, *HeadRequest) (*HeadResponse, error) + Put func(ObjectService_PutServer) error + Search func(*SearchRequest, ObjectService_SearchServer) error + type ObjectService_GetClient interface + Recv func() (*GetResponse, error) + type ObjectService_GetRangeClient interface + Recv func() (*GetRangeResponse, error) + type ObjectService_GetRangeServer interface + Send func(*GetRangeResponse) error + type ObjectService_GetServer interface + Send func(*GetResponse) error + type ObjectService_PutClient interface + CloseAndRecv func() (*PutResponse, error) + Send func(*PutRequest) error + type ObjectService_PutServer interface + Recv func() (*PutRequest, error) + SendAndClose func(*PutResponse) error + type ObjectService_SearchClient interface + Recv func() (*SearchResponse, error) + type ObjectService_SearchServer interface + Send func(*SearchResponse) error + type ObjectType int32 + const ObjectType_REGULAR + const ObjectType_STORAGE_GROUP + const ObjectType_TOMBSTONE + func (ObjectType) Descriptor() protoreflect.EnumDescriptor + func (ObjectType) EnumDescriptor() ([]byte, []int) + func (ObjectType) Type() protoreflect.EnumType + func (x *ObjectType) FromString(s string) bool + func (x ObjectType) Enum() *ObjectType + func (x ObjectType) Number() protoreflect.EnumNumber + func (x ObjectType) String() string + type Option func(*cfg) + func WithCallOptions(opts []grpc.CallOption) Option + type PutIncompleteDetail struct + Statuses []*grpc.Status + func (*PutIncompleteDetail) Descriptor() ([]byte, []int) + func (*PutIncompleteDetail) ProtoMessage() + func (x *PutIncompleteDetail) GetStatuses() []*grpc.Status + func (x *PutIncompleteDetail) ProtoReflect() protoreflect.Message + func (x *PutIncompleteDetail) Reset() + func (x *PutIncompleteDetail) String() string + type PutRequest struct + Body *PutRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (m *PutRequest) SetBody(v *PutRequest_Body) + func (m *PutRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *PutRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *PutRequest) GetBody() *PutRequest_Body + func (x *PutRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *PutRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *PutRequest) ProtoReflect() protoreflect.Message + func (x *PutRequest) Reset() + func (x *PutRequest) String() string + type PutRequest_Body struct + ObjectPart isPutRequest_Body_ObjectPart + func (*PutRequest_Body) Descriptor() ([]byte, []int) + func (*PutRequest_Body) ProtoMessage() + func (m *PutRequest_Body) GetObjectPart() isPutRequest_Body_ObjectPart + func (m *PutRequest_Body) SetChunk(v *PutRequest_Body_Chunk) + func (m *PutRequest_Body) SetInit(v *PutRequest_Body_Init) + func (x *PutRequest_Body) GetChunk() []byte + func (x *PutRequest_Body) GetInit() *PutRequest_Body_Init + func (x *PutRequest_Body) ProtoReflect() protoreflect.Message + func (x *PutRequest_Body) Reset() + func (x *PutRequest_Body) String() string + type PutRequest_Body_Chunk struct + Chunk []byte + func (m *PutRequest_Body_Chunk) GetChunk() []byte + func (m *PutRequest_Body_Chunk) SetChunk(v []byte) + type PutRequest_Body_Init struct + CopiesNumber uint32 + Header *Header + ObjectId *grpc1.ObjectID + Signature *grpc1.Signature + func (*PutRequest_Body_Init) Descriptor() ([]byte, []int) + func (*PutRequest_Body_Init) ProtoMessage() + func (m *PutRequest_Body_Init) SetCopiesNumber(v uint32) + func (m *PutRequest_Body_Init) SetHeader(v *Header) + func (m *PutRequest_Body_Init) SetObjectId(v *refs.ObjectID) + func (m *PutRequest_Body_Init) SetSignature(v *refs.Signature) + func (x *PutRequest_Body_Init) GetCopiesNumber() uint32 + func (x *PutRequest_Body_Init) GetHeader() *Header + func (x *PutRequest_Body_Init) GetObjectId() *grpc1.ObjectID + func (x *PutRequest_Body_Init) GetSignature() *grpc1.Signature + func (x *PutRequest_Body_Init) ProtoReflect() protoreflect.Message + func (x *PutRequest_Body_Init) Reset() + func (x *PutRequest_Body_Init) String() string + type PutRequest_Body_Init_ struct + Init *PutRequest_Body_Init + type PutResponse struct + Body *PutResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*PutResponse) Descriptor() ([]byte, []int) + func (*PutResponse) ProtoMessage() + func (m *PutResponse) SetBody(v *PutResponse_Body) + func (m *PutResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *PutResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *PutResponse) GetBody() *PutResponse_Body + func (x *PutResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *PutResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *PutResponse) ProtoReflect() protoreflect.Message + func (x *PutResponse) Reset() + func (x *PutResponse) String() string + type PutResponse_Body struct + ObjectId *grpc1.ObjectID + func (*PutResponse_Body) Descriptor() ([]byte, []int) + func (*PutResponse_Body) ProtoMessage() + func (m *PutResponse_Body) SetObjectId(v *refs.ObjectID) + func (x *PutResponse_Body) GetObjectId() *grpc1.ObjectID + func (x *PutResponse_Body) ProtoReflect() protoreflect.Message + func (x *PutResponse_Body) Reset() + func (x *PutResponse_Body) String() string + type Range struct + Length uint64 + Offset uint64 + func (*Range) Descriptor() ([]byte, []int) + func (*Range) ProtoMessage() + func (m *Range) SetLength(v uint64) + func (m *Range) SetOffset(v uint64) + func (x *Range) GetLength() uint64 + func (x *Range) GetOffset() uint64 + func (x *Range) ProtoReflect() protoreflect.Message + func (x *Range) Reset() + func (x *Range) String() string + type SearchRequest struct + Body *SearchRequest_Body + MetaHeader *grpc.RequestMetaHeader + VerifyHeader *grpc.RequestVerificationHeader + func (*SearchRequest) Descriptor() ([]byte, []int) + func (*SearchRequest) ProtoMessage() + func (m *SearchRequest) SetBody(v *SearchRequest_Body) + func (m *SearchRequest) SetMetaHeader(v *session.RequestMetaHeader) + func (m *SearchRequest) SetVerifyHeader(v *session.RequestVerificationHeader) + func (x *SearchRequest) GetBody() *SearchRequest_Body + func (x *SearchRequest) GetMetaHeader() *grpc.RequestMetaHeader + func (x *SearchRequest) GetVerifyHeader() *grpc.RequestVerificationHeader + func (x *SearchRequest) ProtoReflect() protoreflect.Message + func (x *SearchRequest) Reset() + func (x *SearchRequest) String() string + type SearchRequest_Body struct + ContainerId *grpc1.ContainerID + Filters []*SearchRequest_Body_Filter + Version uint32 + func (*SearchRequest_Body) Descriptor() ([]byte, []int) + func (*SearchRequest_Body) ProtoMessage() + func (m *SearchRequest_Body) SetContainerId(v *refs.ContainerID) + func (m *SearchRequest_Body) SetFilters(v []*SearchRequest_Body_Filter) + func (m *SearchRequest_Body) SetVersion(v uint32) + func (x *SearchRequest_Body) GetContainerId() *grpc1.ContainerID + func (x *SearchRequest_Body) GetFilters() []*SearchRequest_Body_Filter + func (x *SearchRequest_Body) GetVersion() uint32 + func (x *SearchRequest_Body) ProtoReflect() protoreflect.Message + func (x *SearchRequest_Body) Reset() + func (x *SearchRequest_Body) String() string + type SearchRequest_Body_Filter struct + Key string + MatchType MatchType + Value string + func (*SearchRequest_Body_Filter) Descriptor() ([]byte, []int) + func (*SearchRequest_Body_Filter) ProtoMessage() + func (m *SearchRequest_Body_Filter) SetKey(v string) + func (m *SearchRequest_Body_Filter) SetMatchType(v MatchType) + func (m *SearchRequest_Body_Filter) SetValue(v string) + func (x *SearchRequest_Body_Filter) GetKey() string + func (x *SearchRequest_Body_Filter) GetMatchType() MatchType + func (x *SearchRequest_Body_Filter) GetValue() string + func (x *SearchRequest_Body_Filter) ProtoReflect() protoreflect.Message + func (x *SearchRequest_Body_Filter) Reset() + func (x *SearchRequest_Body_Filter) String() string + type SearchResponse struct + Body *SearchResponse_Body + MetaHeader *grpc.ResponseMetaHeader + VerifyHeader *grpc.ResponseVerificationHeader + func (*SearchResponse) Descriptor() ([]byte, []int) + func (*SearchResponse) ProtoMessage() + func (m *SearchResponse) SetBody(v *SearchResponse_Body) + func (m *SearchResponse) SetMetaHeader(v *session.ResponseMetaHeader) + func (m *SearchResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) + func (x *SearchResponse) GetBody() *SearchResponse_Body + func (x *SearchResponse) GetMetaHeader() *grpc.ResponseMetaHeader + func (x *SearchResponse) GetVerifyHeader() *grpc.ResponseVerificationHeader + func (x *SearchResponse) ProtoReflect() protoreflect.Message + func (x *SearchResponse) Reset() + func (x *SearchResponse) String() string + type SearchResponse_Body struct + IdList []*grpc1.ObjectID + func (*SearchResponse_Body) Descriptor() ([]byte, []int) + func (*SearchResponse_Body) ProtoMessage() + func (m *SearchResponse_Body) SetIdList(v []*refs.ObjectID) + func (x *SearchResponse_Body) GetIdList() []*grpc1.ObjectID + func (x *SearchResponse_Body) ProtoReflect() protoreflect.Message + func (x *SearchResponse_Body) Reset() + func (x *SearchResponse_Body) String() string + type ShortHeader struct + CreationEpoch uint64 + HomomorphicHash *grpc.Checksum + ObjectType ObjectType + OwnerId *grpc.OwnerID + PayloadHash *grpc.Checksum + PayloadLength uint64 + Version *grpc.Version + func (*ShortHeader) Descriptor() ([]byte, []int) + func (*ShortHeader) ProtoMessage() + func (m *ShortHeader) SetCreationEpoch(v uint64) + func (m *ShortHeader) SetHomomorphicHash(v *refs.Checksum) + func (m *ShortHeader) SetObjectType(v ObjectType) + func (m *ShortHeader) SetOwnerId(v *refs.OwnerID) + func (m *ShortHeader) SetPayloadHash(v *refs.Checksum) + func (m *ShortHeader) SetPayloadLength(v uint64) + func (m *ShortHeader) SetVersion(v *refs.Version) + func (x *ShortHeader) GetCreationEpoch() uint64 + func (x *ShortHeader) GetHomomorphicHash() *grpc.Checksum + func (x *ShortHeader) GetObjectType() ObjectType + func (x *ShortHeader) GetOwnerId() *grpc.OwnerID + func (x *ShortHeader) GetPayloadHash() *grpc.Checksum + func (x *ShortHeader) GetPayloadLength() uint64 + func (x *ShortHeader) GetVersion() *grpc.Version + func (x *ShortHeader) ProtoReflect() protoreflect.Message + func (x *ShortHeader) Reset() + func (x *ShortHeader) String() string + type SplitInfo struct + LastPart *grpc.ObjectID + Link *grpc.ObjectID + SplitId []byte + func (*SplitInfo) Descriptor() ([]byte, []int) + func (*SplitInfo) ProtoMessage() + func (m *SplitInfo) SetLastPart(v *refs.ObjectID) + func (m *SplitInfo) SetLink(v *refs.ObjectID) + func (m *SplitInfo) SetSplitId(v []byte) + func (x *SplitInfo) GetLastPart() *grpc.ObjectID + func (x *SplitInfo) GetLink() *grpc.ObjectID + func (x *SplitInfo) GetSplitId() []byte + func (x *SplitInfo) ProtoReflect() protoreflect.Message + func (x *SplitInfo) Reset() + func (x *SplitInfo) String() string + type StatusCommon int32 + const StatusCommon_ACCESS_DENIED + func (StatusCommon) Descriptor() protoreflect.EnumDescriptor + func (StatusCommon) EnumDescriptor() ([]byte, []int) + func (StatusCommon) Type() protoreflect.EnumType + func (x StatusCommon) Enum() *StatusCommon + func (x StatusCommon) Number() protoreflect.EnumNumber + func (x StatusCommon) String() string + type StatusPut int32 + const StatusPut_STATUS_PUT_INCOMPLETE + func (StatusPut) Descriptor() protoreflect.EnumDescriptor + func (StatusPut) EnumDescriptor() ([]byte, []int) + func (StatusPut) Type() protoreflect.EnumType + func (x StatusPut) Enum() *StatusPut + func (x StatusPut) Number() protoreflect.EnumNumber + func (x StatusPut) String() string + type UnimplementedObjectServiceServer struct + func (UnimplementedObjectServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) + func (UnimplementedObjectServiceServer) Get(*GetRequest, ObjectService_GetServer) error + func (UnimplementedObjectServiceServer) GetRange(*GetRangeRequest, ObjectService_GetRangeServer) error + func (UnimplementedObjectServiceServer) GetRangeHash(context.Context, *GetRangeHashRequest) (*GetRangeHashResponse, error) + func (UnimplementedObjectServiceServer) Head(context.Context, *HeadRequest) (*HeadResponse, error) + func (UnimplementedObjectServiceServer) Put(ObjectService_PutServer) error + func (UnimplementedObjectServiceServer) Search(*SearchRequest, ObjectService_SearchServer) error + type UnsafeObjectServiceServer interface v2.11.0-pre Nov 17, 2021
Go to main page