The highest tagged major version is v5.

memorypubsub

package

v2.17.0 Latest Latest Go to latest Published: Sep 12, 2022 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Driver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPubSubDriver(log *zap.Logger, _ string) (*Driver, error)

func (d *Driver) Connections(topic string, res map[string]struct{})

func (d *Driver) Next(ctx context.Context) (*pubsub.Message, error)

func (d *Driver) Publish(msg *pubsub.Message) error

func (d *Driver) PublishAsync(msg *pubsub.Message)

func (d *Driver) Stop()

func (d *Driver) Subscribe(connectionID string, topics ...string) error

func (d *Driver) Unsubscribe(connectionID string, topics ...string) error