connection

package

Go to main page

Versions in this module

v2

v2.1.5

Aug 31, 2025

Changes in this version

type Wrapper

+ func NewSSOAuthWrapper(initialToken string) Wrapper

v2.1.4

Jun 27, 2025

Changes in this version

+ type RawObject []byte

v2.1.3

Feb 24, 2025

v2.1.2

Nov 15, 2024

Changes in this version

+ func DefaultHTTP2TransportSettings(in *http2.Transport)

+ func DefaultHTTPTransportSettings(in *http.Transport)

+ func New[T any](mods ...Mod[T]) T

+ func WithHTTP2InsecureSkipVerify(in *http2.Transport)

+ func WithHTTPInsecureSkipVerify(in *http.Transport)

type Http2Configuration

+ func DefaultHTTP2ConfigurationWrapper(endpoint Endpoint, insecureSkipVerify bool) Http2Configuration

type HttpConfiguration

+ func DefaultHTTPConfigurationWrapper(endpoint Endpoint, insecureSkipVerify bool) HttpConfiguration

+ type Mod func(in *T)

+ func WithHTT2PEndpoint(endpoint Endpoint) Mod[Http2Configuration]

+ func WithHTTP2Transport(mods ...Mod[http2.Transport]) Mod[Http2Configuration]

+ func WithHTTPEndpoint(endpoint Endpoint) Mod[HttpConfiguration]

+ func WithHTTPTransport(mods ...Mod[http.Transport]) Mod[HttpConfiguration]

v2.1.1

Sep 27, 2024

v2.1.0

Apr 2, 2024

Changes in this version

+ type ArangoDBConfiguration struct

+ ArangoQueueTimeoutEnabled bool

+ ArangoQueueTimeoutSec uint

+ Compression *CompressionConfig

+ DriverFlags []string

+ type Compression interface

+ ApplyRequestCompression func(r *httpRequest, rootWriter io.Writer) (io.WriteCloser, error)

+ ApplyRequestHeaders func(r Request)

+ type CompressionConfig struct

+ CompressionType CompressionType

+ RequestCompressionEnabled bool

+ RequestCompressionLevel int

+ ResponseCompressionEnabled bool

+ type CompressionType string

+ const RequestCompressionTypeDeflate

+ const RequestCompressionTypeGzip

type Connection

+ GetConfiguration func() ArangoDBConfiguration

+ SetConfiguration func(config ArangoDBConfiguration)

+ type EncodingCodec interface

type Http2Configuration

+ ArangoDBConfig ArangoDBConfiguration

type HttpConfiguration

+ ArangoDBConfig ArangoDBConfiguration

type Response

+ RawResponse func() *http.Response

v2.0.3

Oct 31, 2023

Changes in this version

+ const ArangoHeaderAsyncIDKey

+ const ArangoHeaderAsyncKey

+ const ArangoHeaderAsyncValue

+ func HasAsyncID(ctx context.Context) (string, bool)

+ func IsAsyncJobInProgress(err error) (string, bool)

+ func IsAsyncRequest(ctx context.Context) bool

+ func RequestDBNameValueExtractor(requestMethod, requestPath string) (string, error)

+ func WithAsync(parent context.Context) context.Context

+ func WithAsyncID(parent context.Context, asyncID string) context.Context

+ type AsyncConnectionWrapper struct

+ func (a *AsyncConnectionWrapper) Do(ctx context.Context, request Request, output interface{}, ...) (Response, error)

type Connection

+ func NewConnectionAsyncWrapper(conn Connection) Connection

type Endpoint

+ func NewMaglevHashEndpoints(eps []string, extractor RequestHashValueExtractor) (Endpoint, error)

+ func NewRoundRobinEndpoints(e []string) Endpoint

+ type ErrorAsyncJobInProgress struct

+ func (a ErrorAsyncJobInProgress) Error() string

+ type RequestHashValueExtractor func(requestMethod, requestPath string) (string, error)

type Response

+ func CallWithChecks(ctx context.Context, c Connection, method, url string, output interface{}, ...) (Response, error)

+ Header func(name string) string

v2.0.2

May 30, 2023

v2.0.1

May 30, 2023

Changes in this version

+ const ApplicationJSON

+ const ApplicationOctetStream

+ const ApplicationVPack

+ const ApplicationZip

+ const ContentType

+ const PlainText

