pubsub

type Message struct {
	Topic    string
	Data     []byte
	Response MessageResponse
}

type MessageHandler func(ctx context.Context, msg *Message) error

type MessageResponse func(data []byte) error

type PubSub interface {
	Publish(topic string, data []byte) error
	Subscribe(topic string, callback MessageHandler) error
	Close() error
}