fatchoy

Mar 11, 2022

Changes in this version

type PacketType

+ const PTypePong

+ const PTypeRequest

+ const PTypeResponse

Mar 11, 2022

Changes in this version

type Endpoint

+ Close func() error

+ ForceClose func(error)

+ IsRunning func() bool

+ Node func() NodeID

+ RemoteAddr func() string

+ Send func(*Packet) error

+ SetNode func(NodeID)

+ SetUserData func(interface{})

+ UserData func() interface{}

+ type EndpointShardedMap struct

+ func NewEndpointShardedMap() *EndpointShardedMap

+ func (m *EndpointShardedMap) Clear()

+ func (m *EndpointShardedMap) Foreach(action func(Endpoint) int)

+ func (m *EndpointShardedMap) Get(node NodeID) Endpoint

+ func (m *EndpointShardedMap) Has(node NodeID) bool

+ func (m *EndpointShardedMap) IsEmpty() bool

+ func (m *EndpointShardedMap) Keys() []NodeID

+ func (m *EndpointShardedMap) Put(node NodeID, endpoint Endpoint)

+ func (m *EndpointShardedMap) PutIfAbsent(node NodeID, endpoint Endpoint)

+ func (m *EndpointShardedMap) Remove(node NodeID)

+ func (m *EndpointShardedMap) Size() int

+ type EndpointSyncMap struct

+ func (m *EndpointSyncMap) Clear()

+ func (m *EndpointSyncMap) Foreach(action func(Endpoint) int)

+ func (m *EndpointSyncMap) Get(node NodeID) Endpoint

+ func (m *EndpointSyncMap) Has(node NodeID) bool

+ func (m *EndpointSyncMap) IsEmpty() bool

+ func (m *EndpointSyncMap) Keys() []NodeID

+ func (m *EndpointSyncMap) Put(node NodeID, endpoint Endpoint)

+ func (m *EndpointSyncMap) PutIfAbsent(node NodeID, endpoint Endpoint)

+ func (m *EndpointSyncMap) Remove(node NodeID)

+ func (m *EndpointSyncMap) Size() int

type Packet

+ Session Endpoint

+ func (m *Packet) SessionNode() NodeID

type ServiceContext

+ func (c *ServiceContext) EnqueuePacket(pkt *Packet)

+ func (c *ServiceContext) TryEnqueuePacket(pkt *Packet) bool

+ func (c *ServiceContext) TryEnqueueTask(task Runnable) bool

+ func (c *ServiceContext) TrySendPacket(pkt *Packet) bool

Mar 10, 2022

Changes in this version

+ const INSTANCE_ANY

+ const NodeTypeMask

+ const REFERER_ALL

type NodeID

+ func (n NodeID) IsTypeClient() bool

type Packet

+ Type PacketType

+ func MakePacket(cmd uint16, body proto.Message) *Packet

type PacketType

+ const PTypeControl

+ const PTypeError

+ const PTypeMessage

+ const PTypePing

+ type TaskFactory struct

+ func (f *TaskFactory) Chan() <-chan Task

+ func (f *TaskFactory) Init(capacity int) *TaskFactory

+ func (f *TaskFactory) Schedule(task Task) error

+ func (f *TaskFactory) Start() error

Feb 24, 2022

Changes in this version

+ const InstanceAll

+ const InstanceAny

+ const RefererAny

+ const ServiceAll

Feb 24, 2022

Changes in this version

type Packet

+ func (m *Packet) SetRefer(node NodeID)

Feb 24, 2022

Changes in this version

+ func GetServiceTypes() []uint8

type MessageEndpoint

+ Node func() NodeID

+ SetNode func(NodeID)

type Packet

+ func AllocPacket() *Packet

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

+ func (m *Packet) Refer() NodeID

type Service

+ Node func() NodeID

+ SetNode func(id NodeID)

type ServiceContext

+ func (c *ServiceContext) EnqueueQueue(pkt *Packet)

+ func (c *ServiceContext) EnqueueTask(task Runnable)

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

+ func (c *ServiceContext) TaskQueue() <-chan Runnable

Feb 15, 2022

Changes in this version

+ func FreePacket(pkt *Packet)

+ func RegisterAllMessages(validNameSuffix []string) (er error)

+ func SetPacketAllocPolicy(policy int)

+ type IPacketAllocator interface

+ Alloc func() *Packet

+ Free func(*Packet)

+ func GetPacketAllocator(policy int) IPacketAllocator

+ type Packet struct

+ Body interface{}

+ Command int32

