pubsub

Documentation

Index

• type PubSub
  • func New(ctx context.Context) (*PubSub, error)
  • func (pb *PubSub) AddEventHandlers(handlers ...cqrs.EventHandler) error
  • func (pb *PubSub) AddSSEHandler(topic string, handler stream.StreamAdapter) http.HandlerFunc
  • func (pb *PubSub) StartEventsRouter(ctx context.Context) error
  • func (pb *PubSub) StartSSERouter(ctx context.Context) error

Types

type PubSub

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

func New

func New(ctx context.Context) (*PubSub, error)

New creates a new PubSub using GCP Pub/Sub as a backend.

func (*PubSub) AddEventHandlers

func (pb *PubSub) AddEventHandlers(handlers ...cqrs.EventHandler) error

func (*PubSub) AddSSEHandler

func (pb *PubSub) AddSSEHandler(topic string, handler stream.StreamAdapter) http.HandlerFunc

func (*PubSub) StartEventsRouter

func (pb *PubSub) StartEventsRouter(ctx context.Context) error

func (*PubSub) StartSSERouter

func (pb *PubSub) StartSSERouter(ctx context.Context) error