memcache

Oct 12, 2023

Changes in this version

+ func ReleaseGetResponseData(data []byte)

+ func ReleaseMGetResult(r MGetResult)

+ type MGetResult struct

+ func (r MGetResult) Result() (MGetResponse, error)

type Option

+ func WithHealthCheckDuration(duration time.Duration) Option

type Pipeline

+ func (p *Pipeline) MGetFast(key string, opts MGetOptions) (MGetResult, error)

+ func (p *Pipeline) Version() func() (VersionResponse, error)

+ type VersionResponse struct

+ Version string

Sep 11, 2023

Changes in this version

type Option

+ func WithMaxCommandsPerBatch(maxCommands int) Option

+ func WithWriteLimit(limit int) Option

Apr 4, 2023

Changes in this version

+ func IsServerError(err error) bool

Mar 27, 2023

Changes in this version

+ const ObjectTooBigErrorMsg

+ const OutOfMemoryErrorMsg

+ func IsServerErrorMsg(err error, msg string) bool

Mar 23, 2023

Changes in this version

+ var ErrKeyEmpty = errors.New("memcached: key is empty")

Mar 22, 2023

Changes in this version

+ var ErrKeyTooLong = errors.New("memcached: key too long")

Mar 8, 2023

Changes in this version

type Option

+ func WithNetConnOptions(options ...netconn.Option) Option

Feb 8, 2023

Changes in this version

type Option

+ func WithDialFunc(dialFunc func(network, address string) (net.Conn, error)) Option

Dec 8, 2022

Changes in this version

type Option

+ func WithDialErrorLogger(fn func(err error)) Option

Nov 29, 2022

Changes in this version

type Option

+ func WithTCPKeepAliveDuration(d time.Duration) Option

Jun 9, 2022

Changes in this version

type Option

+ func WithBufferSize(size int) Option

May 27, 2022

Changes in this version

+ var ErrInvalidKeyFormat = errors.New("memcached: invalid key format")

Apr 22, 2022

Changes in this version

type Client

+ func (c *Client) Close() error

type Pipeline

+ func (p *Pipeline) Execute()

Jan 19, 2022

Changes in this version

+ var ErrAlreadyGotten = errors.New("pipeline error: already gotten")

+ var ErrConnClosed = errors.New("memcache: connection closed")

+ var ErrInvalidMDel = ErrBrokenPipe

+ var ErrInvalidMGet = ErrBrokenPipe

+ var ErrInvalidMSet = ErrBrokenPipe

+ var ErrInvalidResponse = ErrBrokenPipe

+ func NewClientError(msg string) error

+ func NewServerError(msg string) error

+ type Client struct

+ func New(addr string, numConns int, options ...Option) (*Client, error)

+ func (c *Client) Pipeline() *Pipeline

+ type ErrBrokenPipe struct

+ func (e ErrBrokenPipe) Error() string

+ type ErrClientError struct

+ Message string

+ func (e ErrClientError) Error() string

+ type ErrServerError struct

+ Message string

+ func (e ErrServerError) Error() string

+ type FlushWriter interface

+ Flush func() error

+ func NoopFlusher(w io.Writer) FlushWriter

+ type MDelOptions struct

+ CAS uint64

+ I bool

+ TTL uint32

+ type MDelResponse struct

+ Type MDelResponseType

+ type MDelResponseType int

+ const MDelResponseTypeEX

+ const MDelResponseTypeHD

+ const MDelResponseTypeNF

+ type MGetFlags uint64

+ const MGetFlagW

+ const MGetFlagX

+ const MGetFlagZ

+ type MGetOptions struct

+ CAS bool

+ N uint32

+ type MGetResponse struct

+ CAS uint64

+ Data []byte

+ Flags MGetFlags

+ Type MGetResponseType

+ type MGetResponseType int

+ const MGetResponseTypeEN

+ const MGetResponseTypeHD

+ const MGetResponseTypeVA

+ type MSetOptions struct

+ CAS uint64

+ TTL uint32

+ type MSetResponse struct

+ Type MSetResponseType

+ type MSetResponseType int

+ const MSetResponseTypeEX

+ const MSetResponseTypeHD

+ const MSetResponseTypeNF

+ const MSetResponseTypeNS

+ type Option func(opts *memcacheOptions)

+ func WithRetryDuration(d time.Duration) Option

+ type Pipeline struct

+ func (p *Pipeline) Finish()

+ func (p *Pipeline) FlushAll() func() error

+ func (p *Pipeline) MDel(key string, opts MDelOptions) func() (MDelResponse, error)

+ func (p *Pipeline) MGet(key string, opts MGetOptions) func() (MGetResponse, error)

+ func (p *Pipeline) MSet(key string, value []byte, opts MSetOptions) func() (MSetResponse, error)