Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pkg/

directory

Go to main page

Versions in this module

v1

v1.1.2

Apr 20, 2021

v1.1.1

Apr 20, 2021

v1.1.0

Apr 20, 2021

v1.0.9

Apr 19, 2021

v1.0.8

Apr 19, 2021

v1.0.7

Apr 14, 2021

v1.0.6

Mar 30, 2021

v1.0.5

Mar 30, 2021

v1.0.4

Feb 26, 2021

v1.0.3

Feb 25, 2021

v1.0.2

Feb 25, 2021

Changes in this version

+ const NodeDistrictMask

+ const NodeDistrictShift

+ const NodeInstanceMask

+ const NodeServiceMask

+ const NodeServiceShift

+ const NodeTypeClient

+ const NodeTypeShift

+ const NumStats

+ const PacketFlagBitsMask

+ const PacketFlagCompress

+ const PacketFlagEncrypt

+ const PacketFlagError

+ const PacketFlagJSONText

+ const PacketFlagRefer

+ const PacketFlagRpc

+ const StatCommit

+ const StatDropped

+ const StatError

+ const StatExec

+ const StatTimer

+ const TimerChanCapacity

+ const TimerTickInterval

+ var ErrDestinationNotReachable = errors.New("destination not reachable")

+ var ErrExecutorBusy = errors.New("executor is busy")

+ var ErrExecutorClosed = errors.New("executor is closed")

+ var ErrOutboundQueueOverflow = errors.New("outbound queue overflow")

+ var ErrPacketContextEmpty = errors.New("packet dispatch context is empty")

+ func Backtrace(message interface{}, fp *os.File)

+ func Catch()

+ func DateTime() string

+ func DecodeAsMsg(value interface{}, msg proto.Message) error

+ func DecodeAsString(value interface{}) string

+ func DecodeU32(data []byte) (uint32, error)

+ func EncodeNumber(value interface{}, data []byte) []byte

+ func EncodeValue(value interface{}) ([]byte, error)

+ func GetServiceNames() []string

+ func GetServiceTypeByName(name string) uint8

+ func Now() time.Time

+ func ReadFileOption(filename string, opts *Options) error

+ func Register(service Service)

+ func StartClock()

+ func StopClock()

+ func WallClock() *datetime.Clock

+ type BasicRoutePolicy struct

+ func (r *BasicRoutePolicy) IsLoopBack(router *Router, pkt *Packet) bool

+ func (r *BasicRoutePolicy) Lookup(router *Router, pkt *Packet) Endpoint

+ func (r *BasicRoutePolicy) Multicast(router *Router, pkt *Packet) bool

+ type CapturedRunnable struct

+ F func() error

+ func (r *CapturedRunnable) Run() error

+ type Codec interface

+ Clone func() Codec

+ Decode func(rd io.Reader, pkt *Packet) (int, error)

+ Encode func(pkt *Packet, buf *bytes.Buffer) error

+ SetEncryptKey func(key, iv []byte)

+ SetSeqNo func(seq uint16)

+ Version func() uint8

+ type Endpoint interface

+ Codec func() Codec

+ Go func(write, read bool)

+ RawConn func() net.Conn

+ SetUserData func(interface{})

+ Stats func() *Stats

+ UserData func() interface{}

+ type EndpointMap struct

+ func NewEndpointMap() *EndpointMap

+ func (e *EndpointMap) Add(node NodeID, endpoint Endpoint)

+ func (e *EndpointMap) Delete(node NodeID) bool

+ func (e *EndpointMap) Get(node NodeID) Endpoint

+ func (e *EndpointMap) List() []Endpoint

+ func (e *EndpointMap) Reset()

+ func (e *EndpointMap) Size() int

+ type Environ struct

+ AccessKey string

+ ChannelID string

+ ContextInboundQueueSize int

+ ContextOutboundQueueSize int

+ DevelopMode bool

+ EndpointOutboundQueueSize int

+ ExecutorCapacity int

+ ExecutorConcurrency int

+ GameID string

+ MysqlDSN string

+ NetEnableEncryption bool

+ NetPeerPingInterval int

+ NetPeerReadTimeout int

+ NetPrivateKeyFile string

+ NetPublicKeyFile string

+ NetRpcTimeoutInterval int

+ NetSessionReadTimeout int

+ RedisAddr string

+ ServerID string

+ ServerName string