+ var ErrReaderOutputBytes = errors.New("use *[]byte as output argument")

+ var ErrWriterInputBytes = errors.New("use []byte as input argument")

+ func FixupEndpointURLScheme(u string) string

+ func IsCodeError(err error, code int) bool

+ func IsNotFoundError(err error) bool

+ func NewError(code int, message string) error

+ func NewErrorf(code int, message string, args ...interface{}) error

+ func NewHTTP2DialForEndpoint(e Endpoint) func(network, addr string, cfg *tls.Config) (net.Conn, error)

+ func NewNotFoundError(msg string) error

+ func NewUrl(parts ...string) string

+ func WithArangoQueueTime(parent context.Context, duration time.Duration) context.Context

+ func WithArangoQueueTimeout(parent context.Context, useQueueTimeout bool) context.Context

+ func WithDriverFlags(parent context.Context, value []string) context.Context

+ type Array struct

+ func (a *Array) More() bool

+ func (a *Array) Unmarshal(i interface{}) error

+ func (a *Array) UnmarshalJSON(d []byte) error

+ type Authentication interface

+ RequestModifier func(r Request) error

+ func NewBasicAuth(username, password string) Authentication

+ func NewHeaderAuth(key, value string, args ...interface{}) Authentication

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

+ type Connection interface

+ Decoder func(contentType string) Decoder

+ Do func(ctx context.Context, request Request, output interface{}) (Response, error)

+ GetAuthentication func() Authentication

+ GetEndpoint func() Endpoint

+ NewRequest func(method string, urls ...string) (Request, error)

+ NewRequestWithEndpoint func(endpoint string, method string, urls ...string) (Request, error)

+ SetAuthentication func(a Authentication) error

+ SetEndpoint func(e Endpoint) error

+ Stream func(ctx context.Context, request Request) (Response, io.ReadCloser, error)

+ func NewHttp2Connection(config Http2Configuration) Connection

+ func NewHttpConnection(config HttpConfiguration) Connection

+ func NewPool(connections int, factory Factory) (Connection, error)

+ func NewRetryWrapper(conn Connection, retries int, wrapper RetryWrapper) Connection

+ func RetryOn503(conn Connection, retries int) Connection

+ type ContextKey string

+ type Decoder interface

+ Decode func(reader io.Reader, obj interface{}) error

+ Encode func(writer io.Writer, obj interface{}) error

+ Reencode func(in, out interface{}) error

+ type Endpoint interface

+ Get func(endpoints ...string) (string, bool)

+ List func() []string

+ func NewEndpoints(e ...string) Endpoint

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type Factory func() (Connection, error)

+ type Http2Configuration struct

+ Authentication Authentication

+ ContentType string

+ Endpoint Endpoint

+ Transport *http2.Transport

+ func (h Http2Configuration) GetContentType() string

+ type HttpConfiguration struct

+ Authentication Authentication

+ ContentType string

+ Endpoint Endpoint

+ Transport http.RoundTripper

+ func (h HttpConfiguration) GetContentType() string

+ type Request interface

+ AddHeader func(key, value string)

+ AddQuery func(key, value string)

+ Endpoint func() string

+ GetHeader func(key string) (string, bool)

+ GetQuery func(key string) (string, bool)

+ Method func() string

+ SetBody func(i interface{}) error

+ SetFragment func(s string)

+ URL func() string

+ type RequestModifier func(r Request) error

+ func WithBody(i interface{}) RequestModifier

+ func WithFragment(s string) RequestModifier

+ func WithQuery(s, value string) RequestModifier

+ func WithTransactionID(transactionID string) RequestModifier

+ type Response interface

+ Code func() int

+ Content func() string

+ Endpoint func() string

+ Response func() interface{}

+ func Call(ctx context.Context, c Connection, method, url string, output interface{}, ...) (Response, error)

+ func CallDelete(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallGet(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallHead(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallPatch(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallPost(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallPut(ctx context.Context, c Connection, url string, output interface{}, ...) (Response, error)

+ func CallStream(ctx context.Context, c Connection, method, url string, ...) (Response, io.ReadCloser, error)

+ type RetryWrapper func(response Response, err error) bool

+ type Wrapper func(c Connection) Connection

+ func NewJWTAuthWrapper(username, password string) Wrapper

+ func WrapAuthentication(getter AuthenticationGetter) Wrapper

v2.0.0-alpha.1

May 30, 2023

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