handle

Documentation

Overview

Package handle deals with the commands(get/set ...)

Index

• Constants
• Variables
• func Init()
• func Read(conn *net.TCPConn, data []byte) error
• func SessionHash(data []byte) int
• func Start(port int)
• func Write(conn *net.TCPConn, data []byte) error
• type FusionError
  • func (err FusionError) Error() string

Constants

const (
	ADD_STRING = iota + 1
	ADD_STRING_RES
	DEL_KEY
	DEL_KEY_RES
	QUERY_KEY
	QUERY_KEY_RES
	KEEPALIVE
	KEEPALIVE_RES
	HELLO
	HELLO_RES
	ADD_DB
	ADD_DB_RES
)

for access request msg format

const (
	KEYHASHMAX = 1024 * 8
)

Variables

var (
	// Caches to store k/v
	Caches *hashmap.Dbs
	//GstartTime saves app's start time
	GstartTime = time.Now().Unix()
)

Functions

func Init

func Init()

Init get the default caches which has been initialised.

func Read

func Read(conn *net.TCPConn, data []byte) error

Read Wrapper conn.Read

func SessionHash

func SessionHash(data []byte) int

func Start

func Start(port int)

Start run a tcp server

func Write

func Write(conn *net.TCPConn, data []byte) error

Write wrapper conn.Write

Types

type FusionError

type FusionError string

func (FusionError) Error

func (err FusionError) Error() string