Documentation
¶
Index ¶
- func InitMemcachedConn(server string) error
- func NewHandler() (handlers.Handler, error)
- type GetTask
- type Handler
- func (h *Handler) Add(cmd common.SetRequest) error
- func (h *Handler) Append(cmd common.SetRequest) error
- func (h *Handler) Close() error
- func (h *Handler) Delete(cmd common.DeleteRequest) error
- func (h *Handler) GAT(cmd common.GATRequest) (common.GetResponse, error)
- func (h *Handler) Get(cmd common.GetRequest) (<-chan common.GetResponse, <-chan error)
- func (h *Handler) GetE(cmd common.GetRequest) (<-chan common.GetEResponse, <-chan error)
- func (h *Handler) Prepend(cmd common.SetRequest) error
- func (h *Handler) Replace(cmd common.SetRequest) error
- func (h *Handler) Set(cmd common.SetRequest) error
- func (h *Handler) Touch(cmd common.TouchRequest) error
- type Pool
- type SetTask
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitMemcachedConn ¶
InitMemcachedConn init a pool of memcached workers
Types ¶
type GetTask ¶
type GetTask struct {
Cmd common.GetRequest
DataOut chan common.GetResponse
ErrorOut chan error
}
GetTask a get task that can be processed by workers
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler is an handler for executing memcached requests
func (*Handler) Add ¶
func (h *Handler) Add(cmd common.SetRequest) error
Add perform an add request: Not implemented
func (*Handler) Append ¶
func (h *Handler) Append(cmd common.SetRequest) error
Append perform an append: Not implemented
func (*Handler) Delete ¶
func (h *Handler) Delete(cmd common.DeleteRequest) error
Delete perform a delete request: Not implemented
func (*Handler) GAT ¶
func (h *Handler) GAT(cmd common.GATRequest) (common.GetResponse, error)
GAT perform a gat request: Not implemented
func (*Handler) Get ¶
func (h *Handler) Get(cmd common.GetRequest) (<-chan common.GetResponse, <-chan error)
Get perform a get request
func (*Handler) GetE ¶
func (h *Handler) GetE(cmd common.GetRequest) (<-chan common.GetEResponse, <-chan error)
GetE perform a gete request: Not implemented
func (*Handler) Prepend ¶
func (h *Handler) Prepend(cmd common.SetRequest) error
Prepend perform a prepend: Not implemented
type Pool ¶
type Pool struct {
GetWorkQueue chan GetTask
SetWorkQueue chan SetTask
// contains filtered or unexported fields
}
Pool describe a pool for memcached connectors
type SetTask ¶
type SetTask struct {
Cmd common.SetRequest
ErrorOut chan error
}
SetTask a set task that can be processed by workers
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.