replica

Documentation

Index

• Constants
• Variables
• func GetMyIp() []string
• func Init(url string)
• func IsOwner(req *gomemcached.MCRequest) bool
• func ProxyRemoteRead(req *gomemcached.MCRequest) *gomemcached.MCResponse
• func ProxyRemoteWrite(req *gomemcached.MCRequest)
• func QueueRemoteWrite(req *gomemcached.MCRequest)

Constants

const OP_REP = 0x02

const OP_SET = 0x01

Variables

var ConnPoolAvailWaitTime = time.Millisecond

ConnPoolAvailWaitTime is the amount of time to wait for an existing connection from the pool before considering the creation of a new one.

var ConnPoolCallback func(host string, source string, start time.Time, err error)

ConnPoolTimeout is notified whenever connections are acquired from a pool.

var ConnPoolTimeout = time.Hour * 24 * 30

Default timeout for retrieving a connection from the pool.

var TimeoutError = errors.New("timeout waiting to build connection")

Error raised when a connection can't be retrieved from a pool.

Functions

func GetMyIp

func GetMyIp() []string

func Init

func Init(url string)

func IsOwner

func IsOwner(req *gomemcached.MCRequest) bool

func ProxyRemoteRead

func ProxyRemoteRead(req *gomemcached.MCRequest) *gomemcached.MCResponse

we are not the master of this node, so proxy

func ProxyRemoteWrite

func ProxyRemoteWrite(req *gomemcached.MCRequest)

we are not the master of this node, so proxy

func QueueRemoteWrite

func QueueRemoteWrite(req *gomemcached.MCRequest)

return true if data needs to be written here