Versions in this module Expand all Collapse all v0 v0.0.5 Jan 19, 2023 Changes in this version + type DeliverArgs struct + CID int64 + GID string + Message *Message + NID string + UID int64 + type GateClient interface + Bind func(ctx context.Context, cid, uid int64) (miss bool, err error) + Broadcast func(ctx context.Context, kind session.Kind, message *Message) (total int64, err error) + Disconnect func(ctx context.Context, kind session.Kind, target int64, isForce bool) (miss bool, err error) + GetIP func(ctx context.Context, kind session.Kind, target int64) (ip string, miss bool, err error) + Multicast func(ctx context.Context, kind session.Kind, targets []int64, message *Message) (total int64, err error) + Push func(ctx context.Context, kind session.Kind, target int64, message *Message) (miss bool, err error) + Unbind func(ctx context.Context, uid int64) (miss bool, err error) + type GateProvider interface + Bind func(ctx context.Context, cid, uid int64) error + Broadcast func(kind session.Kind, message *packet.Message) (total int64, err error) + Disconnect func(kind session.Kind, target int64, isForce bool) error + GetIP func(kind session.Kind, target int64) (ip string, err error) + Multicast func(kind session.Kind, targets []int64, message *packet.Message) (total int64, err error) + Push func(kind session.Kind, target int64, message *packet.Message) error + Unbind func(ctx context.Context, uid int64) error + type Message struct + Buffer []byte + Route int32 + Seq int32 + type NodeClient interface + Deliver func(ctx context.Context, args *DeliverArgs) (miss bool, err error) + Trigger func(ctx context.Context, args *TriggerArgs) (miss bool, err error) + type NodeProvider interface + CheckRouteStateful func(route int32) (stateful bool, exist bool) + Deliver func(ctx context.Context, args *DeliverArgs) (miss bool, err error) + LocateNode func(ctx context.Context, uid int64) (nid string, miss bool, err error) + Trigger func(ctx context.Context, args *TriggerArgs) (miss bool, err error) + type Server interface + Addr func() string + Endpoint func() *endpoint.Endpoint + Scheme func() string + Start func() error + Stop func() error + type Transporter interface + NewGateClient func(ep *router.Endpoint) (GateClient, error) + NewGateServer func(provider GateProvider) (Server, error) + NewNodeClient func(ep *router.Endpoint) (NodeClient, error) + NewNodeServer func(provider NodeProvider) (Server, error) + type TriggerArgs struct + Event cluster.Event + GID string + UID int64