rabbitmq

type Handler func(ctx context.Context, data []byte) error

type Message struct {
	Type string          `json:"type"`
	Data json.RawMessage `json:"data"`
}

type Option func(*Server)

type Publisher interface {
	Publish(msgType string, data any) error
}

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

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