memorypubsub

Documentation

Index

• type PubSubDriver
  • func NewPubSubDriver(log logger.Logger, _ string) (*PubSubDriver, error)
  • func (p *PubSubDriver) Connections(topic string, res map[string]struct{})
  • func (p *PubSubDriver) Next(ctx context.Context) (*pubsub.Message, error)
  • func (p *PubSubDriver) Publish(msg *pubsub.Message) error
  • func (p *PubSubDriver) PublishAsync(msg *pubsub.Message)
  • func (p *PubSubDriver) Subscribe(connectionID string, topics ...string) error
  • func (p *PubSubDriver) Unsubscribe(connectionID string, topics ...string) error

Types

type PubSubDriver

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

func NewPubSubDriver

func NewPubSubDriver(log logger.Logger, _ string) (*PubSubDriver, error)

func (*PubSubDriver) Connections

func (p *PubSubDriver) Connections(topic string, res map[string]struct{})

func (*PubSubDriver) Next

func (p *PubSubDriver) Next(ctx context.Context) (*pubsub.Message, error)

func (*PubSubDriver) Publish

func (p *PubSubDriver) Publish(msg *pubsub.Message) error

func (*PubSubDriver) PublishAsync

func (p *PubSubDriver) PublishAsync(msg *pubsub.Message)

func (*PubSubDriver) Subscribe

func (p *PubSubDriver) Subscribe(connectionID string, topics ...string) error

func (*PubSubDriver) Unsubscribe

func (p *PubSubDriver) Unsubscribe(connectionID string, topics ...string) error