processors

Documentation

Index

• Variables
• func CreateClient(timeout time.Duration) *http.Client
• type BatchedResponse
  • func ProcessBatch(requests []*http.Request, timeout time.Duration) ([]*BatchedResponse, error)

Variables

var (
	// DefaultTimeout is the default timeout duration specified in seconds
	DefaultTimeout time.Duration
	// DefaultClient is an instance of the custom http.Client created with with the DefaultTimeout
	// (The returned client has a more leniant redirect policy always URL encoding/escaping the location prior to redirect)
	DefaultClient *http.Client
)

Functions

func CreateClient

func CreateClient(timeout time.Duration) *http.Client

CreateClient is used to instantiate a custom http.Client with the specified timeout The returned client has a more leniant redirect policy always URL encoding/escaping the location prior to redirect TODO keep a cache of most commonly used clients so we can reuse them in the same way as we do for `DefaultClient`

Types

type BatchedResponse

type BatchedResponse struct {
	Sequence           int
	Status             string
	Proto              string
	Header             *http.Header
	Body               *bytes.Reader
	ProcessingDuration time.Duration
}

BatchedResponse is a simple type used as a container for the HTTP responses returned by ProcessBatch

func ProcessBatch

func ProcessBatch(requests []*http.Request, timeout time.Duration) ([]*BatchedResponse, error)

ProcessBatch sends a batch of HTTP requests using http.Client. Each request is sent concurrently in a seperate goroutine. The HTTP responses are returned in the same sequence as their corresponding requests.