proxy

Documentation

Index

• type ErrorResponse
• type Gateway
  • func NewGateway(cfg *config.ProxyConfig, db *db.DB, queue queue.TaskQueue) *Gateway
  • func (gw *Gateway) DispatchEvent(ctx context.Context, event *entities.Event) error
  • func (gw *Gateway) Handle(w http.ResponseWriter, r *http.Request)
  • func (gw *Gateway) Start()
  • func (gw *Gateway) Stop() error

Types

type ErrorResponse

type ErrorResponse struct {
	Message string      `json:"message"`
	Error   interface{} `json:"error,omitempty"`
}

type Gateway

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

func NewGateway

func NewGateway(cfg *config.ProxyConfig, db *db.DB, queue queue.TaskQueue) *Gateway

func (*Gateway) DispatchEvent

func (gw *Gateway) DispatchEvent(ctx context.Context, event *entities.Event) error

func (*Gateway) Handle

func (gw *Gateway) Handle(w http.ResponseWriter, r *http.Request)

func (*Gateway) Start

func (gw *Gateway) Start()

Start starts an HTTP server

func (*Gateway) Stop

func (gw *Gateway) Stop() error

Stop stops the HTTP server