fatchoy

package

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

Changes in this version

+ const NodeDistrictMask

+ const NodeDistrictShift

+ const PacketFlagBitsMask

+ const PacketFlagCompress

+ const PacketFlagEncrypt

+ const PacketFlagRefer

+ const TimerTickInterval

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

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

+ 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 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

+ Codec func() Codec

type Environ

+ 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

type MessageSubscriber

+ 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 NodeID

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

+ func (n NodeID) District() uint16

+ func (n NodeID) IsClient() bool

type NodeIDSet

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

type Options

+ ConfigFile string

+ Interface string

+ IsCrossDistrict bool

+ ServiceDistrict int

type Packet

+ Flags uint16

+ Node NodeID

+ Referer uint32

+ func (m *Packet) DecodeAsString() string

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

type PacketQueue

+ func NewMessageQueue() *PacketQueue

type RoutePolicy

+ func NewBasicRoutePolicy(endpoints *EndpointMap) RoutePolicy

type ServiceContext

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

type Stats

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

type TimerNode

+ Priority int64

v0

v0.2.6

Apr 25, 2021

Changes in this version

type Endpoint

+ SetEncryptPair func(cipher.BlockCryptor, cipher.BlockCryptor)

v0.2.5

Apr 21, 2021

Changes in this version

type MessageEndpoint

+ SetUserData func(interface{})

+ UserData func() interface{}

type NetInterface

+ func (i NetInterface) String() string

v0.2.4

Apr 21, 2021

v0.2.3

Apr 21, 2021

v0.2.2

Apr 20, 2021

v0.2.1

Apr 20, 2021

Changes in this version

+ const NET_INTERFACES

+ const NET_PEER_PING_INTERVAL

+ const NET_PEER_READ_INTERVAL

+ const NET_RPC_TTL

+ const NET_SESSION_READ_TIMEOUT

+ const NodeInstanceMask

+ const NodeServiceMask

+ const NodeServiceShift

+ const NodeTypeClient

+ const NodeTypeShift

+ const NumStats

+ const PacketFlagCompressed

+ const PacketFlagEncrypted

+ const PacketFlagError

+ const PacketFlagJSONText

+ const PacketFlagRpc

+ const RUNTIME_CONTEXT_INBOUND_SIZE

+ const RUNTIME_CONTEXT_OUTBOUND_SIZE

+ const RUNTIME_ENDPOINT_OUTBOUND_SIZE

+ const RUNTIME_EXECUTOR_CAPACITY

+ const RUNTIME_EXECUTOR_CONCURRENCY

+ const StatCommit

+ const StatDropped

+ const StatError

+ const StatExec

+ const StatTimer

+ const TimerChanCapacity

+ const TimerPrecision

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

+ 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{}, f *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 ParseNetInterface(text string) *protocol.InterfaceAddr

+ func Register(service Service)

+ func StartClock()

+ func StopClock()

+ func WallClock() *datetime.Clock

+ type CapturedRunnable struct

+ F func() error

+ func (r *CapturedRunnable) Run() error

+ type Endpoint interface

+ Encoder func() ProtocolCodec

+ Go func(write, read bool)

+ RawConn func() net.Conn

+ SetEncrypt func(cipher.BlockCryptor, cipher.BlockCryptor)

+ 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

+ func LoadEnviron() *Environ

+ func NewEnviron() *Environ

+ func (e *Environ) IsProd() bool

+ func (e *Environ) SetByOption(opt *Options)

+ 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 int32) 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(msgId int32, node NodeID)

+ func (s *MessageSubscriber) AddSubNodeRange(startId, endId int32, node NodeID)

+ func (s *MessageSubscriber) DeleteNodeSubscription(node NodeID)

+ func (s *MessageSubscriber) GetSubscribeNodes(startId, endId int32) NodeIDSet

+ func (s *MessageSubscriber) GetSubscribeNodesOf(msgID int32) NodeIDSet

+ type MessageSubscription struct

+ EndID int32

+ Nodes NodeIDSet

+ StartID int32

+ func (s *MessageSubscription) Match(id int32) bool

+ func (s *MessageSubscription) MatchRange(startId, endId int32) bool

+ type MySQLConf struct

+ Addr string

+ Database string

+ Password string

+ User string

+ func (c *MySQLConf) DSN() string

+ type NetInterface protocol.InterfaceAddr

+ func (i NetInterface) AdvertiseInterface() string

+ func (i NetInterface) Interface() string

+ type NodeID uint32

+ func MakeNodeID(service uint8, instance uint16) NodeID

+ func MakeSessionNodeID(session uint32) NodeID

+ func MustParseNodeID(s string) NodeID

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

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

+ func (n NodeID) Instance() uint16

+ func (n NodeID) IsBackend() bool

+ func (n NodeID) Service() uint8

+ func (n NodeID) String() string

+ type NodeIDSet []NodeID

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

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

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

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

+ type Options struct

+ EnableSysLog bool

+ EnvFile string

+ EtcdAddress string

+ EtcdKeySpace string

+ EtcdLeaseTTL int

+ List bool

+ LogLevel string

+ PprofAddr string

+ ResourceDir string

+ ServiceDependency string

+ ServiceIndex uint16

+ ServiceType string

+ ShowVersion bool

+ SysLogParams string

+ WorkingDir string

+ func NewOptions() *Options

+ func ParseOptions() (*Options, error)

+ type Packet struct

+ Body interface{}

+ Command uint32

+ Endpoint MessageEndpoint

+ Flag uint16

+ Seq uint32

+ func MakePacket() *Packet

+ func NewPacket(command, seq uint32, flag uint16, body interface{}) *Packet

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

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

+ func (m *Packet) DecodeBodyAsString() string

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

+ func (m *Packet) EncodeBody() ([]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 NewPacketQueue() *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 ProtocolCodec interface

+ type ProtocolDecoder interface

+ Unmarshal func(r io.Reader, decrypt cipher.BlockCryptor, pkt *Packet) (int, error)

+ type ProtocolEncoder interface

+ Marshal func(w io.Writer, encrypt cipher.BlockCryptor, pkt *Packet) (int, error)

+ type RoutePolicy interface

+ IsLoopBack func(*Router, *Packet) bool

+ Lookup func(*Router, *Packet) Endpoint

+ Multicast func(*Router, *Packet) bool

+ 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 int64) bool

+ func (s *Scheduler) Go()

+ func (s *Scheduler) Init() error

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

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

+ 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(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) 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(i int, delta int64) int64

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

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

+ func (s *Stats) Get(i int) int64

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

+ type TimerHeap []*TimerNode

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

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

+ func (q *TimerHeap) Update(item *TimerNode, ts 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

+ ExpireTs int64

+ Index int32

+ R Runner

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