connection

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

type Authentication interface {
	RequestModifier(r Request) error
}

type AuthenticationGetter func(ctx context.Context, conn Connection) (Authentication, error)

type Connection interface {
	// NewRequest initializes Request object
	NewRequest(method string, urls ...string) (Request, error)
	// NewRequestWithEndpoint initializes Request object with specific endpoint
	NewRequestWithEndpoint(endpoint string, method string, urls ...string) (Request, error)
	// Do executes the given Request and parses the response into output
	Do(ctx context.Context, request Request, output interface{}) (Response, error)
	// Stream executes the given Request and returns a reader for Response body
	Stream(ctx context.Context, request Request) (Response, io.ReadCloser, error)
	// GetEndpoint returns Endpoint which is currently used to execute requests
	GetEndpoint() Endpoint
	// SetEndpoint changes Endpoint which is used to execute requests
	SetEndpoint(e Endpoint) error
	// GetAuthentication returns Authentication
	GetAuthentication() Authentication
	// SetAuthentication returns Authentication parameters used to execute requests
	SetAuthentication(a Authentication) error
	// Decoder returns Decoder to use for Response body decoding
	Decoder(contentType string) Decoder
}

type ContextKey string

type Decoder interface {
	Decode(reader io.Reader, obj interface{}) error
	Encode(writer io.Writer, obj interface{}) error
	Reencode(in, out interface{}) error
}

type Endpoint interface {
	// Get return one of endpoints if is valid, if no default one is returned
	Get(endpoints ...string) (string, bool)

	List() []string
}

type Error struct {
	Code    int
	Message string
}

type Factory func() (Connection, error)

type Http2Configuration struct {
	Authentication Authentication
	Endpoint       Endpoint

	ContentType string

	Transport *http2.Transport
}

type HttpConfiguration struct {
	Authentication Authentication
	Endpoint       Endpoint

	ContentType string

	Transport http.RoundTripper
}

type Request interface {
	Method() string
	URL() string

	Endpoint() string

	SetBody(i interface{}) error
	AddHeader(key, value string)
	AddQuery(key, value string)

	GetHeader(key string) (string, bool)
	GetQuery(key string) (string, bool)

	SetFragment(s string)
}

type RequestModifier func(r Request) error

type Response interface {
	// Code returns an HTTP compatible status code of the response.
	Code() int
	// Response returns underlying response object
	Response() interface{}
	// Endpoint returns the endpoint that handled the request.
	Endpoint() string
	// Content returns Content-Type
	Content() string
}

type RetryWrapper func(response Response, err error) bool

type Wrapper func(c Connection) Connection