net

Documentation

Index

• func HealthCheck(w http.ResponseWriter, r *http.Request)
• func JSONError(w http.ResponseWriter, httpStatus int, err error)
• func JSONResponse(w http.ResponseWriter, httpStatus int, response any)
• type HandshakeData
• type HealthStatus
• type Networking
  • func NewNetworking(cfg *config.Config, db *storage.Database, mqtt safemqtt.Client) *Networking
  • func (n *Networking) HandShake(w http.ResponseWriter, r *http.Request)
  • func (n *Networking) ListenAndServe(address, port string) error
  • func (n *Networking) PreHandShake(response http.ResponseWriter, request *http.Request) (*HandshakeData, bool)
  • func (n *Networking) ReadyCheck(w http.ResponseWriter, r *http.Request)
• type ReadyStatus
• type SuccessfulHandshakeData

Functions

func HealthCheck

func HealthCheck(w http.ResponseWriter, r *http.Request)

func JSONError

func JSONError(w http.ResponseWriter, httpStatus int, err error)

func JSONResponse

func JSONResponse(w http.ResponseWriter, httpStatus int, response any)

Types

type HandshakeData

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

type HealthStatus

type HealthStatus struct {
	Status string `json:"status"`
}

type Networking

type Networking struct {
	HandshakeChan chan *SuccessfulHandshakeData
	// contains filtered or unexported fields
}

func NewNetworking

func NewNetworking(cfg *config.Config, db *storage.Database, mqtt safemqtt.Client) *Networking

func (*Networking) HandShake

func (n *Networking) HandShake(w http.ResponseWriter, r *http.Request)

func (*Networking) ListenAndServe

func (n *Networking) ListenAndServe(address, port string) error

func (*Networking) PreHandShake

func (n *Networking) PreHandShake(response http.ResponseWriter, request *http.Request) (*HandshakeData, bool)

PreHandShake TODO: it's "god" method needs to be simplified // antst: agree :)

func (*Networking) ReadyCheck

func (n *Networking) ReadyCheck(w http.ResponseWriter, r *http.Request)

type ReadyStatus

type ReadyStatus struct {
	Database   string `json:"database"`
	MessageBus string `json:"messageBus"`
}

type SuccessfulHandshakeData

type SuccessfulHandshakeData struct {
	Connection *socket.Connection
	UserID     uuid.UUID
	SessionID  uuid.UUID
	URL        *url.URL
}