server

Documentation

Index

• func ClientHandler(conn net.Conn, app *App)
• type App
  • func NewApp(conf *config.Config) *App
  • func (app *App) Close() error
  • func (app *App) GetTidis() *tidis.Tidis
  • func (app *App) Run()
• type Client
  • func (c *Client) CommitTxn() error
  • func (c *Client) FlushResp(resp interface{}) error
  • func (c *Client) GetCurrentTxn() kv.Transaction
  • func (c *Client) IsTxn() bool
  • func (c *Client) NewTxn() error
  • func (c *Client) Resp(resp interface{}) error
  • func (c *Client) Resp1(resp interface{}) error
  • func (c *Client) RollbackTxn() error
• type CmdFunc
• type Command

Functions

func ClientHandler

func ClientHandler(conn net.Conn, app *App)

Types

type App

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

func NewApp

func NewApp(conf *config.Config) *App

initialize an app

func (*App) Close

func (app *App) Close() error

func (*App) GetTidis

func (app *App) GetTidis() *tidis.Tidis

func (*App) Run

func (app *App) Run()

type Client

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

func (*Client) CommitTxn

func (c *Client) CommitTxn() error

func (*Client) FlushResp

func (c *Client) FlushResp(resp interface{}) error

func (*Client) GetCurrentTxn

func (c *Client) GetCurrentTxn() kv.Transaction

func (*Client) IsTxn

func (c *Client) IsTxn() bool

func (*Client) NewTxn

func (c *Client) NewTxn() error

for multi transaction commands

func (*Client) Resp

func (c *Client) Resp(resp interface{}) error

func (*Client) Resp1

func (c *Client) Resp1(resp interface{}) error

treat string as bulk array

func (*Client) RollbackTxn

func (c *Client) RollbackTxn() error

type CmdFunc

type CmdFunc func(c *Client) error

type Command

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