pkg

type Aof struct {
	Fd  *os.File
	Log log.ILog
}

type Client struct {
	Conn            net.Conn
	Index           int
	Name            string
	Log             log.ILog
	Db              *RedisDb
	QueryBuf        []byte
	Query           string
	Argv            []*RedisObject
	LastInteraction string
	ReqType         int // 协议类型
	MultiBulkLen    int
	QbPos           int
	BulkLen         int
	Cmd             *RedisCommand
	LastCmd         *RedisCommand
	Pending         chan *Pending
	Flags           int
	PubSubChannel   map[string]bool
}

type ClusterNode struct {
}

type ClusterState struct {
}

type Dict struct {
	Storage map[string]*RedisObject
}

type Pending struct {
}

type PubSubPattern struct {
	Client  *Client
	Pattern *RedisObject
}

type Rdb struct {
}

type RedisCommand struct {
	Name         string
	Proc         func(c *Client)
	Arity        int
	SFlags       string
	Flags        int
	GetKeysProc  *int
	FirstKey     int
	LastKey      int
	KeyStep      int
	Microseconds int
	Calls        int
}

type RedisDb struct {
	Id     int
	AvgTtl int
	Dict   *Dict
}

type RedisObject struct {
	Encoding int
	TypeFlag int
	Lru      int
	Refcount int
	Ptr      interface{}
}

type ReplicationMain struct {
	Host   string
	Port   int
	Client *Client
	Auth   string
	State  int
}

type ReplicationReplica struct {
	Host  string
	Port  int
	State int
}

type Server struct {
	RequirePass          bool
	Log                  log.ILog
	Clients              map[int]*Client
	Db                   []*RedisDb
	No                   int
	StatRejectedConn     int
	CurrentClient        chan *Client
	Listener             net.Listener
	Aof                  *Aof
	WaitCloseClients     chan int
	NewClients           chan net.Conn
	Commands             map[string]*RedisCommand
	ClientMaxQueryBufLen int
	AofState             int
	AofFsync             int
	AofSelectedDb        int
	ReplicaList          []*ReplicationReplica
	Main                 *ReplicationMain
	PubSubChannels       map[string][]*Client
	Monitors             []*Client
}