config

Documentation

Index

• Constants
• Variables
• type SecLayerContext
• type SecRequest
• type SecResult
• type SkAppCtx

Constants

const (
	ProductStatusNormal       = 0 //商品状态正常
	ProductStatusSaleOut      = 1 //商品售罄
	ProductStatusForceSaleOut = 2 //商品强制售罄
)

Variables

var CoreCtx = &SkAppCtx{}

var Logger log.Logger

var SecLayerCtx = &SecLayerContext{
	Read2HandleChan:  make(chan *SecRequest, 1024),
	Handle2WriteChan: make(chan *SecResult, 1024),
	HistoryMap:       make(map[int]*srv_user.UserBuyHistory, 1024),
	ProductCountMgr:  srv_product.NewProductCountMgr(),
}

var ZipkinTracer *zipkin.Tracer

Types

type SecLayerContext

type SecLayerContext struct {
	RWSecProductLock sync.RWMutex

	WaitGroup sync.WaitGroup

	Read2HandleChan  chan *SecRequest
	Handle2WriteChan chan *SecResult

	HistoryMap     map[int]*srv_user.UserBuyHistory
	HistoryMapLock sync.Mutex

	ProductCountMgr *srv_product.ProductCountMgr //商品计数
}

type SecRequest

type SecRequest struct {
	ProductId     int             `json:"product_id"` //商品ID
	Source        string          `json:"source"`
	AuthCode      string          `json:"auth_code"`
	SecTime       int64           `json:"sec_time"`
	Nance         string          `json:"nance"`
	UserId        int             `json:"user_id"`
	UserAuthSign  string          `json:"user_auth_sign"` //用户授权签名
	ClientAddr    string          `json:"client_addr"`
	ClientRefence string          `json:"client_refence"`
	CloseNotify   <-chan bool     `json:"-"`
	ResultChan    chan *SecResult `json:"-"`
}

type SecResult

type SecResult struct {
	ProductId int    `json:"product_id"` //商品ID
	UserId    int    `json:"user_id"`    //用户ID
	Token     string `json:"token"`      //Token
	TokenTime int64  `json:"token_time"` //Token生成时间
	Code      int    `json:"code"`       //状态码
}

type SkAppCtx

type SkAppCtx struct {
	SecReqChan       chan *SecRequest
	SecReqChanSize   int
	RWSecProductLock sync.RWMutex

	UserConnMap     map[string]chan *SecResult
	UserConnMapLock sync.Mutex
}