proxy

package

v1.0.1 Latest Latest Go to latest Published: Feb 6, 2026 License: Apache-2.0 Imports: 40 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrQueueDisabled = errors.New("queue is disabled")
)

This section is empty.

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

func NewGateway(opts Options, services *services.Services) *Gateway

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

func (g *Gateway) HandleMessages(ctx context.Context, messages []*queue.Message) error

func (g *Gateway) Name() string

func (g *Gateway) Start() error

Start starts an HTTP server

func (g *Gateway) Stop(ctx context.Context) error

Stop stops the HTTP server

type HttpError struct {
	Code    int
	Message string
	Err     error
}

func (e *HttpError) Error() string

type Options struct {
	Cfg         *modules.ProxyConfig
	Middlewares []mux.MiddlewareFunc
	DB          *db.DB
	Dispatcher  *dispatcher.Dispatcher
}

type Response struct {
	Headers map[string]string
	Code    int
	Body    []byte
}

Path	Synopsis
middlewares
router