server

Documentation

Index

• Constants
• func GetRouteIDFromAuthHeader(c *gin.Context) string
• func HandleError(_ *gin.Context, err error) (int, interface{})
• func MetricsMiddleware(c *gin.Context)
• func NewServer() (*server, error)
• func RouteHandlerForInternalAPI(c *gin.Context)
• type AboutResponse
• type HttpApiReqMessage
  • func NewHttpApiReqMessageFromHttpRequest(req *http.Request) (*HttpApiReqMessage, error)
  • func NewHttpApiReqMessageFromNatsMessage(m *nats.Msg) (*HttpApiReqMessage, error)
  • func (req *HttpApiReqMessage) ToHttpRequest() *http.Request
• type HttpApiResponseMessage
  • func NewHttpApiResponseMessageFromError(err error) *HttpApiResponseMessage
  • func NewHttpApiResponseMessageFromHttpResponse(resp *http.Response) *HttpApiResponseMessage
• type HttpReqHeader
• type JsonError

Constants

const RequestForLocationID = "natssync.location.request"

RequestForLocationID send this message to get the location ID

const ResponseForLocationID = "natssync.location.response"

ResponseForLocationID this is the response subject, the data is the location ID, this message can be sent without a request, if the location ID changes

Functions

func GetRouteIDFromAuthHeader

func GetRouteIDFromAuthHeader(c *gin.Context) string

func HandleError

func HandleError(_ *gin.Context, err error) (int, interface{})

func MetricsMiddleware

func MetricsMiddleware(c *gin.Context)

func NewServer

func NewServer() (*server, error)

func RouteHandlerForInternalAPI

func RouteHandlerForInternalAPI(c *gin.Context)

Types

type AboutResponse

type AboutResponse struct {
	AppVersion string `json:"appVersion"`
}

type HttpApiReqMessage

type HttpApiReqMessage struct {
	HttpMethod string
	HttpPath   string
	Body       []byte
	Headers    []HttpReqHeader
	Target     string
}

func NewHttpApiReqMessageFromHttpRequest

func NewHttpApiReqMessageFromHttpRequest(req *http.Request) (*HttpApiReqMessage, error)

func NewHttpApiReqMessageFromNatsMessage

func NewHttpApiReqMessageFromNatsMessage(m *nats.Msg) (*HttpApiReqMessage, error)

func (*HttpApiReqMessage) ToHttpRequest

func (req *HttpApiReqMessage) ToHttpRequest() *http.Request

type HttpApiResponseMessage

type HttpApiResponseMessage struct {
	HttpStatusCode int
	RespBody       string
	RequestID      string
	Headers        map[string]string
}

func NewHttpApiResponseMessageFromError

func NewHttpApiResponseMessageFromError(err error) *HttpApiResponseMessage

func NewHttpApiResponseMessageFromHttpResponse

func NewHttpApiResponseMessageFromHttpResponse(resp *http.Response) *HttpApiResponseMessage

type HttpReqHeader

type HttpReqHeader struct {
	Key    string
	Values []string
}

type JsonError

type JsonError struct {
	Message string `json:"message"`
}