inmem

Documentation

Index

• type Inmem
  • func NewPubSub() *Inmem
  • func (p *Inmem) Publish(_ context.Context, topic string, msg []byte) error
  • func (p *Inmem) Subscribe(_ context.Context, name, topic string) (<-chan pubsub.Event, error)

Types

type Inmem

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

func NewPubSub

func NewPubSub() *Inmem

func (*Inmem) Publish

func (p *Inmem) Publish(_ context.Context, topic string, msg []byte) error

func (*Inmem) Subscribe

func (p *Inmem) Subscribe(_ context.Context, name, topic string) (<-chan pubsub.Event, error)