Versions in this module Expand all Collapse all v1 v1.1.3 Apr 15, 2024 v1.1.2 Apr 2, 2024 v1.1.1 Feb 2, 2024 v1.1.0 Dec 29, 2023 Changes in this version + type CacheResponse struct + ReleaseFunc func() + func (r *CacheResponse) Reset() type Request + func (m *Request) GetMethod() CmdMethod v1.0.2 Dec 21, 2023 v1.0.1 Dec 15, 2023 v1.0.0 Nov 13, 2023 Changes in this version + var CmdMethod_name = map[int32]string + var CmdMethod_value = map[string]int32 + var ErrIntOverflowCache = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthCache = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupCache = fmt.Errorf("proto: unexpected end of group") + type CacheKey struct + Offset int64 + Path string + Sz int64 + func (*CacheKey) Descriptor() ([]byte, []int) + func (*CacheKey) ProtoMessage() + func (m *CacheKey) GetOffset() int64 + func (m *CacheKey) GetPath() string + func (m *CacheKey) GetSz() int64 + func (m *CacheKey) Marshal() (dAtA []byte, err error) + func (m *CacheKey) MarshalTo(dAtA []byte) (int, error) + func (m *CacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CacheKey) Reset() + func (m *CacheKey) Size() (n int) + func (m *CacheKey) String() string + func (m *CacheKey) Unmarshal(dAtA []byte) error + func (m *CacheKey) XXX_DiscardUnknown() + func (m *CacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CacheKey) XXX_Merge(src proto.Message) + func (m *CacheKey) XXX_Size() int + func (m *CacheKey) XXX_Unmarshal(b []byte) error + type CacheKeys struct + Keys []CacheKey + func (*CacheKeys) Descriptor() ([]byte, []int) + func (*CacheKeys) ProtoMessage() + func (m *CacheKeys) GetKeys() []CacheKey + func (m *CacheKeys) Marshal() (dAtA []byte, err error) + func (m *CacheKeys) MarshalTo(dAtA []byte) (int, error) + func (m *CacheKeys) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CacheKeys) Reset() + func (m *CacheKeys) Size() (n int) + func (m *CacheKeys) String() string + func (m *CacheKeys) Unmarshal(dAtA []byte) error + func (m *CacheKeys) XXX_DiscardUnknown() + func (m *CacheKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CacheKeys) XXX_Merge(src proto.Message) + func (m *CacheKeys) XXX_Size() int + func (m *CacheKeys) XXX_Unmarshal(b []byte) error + type CmdMethod int32 + const CmdMethod_RemoteRead + func (CmdMethod) EnumDescriptor() ([]byte, []int) + func (x CmdMethod) String() string + type RemoteReadRequest struct + RequestCacheKey []*RequestCacheKey + func (*RemoteReadRequest) Descriptor() ([]byte, []int) + func (*RemoteReadRequest) ProtoMessage() + func (m *RemoteReadRequest) GetRequestCacheKey() []*RequestCacheKey + func (m *RemoteReadRequest) Marshal() (dAtA []byte, err error) + func (m *RemoteReadRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RemoteReadRequest) Reset() + func (m *RemoteReadRequest) Size() (n int) + func (m *RemoteReadRequest) String() string + func (m *RemoteReadRequest) Unmarshal(dAtA []byte) error + func (m *RemoteReadRequest) XXX_DiscardUnknown() + func (m *RemoteReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoteReadRequest) XXX_Merge(src proto.Message) + func (m *RemoteReadRequest) XXX_Size() int + func (m *RemoteReadRequest) XXX_Unmarshal(b []byte) error + type RemoteReadResponse struct + ResponseCacheData []*ResponseCacheData + func (*RemoteReadResponse) Descriptor() ([]byte, []int) + func (*RemoteReadResponse) ProtoMessage() + func (m *RemoteReadResponse) GetResponseCacheData() []*ResponseCacheData + func (m *RemoteReadResponse) Marshal() (dAtA []byte, err error) + func (m *RemoteReadResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RemoteReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RemoteReadResponse) Reset() + func (m *RemoteReadResponse) Size() (n int) + func (m *RemoteReadResponse) String() string + func (m *RemoteReadResponse) Unmarshal(dAtA []byte) error + func (m *RemoteReadResponse) XXX_DiscardUnknown() + func (m *RemoteReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoteReadResponse) XXX_Merge(src proto.Message) + func (m *RemoteReadResponse) XXX_Size() int + func (m *RemoteReadResponse) XXX_Unmarshal(b []byte) error + type Request struct + CmdMethod CmdMethod + RemoteReadRequest *RemoteReadRequest + RequestID uint64 + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) DebugString() string + func (m *Request) GetCmdMethod() CmdMethod + func (m *Request) GetID() uint64 + func (m *Request) GetRemoteReadRequest() *RemoteReadRequest + func (m *Request) GetRequestID() uint64 + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Method() uint32 + func (m *Request) Reset() + func (m *Request) SetID(id uint64) + func (m *Request) SetMethod(v uint32) + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) UnwrapError() error + func (m *Request) WrapError(err error) + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type RequestCacheKey struct + CacheKey *CacheKey + Index int32 + func (*RequestCacheKey) Descriptor() ([]byte, []int) + func (*RequestCacheKey) ProtoMessage() + func (m *RequestCacheKey) GetCacheKey() *CacheKey + func (m *RequestCacheKey) GetIndex() int32 + func (m *RequestCacheKey) Marshal() (dAtA []byte, err error) + func (m *RequestCacheKey) MarshalTo(dAtA []byte) (int, error) + func (m *RequestCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestCacheKey) Reset() + func (m *RequestCacheKey) Size() (n int) + func (m *RequestCacheKey) String() string + func (m *RequestCacheKey) Unmarshal(dAtA []byte) error + func (m *RequestCacheKey) XXX_DiscardUnknown() + func (m *RequestCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestCacheKey) XXX_Merge(src proto.Message) + func (m *RequestCacheKey) XXX_Size() int + func (m *RequestCacheKey) XXX_Unmarshal(b []byte) error + type Response struct + CmdMethod CmdMethod + Error []byte + RemoteReadResponse *RemoteReadResponse + RequestID uint64 + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) DebugString() string + func (m *Response) GetCmdMethod() CmdMethod + func (m *Response) GetError() []byte + func (m *Response) GetID() uint64 + func (m *Response) GetRemoteReadResponse() *RemoteReadResponse + func (m *Response) GetRequestID() uint64 + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Method() uint32 + func (m *Response) Reset() + func (m *Response) SetID(id uint64) + func (m *Response) SetMethod(v uint32) + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) UnwrapError() error + func (m *Response) WrapError(err error) + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type ResponseCacheData struct + Data []byte + Hit bool + Index int32 + func (*ResponseCacheData) Descriptor() ([]byte, []int) + func (*ResponseCacheData) ProtoMessage() + func (m *ResponseCacheData) GetData() []byte + func (m *ResponseCacheData) GetHit() bool + func (m *ResponseCacheData) GetIndex() int32 + func (m *ResponseCacheData) Marshal() (dAtA []byte, err error) + func (m *ResponseCacheData) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseCacheData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseCacheData) Reset() + func (m *ResponseCacheData) Size() (n int) + func (m *ResponseCacheData) String() string + func (m *ResponseCacheData) Unmarshal(dAtA []byte) error + func (m *ResponseCacheData) XXX_DiscardUnknown() + func (m *ResponseCacheData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseCacheData) XXX_Merge(src proto.Message) + func (m *ResponseCacheData) XXX_Size() int + func (m *ResponseCacheData) XXX_Unmarshal(b []byte) error + type TargetCacheKey struct + TargetKey map[string]*CacheKeys + func (*TargetCacheKey) Descriptor() ([]byte, []int) + func (*TargetCacheKey) ProtoMessage() + func (m *TargetCacheKey) GetTargetKey() map[string]*CacheKeys + func (m *TargetCacheKey) Marshal() (dAtA []byte, err error) + func (m *TargetCacheKey) MarshalTo(dAtA []byte) (int, error) + func (m *TargetCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TargetCacheKey) Reset() + func (m *TargetCacheKey) Size() (n int) + func (m *TargetCacheKey) String() string + func (m *TargetCacheKey) Unmarshal(dAtA []byte) error + func (m *TargetCacheKey) XXX_DiscardUnknown() + func (m *TargetCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TargetCacheKey) XXX_Merge(src proto.Message) + func (m *TargetCacheKey) XXX_Size() int + func (m *TargetCacheKey) XXX_Unmarshal(b []byte) error v1.0.0-rc2 Oct 24, 2023
Go to main page