store

Documentation

Overview

* @Author: calmwu * @Date: 2018-06-13 11:42:36 * @Last Modified by: calmwu * @Last Modified time: 2018-06-13 11:54:08 * @Comment:

* @Author: calmwu * @Date: 2018-01-29 19:29:06 * @Last Modified by: calmwu * @Last Modified time: 2018-05-16 18:22:00 * @Comment:

Index

• Constants
• func QueryRecords(session *gocql.Session, cqlContent string) []map[string]interface{}
• type CDKeyStatusT
• type CassandraStoreMgr
  • func (casMgr *CassandraStoreMgr) FiniCassandraSessions()
  • func (casMgr *CassandraStoreMgr) GetSessionByKeyspace(keyspace string) *gocql.Session
  • func (casMgr *CassandraStoreMgr) InitCassandraSessions(cassandraConf *common.CassandraConfS) error
  • func (casMgr *CassandraStoreMgr) QueryResult(req *base.ProtoRequestS, remoteIP string) interface{}
  • func (casMgr *CassandraStoreMgr) SubmitRequest(cpd *proto.CassandraProcDataS)
• type CassandraWorkerMgr
  • func (cwm *CassandraWorkerMgr) Start(workerCount int)
  • func (cwm *CassandraWorkerMgr) Stop()
• type TblUserMatchInfoS
• type TblUserOnineS
• type TblUserTotalRechargeS
• type UserMatchParamsS

Constants

const (
	TBNAME_USERONLINE    = "tbl_UserOnline"
	TBNAME_USERMATCHINFO = "tbl_UserMatchInfo"
	TBNAME_USERRECHARGE  = "tbl_UserTotalRecharge"

	MAX_BATCHCDKEY_COUNT       = 500
	MAX_RECENTCDKEYBATCH_COUNT = 100
	MAX_GEOUIN_COUNT           = 50
)

const (
	ECDKEY_STATUS_ACTIVATE = 1
	ECDKEY_STATUS_RECEIVED = 2
	ECDKEY_STATUS_ABOLISH  = 3
	ECDKEY_STATUS_EXPIRE   = 4
)

Functions

func QueryRecords

func QueryRecords(session *gocql.Session, cqlContent string) []map[string]interface{}

Types

type CDKeyStatusT

type CDKeyStatusT int

type CassandraStoreMgr

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

var (
	CasMgr *CassandraStoreMgr = nil
)

func (*CassandraStoreMgr) FiniCassandraSessions

func (casMgr *CassandraStoreMgr) FiniCassandraSessions()

func (*CassandraStoreMgr) GetSessionByKeyspace

func (casMgr *CassandraStoreMgr) GetSessionByKeyspace(keyspace string) *gocql.Session

func (*CassandraStoreMgr) InitCassandraSessions

func (casMgr *CassandraStoreMgr) InitCassandraSessions(cassandraConf *common.CassandraConfS) error

func (*CassandraStoreMgr) QueryResult

func (casMgr *CassandraStoreMgr) QueryResult(req *base.ProtoRequestS, remoteIP string) interface{}

func (*CassandraStoreMgr) SubmitRequest

func (casMgr *CassandraStoreMgr) SubmitRequest(cpd *proto.CassandraProcDataS)

type CassandraWorkerMgr

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

func (*CassandraWorkerMgr) Start

func (cwm *CassandraWorkerMgr) Start(workerCount int)

func (*CassandraWorkerMgr) Stop

func (cwm *CassandraWorkerMgr) Stop()

type TblUserMatchInfoS

type TblUserMatchInfoS struct {
	Uin                 int         `mapstructure:"uin"`
	MatchCount          int         `mapstructure:"matchcount"`
	MatchTotalTime      int         `mapstructure:"matchtotaltime"`
	MatchMaxDuration    int         `mapstructure:"MatchMaxDuration"`
	MatchWinCount       int         `mapstructure:"matchwincount"`
	MatchLostCount      int         `mapstructure:"matchlostcount"`
	MatchTieCount       int         `mapstructure:"matchtiecount"`
	MatchSurrenderCount int         `mapstructure:"matchsurrendercount"`
	MatchEscapeCount    int         `mapstructure:"matchescapecount"`
	MatchShipStatistics map[int]int `mapstructure:"matchshipstatistics"`
	RecentlyUseShips    []int       `mapstructure:"RecentlyUseShips"`
	LineUpStatistics    map[int]int `mapstructure:"lineupstatistics"`
	VersionID           int         `mapstructure:"versionid"`
}

type TblUserOnineS

type TblUserOnineS struct {
	Uin             int    `mapstructure:"Uin"`
	CreateTime      int64  `mapstructure:"CreateTime"`
	ISOCountryCode  string `mapstructure:"ISOCountryCode"`
	LoginTime       int64  `mapstructure:"LoginTime"`
	LogoutTime      int64  `mapstructure:"LogoutTime"`
	MaxOnlinetime   int64  `mapstructure:"MaxOnlinetime"`
	TotalOnlineTime int64  `mapstructure:"TotalOnlineTime"`
	VersionID       int    `mapstructure:"VersionID"`
	Platform        string `mapstructure:"Platform"`
}

type TblUserTotalRechargeS

type TblUserTotalRechargeS struct {
	Uin           int     `mapstructure:"Uin"`
	ChannelID     string  `mapstructure:"ChannelID"`
	TotalCost     float32 `mapstructure:"TotalCost"`
	RechargeCount int     `mapstructure:"RechargeCount"`
}

type UserMatchParamsS

type UserMatchParamsS struct {
	MatchDuration int   `json:"MatchDuration"`
	MatchResult   int   `json:"MatchResult"`
	ShipIDs       []int `json:"ShipIDs"`
	LineUpId      int   `json:"LineUpId"`
}