transport

Documentation

Index

• func NewBaggageclaimRoundTripper(workerName string, baggageclaimURL *string, db TransportDB, ...) http.RoundTripper
• func NewGardenRoundTripper(workerName string, workerHost *string, db TransportDB, ...) http.RoundTripper
• func NewHijackableClient(workerName string, db TransportDB, ...) retryhttp.HijackableClient
• type ReadCloser
• type RequestGenerator
• type RoundTripper
• type TransportDB
• type UnreachableWorkerRetryer
  • func (r *UnreachableWorkerRetryer) IsRetryable(err error) bool
• type WorkerHijackStreamer
  • func (h *WorkerHijackStreamer) Hijack(handler string, body io.Reader, params rata.Params, query url.Values, ...) (net.Conn, *bufio.Reader, error)
  • func (h *WorkerHijackStreamer) Stream(handler string, body io.Reader, params rata.Params, query url.Values, ...) (io.ReadCloser, error)
• type WorkerMissingError
  • func (e WorkerMissingError) Error() string
• type WorkerUnreachableError
  • func (e WorkerUnreachableError) Error() string

Functions

func NewBaggageclaimRoundTripper

func NewBaggageclaimRoundTripper(workerName string, baggageclaimURL *string, db TransportDB, innerRoundTripper http.RoundTripper) http.RoundTripper

func NewGardenRoundTripper

func NewGardenRoundTripper(workerName string, workerHost *string, db TransportDB, innerRoundTripper http.RoundTripper) http.RoundTripper

func NewHijackableClient

func NewHijackableClient(workerName string, db TransportDB, innerHijackableClient retryhttp.HijackableClient) retryhttp.HijackableClient

Types

type ReadCloser

type ReadCloser interface {
	Read(p []byte) (n int, err error)
	Close() error
}

type RequestGenerator

type RequestGenerator interface {
	CreateRequest(name string, params rata.Params, body io.Reader) (*http.Request, error)
}

type RoundTripper

type RoundTripper interface {
	RoundTrip(*http.Request) (*http.Response, error)
}

type TransportDB

type TransportDB interface {
	GetWorker(name string) (db.Worker, bool, error)
}

type UnreachableWorkerRetryer

type UnreachableWorkerRetryer struct {
	DelegateRetryer retryhttp.Retryer
}

func (*UnreachableWorkerRetryer) IsRetryable

func (r *UnreachableWorkerRetryer) IsRetryable(err error) bool

type WorkerHijackStreamer

type WorkerHijackStreamer struct {
	HttpClient       *http.Client
	HijackableClient retryhttp.HijackableClient
	Req              RequestGenerator
}

instead of httpClient defined in default Garden HijackStreamer

func (*WorkerHijackStreamer) Hijack

func (h *WorkerHijackStreamer) Hijack(handler string, body io.Reader, params rata.Params, query url.Values, contentType string) (net.Conn, *bufio.Reader, error)

func (*WorkerHijackStreamer) Stream

func (h *WorkerHijackStreamer) Stream(handler string, body io.Reader, params rata.Params, query url.Values, contentType string) (io.ReadCloser, error)

type WorkerMissingError

type WorkerMissingError struct {
	WorkerName string
}

func (WorkerMissingError) Error

func (e WorkerMissingError) Error() string

type WorkerUnreachableError

type WorkerUnreachableError struct {
	WorkerName  string
	WorkerState string
}

func (WorkerUnreachableError) Error

func (e WorkerUnreachableError) Error() string