memory

Documentation

Index

• type MemoryProvider
  • func (mp *MemoryProvider) Publish(ctx context.Context, topic string, m *pubsub.Msg) error
  • func (mp *MemoryProvider) Shutdown()
  • func (mp *MemoryProvider) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)

Types

type MemoryProvider

type MemoryProvider struct {
	Msgs         map[string][]*pubsub.Msg
	ErrorHandler func(err error)
	// contains filtered or unexported fields
}

func (*MemoryProvider) Publish

func (mp *MemoryProvider) Publish(ctx context.Context, topic string, m *pubsub.Msg) error

func (*MemoryProvider) Shutdown

func (mp *MemoryProvider) Shutdown()

func (*MemoryProvider) Subscribe

func (mp *MemoryProvider) Subscribe(opts pubsub.HandlerOptions, h pubsub.MsgHandler)