errorshandler

Documentation

Index

• Constants
• func GetQueueCache(nonDefaultQueues []string) map[string]bool
• type BrokerMessage
• type CatcherMessage
• type Handler
  • func (handler *Handler) HandleHTTP(ctx *fasthttp.RequestCtx)
  • func (handler *Handler) HandleWebsocket(ctx *fasthttp.RequestCtx)
• type ResponseMessage

Constants

const DefaultQueueName = "errors/default"

Functions

func GetQueueCache

func GetQueueCache(nonDefaultQueues []string) map[string]bool

GetQueueCache - construct searching set from array of queue names

Types

type BrokerMessage

type BrokerMessage struct {
	ProjectId   string          `json:"projectId"`
	Payload     json.RawMessage `json:"payload"`
	CatcherType string          `json:"catcherType"`
}

BrokerMessage represents message to a queue

type CatcherMessage

type CatcherMessage struct {
	Token       string          `json:"token"`
	Payload     json.RawMessage `json:"payload"`
	CatcherType string          `json:"catcherType"`
}

ResponseMessage represents incoming message from a client

type Handler

type Handler struct {
	Broker    *broker.Broker
	JwtSecret string

	// Maximum POST body size in bytes for error messages
	MaxErrorCatcherMessageSize int

	ErrorsBlockedByLimit prometheus.Counter
	ErrorsProcessed      prometheus.Counter

	RedisClient           *redis.RedisClient
	AccountsMongoDBClient *accounts.AccountsMongoDBClient

	NonDefaultQueues map[string]bool
}

Handler of error messages

func (*Handler) HandleHTTP

func (handler *Handler) HandleHTTP(ctx *fasthttp.RequestCtx)

HandleHTTP processes HTTP requests with JSON body

func (*Handler) HandleWebsocket

func (handler *Handler) HandleWebsocket(ctx *fasthttp.RequestCtx)

HandleWebsocket handles WebSocket connection

type ResponseMessage

type ResponseMessage struct {
	Code    int    `json:"code"`
	Error   bool   `json:"error"`
	Message string `json:"message"`
}

ResponseMessage represents response message to a client