Documentation
¶
Index ¶
- Constants
- func AsyncMw(cacheConn *responsecache.Cache) func(http.Handler) http.Handler
- func BadRequest(ctx context.Context, writer http.ResponseWriter, msg string)
- func CachedResponse(cacheConn *responsecache.Cache) http.HandlerFunc
- func CreateRouter(logger logging.Logger, handler *Handler, cacheConn *responsecache.Cache) *chi.Mux
- func InternalError(ctx context.Context, writer http.ResponseWriter, s string)
- func LoggingMiddleware(logger logging.Logger) func(http.Handler) http.Handler
- func NewAsyncResponseWriter() *asyncResponseWriter
- func NotFound(ctx context.Context, w http.ResponseWriter, msg string)
- func StatusAccepted(ctx context.Context, writer http.ResponseWriter, s, backgroundID string)
- func StatusOk(ctx context.Context, writer http.ResponseWriter, s string)
- func TraceWrapRouter(router *chi.Mux) http.Handler
- func WithLogRequestBoundaries() func(next http.Handler) http.Handler
- type Handler
- type Message
Constants ¶
View Source
const ( HTTPHeaderXBackground = "x-background" HTTPHeaderXBackgroundTTL = "x-background-ttl" DefaultTimeout = 100 * time.Millisecond )
View Source
const ErrMsgWritingResponse = "Error while writing response"
View Source
const TracerNameServer = "public-api"
Variables ¶
This section is empty.
Functions ¶
func BadRequest ¶
func BadRequest(ctx context.Context, writer http.ResponseWriter, msg string)
func CachedResponse ¶
func CachedResponse(cacheConn *responsecache.Cache) http.HandlerFunc
func CreateRouter ¶
func CreateRouter(logger logging.Logger, handler *Handler, cacheConn *responsecache.Cache) *chi.Mux
func InternalError ¶
func InternalError(ctx context.Context, writer http.ResponseWriter, s string)
func LoggingMiddleware ¶
func NewAsyncResponseWriter ¶
func NewAsyncResponseWriter() *asyncResponseWriter
func StatusAccepted ¶
func StatusAccepted(ctx context.Context, writer http.ResponseWriter, s, backgroundID string)
func TraceWrapRouter ¶
Types ¶
type Handler ¶
type Handler struct {
UserClient userPb.UsersClient
UserTxClient userTxPb.DistributedTxServiceClient
OrderClient orderPb.OrdersManagerServiceClient
OrderTxClient orderPb.TnxConfirmingServiceClient
}
func NewHandler ¶
func NewHandler(userConn *grpc.ClientConn, orderConn *grpc.ClientConn) *Handler
func (*Handler) SendMessage ¶
func (h *Handler) SendMessage(writer http.ResponseWriter, request *http.Request)
SendMessage godoc @Summary Send message @Description Put message with name and label to DB by 2pc transactions @Tags accounts @Accept json @Produce json @Param message body Message true "Message" @Success 200 {string} string "ok" @Failure 400 {string} string "message decode error" @Failure 500 {string} string "server error" @Router /send [post].
Source Files
Click to show internal directories.
Click to hide internal directories.