+ func LoadEnviron() *Environ

+ func NewEnviron() *Environ

+ func (e Environ) String() string

+ type Executor struct

+ func (e *Executor) Busyness() float32

+ func (e *Executor) Execute(r Runner) error

+ func (e *Executor) Go()

+ func (e *Executor) Init(queueSize, concurrency int) error

+ func (e *Executor) Shutdown()

+ func (e *Executor) Stats() *Stats

+ type MessageEndpoint interface

+ Close func() error

+ Context func() *ServiceContext

+ ForceClose func(error)

+ IsClosing func() bool

+ NodeID func() NodeID

+ RemoteAddr func() string

+ SendPacket func(*Packet) error

+ SetContext func(*ServiceContext)

+ SetNodeID func(NodeID)

+ type MessageSubscriber struct

+ func NewMessageSub() *MessageSubscriber

+ func (s *MessageSubscriber) AddSubNode(start, end int32, node NodeID)

+ func (s *MessageSubscriber) DeleteNodeSubs(dest NodeID)

+ func (s *MessageSubscriber) DeleteSubNode(start, end int32, node NodeID)

+ func (s *MessageSubscriber) GetSubNodes(startMsg, endMsg int32) NodeIDSet

+ func (s *MessageSubscriber) HasSubNodes(startMsg, endMsg int32) bool

+ type MySQLConf struct

+ Addr string

+ Database string

+ Password string

+ User string

+ func (c *MySQLConf) DSN() string

+ type NodeID uint32

+ func MakeNodeID(district uint16, service, instance uint8) NodeID

+ func MakeSessionNodeID(session uint32) NodeID

+ func MustParseNodeID(s string) NodeID

+ func (n *NodeID) SetDistrict(v uint16)

+ func (n *NodeID) SetInstance(v uint8)

+ func (n *NodeID) SetService(v uint8)

+ func (n NodeID) District() uint16

+ func (n NodeID) Instance() uint8

+ func (n NodeID) IsBackend() bool

+ func (n NodeID) IsClient() bool

+ func (n NodeID) Service() uint8

+ func (n NodeID) String() string

+ type NodeIDSet []NodeID

+ func (s NodeIDSet) Add(node NodeID) NodeIDSet

+ func (s NodeIDSet) Copy() []NodeID

+ func (s NodeIDSet) Delete(node NodeID) NodeIDSet

+ func (s NodeIDSet) Has(node NodeID) int

+ type Options struct

+ ConfigFile string

+ EnableSysLog bool

+ EnvFile string

+ EtcdAddress string

+ EtcdKeySpace string

+ EtcdLeaseTTL int

+ Interface string

+ IsCrossDistrict bool

+ List bool

+ LogLevel string

+ PprofAddr string

+ ResourceDir string

+ ServiceDependency string

+ ServiceDistrict int

+ ServiceIndex int

+ ServiceType string

+ ShowVersion bool

+ SysLogParams string

+ WorkingDir string

+ func NewOptions() *Options

+ func ParseOptions() (*Options, error)

+ type Packet struct

+ Body interface{}

+ Command uint32

+ Endpoint MessageEndpoint

+ Flags uint16

+ Node NodeID

+ Referer uint32

+ Seq uint16

+ func MakePacket() *Packet

+ func NewPacket(node NodeID, command, refer uint32, flags, seq uint16, body interface{}) *Packet

+ func (m *Packet) Ack(msgId int32, ack proto.Message) error

+ func (m *Packet) Clone() *Packet

+ func (m *Packet) DecodeAsString() string

+ func (m *Packet) DecodeMsg(msg proto.Message) error

+ func (m *Packet) Encode() ([]byte, error)

+ func (m *Packet) Errno() uint32

+ func (m *Packet) Refuse(command int32, errno uint32) error

+ func (m *Packet) Reply(ack proto.Message) error

+ func (m *Packet) ReplyAny(command uint32, data interface{}) error

+ func (m *Packet) Reset()

+ func (m *Packet) Run() error

+ func (m *Packet) SetErrno(ec uint32)

+ func (m Packet) String() string

+ type PacketFilter func(*Packet) bool

+ type PacketHandler func(*Packet) error

+ type PacketQueue struct

+ C chan struct{}

+ func NewMessageQueue() *PacketQueue

+ func (q *PacketQueue) Len() int

+ func (q *PacketQueue) Notify()