+ Endpoint MessageEndpoint

+ Flags PacketFlag

+ MsgID uint32

+ Node NodeID

+ Refers []NodeID

+ Seq uint16

+ func NewPacket(cmd int32, flags PacketFlag, seq uint16, body interface{}) *Packet

+ func (m *Packet) AddRefers(refers ...NodeID)

+ func (m *Packet) AutoDecode() error

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

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

+ func (m *Packet) EncodeToBytes() []byte

+ func (m *Packet) Errno() int32

+ func (m *Packet) Refuse(errno int32) error

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

+ func (m *Packet) ReplyAny(body interface{}) error

+ func (m *Packet) Reset()

+ func (m *Packet) SetBody(val interface{})

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

+ func (m *Packet) String() string

type ServiceContext

+ func (c *ServiceContext) SendPacket(pkt *Packet)

Jan 27, 2022

Changes in this version

+ const PendingQueueCapacity

+ const TaskCancelled

+ const TaskExecuted

+ const TaskScheduled

+ const TaskStateInit

+ const TimeoutQueueCapacity

+ var ErrNoHandlers = errors.New("no handlers for command")

+ func DeregisterHandler(command int32)

+ func DispatchMessage(ctx context.Context, msg *Message) error

+ func RegisterHandler(command int32, action MessageHandler)

+ func SetPanicHandler(f PanicHandler)

+ type MessageDispatcher struct

+ func DefaultDispatcher() *MessageDispatcher

+ func NewMessageDispatcher() *MessageDispatcher

+ func (d *MessageDispatcher) Deregister(command int32)

+ func (d *MessageDispatcher) DeregisterOne(command int32, handler MessageHandler)

+ func (d *MessageDispatcher) Dispatch(ctx context.Context, msg *Message) error

+ func (d *MessageDispatcher) Register(command int32, handler MessageHandler)

+ func (d *MessageDispatcher) SetPanicHandler(f PanicHandler)

+ type PanicHandler func(*Message, interface{})

+ type Runnable interface

+ Run func() error

+ type Task struct

+ func NewTask(action func() error) *Task

+ func (r *Task) Cancel() bool

+ func (r *Task) Run() error

+ func (r *Task) SetState(state int32)

+ func (r *Task) State() int32

+ type Timer interface

+ Cancel func(id int) bool

+ Chan func() <-chan Runnable

+ IsPending func(id int) bool

+ RunAfter func(timeUnits int, r Runnable) int

+ RunEvery func(interval int, r Runnable) int

+ Shutdown func()

+ Size func() int

+ Start func()

+ func NewDefaultTimerQueue() Timer

+ func NewTimerQueue(tickInterval, timeUnit time.Duration) Timer

+ type TimerQueue struct

+ C chan Runnable

+ func (s *TimerQueue) Cancel(id int) bool

+ func (s *TimerQueue) Chan() <-chan Runnable

+ func (s *TimerQueue) IsPending(id int) bool

+ func (s *TimerQueue) RunAfter(timeUnits int, r Runnable) int

+ func (s *TimerQueue) RunEvery(interval int, r Runnable) int

+ func (s *TimerQueue) Shutdown()

+ func (s *TimerQueue) Size() int

+ func (s *TimerQueue) Start()

Jan 27, 2022

Changes in this version

+ const AllocPolicyArena

+ const AllocPolicyPool

+ const AllocPolicyRuntime

+ func FreeMessage(msg *Message)

+ func GetEnv(key string, def string) string

+ func GetEnvBool(key string) bool

+ func GetEnvFloat(key string, def float64) float64

+ func GetEnvInt(key string, def int) int

+ func GetEnvInt64(key string, def int64) int64

+ func SetMessageAllocPolicy(policy int)

type IMessageAllocator

+ func GetMessageAllocator(policy int) IMessageAllocator

Jan 22, 2022

Changes in this version

type Message

+ func (m *Message) AutoDecode() error

Jan 22, 2022

Changes in this version

+ const SuffixACK

+ const SuffixNTF

+ const SuffixREQ

+ func CreateMessageByID(hash uint32) proto.Message

+ func CreateMessageByName(name string) proto.Message

+ func CreatePairingAck(req proto.Message) proto.Message

+ func CreatePairingAckBy(reqName string) proto.Message

+ func GetMessageIDByName(name string) uint32

+ func GetMessageIDOf(msg proto.Message) uint32

+ func GetMessageNameByID(hash uint32) string

+ func GetPairingAckName(reqName string) string

+ func RegisterAllAPI()

type Message

