cache

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCache        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCache          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCache = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdMethod_name = map[int32]string{
	0: "RemoteRead",
}
View Source 
var CmdMethod_value = map[string]int32{
	"RemoteRead": 0,
}

Functions

This section is empty.

Types

type CacheKey 

type CacheKey struct {
	Path   string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Sz     int64  `protobuf:"varint,3,opt,name=Sz,proto3" json:"Sz,omitempty"`
}

func (*CacheKey) Descriptor 

func (*CacheKey) Descriptor() ([]byte, []int)

func (*CacheKey) GetOffset 

func (m *CacheKey) GetOffset() int64

func (*CacheKey) GetPath 

func (m *CacheKey) GetPath() string

func (*CacheKey) GetSz 

func (m *CacheKey) GetSz() int64

func (*CacheKey) Marshal 

func (m *CacheKey) Marshal() (dAtA []byte, err error)

func (*CacheKey) MarshalTo 

func (m *CacheKey) MarshalTo(dAtA []byte) (int, error)

func (*CacheKey) MarshalToSizedBuffer 

func (m *CacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CacheKey) ProtoMessage 

func (*CacheKey) ProtoMessage()

func (*CacheKey) Reset 

func (m *CacheKey) Reset()

func (*CacheKey) Size 

func (m *CacheKey) Size() (n int)

func (*CacheKey) String 

func (m *CacheKey) String() string

func (*CacheKey) Unmarshal 

func (m *CacheKey) Unmarshal(dAtA []byte) error

func (*CacheKey) XXX_DiscardUnknown 

func (m *CacheKey) XXX_DiscardUnknown()

func (*CacheKey) XXX_Marshal 

func (m *CacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheKey) XXX_Merge 

func (m *CacheKey) XXX_Merge(src proto.Message)

func (*CacheKey) XXX_Size 

func (m *CacheKey) XXX_Size() int

func (*CacheKey) XXX_Unmarshal 

func (m *CacheKey) XXX_Unmarshal(b []byte) error

type CacheKeys 

type CacheKeys struct {
	Keys []CacheKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys"`
}

func (*CacheKeys) Descriptor 

func (*CacheKeys) Descriptor() ([]byte, []int)

func (*CacheKeys) GetKeys 

func (m *CacheKeys) GetKeys() []CacheKey

func (*CacheKeys) Marshal 

func (m *CacheKeys) Marshal() (dAtA []byte, err error)

func (*CacheKeys) MarshalTo 

func (m *CacheKeys) MarshalTo(dAtA []byte) (int, error)

func (*CacheKeys) MarshalToSizedBuffer 

func (m *CacheKeys) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CacheKeys) ProtoMessage 

func (*CacheKeys) ProtoMessage()

func (*CacheKeys) Reset 

func (m *CacheKeys) Reset()

func (*CacheKeys) Size 

func (m *CacheKeys) Size() (n int)

func (*CacheKeys) String 

func (m *CacheKeys) String() string

func (*CacheKeys) Unmarshal 

func (m *CacheKeys) Unmarshal(dAtA []byte) error

func (*CacheKeys) XXX_DiscardUnknown 

func (m *CacheKeys) XXX_DiscardUnknown()

func (*CacheKeys) XXX_Marshal 

func (m *CacheKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CacheKeys) XXX_Merge 

func (m *CacheKeys) XXX_Merge(src proto.Message)

func (*CacheKeys) XXX_Size 

func (m *CacheKeys) XXX_Size() int

func (*CacheKeys) XXX_Unmarshal 

func (m *CacheKeys) XXX_Unmarshal(b []byte) error

type CacheResponse added in v1.1.0 

type CacheResponse struct {
	Response
	ReleaseFunc func()
}

func (*CacheResponse) Reset added in v1.1.0 

func (r *CacheResponse) Reset()

type CmdMethod 

type CmdMethod int32
const (
	// RemoteRead is the command that remote read file.
	CmdMethod_RemoteRead CmdMethod = 0
)

func (CmdMethod) EnumDescriptor 

func (CmdMethod) EnumDescriptor() ([]byte, []int)

func (CmdMethod) String 

func (x CmdMethod) String() string

type RemoteReadRequest 

