redis

type Codec[T any] interface {
	Marshal(v T) ([]byte, error)
	Unmarshal(data []byte, v *T) error
}

type ErrorLogger interface {
	Error(args ...any)
}

type JSONCodec[T any] struct{}

type Options struct {
	// Prefix 与 signal_name 组成 channel：{prefix}:{signal_name}。
	Prefix string
	// Channel 显式指定 channel，优先级高于 Prefix + SignalName。
	Channel string
	// BufferSize 为 Pub/Sub channel 缓冲区大小。
	BufferSize int
	// ReadTimeout 保留字段，用于后续扩展读取超时策略。
	ReadTimeout time.Duration
	// ErrorHandler 处理监听中的非致命错误（如 decode 失败）。
	ErrorHandler func(error)
}

type Signaler[T signaling.Signal] struct {
	// contains filtered or unexported fields
}