memcached

Documentation

Index

• Variables
• type Configuration
• type Memcached
  • func New(tm *stats.TimelineManager, configuration *Configuration) (*Memcached, error)
  • func (mc *Memcached) Delete(router, namespace []byte, fqnKeys ...string) error
  • func (mc *Memcached) Get(router, namespace []byte, fqnKeys ...string) ([]byte, bool, error)
  • func (mc *Memcached) Put(router, value, ttl, namespace []byte, fqnKeys ...string) error

Variables

var (
	// ClusterRouter - a router to signal a full cluster route
	ClusterRouter []byte = []byte{0, 0}
)

Types

type Configuration

type Configuration struct {
	// Nodes - the memcached nodes
	Nodes []string

	// NumConnectionsPerNode - idle connection per node
	NumConnectionsPerNode int

	// ReconnectionTimeout - the time duration between connection retries
	ReconnectionTimeout string

	// MaxWriteTimeout - the max time duration to wait a write operation
	MaxWriteTimeout string

	// MaxReadTimeout - the max time duration to wait a read operation
	MaxReadTimeout string

	// MaxWriteRetries - the maximum number of write retries
	MaxWriteRetries int

	// ReadBufferSize - the size of the read buffer in bytes
	ReadBufferSize int

	// EnableMetrics - enables the memcached metrics
	EnableMetrics bool
}

Configuration - configuration wrapper

type Memcached

type Memcached struct {
	// contains filtered or unexported fields
}

Memcached - main struct

func New

func New(tm *stats.TimelineManager, configuration *Configuration) (*Memcached, error)

New - initializes

func (*Memcached) Delete

func (mc *Memcached) Delete(router, namespace []byte, fqnKeys ...string) error

Delete - deletes an object from the cache

func (*Memcached) Get

func (mc *Memcached) Get(router, namespace []byte, fqnKeys ...string) ([]byte, bool, error)

Get - returns an object from the cache

func (*Memcached) Put

func (mc *Memcached) Put(router, value, ttl, namespace []byte, fqnKeys ...string) error

Put - puts an object in the cache