presto/client

Search:
Group by:
Source   Edit  

Types

RestClient = object of RootObj
  session*: HttpSessionRef
  address*: HttpAddress
Source   Edit   
RestClientFlag {.pure.} = enum
  CommaSeparatedArray,      ## Arrays could be passed as comma-delimieted strings
  ResolveAlways              ## DNS resolution will be made for every request
Source   Edit   
RestClientMetricsType {.pure.} = enum
  ResolveTime, ConnectTime, RequestTime, ResponseTime, Status
Source   Edit   
RestConnectionFlag = enum
  Dedicated, Close
Source   Edit   
RestHttpResponseRef = HttpClientResponseRef
Source   Edit   
RestPlainResponse = object
  status*: int
  contentType*: Opt[ContentTypeData]
  headers*: HttpTable
  data*: seq[byte]
Source   Edit   
RestRequestFlag {.pure.} = enum
  ConsumeBody
Source   Edit   
RestResponse[T] = object
  status*: int
  contentType*: Opt[ContentTypeData]
  data*: T
Source   Edit   
RestStatus = distinct int
Source   Edit  

Consts

RestClientMetricsAllTypes = {RestClientMetricsType.ResolveTime,
                             RestClientMetricsType.ConnectTime,
                             RestClientMetricsType.RequestTime,
                             RestClientMetricsType.ResponseTime,
                             RestClientMetricsType.Status}
Source   Edit  

Procs

func `$`(x: Opt[ContentTypeData]): string {....raises: [], gcsafe, tags: [],
    forbids: [].}
Source   Edit   
func `$`(x: RestStatus): string {.borrow, ...raises: [], gcsafe, tags: [],
                                  forbids: [].}
Source   Edit   
func `<`(x, y: RestStatus): bool {.borrow, ...raises: [], gcsafe, tags: [],
                                   forbids: [].}
Source   Edit   
func `<=`(x, y: RestStatus): bool {.borrow, ...raises: [], gcsafe, tags: [],
                                    forbids: [].}
Source   Edit   
func `==`(a: Opt[ContentTypeData]; b: MediaType): bool {....raises: [], gcsafe,
    tags: [], forbids: [].}
Source   Edit   
func `==`(x, y: RestStatus): bool {.borrow, ...raises: [], gcsafe, tags: [],
                                    forbids: [].}
Source   Edit   
proc closeWait(client: RestClientRef): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe,
    tags: [RootEffect], forbids: [].}
Source   Edit   
proc new(t: typedesc[RestClientRef]; address: HttpAddress;
         flags: RestClientFlags = {}; httpFlags: HttpClientFlags = {};
         maxConnections: int = -1; maxRedirections: int = HttpMaxRedirections;
         connectTimeout = HttpConnectTimeout;
         headersTimeout = HttpHeadersTimeout;
         idleTimeout = HttpConnectionIdleTimeout;
         idlePeriod = HttpConnectionCheckPeriod; bufferSize: int = 4096;
         userAgent = PrestoIdent; socketFlags: set[SocketFlags] = {};
         dualstack = DualStackType.Auto): RestClientRef {....raises: [], gcsafe.}
Source   Edit   
proc new(t: typedesc[RestClientRef]; ta: TransportAddress;
         scheme: HttpClientScheme = HttpClientScheme.NonSecure;
         flags: RestClientFlags = {}; httpFlags: HttpClientFlags = {};
         maxConnections: int = -1; maxRedirections: int = HttpMaxRedirections;
         connectTimeout = HttpConnectTimeout;
         headersTimeout = HttpHeadersTimeout;
         idleTimeout = HttpConnectionIdleTimeout;
         idlePeriod = HttpConnectionCheckPeriod; bufferSize: int = 4096;
         userAgent = PrestoIdent; socketFlags: set[SocketFlags] = {};
         dualstack = DualStackType.Auto): RestClientRef {....raises: [], gcsafe.}
