cluster

type BroadcastArgs struct {
	Kind       Session  // Kind is the session kind, either Conn or 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 is the session kind, either Conn or 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 is the session kind, either Conn or 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 is the session kind, either Conn or 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 is the session kind, either Conn or 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 is the session kind, either Conn or 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 Session int

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 is the session kind, either Conn or 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 is the session kind, either Conn or User
	Targets []int64 // Targets are the session targets, either CIDs or UIDs
	Channel string  // Channel is the channel name
}