+ func (q *PacketQueue) Peek() *Packet

+ func (q *PacketQueue) Pop() *Packet

+ func (q *PacketQueue) Push(v *Packet)

+ func (q *PacketQueue) Reset()

+ type RoutePolicy interface

+ IsLoopBack func(*Router, *Packet) bool

+ Lookup func(*Router, *Packet) Endpoint

+ Multicast func(*Router, *Packet) bool

+ func NewBasicRoutePolicy(endpoints *EndpointMap) RoutePolicy

+ type Router struct

+ func NewRouter(node NodeID) *Router

+ func (r *Router) AddPolicy(policy RoutePolicy)

+ func (r *Router) IsLoopBack(pkt *Packet) bool

+ func (r *Router) NodeID() NodeID

+ func (r *Router) Route(pkt *Packet) error

+ type RoutingTable struct

+ func NewRoutingTable() *RoutingTable

+ func (r *RoutingTable) AddEntry(src, dst NodeID)

+ func (r *RoutingTable) DeleteDestEntry(dest NodeID)

+ func (r *RoutingTable) DeleteEntry(src NodeID)

+ func (r *RoutingTable) EntryList() []RoutingTableEntry

+ func (r *RoutingTable) GetEntry(key NodeID) NodeID

+ type RoutingTableEntry struct

+ type Runnable struct

+ F func() error

+ func (r *Runnable) Run() error

+ type Runner interface

+ Run func() error

+ func NewCapturedRunnable(f func() error) Runner

+ func NewRunner(f func() error) Runner

+ type Scheduler struct

+ C chan *TimerNode

+ func (s *Scheduler) Cancel(id int32) bool

+ func (s *Scheduler) Go()

+ func (s *Scheduler) Init() error

+ func (s *Scheduler) RunAfter(delay int32, r Runner) int32

+ func (s *Scheduler) RunEvery(delay int32, r Runner) int32

+ func (s *Scheduler) Shutdown()

+ type Service interface

+ Context func() *ServiceContext

+ Dispatch func(*Packet) error

+ Execute func(Runner) error

+ ID func() uint8

+ Init func(*ServiceContext) error

+ Name func() string

+ NodeID func() NodeID

+ SetNodeID func(NodeID)

+ Shutdown func()

+ Startup func() error

+ func GetServiceByID(srvType uint8) Service

+ func GetServiceByName(name string) Service

+ type ServiceContext struct

+ func NewServiceContext(opt *Options, env *Environ) *ServiceContext

+ func (c *ServiceContext) AddFinalizer(finalizer func())

+ func (c *ServiceContext) Env() *Environ

+ func (c *ServiceContext) Go()

+ func (c *ServiceContext) InboundQueue() chan<- *Packet

+ func (c *ServiceContext) IsClosing() bool

+ func (c *ServiceContext) Options() *Options

+ func (c *ServiceContext) Router() *Router

+ func (c *ServiceContext) SendMessage(pkt *Packet) error

+ func (c *ServiceContext) Service() Service

+ func (c *ServiceContext) SetMessageFilter(f PacketFilter) PacketFilter

+ func (c *ServiceContext) Shutdown()

+ func (c *ServiceContext) Start(srv Service) error

+ type Stats struct

+ func NewStats(n int) *Stats

+ func (s *Stats) Add(field int, delta int64) (v int64)

+ func (s *Stats) Clone() *Stats

+ func (s *Stats) Get(field int) (v int64)

+ func (s *Stats) Set(field int, v int64)

+ func (s *Stats) Values() []int64

+ type TimerHeap []*TimerNode

+ func (q *TimerHeap) Pop() interface{}

+ func (q *TimerHeap) Push(x interface{})

+ func (q *TimerHeap) Update(item *TimerNode, priority int64)

+ func (q TimerHeap) Empty() bool

+ func (q TimerHeap) Len() int

+ func (q TimerHeap) Less(i, j int) bool

+ func (q TimerHeap) Peek() *TimerNode

+ func (q TimerHeap) Swap(i, j int)

+ type TimerNode struct

+ Index int32

+ Priority int64

+ R Runner

v0

v0.2.6

Apr 25, 2021

v0.2.5

Apr 21, 2021

v0.2.4

Apr 21, 2021

v0.2.3

Apr 21, 2021

v0.2.2

Apr 20, 2021

v0.2.1

Apr 20, 2021