Documentation
¶
Index ¶
- Constants
- func MatchesPattern(req *http.Request, pattern string) bool
- type PendingRequest
- type Queue
- func (q *Queue) Decide(id, decision string, mod *PendingRequest) error
- func (q *Queue) Enqueue(pr *PendingRequest) error
- func (q *Queue) GetByPrefix(prefix string) (*PendingRequest, error)
- func (q *Queue) Pending() ([]*PendingRequest, error)
- func (q *Queue) Remove(id string) error
- func (q *Queue) WaitDecision(id string, timeout time.Duration) (*PendingRequest, error)
Constants ¶
View Source
const ( DecisionForward = "forward" DecisionDrop = "drop" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type PendingRequest ¶
type PendingRequest struct {
ID string `json:"id"`
Timestamp time.Time `json:"timestamp"`
Method string `json:"method"`
URL string `json:"url"`
Headers http.Header `json:"headers"`
Body string `json:"body,omitempty"`
Decision string `json:"decision,omitempty"`
ModMethod string `json:"mod_method,omitempty"`
ModHeaders http.Header `json:"mod_headers,omitempty"`
ModBody string `json:"mod_body,omitempty"`
}
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) Enqueue ¶
func (q *Queue) Enqueue(pr *PendingRequest) error
func (*Queue) GetByPrefix ¶
func (q *Queue) GetByPrefix(prefix string) (*PendingRequest, error)
func (*Queue) Pending ¶
func (q *Queue) Pending() ([]*PendingRequest, error)
func (*Queue) WaitDecision ¶
Source Files
Click to show internal directories.
Click to hide internal directories.