httpq

README

httpq

With Httpq, you can buffer HTTP requests and replay them later, and persistence can be either to Redis or to disk. This is useful for buffering HTTP requests that do not have to be processed in realtime, such as webhooks.

Installation

$ go install github.com/DavidHuie/httpq/cmd/httpq

Using Redis

$ httpq -redis=true -redis_url=":6379"

Using disk persistence

$ httpq -db_path="/tmp/httpq.db"

Queuing a request

$ curl localhost:3000/push

Replaying a request

$ curl localhost:3000/pop

GET /push HTTP/1.1
Host: localhost:3000
Accept: */*
User-Agent: curl/7.37.1

Determining size of queue

The result is returning as JSON.

$ curl localhost:3000/size

{"size":3}

Documentation

Index

• type Httpq
  • func NewHttpq(q Queue, debug bool) *Httpq
  • func (h *Httpq) PopRequest() (*http.Request, error)
  • func (h *Httpq) PopRequestBytes() ([]byte, error)
  • func (h *Httpq) PushRequest(r *http.Request) error
  • func (h *Httpq) Size() (uint64, error)
• type Queue
• type Server
  • func NewServer(httpq *Httpq) *Server
  • func (s *Server) Pop(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Push(w http.ResponseWriter, r *http.Request)
  • func (s *Server) Size(w http.ResponseWriter, r *http.Request)

Types

type Httpq

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

func NewHttpq

func NewHttpq(q Queue, debug bool) *Httpq

func (*Httpq) PopRequest

func (h *Httpq) PopRequest() (*http.Request, error)

func (*Httpq) PopRequestBytes

func (h *Httpq) PopRequestBytes() ([]byte, error)

func (*Httpq) PushRequest

func (h *Httpq) PushRequest(r *http.Request) error

func (*Httpq) Size

func (h *Httpq) Size() (uint64, error)

type Queue

type Queue interface {
	Push([]byte) error
	Pop() ([]byte, error)
	Size() (uint64, error)
}

type Server

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

func NewServer

func NewServer(httpq *Httpq) *Server

func (*Server) Pop

func (s *Server) Pop(w http.ResponseWriter, r *http.Request)

func (*Server) Push

func (s *Server) Push(w http.ResponseWriter, r *http.Request)

func (*Server) Size

func (s *Server) Size(w http.ResponseWriter, r *http.Request)