pubsub

type Cbfunc struct {
	CbString func(msg string)
	CbByte   func(msg []byte)
	CbAny    func(msg any)
}

type Handler interface {
	Subscribe(param Params, cbs *Cbfunc) // 订阅消息
	Publish(param Params, msg any) error // 发布消息
}

type Options struct {
	Ctx   context.Context
	Loger *zaploger.Logger
}

type Params struct {
	Topic string // 订阅主题
	Key   string // 订阅的key 主要在kafka的时候可以用这个
}

type PubSub struct {
	Handler Handler
}