sse

Documentation

Index

• type ClientAuthorizationStatus
• type SSEAuthRequestMessage
• type SSEBroker
• type SSEController
  • func New(db *gorm.DB, config *models.Config, bus *EventBus.Bus) *SSEController
  • func (s *SSEController) HandleEvents(w http.ResponseWriter, r *http.Request)
  • func (s *SSEController) Start()
• type SSEMessage

Types

type ClientAuthorizationStatus

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

type SSEAuthRequestMessage

type SSEAuthRequestMessage struct {
	UserId   uuid.UUID
	SourceIP string
	Message  SSEMessage
}

type SSEBroker

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

type SSEController

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

func New

func New(db *gorm.DB, config *models.Config, bus *EventBus.Bus) *SSEController

New creates an instance of the controller and sets its DB handle

func (*SSEController) HandleEvents

func (s *SSEController) HandleEvents(w http.ResponseWriter, r *http.Request)

func (*SSEController) Start

func (s *SSEController) Start()

Start ensures each client receives a periodic ping to maintain the connection This signals the app that the connection shouldn't be closes Also aims at signalling potential corporate proxies that they should not close the connection.

type SSEMessage

type SSEMessage struct {
	Action string
	Nonce  string
	Issuer string
}