cache

package
v0.0.0-...-e75d4ac Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCacheEndpoints 

func NewCacheEndpoints() []*api.Endpoint

func RegisterCacheHandler 

func RegisterCacheHandler(s server.Server, hdlr CacheHandler, opts ...server.HandlerOption) error

Types

type CacheHandler 

type CacheHandler interface {
	Put(context.Context, *CacheMessage, *CacheMessage) error
	Set(context.Context, *CacheMessage, *CacheMessage) error
	Get(context.Context, *CacheKeyRequest, *CacheMessage) error
	Delete(context.Context, *CacheKeyRequest, *CacheMessage) error
	List(context.Context, *CacheListRequest, *CacheListResponse) error
}

type CacheKeyRequest 

type CacheKeyRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheKeyRequest) Descriptor 

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

func (*CacheKeyRequest) GetKey 

func (m *CacheKeyRequest) GetKey() []byte

func (*CacheKeyRequest) ProtoMessage 

func (*CacheKeyRequest) ProtoMessage()

func (*CacheKeyRequest) Reset 

func (m *CacheKeyRequest) Reset()

func (*CacheKeyRequest) String 

func (m *CacheKeyRequest) String() string

func (*CacheKeyRequest) XXX_DiscardUnknown 

func (m *CacheKeyRequest) XXX_DiscardUnknown()

func (*CacheKeyRequest) XXX_Marshal 

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

func (*CacheKeyRequest) XXX_Merge 

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

func (*CacheKeyRequest) XXX_Size 

func (m *CacheKeyRequest) XXX_Size() int

func (*CacheKeyRequest) XXX_Unmarshal 

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

type CacheListRequest 

type CacheListRequest struct {
	Limit                *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*CacheListRequest) Descriptor 

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

func (*CacheListRequest) GetLimit 

func (m *CacheListRequest) GetLimit() *wrappers.UInt32Value

func (*CacheListRequest) GetOffset 

func (m *CacheListRequest) GetOffset() *wrappers.UInt32Value

func (*CacheListRequest) ProtoMessage 

func (*CacheListRequest) ProtoMessage()

func (*CacheListRequest) Reset 

func (m *CacheListRequest) Reset()

func (*CacheListRequest) String 

func (m *CacheListRequest) String() string

func (*CacheListRequest) XXX_DiscardUnknown 

func (m *CacheListRequest) XXX_DiscardUnknown()

func (*CacheListRequest) XXX_Marshal 

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

func (*CacheListRequest) XXX_Merge 

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

func (*CacheListRequest) XXX_Size 

func (m *CacheListRequest) XXX_Size() int

func (*CacheListRequest) XXX_Unmarshal 

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

type CacheListResponse 

type CacheListResponse struct {
	Items                []*CacheMessage `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CacheListResponse) Descriptor 

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

func (*CacheListResponse) GetItems 

func (m *CacheListResponse) GetItems() []*CacheMessage

func (*CacheListResponse) ProtoMessage 

func (*CacheListResponse) ProtoMessage()

func (*CacheListResponse) Reset 

func (m *CacheListResponse) Reset()

func (*CacheListResponse) String 

func (m *CacheListResponse) String() string

func (*CacheListResponse) XXX_DiscardUnknown 

func (m *CacheListResponse) XXX_DiscardUnknown()

func (*CacheListResponse) XXX_Marshal 

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

func (*CacheListResponse) XXX_Merge 

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

func (*CacheListResponse) XXX_Size 

func (m *CacheListResponse) XXX_Size() int

func (*CacheListResponse) XXX_Unmarshal 

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

type CacheMessage 

type CacheMessage struct {
	Key                  []byte               `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte               `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Expiration           *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CacheMessage) Descriptor 

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

func (*CacheMessage) GetExpiration 

func (m *CacheMessage) GetExpiration() *timestamp.Timestamp

func (*CacheMessage) GetKey 

func (m *CacheMessage) GetKey() []byte

func (*CacheMessage) GetValue 

func (m *CacheMessage) GetValue() []byte

func (*CacheMessage) ProtoMessage 

func (*CacheMessage) ProtoMessage()

func (*CacheMessage) Reset 

func (m *CacheMessage) Reset()

func (*CacheMessage) String 

func (m *CacheMessage) String() string

func (*CacheMessage) XXX_DiscardUnknown 

func (m *CacheMessage) XXX_DiscardUnknown()

func (*CacheMessage) XXX_Marshal 

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

func (*CacheMessage) XXX_Merge 

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

func (*CacheMessage) XXX_Size 

func (m *CacheMessage) XXX_Size() int

func (*CacheMessage) XXX_Unmarshal 

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

type CacheService 

type CacheService interface {
	Put(ctx context.Context, in *CacheMessage, opts ...client.CallOption) (*CacheMessage, error)
	Set(ctx context.Context, in *CacheMessage, opts ...client.CallOption) (*CacheMessage, error)
	Get(ctx context.Context, in *CacheKeyRequest, opts ...client.CallOption) (*CacheMessage, error)
	Delete(ctx context.Context, in *CacheKeyRequest, opts ...client.CallOption) (*CacheMessage, error)
	List(ctx context.Context, in *CacheListRequest, opts ...client.CallOption) (*CacheListResponse, error)
}

func NewCacheService 

func NewCacheService(name string, c client.Client) CacheService

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.