sse

Documentation

Index

• func PublishUsingBrokerInContext(ctx context.Context, event Event) error
• type Broker
  • func NewBroker(logger zerolog.Logger, chatService ChatService) *Broker
  • func (b *Broker) Close()
  • func (b *Broker) Middleware(next http.Handler) http.Handler
  • func (b *Broker) Publish(e Event)
  • func (b *Broker) ServeHTTPForChannel(w http.ResponseWriter, r *http.Request)
  • func (b *Broker) ServeHTTPForChannelList(w http.ResponseWriter, r *http.Request)
  • func (b *Broker) SubscribeToChannel(channelUUID string) chan Event
  • func (b *Broker) SubscribeToChannelListUpdates(userUUID string) chan Event
  • func (b *Broker) Unsubscribe(c chan Event)
• type ChatService
• type Event
  • func NewEvent(t string, channel model.Channel, message model.Message, currentUserUUID string) Event

Functions

func PublishUsingBrokerInContext

func PublishUsingBrokerInContext(ctx context.Context, event Event) error

Types

type Broker

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

func NewBroker

func NewBroker(logger zerolog.Logger, chatService ChatService) *Broker

func (*Broker) Close

func (b *Broker) Close()

func (*Broker) Middleware

func (b *Broker) Middleware(next http.Handler) http.Handler

func (*Broker) Publish

func (b *Broker) Publish(e Event)

func (*Broker) ServeHTTPForChannel

func (b *Broker) ServeHTTPForChannel(w http.ResponseWriter, r *http.Request)

func (*Broker) ServeHTTPForChannelList

func (b *Broker) ServeHTTPForChannelList(w http.ResponseWriter, r *http.Request)

func (*Broker) SubscribeToChannel

func (b *Broker) SubscribeToChannel(channelUUID string) chan Event

func (*Broker) SubscribeToChannelListUpdates

func (b *Broker) SubscribeToChannelListUpdates(userUUID string) chan Event

func (*Broker) Unsubscribe

func (b *Broker) Unsubscribe(c chan Event)

type ChatService

type ChatService interface {
	IsMemberOfChannel(channelUUID, userUUID string) (bool, error)
	GetChannelList(user model.User) ([]model.Channel, error)
}

type Event

type Event struct {
	ID              string
	Type            string
	Message         model.Message
	Channel         model.Channel
	CurrentUserUUID string
}

func NewEvent

func NewEvent(t string, channel model.Channel, message model.Message, currentUserUUID string) Event