katsubushi

Mar 18, 2020

Changes in this version

+ type MemdBCmdStat struct

+ Key string

+ Opaque [4]byte

+ func (cmd *MemdBCmdStat) Execute(app *App, w io.Writer) error

Jun 19, 2018

Changes in this version

type App

+ func NewAppWithGenerator(gen Generator, opt Option) (*App, error)

type Client

+ func (c *Client) SetTimeout(t time.Duration)

Feb 22, 2018

Changes in this version

type App

+ func (app *App) BytesToBinaryCmd(req bRequest) (cmd MemdCmd, err error)

+ func (app *App) IsBinaryProtocol(r *bufio.Reader) (bool, error)

+ func (app *App) RespondToBinary(r io.Reader, conn net.Conn)

+ type MemdBCmdGet struct

+ Key string

+ Name string

+ Opaque [4]byte

+ func (cmd *MemdBCmdGet) Execute(app *App, w io.Writer) error

+ type MemdBCmdVersion struct

+ Opaque [4]byte

+ func (cmd MemdBCmdVersion) Execute(app *App, w io.Writer) error

+ type Option struct

+ IdleTimeout *time.Duration

+ WorkerID uint

Dec 18, 2017

Changes in this version

+ const SequenceBits

+ const WorkerIDBits

+ var DefaultIdleTimeout = 600 * time.Second

+ var Epoch = time.Date(2015, 1, 1, 0, 0, 0, 0, time.UTC)

+ var ErrDuplicatedWorkerID = errors.New("duplicated worker")

+ var ErrInvalidWorkerID = errors.New("invalid worker id")

+ var InfiniteIdleTimeout = time.Duration(0)

+ var Version = "development"

+ func Dump(id uint64) (t time.Time, workerID uint64, sequense uint64)

+ func SetLogLevel(str string) error

+ func StdLogger() *stdlog.Logger

+ func ToID(t time.Time) uint64

+ func ToTime(id uint64) time.Time

+ type App struct

+ Listener net.Listener

+ func NewApp(workerID uint) (*App, error)

+ func (app *App) BytesToCmd(data []byte) (cmd MemdCmd, err error)

+ func (app *App) GetStats() MemdStats

+ func (app *App) Listen(ctx context.Context, l net.Listener) error

+ func (app *App) ListenSock(ctx context.Context, sockpath string) error

+ func (app *App) ListenTCP(ctx context.Context, addr string) error

+ func (app *App) NextID() (uint64, error)

+ func (app *App) Ready() chan interface{}

+ func (app *App) SetIdleTimeout(timeout int) error

+ type Client struct

+ func NewClient(addrs ...string) *Client

+ func (c *Client) Fetch() (uint64, error)

+ func (c *Client) FetchMulti(n int) ([]uint64, error)

+ type Generator struct

+ WorkerID uint

+ func NewGenerator(workerID uint) (*Generator, error)

+ func (g *Generator) NextID() (uint64, error)

+ type ListenFunc func(context.Context, string) error

+ type MemdCmd interface

+ Execute func(*App, io.Writer) error

+ type MemdCmdGet struct

+ Keys []string

+ Name string

+ func (cmd *MemdCmdGet) Execute(app *App, conn io.Writer) error

+ type MemdCmdQuit int

+ func (cmd MemdCmdQuit) Execute(app *App, conn io.Writer) error

+ type MemdCmdStats int

+ func (cmd MemdCmdStats) Execute(app *App, conn io.Writer) error

+ type MemdCmdVersion int

+ func (cmd MemdCmdVersion) Execute(app *App, w io.Writer) error

+ type MemdStats struct

+ CmdGet int64

+ CurrConnections int64

+ GetHits int64

+ GetMisses int64

+ Pid int

+ Time int64

+ TotalConnections int64

+ Uptime int64

+ Version string

+ func (s MemdStats) WriteTo(w io.Writer) (int64, error)

+ type MemdValue struct

+ Flags int

+ Keys []string

+ Values []string

+ func (v MemdValue) WriteTo(w io.Writer) (int64, error)