WithAuthToken returns a new context with the given auth token.

FlushSchemas stores schemas into the file without any modifications.

JSONHTTPClient returns the underlying JSON HTTP client. This is useful for testing, or for calling methods that aren't exposed by the Connector interf

With returns a new context with the given values added. The values are added to the logger automatically.

Failure fulfills the promise with an error. Use this when the async computation failed and you need to propagate the error. Example: fut, promise

FormatRFC3339inUTCWithMilliseconds similar to FormatRFC3339inUTC but adds milliseconds. 15:04:05.039 => milliseconds is a decimal part of seconds.

GetRecordsByIds fetches full records from the provider for a specific set of IDs. This method is primarily used during webhook processing to enrich e

IntegerRequired returns the integer at key. Examples: IntegerRequired("") // current node IntegerRequired("count") // direct lookup New(n

ParseJSONResponse parses the given HTTP response and returns a JSONHTTPResponse.

AwaitContext blocks until the future completes or the context is canceled. This is the context-aware version of Await, allowing for timeouts and canc

FilterSortedRecords filters and returns only the records that have changed since the last sync, based on a provided timestamp key and reference value.

NewApiKeyHeaderAuthHTTPClient returns a new http client, with automatic API key authentication. Specifically this means that the client will automatic

NewClient will create a new authenticated client based on the provider's auth type.

runWrite invokes Write with the given params and logs the outcome. Errors are recorded as warnings (not fatal) so subsequent tests still run — useful

ExtractLowercaseFieldsFromRaw returns a map of fields from a record. The fields are all returned in lowercase.

Go executes the callback in a new goroutine and resolves the promise with the result. Panics are recovered and converted to errors.

IsCreate reports whether the Write is creating a new record. Write is considered a Create when no record identifier is provided. Callers should prefe

MakeMarshaledDataFuncWithId constructs a MarshalFromNodeFunc that converts records into ReadResultRow slices with the Id field populated. It combines

ValidateMetadataContainsRead checks that every field present in the Read response is declared in the metadata returned by ListObjectMetadata for the s

setupAssociationConnector creates a connector with schemas that have associations

AppendError will associate an error with the object. It is possible that single object may have multiple errors.

GoContext executes the callback with a context in a new goroutine and resolves the promise. The context allows for cancellation and timeout handling.

InterpretError interprets the given HTTP response (in a fairly straightforward way) and returns an error that can be handled by the caller.

IsVerboseLogging returns true if the logger is configured to allow verbose messages.

SetUnitTestMockServerBaseURL replaces the URL Origin with mock server URL Origin. This allows to reroute all requests to mock server used in unit test

VerboseLogger returns a logger used for more verbose logging. nolint:contextcheck,cyclop

cancel marks the promise as canceled and executes all registered cancel functions. This is an internal method used by the future package for cancella

AssertErr compares expected and actual errors and records a mismatch in the result if they do not match. Matching rules: - If both expectedErr and a

GenerateRandomRecord generates a random record conforming to the object's schema.

Int64 adds a 64-bit integer to the hash. The integer is encoded as 8 bytes in big-endian format for deterministic representation across different arch

MakeGetMarshaledDataWithId constructs a MarshalFunc that converts records into ReadResultRow slices with the Id field populated. It uses the provided

nolint:errchkjson

SelectOne reads one object metadata from the static file. NOTE: empty module id is treated as root module.

ValidateMetadataExactlyMatchesRead verifies that *all* metadata fields returned by ListObjectMetadata are present in the Read response for the object.

Helper function to parse JSON schema into InputSchema

newClassedErr constructs a classified sentinel error. The actual error (errors.New) is stored inside and accessible via Unwrap(). The returned pointer

readObject reads data from a SuperSend object and prints the results.

Add will appropriately store the data, abiding to data structure rules. NOTE: empty module id is treated as root module.

Close closes the given Closer and fails if there is an error.

ContentHTML is a setup handler, which configures server to use HTML.

CustomFieldKey returns the connector field name for a GetResponse customFieldId.

Permute generates an Or condition containing one branch for every permutation of the provided items. For each permutation, the conditionMaker function

ResponseChainedFuncs combines functions into order pipeline. Together acts as unified response handler. This is useful if Response method or ResponseS

buildJobNestedURL extracts jobId from the record and builds a URL of the form api/v2/jobs/{jobId}/<segments...>. Returns errMissingParentID if jobId i

incrementField adds a field separator (null byte) before each field after the first. This ensures that different field combinations produce different

BoolOptional returns the bool at key if present. Examples: IntegerOptional("") // current node BoolOptional("enabled") // dire

BoolRequired returns the bool at key. Examples: BoolRequired("") // current node BoolRequired("enabled") // direct lookup New(node, "a",

Execute concurrently runs all provided tasks in parallel and collects their results into a Result struct containing both successful records and errors

ForEach applies the provided function f to each element of s, returning a new slice containing the results. Example: names := []string{"alice", "bo

Get makes a GET request to the given URL and returns the response. If the response is not a 2xx, an error is returned. If the response is a 401, the c

ReadObjects will explore OpenAPI file returning list of Schemas. See every parameter for detailed customization. operationName - under which REST ope

WithAuthenticatedClient sets the http client to use for the connector. Its usage is optional.

WithUnencodedQueryParam adds a single unencoded query param.