+ func (m *Message) Refuse(errno int32) error

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

+ func (m *Message) ReplyAny(body interface{}) error

Jan 22, 2022

Changes in this version

type Message

+ func (m *Message) AddRefers(refers ...NodeID)

Jan 22, 2022

Changes in this version

+ type ArenaAllocator struct

+ func NewArenaAllocator(blockSize int) *ArenaAllocator

+ func (a *ArenaAllocator) Alloc() *Message

+ func (a *ArenaAllocator) Free(msg *Message)

+ func (a *ArenaAllocator) PtrIndex(msg *Message) int

+ type IMessageAllocator interface

+ Alloc func() *Message

+ Free func(*Message)

+ func NewPoolAllocator() IMessageAllocator

+ func NewRuntimeAllocator() IMessageAllocator

type Message

+ func AllocMessage() *Message

+ type PoolAllocator struct

+ func (a *PoolAllocator) Alloc() *Message

+ func (a *PoolAllocator) Free(msg *Message)

+ type RuntimeAllocator struct

+ func (a *RuntimeAllocator) Alloc() *Message

+ func (a *RuntimeAllocator) Free(msg *Message)

Jan 22, 2022

Changes in this version

+ func IBody2Bytes(body interface{}) []byte

+ func IBody2Float(body interface{}) float64

+ func IBody2Int64(body interface{}) int64

+ func IBody2String(body interface{}) string

+ func IBodyAsBytes(body interface{}) []byte

+ func PB2JSON(msg proto.Message) string

+ func SafeToBody(val interface{}) interface

+ func SetMessageAllocator(alloc MessageAllocator)

type Endpoint

+ OutMsgChan func() chan<- *Message

+ type Message struct

+ Body interface{}

+ Command int32

+ Endpoint MessageEndpoint

+ Flags PacketFlag

+ MsgID uint32

+ Node NodeID

+ Refers []NodeID

+ Seq uint16

+ func MakeMessage() *Message

+ func NewMessage(cmd int32, flags PacketFlag, seq uint16, body interface{}) *Message

+ func (m *Message) Clone() *Message

+ func (m *Message) DecodeTo(msg proto.Message) error

+ func (m *Message) EncodeToBytes() []byte

+ func (m *Message) Errno() int32

+ func (m *Message) Reset()

+ func (m *Message) SetBody(val interface{})

+ func (m *Message) SetErrno(ec int32)

+ func (m *Message) String() string

+ type MessageAllocator func() *Message

type MessageEndpoint

+ Send func(*Message) error

+ type MessageHandler func(*Message) error

+ type NetPacket struct

+ Body []byte

+ Head []byte

+ Session Endpoint

+ Timestamp int64

type PacketFlag

+ const PFlagRawBody

+ const PFlagReserve

Jan 21, 2022

Changes in this version

+ const FOREACH_CONTINUE

+ const FOREACH_EXIT

Jan 21, 2022

Changes in this version

+ func RegisterPacketMaker(name string, f PacketMaker)

+ func RegisterService(s Service)

type PacketMaker

+ func GetPacketMaker(name string) PacketMaker

Jan 20, 2022

Changes in this version

type PacketMaker

+ var DefaultPacketMaker PacketMaker

Jan 20, 2022

Changes in this version

+ type PacketMaker func() IPacket

Jan 20, 2022

Changes in this version

type Endpoint

+ ErrorChan func() <-chan error

Jan 19, 2022

Changes in this version

type Service

+ func CreateService(name string) Service

Jan 18, 2022

Changes in this version

type ServiceContext

+ func (c *ServiceContext) SetInstance(inst Service)

Jan 18, 2022

Changes in this version

+ const StateStarting

Jan 18, 2022

Changes in this version

+ func GetServiceNames() []string

+ func Register(service Service)

type IPacket

+ AutoDecode func() error

type PacketFlag

+ const PFlagHashMsg

type Service

+ func GetServiceByName(name string) Service

Jan 17, 2022

Changes in this version

+ var ErrContextInboundQueueFull = errors.New("context inbound queue full")

type Service

+ SetState func(State)

+ State func() State

type ServiceContext

+ func (c *ServiceContext) ASend(pkt IPacket) error

Jan 14, 2022

Changes in this version

type PacketFlag

+ const PFlagHashedCmd

+ const PFlagHashedMsg

Jan 13, 2022

Changes in this version

type PacketFlag

+ const PFlagHashCmd

Jan 12, 2022

Changes in this version

type PacketFlag

+ const PFlagRPC

Jan 12, 2022

