emitter

type BroadcastMessage = adapter.BroadcastMessage

type BroadcastOperator struct {
	// contains filtered or unexported fields
}

type BroadcastOperatorInterface interface {
	To(room ...socket.Room) BroadcastOperatorInterface
	In(room ...socket.Room) BroadcastOperatorInterface
	Except(room ...socket.Room) BroadcastOperatorInterface
	Compress(compress bool) BroadcastOperatorInterface
	Volatile() BroadcastOperatorInterface
	Emit(ev string, args ...any) error
	SocketsJoin(rooms ...socket.Room) error
	SocketsLeave(rooms ...socket.Room) error
	DisconnectSockets(state bool) error
}

type BroadcastOptions struct {
	// Nsp is the Socket.IO namespace for the broadcast.
	Nsp string

	// BroadcastChannel is the Redis channel used for broadcasting packets to clients.
	// Format: "{key}#{nsp}#" or "{key}#{nsp}#{room}#" for room-specific broadcasts.
	BroadcastChannel string

	// RequestChannel is the Redis channel used for inter-server requests.
	// Format: "{key}-request#{nsp}#"
	RequestChannel string

	// Parser is the encoder/decoder for serializing messages.
	Parser redis.Parser

	// Sharded indicates whether to use Redis sharded Pub/Sub (SPUBLISH).
	// Set to true when using Redis Cluster with sharded Pub/Sub (Redis 7.0+).
	Sharded bool

	// SubscriptionMode controls how room-specific channels are computed.
	// This should match the adapter's subscriptionMode setting.
	SubscriptionMode redis.SubscriptionMode
}

type ClusterMessage = adapter.ClusterMessage

type DisconnectSocketsMessage = adapter.DisconnectSocketsMessage

type Emitter struct {
	// contains filtered or unexported fields
}

type EmitterOptions struct {
	// contains filtered or unexported fields
}

type EmitterOptionsInterface interface {
	// SetKey sets the Redis key prefix for channel names.
	SetKey(string)
	// GetRawKey returns the raw Optional wrapper for the key setting.
	GetRawKey() types.Optional[string]
	// Key returns the Redis key prefix, or empty string if not set.
	Key() string

	// SetParser sets the parser for encoding messages.
	SetParser(redis.Parser)
	// GetRawParser returns the raw Optional wrapper for the parser setting.
	GetRawParser() types.Optional[redis.Parser]
	// Parser returns the parser, or nil if not set.
	Parser() redis.Parser

	// SetSharded enables or disables Redis sharded Pub/Sub.
	// When enabled, uses SPUBLISH for Redis Cluster sharded Pub/Sub (Redis 7.0+).
	SetSharded(bool)
	// GetRawSharded returns the raw Optional wrapper for the sharded setting.
	GetRawSharded() types.Optional[bool]
	// Sharded returns whether sharded Pub/Sub is enabled.
	Sharded() bool

	// SetSubscriptionMode sets the subscription mode for sharded Pub/Sub.
	// This should match the adapter's subscriptionMode setting.
	SetSubscriptionMode(redis.SubscriptionMode)
	// GetRawSubscriptionMode returns the raw Optional wrapper for the subscriptionMode setting.
	GetRawSubscriptionMode() types.Optional[redis.SubscriptionMode]
	// SubscriptionMode returns the subscription mode.
	SubscriptionMode() redis.SubscriptionMode
}

type Packet = redis.RedisPacket

type Request = redis.RedisRequest

type Response = redis.RedisResponse

type ServerSideEmitMessage = adapter.ServerSideEmitMessage

type ShardedBroadcastOperator struct {
	// contains filtered or unexported fields
}

type SocketsJoinLeaveMessage = adapter.SocketsJoinLeaveMessage