link

Apr 2, 2024

Changes in this version

+ var ErrGateNotFoundUserSource = errors.New("gate not found user source")

+ var ErrNodeNotFoundUserSource = errors.New("node not found user source")

+ type BroadcastDeliverArgs struct

+ Kind DeliverKind

+ Message interface{}

+ type DeliverKind int

+ const Center

+ const Game

+ const Gate

+ type GetIdArgs struct

+ GID string

+ Kind session.Kind

+ Target int64

+ type IsOnlineArgs struct

+ GID string

+ Kind session.Kind

+ Target int64

type Link

+ func (l *Link) BlockConn(ctx context.Context, onid string, nnid string, target uint64)

+ func (l *Link) BroadcastDeliver(ctx context.Context, args *BroadcastDeliverArgs) error

+ func (l *Link) FetchServiceAliasIDs(ctx context.Context, kind cluster.Kind, alias string, states ...cluster.State) ([]string, error)

+ func (l *Link) FetchServiceAliasList(ctx context.Context, kind cluster.Kind, alias string, states ...cluster.State) ([]*registry.ServiceInstance, error)

+ func (l *Link) GetID(ctx context.Context, args *GetIdArgs) (int64, error)

+ func (l *Link) IsOnline(ctx context.Context, args *IsOnlineArgs) (bool, error)

+ func (l *Link) MulticastDeliver(ctx context.Context, args *MulticastDeliverArgs) error

+ func (l *Link) Ping(ctx context.Context, gid string, message string) (string, error)

+ func (l *Link) Stat(ctx context.Context, kind session.Kind) (int64, error)

+ type MulticastDeliverArgs struct

+ Kind DeliverKind

+ Message interface{}

+ Targets []string

Sep 15, 2023

Changes in this version

+ var ErrInvalidArgument = errors.New("invalid argument")

+ var ErrInvalidGID = errors.New("invalid gate id")

+ var ErrInvalidMessage = errors.New("invalid message")

+ var ErrInvalidNID = errors.New("invalid node id")

+ var ErrInvalidSessionKind = errors.New("invalid session kind")

+ var ErrNotFoundUserSource = errors.New("not found user source")

+ var ErrReceiveTargetEmpty = errors.New("the receive target is empty")

+ type BroadcastArgs struct

+ Kind session.Kind

+ Message *Message

+ type DeliverArgs struct

+ CID int64

+ Message interface{}

+ NID string

+ UID int64

+ type DisconnectArgs struct

+ GID string

+ IsForce bool

+ Kind session.Kind

+ Target int64

+ type GetIPArgs struct

+ GID string

+ Kind session.Kind

+ Target int64

+ type Link struct

+ func NewLink(opts *Options) *Link

+ func (l *Link) AskGate(ctx context.Context, uid int64, gid string) (string, bool, error)

+ func (l *Link) AskNode(ctx context.Context, uid int64, nid string) (string, bool, error)

+ func (l *Link) BindGate(ctx context.Context, uid int64, gid string, cid int64) error

+ func (l *Link) BindNode(ctx context.Context, uid int64, nid string) error

+ func (l *Link) Broadcast(ctx context.Context, args *BroadcastArgs) (int64, error)

+ func (l *Link) Deliver(ctx context.Context, args *DeliverArgs) error

+ func (l *Link) Disconnect(ctx context.Context, args *DisconnectArgs) error

+ func (l *Link) FetchServiceList(ctx context.Context, kind cluster.Kind, states ...cluster.State) ([]*registry.ServiceInstance, error)

+ func (l *Link) GetIP(ctx context.Context, args *GetIPArgs) (string, error)

+ func (l *Link) LocateGate(ctx context.Context, uid int64) (string, error)

+ func (l *Link) LocateNode(ctx context.Context, uid int64) (string, error)

+ func (l *Link) Multicast(ctx context.Context, args *MulticastArgs) (int64, error)

+ func (l *Link) Push(ctx context.Context, args *PushArgs) error

+ func (l *Link) Trigger(ctx context.Context, args *TriggerArgs) error

+ func (l *Link) UnbindGate(ctx context.Context, uid int64) error

+ func (l *Link) UnbindNode(ctx context.Context, uid int64, nid string) error

+ func (l *Link) WatchServiceInstance(ctx context.Context, kinds ...cluster.Kind)

+ func (l *Link) WatchUserLocate(ctx context.Context, kinds ...cluster.Kind)

+ type Message struct

+ Data interface{}

+ Route int32

+ Seq int32

+ type MulticastArgs struct

+ GID string

+ Kind session.Kind

+ Message *Message

+ Targets []int64

+ type Options struct

+ BalanceStrategy dispatcher.BalanceStrategy

+ Codec encoding.Codec

+ Encryptor crypto.Encryptor

+ GID string

+ Locator locate.Locator

+ NID string

+ Registry registry.Registry

+ Transporter transport.Transporter

+ type PushArgs struct

+ GID string

+ Kind session.Kind

+ Message *Message

+ Target int64

+ type TriggerArgs struct

+ CID int64

+ Event cluster.Event

+ UID int64