Changes in this version

+ const EndpointMapShardCount

+ const StateShuttingDown

+ type ConcurrentEndpointMap struct

+ func NewConcurrentEndpointMap() *ConcurrentEndpointMap

+ func (m *ConcurrentEndpointMap) Clear()

+ func (m *ConcurrentEndpointMap) Foreach(action func(Endpoint) bool)

+ func (m *ConcurrentEndpointMap) Get(node NodeID) Endpoint

+ func (m *ConcurrentEndpointMap) Has(node NodeID) bool

+ func (m *ConcurrentEndpointMap) IsEmpty() bool

+ func (m *ConcurrentEndpointMap) IterBuffered() <-chan Tuple

+ func (m *ConcurrentEndpointMap) Keys() []NodeID

+ func (m *ConcurrentEndpointMap) Pop(node NodeID) Endpoint

+ func (m *ConcurrentEndpointMap) Put(node NodeID, endpoint Endpoint)

+ func (m *ConcurrentEndpointMap) PutIfAbsent(node NodeID, endpoint Endpoint)

+ func (m *ConcurrentEndpointMap) Remove(node NodeID)

+ func (m *ConcurrentEndpointMap) Size() int

+ func (m *ConcurrentEndpointMap) Values() []Endpoint

+ type EndpointHashMap struct

+ func NewEndpointHashMap() *EndpointHashMap

+ func (m *EndpointHashMap) Clear()

+ func (m *EndpointHashMap) Foreach(action func(Endpoint) bool)

+ func (m *EndpointHashMap) Get(node NodeID) Endpoint

+ func (m *EndpointHashMap) Has(node NodeID) bool

+ func (m *EndpointHashMap) IsEmpty() bool

+ func (m *EndpointHashMap) Keys() []NodeID

+ func (m *EndpointHashMap) Pop(node NodeID) Endpoint

+ func (m *EndpointHashMap) Put(node NodeID, endpoint Endpoint)

+ func (m *EndpointHashMap) PutIfAbsent(node NodeID, endpoint Endpoint)

+ func (m *EndpointHashMap) Remove(node NodeID)

+ func (m *EndpointHashMap) Size() int

+ func (m *EndpointHashMap) Values() []Endpoint

type EndpointMap

+ Clear func()

+ Foreach func(func(Endpoint) bool)

+ Has func(node NodeID) bool

+ IsEmpty func() bool

+ Keys func() []NodeID

+ Pop func(node NodeID) Endpoint

+ Put func(node NodeID, endpoint Endpoint)

+ PutIfAbsent func(node NodeID, endpoint Endpoint)

+ Remove func(node NodeID)

+ Values func() []Endpoint

+ type EndpointMapShard struct

+ func (s *EndpointMapShard) Clear()

+ func (s *EndpointMapShard) Range(action func(Endpoint) bool)

+ type Tuple struct

+ Key NodeID

+ Val Endpoint

Jan 5, 2022

Changes in this version

type IPacket

+ Recycle func()

+ Reset func()

Dec 28, 2021

Changes in this version

type IPacket

+ MsgID func() int32

+ SetMsgID func(int32)

type PacketFlag

+ const PFlagCall

+ const PFlagMsg

Dec 22, 2021

Changes in this version

type IPacket

+ EncodeToBytes func() []byte

+ Flags func() PacketFlag

+ ReplyAny func(body interface{}) error

+ SetFlags func(PacketFlag)

type ServiceContext

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

Dec 20, 2021

Changes in this version

type ServiceContext

+ func (c *ServiceContext) RootCtx() context.Context

Dec 20, 2021

Changes in this version

type ServiceContext

+ func (c *ServiceContext) QuitDone() <-chan struct{}

+ func (c *ServiceContext) Run(ctx context.Context, instance Service) error

+ func (c *ServiceContext) StartTime() time.Time

Dec 20, 2021

Changes in this version

type PacketFlag

+ const PFlagMulticast

+ const PFlagRoute

+ func (g PacketFlag) Clear(n PacketFlag) PacketFlag

+ func (g PacketFlag) Has(n PacketFlag) bool

Dec 15, 2021

Changes in this version

+ const StateStarted

type MessageEndpoint

+ IsRunning func() bool

Dec 11, 2021

Changes in this version

+ const StateInit

+ const StateRunning

+ const StateShutdown

+ const StateTerminated

+ type State int32

+ func (s *State) CAS(old, new int32) bool

+ func (s *State) Get() int32

+ func (s *State) Set(n int32)

+ func (s State) IsRunning() bool

