Rat adds a rational number (jsonschema.Rat) to the hash. Nil values are represented as byte 0, non-nil values as byte 1 followed by the string represe

ReadUsingSearchAPI uses the POST /search endpoint to filter object records and return the result. This endpoint has a limit of 10,000 records. If the

Remove will delete a key from the set.

Search searches for records in the given object and time range. Parameters: - ctx: context for the operation - params: parameters specifying the obje

UpdatedFields returns the field name(s) the topic implies. Empty slice for generic update/create topics.

UpdatedFields returns the fields that were updated in the event.

ValidateCreateDelete is a comprehensive test scenario utilizing Read/Write/Delete connector operations. Flow: 1. Create an object using the "CP" payl

ValidateSubscribeReceiveEvents is a comprehensive test scenario utilizing subscription connector operations. Flow: 1. Starts local server 2. Asks use

WithApiKeyHeaderClient option sets up client that utilises API Key authentication. Passed via Header.

WithMetadata sets authentication metadata expected by connector.

asMap returns the event as a StringMap.

asMap returns the event as a StringMap.

buildRowRestriction constructs the WHERE clause for the Storage API session. For incremental reads: timestampColumn >= Since AND timestampColumn < Un

unmarshal the write response.

unmarshal the write response.

unmarshal the write response.

nolint: gochecknoglobals Apollo uses mismatched API object names and display names in the documentation. We want to support both naming conventions. T

containsFieldInSOQL checks if a field name appears in the SOQL SELECT clause.

getAPIURL builds the url we can write/read data from Depending on the operation(read or write), some objects will need different endpoints. That's the

getBaseURL will use module URL if module is specified in the registry. Otherwise, it will fall back internally to ProviderInfo.BaseURL.

rawString returns the string value at key in the row's raw payload, or "".

readZipFiles reads all files from a zip and returns a map of filename -> content.

according to Zoho CRM API requirements (max 2 objects per group). so we are building the payload with recursion nolint:cyclop,funlen

BulkWrite launches async Bulk Job to upsert records. https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/create_job.htm Afte

CreateEventChannel . nolint: lll https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_platformeventchann

TODO: Uncomment when we implement UpdateRegistration UpdateRegistration( ctx context.Context, params SubscriptionRegistrationParams, previousResult

EachErrorEquals compares two slices of heterogeneous error values. It returns true if each corresponding pair of elements is considered equal accordin

GenerateApexTestClassName returns the Apex test class name paired with a trigger. Salesforce production deploys with testLevel=RunSpecifiedTests requi

GetAssociations returns a mapping of object names to their association metadata. Each object can have zero or more fields configured as associations

GoContextWithExecutor creates a new Future with context support using a custom executor. This combines the context-awareness of GoContext with the fl

GoWithExecutor creates a new Future and executes the function using a custom executor. This allows you to customize how the async operation is execut

Init initializes a connector with the given provider and parameters by using Connector as a base type. It runs the constructor with the connector and

IsValid checks if the FieldType is known.

JSONHTTPClient returns the underlying JSON HTTP client.

JSONHTTPClient returns the underlying JSON HTTP client.

MakeJSONGetRequest creates a GET request with the given headers and adds the Accept: application/json header. It then returns the request.

Map transforms a Try[A] into a Try[B] by applying function f to the value if successful. If the original Try is a failure, the error is propagated to

MapContextWithExecutor transforms a Future[A] into a Future[B] with context support using a custom executor. This combines context-awareness with cus

NewCatalogVariables converts JSON into supported list of Catalog Variables. This enforces type checking.

NewConnector creates a new Gusto connector for the production environment.