[Q] How to define pubSub. Subreader in a custom plugin

[zaishui15]

I want to define pubSub. Subreader, but it is a private package。How to solve

import (
	"github.com/spiral/roadrunner-plugins/v2/broadcast"
	"github.com/spiral/roadrunner-plugins/v2/internal/common/pubsub"
)
type Plugin struct {
	pb       broadcast.Broadcaster
	driver   pubsub.SubReader
}
func (s *Plugin) Serve() chan error {
	errCh := make(chan error, 1)
	s.driver, err = s.pb.GetDriver("default")
	if err != nil {
		errCh <- err
		return errCh
	}
	err = s.driver.Subscribe("id", "topic")
	if err != nil {
		errCh <- err
		return errCh
	}
	go func() {
		for {
			msg, _ := s.driver.Next(s.ctx)
			fmt.Println(msg)
		}
	}()
	return errCh
}
func (s *Plugin) Stop() error {
	s.driver.Unsubscribe("id", "topic")
	return nil
}

[rustatian]

@zaishui15 Hey. You forgot the Init function. You may have a look at the test plugin: https://github.com/spiral/roadrunner-plugins/blob/master/tests/plugins/broadcast/plugins/plugin1.go

[zaishui15]

My plugins is written outside, can't be used

"github.com/spiral/roadrunner-plugins/v2/internal/common/pubsub"

[rustatian]

Ah, got u. I'll expose this API in 2.5.2.

[zaishui15]

thanks