app

Documentation

Index

• func DoErrorResponse(ctx *fasthttp.RequestCtx, e errors.APIError)
• type ErrorResponse
• type Server
  • func New(gctx global.Context) (*Server, <-chan struct{})
  • func (s Server) GetConcurrentConnections() int32
  • func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)
  • func (s *Server) HandleSessionMutation(gctx global.Context)
  • func (s *Server) Middleware() func(next http.Handler) http.Handler
  • func (s *Server) TrackConnection(gctx global.Context, r *http.Request, con client.Connection)
• type SessionMutationEventPut
• type SessionMutationResponse

Functions

func DoErrorResponse

func DoErrorResponse(ctx *fasthttp.RequestCtx, e errors.APIError)

Types

type ErrorResponse

type ErrorResponse struct {
	Status     string         `json:"status"`
	StatusCode int            `json:"status_code"`
	Error      string         `json:"error"`
	ErrorCode  int            `json:"error_code"`
	Details    map[string]any `json:"details"`
}

type Server

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

func New

func New(gctx global.Context) (*Server, <-chan struct{})

func (Server) GetConcurrentConnections

func (s Server) GetConcurrentConnections() int32

func (*Server) HandleHealth

func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)

func (*Server) HandleSessionMutation

func (s *Server) HandleSessionMutation(gctx global.Context)

func (*Server) Middleware

func (s *Server) Middleware() func(next http.Handler) http.Handler

func (*Server) TrackConnection

func (s *Server) TrackConnection(gctx global.Context, r *http.Request, con client.Connection)

type SessionMutationEventPut

type SessionMutationEventPut struct {
	Condition map[string]string
}

type SessionMutationResponse

type SessionMutationResponse struct {
	RequestID string `json:"request_id"`
}