Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRouter ¶
func NewRouter( orgSvc *services.OrganizationService, entitySvc *services.EntityService, natsEmbedded *embeddednats.EmbeddedNATS, sseHandler *SSEHandler, apiHandler http.Handler, sessionAuth *middleware.SessionAuth, ) *http.ServeMux
Types ¶
type SSEHandler ¶
type SSEHandler struct {
// contains filtered or unexported fields
}
SSEHandler handles Server-Sent Events streaming
func NewSSEHandler ¶
func NewSSEHandler(nc *nats.Conn, js nats.JetStreamContext) *SSEHandler
NewSSEHandler creates a new SSE handler
func (*SSEHandler) StreamMessages ¶
func (h *SSEHandler) StreamMessages(w http.ResponseWriter, r *http.Request)
StreamMessages streams NATS messages to the client via SSE
func (*SSEHandler) StreamMessagesWithFilter ¶
func (h *SSEHandler) StreamMessagesWithFilter(w http.ResponseWriter, r *http.Request)
StreamMessagesWithFilter streams filtered NATS messages
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer(dbService *db.Service, nc *nats.Conn, natsEmbedded *embeddednats.EmbeddedNATS, apiHandler http.Handler) (*Server, error)
NewServer creates a new web server instance
func NewWebService ¶
func NewWebService(dbService *db.Service, nc *nats.Conn, natsEmbedded *embeddednats.EmbeddedNATS, apiHandler http.Handler) (*Server, error)
NewWebService creates a new web service with environment-based configuration
func (*Server) HandleHealthCheck ¶
func (s *Server) HandleHealthCheck(w http.ResponseWriter, r *http.Request)
HandleHealthCheck handles the health check endpoint Note: This is now handled by the API router, but kept here if needed for internal checks
func (*Server) HealthCheck ¶
HealthCheck returns the health status of the web service (implements Service interface)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.