transport

package

v3.4.0 Latest Latest Go to latest Published: Sep 24, 2019 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aseure/algoliasearch-client-go

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 ¶

View Source

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

View Source

const (
	DefaultResetPeriod = 5 * time.Minute
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL