Documentation ¶
Index ¶
- func AddCall(id CallId, call Call)
- func CallExist(id CallId) bool
- func Int(str string) int
- func Int64(str string) int64
- func RemoveCall(id CallId)
- type Call
- type CallId
- type CallPool
- type ClusterTimeWheel
- type Context
- type LocalTimeWheel
- type Node
- type Options
- type OrderList
- type Target
- type TimeWheel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RemoveCall ¶
func RemoveCall(id CallId)
Types ¶
type ClusterTimeWheel ¶
type ClusterTimeWheel struct {
// contains filtered or unexported fields
}
func (*ClusterTimeWheel) RemoveTimer ¶
func (wheel *ClusterTimeWheel) RemoveTimer(id string)
func (*ClusterTimeWheel) Run ¶
func (wheel *ClusterTimeWheel) Run() TimeWheel
func (*ClusterTimeWheel) Stop ¶
func (wheel *ClusterTimeWheel) Stop()
func (*ClusterTimeWheel) UnMarkLocation ¶ added in v1.0.1
func (wheel *ClusterTimeWheel) UnMarkLocation(id string)
type Context ¶
type Context struct { Name string `json:"name,omitempty"` Data map[string]interface{} `json:"data,omitempty"` }
Context 定时器上下文
func NewContext ¶
type LocalTimeWheel ¶
type LocalTimeWheel struct {
// contains filtered or unexported fields
}
LocalTimeWheel 基于本地内存实现
func (*LocalTimeWheel) RemoveTimer ¶
func (wheel *LocalTimeWheel) RemoveTimer(id string)
func (*LocalTimeWheel) Run ¶
func (wheel *LocalTimeWheel) Run() TimeWheel
func (LocalTimeWheel) Stop ¶
func (wheel LocalTimeWheel) Stop()
type Options ¶
type OrderList ¶
type OrderList struct { Header *Node // contains filtered or unexported fields }
func NewOrderList ¶
func NewOrderList() *OrderList
Click to show internal directories.
Click to hide internal directories.