type RemoteReadRequest struct {
	// RequestCacheKey is the requested cache key.
	RequestCacheKey []*RequestCacheKey `protobuf:"bytes,1,rep,name=RequestCacheKey,proto3" json:"RequestCacheKey,omitempty"`
}

RemoteReadRequest is the request that try to get cache from this node. statement that need to be executed on the specified CN node.

func (*RemoteReadRequest) Descriptor 

func (*RemoteReadRequest) Descriptor() ([]byte, []int)

func (*RemoteReadRequest) GetRequestCacheKey 

func (m *RemoteReadRequest) GetRequestCacheKey() []*RequestCacheKey

func (*RemoteReadRequest) Marshal 

func (m *RemoteReadRequest) Marshal() (dAtA []byte, err error)

func (*RemoteReadRequest) MarshalTo 

func (m *RemoteReadRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoteReadRequest) MarshalToSizedBuffer 

func (m *RemoteReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteReadRequest) ProtoMessage 

func (*RemoteReadRequest) ProtoMessage()

func (*RemoteReadRequest) Reset 

func (m *RemoteReadRequest) Reset()

func (*RemoteReadRequest) Size 

func (m *RemoteReadRequest) Size() (n int)

func (*RemoteReadRequest) String 

func (m *RemoteReadRequest) String() string

func (*RemoteReadRequest) Unmarshal 

func (m *RemoteReadRequest) Unmarshal(dAtA []byte) error

func (*RemoteReadRequest) XXX_DiscardUnknown 

func (m *RemoteReadRequest) XXX_DiscardUnknown()

func (*RemoteReadRequest) XXX_Marshal 

func (m *RemoteReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteReadRequest) XXX_Merge 

func (m *RemoteReadRequest) XXX_Merge(src proto.Message)

func (*RemoteReadRequest) XXX_Size 

func (m *RemoteReadRequest) XXX_Size() int

func (*RemoteReadRequest) XXX_Unmarshal 

func (m *RemoteReadRequest) XXX_Unmarshal(b []byte) error

type RemoteReadResponse 

type RemoteReadResponse struct {
	ResponseCacheData []*ResponseCacheData `protobuf:"bytes,1,rep,name=ResponseCacheData,proto3" json:"ResponseCacheData,omitempty"`
}

RemoteReadResponse is the response of remote read.

func (*RemoteReadResponse) Descriptor 

func (*RemoteReadResponse) Descriptor() ([]byte, []int)

func (*RemoteReadResponse) GetResponseCacheData 

func (m *RemoteReadResponse) GetResponseCacheData() []*ResponseCacheData

func (*RemoteReadResponse) Marshal 

func (m *RemoteReadResponse) Marshal() (dAtA []byte, err error)

func (*RemoteReadResponse) MarshalTo 

func (m *RemoteReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoteReadResponse) MarshalToSizedBuffer 

func (m *RemoteReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteReadResponse) ProtoMessage 

func (*RemoteReadResponse) ProtoMessage()

func (*RemoteReadResponse) Reset 

func (m *RemoteReadResponse) Reset()

func (*RemoteReadResponse) Size 

func (m *RemoteReadResponse) Size() (n int)

func (*RemoteReadResponse) String 

func (m *RemoteReadResponse) String() string

func (*RemoteReadResponse) Unmarshal 

func (m *RemoteReadResponse) Unmarshal(dAtA []byte) error

func (*RemoteReadResponse) XXX_DiscardUnknown 

func (m *RemoteReadResponse) XXX_DiscardUnknown()

func (*RemoteReadResponse) XXX_Marshal 

func (m *RemoteReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteReadResponse) XXX_Merge 

func (m *RemoteReadResponse) XXX_Merge(src proto.Message)

func (*RemoteReadResponse) XXX_Size 

func (m *RemoteReadResponse) XXX_Size() int

func (*RemoteReadResponse) XXX_Unmarshal 

func (m *RemoteReadResponse) XXX_Unmarshal(b []byte) error

type Request 

type Request struct {
	// RequestID is the request ID.
	RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	// CmdMethod is the type of command.
	CmdMethod CmdMethod `protobuf:"varint,2,opt,name=CmdMethod,proto3,enum=cache.CmdMethod" json:"CmdMethod,omitempty"`
	// RemoteReadRequest is the request to remote read.
	RemoteReadRequest *RemoteReadRequest `protobuf:"bytes,3,opt,name=RemoteReadRequest,proto3" json:"RemoteReadRequest,omitempty"`
}

