proxy

Documentation

Index

• Variables
• type Gateway
  • func NewGateway(opts Options) *Gateway
  • func (gw *Gateway) Handle(w http.ResponseWriter, r *http.Request)
  • func (gw *Gateway) HandleMessages(ctx context.Context, messages []*queue.Message) error
  • func (gw *Gateway) Start()
  • func (gw *Gateway) Stop() error
• type Options

Variables

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

Types

type Gateway

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

func NewGateway

func NewGateway(opts Options) *Gateway

func (*Gateway) Handle

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

func (*Gateway) HandleMessages

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

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

type Options

type Options struct {
	Cfg         *config.ProxyConfig
	Middlewares []mux.MiddlewareFunc
	DB          *db.DB
	Dispatcher  *dispatcher.Dispatcher
	Metrics     *metrics.Metrics
	Tracer      *tracing.Tracer
	EventBus    eventbus.Bus
	Srv         *service.Service
}