pubsub_inmem

Documentation

Index

• Constants
• type PubsubInmem
  • func New(app app_context.Context, serializer ...message.Serializer) *PubsubInmem
  • func (p *PubsubInmem) Publish(topicName string, obj interface{}) error
  • func (p *PubsubInmem) Shutdown(ctx context.Context) error
  • func (p *PubsubInmem) Subscribe(topic pubsub_subscriber.Topic) (string, error)
  • func (p *PubsubInmem) Unsubscribe(topicName string, subscriptionId ...string)

Constants

const Provider string = "inmem"

Types

type PubsubInmem

type PubsubInmem struct {
	pubsub_subscriber.SubscriberBase
	pubsub.PublisherBase
}

func New

func New(app app_context.Context, serializer ...message.Serializer) *PubsubInmem

func (*PubsubInmem) Publish

func (p *PubsubInmem) Publish(topicName string, obj interface{}) error

func (*PubsubInmem) Shutdown

func (p *PubsubInmem) Shutdown(ctx context.Context) error

func (*PubsubInmem) Subscribe

func (p *PubsubInmem) Subscribe(topic pubsub_subscriber.Topic) (string, error)

func (*PubsubInmem) Unsubscribe

func (p *PubsubInmem) Unsubscribe(topicName string, subscriptionId ...string)