transport

Documentation

Index

• Constants
• func URLDecode(data []byte, itf interface{}) error
• func URLEncode(itf interface{}) string
• type Host
• type Outcome
• type Requester
• type RetryStrategy
  • func (s *RetryStrategy) Decide(h Host, code int, err error) Outcome
  • func (s *RetryStrategy) GetTryableHosts(k call.Kind) (hosts []Host)
• type StatefulHost
  • func NewStatefulHost(host string, accept func(k call.Kind) bool) *StatefulHost
  • func Shuffle(hosts []*StatefulHost) []*StatefulHost
• type Transport
  • func New(hosts []*StatefulHost, requester Requester, appID string, apiKey string, ...) *Transport
  • func (t *Transport) Request(res interface{}, method string, path string, body interface{}, k call.Kind, ...) error

Constants

const (
	DefaultConnectTimeout      = 2 * time.Second
	DefaultKeepAliveDuration   = 5 * time.Minute
	DefaultMaxIdleConnsPerHost = 64
	DefaultTLSHandshakeTimeout = 2 * time.Second
)

const (
	DefaultResetPeriod = 5 * time.Minute
)

Functions

func URLDecode

func URLDecode(data []byte, itf interface{}) error

func URLEncode

func URLEncode(itf interface{}) string

Types

type Host

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

type Outcome

type Outcome int

const (
	DefaultReadTimeout  = 5 * time.Second
	DefaultWriteTimeout = 30 * time.Second

	Success Outcome = iota
	Failure
	Retry
)

type Requester

type Requester interface {
	Request(req *http.Request) (*http.Response, error)
}

type RetryStrategy

type RetryStrategy struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*RetryStrategy) Decide

func (s *RetryStrategy) Decide(h Host, code int, err error) Outcome

func (*RetryStrategy) GetTryableHosts

func (s *RetryStrategy) GetTryableHosts(k call.Kind) (hosts []Host)

type StatefulHost

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

func NewStatefulHost

func NewStatefulHost(host string, accept func(k call.Kind) bool) *StatefulHost

func Shuffle

func Shuffle(hosts []*StatefulHost) []*StatefulHost

type Transport

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

func New

func New(
	hosts []*StatefulHost,
	requester Requester,
	appID string,
	apiKey string,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	defaultHeaders map[string]string,
	extraUserAgent string,
	compression compression.Compression,
) *Transport

func (*Transport) Request

func (t *Transport) Request(
	res interface{},
	method string,
	path string,
	body interface{},
	k call.Kind,
	opts ...interface{},
) error