cluster

type BroadcastArgs struct {
	Kind       session.Kind // Kind is the session kind, either session.Conn or session.User
	Message    *Message     // Message is the message to broadcast
	Disconnect bool         // Disconnect reports whether to gracefully close the connection after pushing
	Ack        bool         // Ack reports whether the push result should be acknowledged
}

type DeliverArgs struct {
	NID     string   // NID is the receiving node. When it is set, the message is delivered to that node directly; otherwise the system locates the node the user belongs to and delivers the message there
	UID     int64    // UID is the user ID
	Message *Message // Message is the message to deliver
}

type DisconnectArgs struct {
	GID    string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind   session.Kind // Kind is the session kind, either session.Conn or session.User
	Target int64        // Target is the session target, either a CID or a UID
	Force  bool         // Force reports whether to force the disconnection
}

type Dispatch = def.Dispatch

type Event int

type GetIPArgs struct {
	GID    string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind   session.Kind // Kind is the session kind, either session.Conn or session.User
	Target int64        // Target is the session target, either a CID or a UID
}

type Hook int

type IsOnlineArgs struct {
	GID    string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind   session.Kind // Kind is the session kind, either session.Conn or session.User
	Target int64        // Target is the session target, either a CID or a UID
}

type Kind int

type Message struct {
	Seq   int32 // Seq is the sequence number
	Route int32 // Route is the route ID
	Data  any   // Data is the message payload, which accepts json, proto or []byte
}

type MulticastArgs struct {
	GID        string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind       session.Kind // Kind is the session kind, either session.Conn or session.User
	Targets    []int64      // Targets are the session targets, either CIDs or UIDs
	Message    *Message     // Message is the message to multicast
	Disconnect bool         // Disconnect reports whether to gracefully close the connection after pushing
	Ack        bool         // Ack reports whether the push result should be acknowledged
}

type PublishArgs struct {
	Channel    string   // Channel is the channel name
	Message    *Message // Message is the message to publish
	Disconnect bool     // Disconnect reports whether to gracefully close the connection after pushing
	Ack        bool     // Ack reports whether the push result should be acknowledged
}

type PushArgs struct {
	GID        string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind       session.Kind // Kind is the session kind, either session.Conn or session.User
	Target     int64        // Target is the session target, either a CID or a UID
	Message    *Message     // Message is the message to push
	Disconnect bool         // Disconnect reports whether to gracefully close the connection after pushing
	Ack        bool         // Ack reports whether the push result should be acknowledged
}

type State int

type SubscribeArgs struct {
	GID     string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind    session.Kind // Kind is the session kind, either session.Conn or session.User
	Targets []int64      // Targets are the session targets, either CIDs or UIDs
	Channel string       // Channel is the channel name
}

type TriggerArgs struct {
	Event int   // Event is the event type
	CID   int64 // CID is the connection ID
	UID   int64 // UID is the user ID
}

type UnsubscribeArgs struct {
	GID     string       // GID is the gate ID, it may be omitted when the session kind is user
	Kind    session.Kind // Kind is the session kind, either session.Conn or session.User
	Targets []int64      // Targets are the session targets, either CIDs or UIDs
	Channel string       // Channel is the channel name
}