Request is the request of file-service cache server.

func (*Request) DebugString 

func (m *Request) DebugString() string

DebugString implements the morpc.Message interface.

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetCmdMethod 

func (m *Request) GetCmdMethod() CmdMethod

func (*Request) GetID 

func (m *Request) GetID() uint64

GetID implements the morpc.Message interface.

func (*Request) GetRemoteReadRequest 

func (m *Request) GetRemoteReadRequest() *RemoteReadRequest

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) Method 

func (m *Request) Method() uint32

Method implements the morpc.MethodBasedMessage interface.

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) SetID 

func (m *Request) SetID(id uint64)

SetID implements the morpc.Message interface.

func (*Request) SetMethod 

func (m *Request) SetMethod(v uint32)

SetMethod implements the morpc.MethodBasedMessage interface.

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) UnwrapError 

func (m *Request) UnwrapError() error

UnwrapError implements the morpc.MethodBasedMessage interface.

func (*Request) WrapError 

func (m *Request) WrapError(err error)

WrapError implements the morpc.MethodBasedMessage interface.

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type RequestCacheKey 

type RequestCacheKey struct {
	Index    int32     `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	CacheKey *CacheKey `protobuf:"bytes,2,opt,name=CacheKey,proto3" json:"CacheKey,omitempty"`
}

func (*RequestCacheKey) Descriptor 

func (*RequestCacheKey) Descriptor() ([]byte, []int)

func (*RequestCacheKey) GetCacheKey 

func (m *RequestCacheKey) GetCacheKey() *CacheKey

func (*RequestCacheKey) GetIndex 

func (m *RequestCacheKey) GetIndex() int32

func (*RequestCacheKey) Marshal 

func (m *RequestCacheKey) Marshal() (dAtA []byte, err error)

func (*RequestCacheKey) MarshalTo 

func (m *RequestCacheKey) MarshalTo(dAtA []byte) (int, error)

func (*RequestCacheKey) MarshalToSizedBuffer 

func (m *RequestCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestCacheKey) ProtoMessage 

func (*RequestCacheKey) ProtoMessage()

func (*RequestCacheKey) Reset 

func (m *RequestCacheKey) Reset()

func (*RequestCacheKey) Size 

func (m *RequestCacheKey) Size() (n int)

func (*RequestCacheKey) String 

func (m *RequestCacheKey) String() string

func (*RequestCacheKey) Unmarshal 

func (m *RequestCacheKey) Unmarshal(dAtA []byte) error

func (*RequestCacheKey) XXX_DiscardUnknown 

func (m *RequestCacheKey) XXX_DiscardUnknown()

func (*RequestCacheKey) XXX_Marshal 

func (m *RequestCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestCacheKey) XXX_Merge 

func (m *RequestCacheKey) XXX_Merge(src proto.Message)

func (*RequestCacheKey) XXX_Size 

func (m *RequestCacheKey) XXX_Size() int

func (*RequestCacheKey) XXX_Unmarshal 

func (m *RequestCacheKey) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	// RequestID is the request ID.
	RequestID uint64 `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	// CmdMethod is the type of command.
	CmdMethod CmdMethod `protobuf:"varint,2,opt,name=CmdMethod,proto3,enum=cache.CmdMethod" json:"CmdMethod,omitempty"`
	// Error is used to return moerr. Set
	Error []byte `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	// RemoteReadResponse is the response of remote read.
	RemoteReadResponse *RemoteReadResponse `protobuf:"bytes,4,opt,name=RemoteReadResponse,proto3" json:"RemoteReadResponse,omitempty"`
}

Response is the response to request.

func (*Response) DebugString 

func (m *Response) DebugString() string

DebugString implements the morpc.Message interface.

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetCmdMethod 

func (m *Response) GetCmdMethod() CmdMethod

func (*Response) GetError 

func (m *Response) GetError() []byte

func (*Response) GetID 

func (m *Response) GetID() uint64

GetID implements the morpc.Message interface.

func (*Response) GetRemoteReadResponse 

func (m *Response) GetRemoteReadResponse() *RemoteReadResponse

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) Method 

func (m *Response) Method() uint32

Method implements the morpc.MethodBasedMessage interface.

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) SetID 

func (m *Response) SetID(id uint64)

SetID implements the morpc.Message interface.

func (*Response) SetMethod 

func (m *Response) SetMethod(v uint32)

SetMethod implements the morpc.MethodBasedMessage interface.

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) UnwrapError 

func (m *Response) UnwrapError() error

UnwrapError implements the morpc.MethodBasedMessage interface.

func (*Response) WrapError 

func (m *Response) WrapError(err error)

WrapError implements the morpc.MethodBasedMessage interface.

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type ResponseCacheData 

type ResponseCacheData struct {
	Index int32  `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Hit   bool   `protobuf:"varint,2,opt,name=Hit,proto3" json:"Hit,omitempty"`
	Data  []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
}