+ func (s State) IsShuttingDown() bool

+ func (s State) IsTerminated() bool

Nov 19, 2021

Changes in this version

type IPacket

+ ReplyWith func(command int32, body interface{}) error

Nov 18, 2021

Changes in this version

type ServiceContext

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

Nov 18, 2021

Changes in this version

type Service

+ Context func() *ServiceContext

type ServiceContext

+ func (c *ServiceContext) InitRegistrar(hostAddr, namespace string) error

+ func (c *ServiceContext) Registrar() *discovery.Client

+ func (c *ServiceContext) RunID() string

+ func (c *ServiceContext) Send(pkt IPacket)

Nov 18, 2021

Changes in this version

type ServiceContext

+ func (c *ServiceContext) WorkCtx() context.Context

Nov 18, 2021

Changes in this version

type ServiceContext

+ func (c *ServiceContext) Instance() Service

+ func (c *ServiceContext) WaitDone() <-chan struct{}

Nov 18, 2021

Changes in this version

+ const INSTANCE_ALL

+ const NodeInstanceMask

+ const NodeServiceMask

+ const NodeServiceShift

+ const NodeTypeShift

+ const SERVICE_ALL

+ const VERSION

+ var ClockEpoch int64 = 1577836800

+ func DateTime() string

+ func Now() time.Time

+ func NowString() string

+ func StartClock()

+ func StopClock()

+ func WallClock() *datetime.Clock

+ type Endpoint interface

+ Go func(EndpointFlag)

+ RawConn func() net.Conn

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

+ Stats func() *stats.Stats

+ type EndpointFlag uint32

+ const EndpointReadWriter

+ const EndpointReader

+ const EndpointWriter

+ 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) Range(f func(Endpoint) bool)

+ func (e *EndpointMap) Reset()

+ func (e *EndpointMap) Size() int

+ type IPacket interface

+ AddRefers func(...NodeID)

+ Body func() interface{}

+ BodyToBytes func() []byte

+ BodyToFloat func() float64

+ BodyToInt func() int64

+ BodyToString func() string

+ Clone func() IPacket

+ Command func() int32

+ Decode func() error

+ DecodeTo func(msg proto.Message) error

+ Endpoint func() MessageEndpoint

+ Errno func() int32

+ Flag func() PacketFlag

+ Node func() NodeID

+ Refers func() []NodeID

+ Refuse func(errno int32) error

+ RefuseWith func(command, errno int32) error

+ Reply func(command int32, body interface{}) error

+ ReplyMsg func(ack proto.Message) error

+ Seq func() uint16

+ SetBody func(v interface{})

+ SetCommand func(int32)

+ SetEndpoint func(MessageEndpoint)

+ SetErrno func(ec int32)

+ SetFlag func(PacketFlag)

+ SetNode func(NodeID)

+ SetRefers func([]NodeID)

+ SetSeq func(uint16)

+ SetType func(PacketType)

+ Type func() PacketType

+ type MessageEndpoint interface

+ Close func() error

+ ForceClose func(error)

+ IsClosing func() bool

+ NodeID func() NodeID

+ RemoteAddr func() string

+ SendPacket func(IPacket) error

+ SetNodeID func(NodeID)

+ SetUserData func(interface{})

+ UserData func() interface{}

+ type NodeID uint32

+ func MakeNodeID(service uint8, instance uint16) NodeID

+ func MustParseNodeID(s string) NodeID

+ func (n NodeID) Instance() uint16

+ func (n NodeID) IsTypeBackend() bool

+ func (n NodeID) Service() uint8

+ func (n NodeID) String() string

+ type NodeIDSet = collections.OrderedIDSet

+ type PacketFlag uint8

+ const PFlagCompressed

+ const PFlagEncrypted

+ const PFlagError

+ const PFlagRpc

+ type PacketHandler func(IPacket) error

+ type PacketType int8

+ const PTypeMulticast

+ const PTypePacket

+ const PTypeRoute

+ type Service interface

+ Init func(*ServiceContext) error

+ Name func() string

+ NodeID func() NodeID

+ ServiceContext func() *ServiceContext

+ SetNodeID func(id NodeID)

+ Startup func() error

+ Type func() int8

+ type ServiceContext struct

+ func NewServiceContext(ctx context.Context, srv Service, queueSize int) *ServiceContext

+ func (c *ServiceContext) Close()

+ func (c *ServiceContext) Context() context.Context

+ func (c *ServiceContext) MessageQueue() chan IPacket

+ func (c *ServiceContext) Service() Service