Source   Edit   
proc new(t: typedesc[RestClientRef]; url: string; flags: RestClientFlags = {};
         httpFlags: HttpClientFlags = {}; maxConnections: int = -1;
         maxRedirections: int = HttpMaxRedirections;
         connectTimeout = HttpConnectTimeout;
         headersTimeout = HttpHeadersTimeout;
         idleTimeout = HttpConnectionIdleTimeout;
         idlePeriod = HttpConnectionCheckPeriod; bufferSize: int = 4096;
         userAgent = PrestoIdent; socketFlags: set[SocketFlags] = {};
         dualstack = DualStackType.Auto): RestResult[RestClientRef] {.
    ...raises: [], gcsafe.}
Source   Edit   
func raiseRestCommunicationError(exc: ref AsyncStreamError) {.noreturn,
    noinline, ...raises: [RestCommunicationError], raises: [], gcsafe, tags: [],
    forbids: [].}
Source   Edit   
func raiseRestCommunicationError(exc: ref HttpError) {.noreturn, noinline,
    ...raises: [RestCommunicationError], raises: [], gcsafe, tags: [], forbids: [].}
Source   Edit   
func raiseRestDecodingBytesError(message: cstring) {.noreturn, noinline,
    ...raises: [RestDecodingError], raises: [], gcsafe, tags: [], forbids: [].}
Source   Edit   
func raiseRestEncodingBytesError(field: static string) {.noreturn, noinline,
    ...raises: [RestEncodingError], raises: [], gcsafe.}
Source   Edit   
func raiseRestEncodingStringError(field: static string) {.noreturn, noinline,
    ...raises: [RestEncodingError], raises: [], gcsafe.}
Source   Edit   
func raiseRestRedirectionError(msg: string) {.noreturn, noinline,
    ...raises: [RestRedirectionError], raises: [], gcsafe, tags: [], forbids: [].}
Source   Edit   
func raiseRestResponseError(resp: RestPlainResponse) {.noreturn, noinline,
    ...raises: [RestResponseError], raises: [], gcsafe, tags: [], forbids: [].}
Source   Edit   
proc requestWithBody(req: HttpClientRequestRef; pbytes: pointer; nbytes: uint64;
                     chunkSize: int; endpoint: Opt[string];
                     metricsTypes: RestClientMetricsTypes): InternalRaisesFuture[
    HttpClientResponseRef, (CancelledError, RestCommunicationError)] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe,
    tags: [RootEffect], forbids: [].}
Source   Edit   
proc requestWithoutBody(req: HttpClientRequestRef; endpoint: Opt[string];
                        metricsTypes: RestClientMetricsTypes): InternalRaisesFuture[
    HttpClientResponseRef, (CancelledError, RestCommunicationError)] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], gcsafe,
    tags: [RootEffect], forbids: [].}
Source   Edit  

Macros

macro rest(prc: untyped): untyped {..}
Source   Edit  

Templates

template accept(v: string) {.pragma.}
Source   Edit   
template chroniclesExpandItIMPL(record: auto; it_name: static string;
                                it: HttpAddress) {..}
Source   Edit   
template chroniclesExpandItIMPL[RecordType: tuple](record: RecordType;
    it_name: static string; it: HttpAddress; enabled: auto) {..}
Source   Edit   
template chroniclesFormatItIMPL(it: HttpClientConnectionRef): auto {..}
Source   Edit   
template connection(v: RestConnectionFlag) {.pragma.}
Source   Edit   
template endpoint(v: string) {.pragma.}
Source   Edit   
template meth(v: HttpMethod) {.pragma.}
Source   Edit   
template metrics() {.pragma.}
Source   Edit   
template metrics(v: string) {.pragma.}
Source   Edit   
template metricsTypes(v: RestClientMetricsTypes) {.pragma.}
Source   Edit  

Made with Nim. Generated: 2026-09-04 07:12:53 UTC