ResponseCacheData is the response of remote read.

func (*ResponseCacheData) Descriptor 

func (*ResponseCacheData) Descriptor() ([]byte, []int)

func (*ResponseCacheData) GetData 

func (m *ResponseCacheData) GetData() []byte

func (*ResponseCacheData) GetHit 

func (m *ResponseCacheData) GetHit() bool

func (*ResponseCacheData) GetIndex 

func (m *ResponseCacheData) GetIndex() int32

func (*ResponseCacheData) Marshal 

func (m *ResponseCacheData) Marshal() (dAtA []byte, err error)

func (*ResponseCacheData) MarshalTo 

func (m *ResponseCacheData) MarshalTo(dAtA []byte) (int, error)

func (*ResponseCacheData) MarshalToSizedBuffer 

func (m *ResponseCacheData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseCacheData) ProtoMessage 

func (*ResponseCacheData) ProtoMessage()

func (*ResponseCacheData) Reset 

func (m *ResponseCacheData) Reset()

func (*ResponseCacheData) Size 

func (m *ResponseCacheData) Size() (n int)

func (*ResponseCacheData) String 

func (m *ResponseCacheData) String() string

func (*ResponseCacheData) Unmarshal 

func (m *ResponseCacheData) Unmarshal(dAtA []byte) error

func (*ResponseCacheData) XXX_DiscardUnknown 

func (m *ResponseCacheData) XXX_DiscardUnknown()

func (*ResponseCacheData) XXX_Marshal 

func (m *ResponseCacheData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseCacheData) XXX_Merge 

func (m *ResponseCacheData) XXX_Merge(src proto.Message)

func (*ResponseCacheData) XXX_Size 

func (m *ResponseCacheData) XXX_Size() int

func (*ResponseCacheData) XXX_Unmarshal 

func (m *ResponseCacheData) XXX_Unmarshal(b []byte) error

type TargetCacheKey 

type TargetCacheKey struct {
	TargetKey map[string]*CacheKeys `` /* 159-byte string literal not displayed */
}

func (*TargetCacheKey) Descriptor 

func (*TargetCacheKey) Descriptor() ([]byte, []int)

func (*TargetCacheKey) GetTargetKey 

func (m *TargetCacheKey) GetTargetKey() map[string]*CacheKeys

func (*TargetCacheKey) Marshal 

func (m *TargetCacheKey) Marshal() (dAtA []byte, err error)

func (*TargetCacheKey) MarshalTo 

func (m *TargetCacheKey) MarshalTo(dAtA []byte) (int, error)

func (*TargetCacheKey) MarshalToSizedBuffer 

func (m *TargetCacheKey) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TargetCacheKey) ProtoMessage 

func (*TargetCacheKey) ProtoMessage()

func (*TargetCacheKey) Reset 

func (m *TargetCacheKey) Reset()

func (*TargetCacheKey) Size 

func (m *TargetCacheKey) Size() (n int)

func (*TargetCacheKey) String 

func (m *TargetCacheKey) String() string

func (*TargetCacheKey) Unmarshal 

func (m *TargetCacheKey) Unmarshal(dAtA []byte) error

func (*TargetCacheKey) XXX_DiscardUnknown 

func (m *TargetCacheKey) XXX_DiscardUnknown()

func (*TargetCacheKey) XXX_Marshal 

func (m *TargetCacheKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TargetCacheKey) XXX_Merge 

func (m *TargetCacheKey) XXX_Merge(src proto.Message)

func (*TargetCacheKey) XXX_Size 

func (m *TargetCacheKey) XXX_Size() int

func (*TargetCacheKey) XXX_Unmarshal 

func (m *TargetCacheKey) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.