store

package

v0.0.0-...-b988991 Latest Latest Go to latest Published: Apr 16, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wubo0067/calmwu-go

Links

Open Source Insights

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
type CassandraWorkerMgr
- func (cwm *CassandraWorkerMgr) Start(workerCount int)
- func (cwm *CassandraWorkerMgr) Stop()
type TblUserMatchInfoS
type TblUserOnineS
type TblUserTotalRechargeS
type UserMatchParamsS

Constants ¶

View Source

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
)

View Source

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

Variables ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL