getURL returns the base prefixed URL.

modulePath returns the module's URL prefix (e.g. "/api/v2") from schemas.json root.path. Used by URL builders here that compose paths with dynamic rec

ComparatorSubscriptionWithResult returns a comparator for subscription results that first compares the common SubscriptionResult fields and then compa

Complete fulfills the promise with a value and error pair. This is a convenience method that matches Go's standard (value, error) return pattern. It

ConstructApexTrigger builds the zip deployment package containing three Apex artifacts: 1. The trigger itself (triggers/<TriggerName>.trigger) — a th

FilterBy returns a new SearchFilter with an additional FieldFilter appended. The receiver is treated as immutable: FilterBy does not modify the origi

GetIdFields returns a mapping of object names to their ID field names. The ID field is the field within each record that serves as its unique identif

GetPanicRecoveryError converts a recovered panic value and optional stack trace into a standard error. If the panic value is nil, it returns nil. If t

IsSuccess returns true if the Try contains a successful value (Error is nil).

NewAllowPathStrategy produces a path matching strategy that will accept only those paths that matched the list. Others will be denied. You can use sta

SelectFields returns a new map containing only the whitelisted fields.

SetBaseURL TODO use components.Connector to inherit this method.

Subscribe registers a new subscription to receive notifications for storage events. The subscription context contains the callback function, event fil

UpdateSubscription applies detected changes to an existing provider-side subscription. This method is called only after the framework detects changes

getFullyQualifiedName returns the fully qualified name for an object. Only the database, schema, and object names are uppercased (FQN components).

This is the main gateway method that handles errors produced - by http clients JSON, XML, etc.; - by underlying oauth2 library; Otherwise if the conn

makeSOQL returns the SOQL query for the desired read operation. The timestampColumn parameter specifies which field to use for Since/Until filtering (

resolveTopics returns the deduplicated, sorted AccuLynx topic-name slice for the given events. Objects must be in objectEventTopics; pass-through even

sendRequest sends the given request and returns the response & response body.

FlattenNestedFields returns a procedure which copies fields of a nested object to the top level. Ex: Every object has special field "attributes" whic

Float64Ptr adds a float64 pointer to the hash. Nil pointers are represented as byte 0, non-nil pointers as byte 1 followed by the 8-byte IEEE 754 repr

GetMarshaledData converts records into ReadResultRow slices without populating the Id field. Deprecated: For new connectors, prefer readhelper.MakeGe

HeaderLink extracts and parses Link Header of HTTP response. nolint:lll Example: given the header below we want to return one of the URLs based on th

IsContextAlive returns true if the context is not done.

IsFailure returns true if the Try contains an error (Error is not nil).

NewBasicAuthHTTPClient returns a new http client, with automatic Basic authentication. Specifically this means that the client will automatically add

Operation loads and renders a GraphQL query or mutation from a template file. It reads a .graphql template from the embedded filesystem and executes

RawEventName returns AccuLynx's topicName verbatim (e.g. "job_created").

RecordId returns the affected contact/job id from event.<object>.id. Returns errParentRecordIDUnavailable for topics where AccuLynx omits the parent i

Register performs a provider-specific registration required to enable webhook subscriptions. This is typically a one-time operation per installation

Validate finalizes the comparison and fails the test if any mismatches were recorded. If the CompareResult is successful (OK == true), Validate is a

---- helpers ---- capture prints a successful WriteResult and extracts uuid + version from the data payload so the caller can use them in subsequent u

printError prints error and returns true if error is not nil.

AsInt is a helper function that extracts an integer from the map. This function will convert number values such as int, uint, and float to int64. By d

Bool adds a boolean value to the hash. True is represented as byte 1, false as byte 0.

CamelCaseToSpaceSeparated converts camel case into lower case space separated string.

ClassOf returns the ErrorClass for an error, walking the error chain. Resolution order: 1. Any error in the chain implementing Classifier wins (senti

ContentXML is a setup handler, which configures server to use XML.

DeleteSubscription removes an existing provider-side subscription. This method is called when the framework determines that no subscription lookups r

FlatMap transforms a Try[A] into a Try[B] by applying function f to the value if successful. Unlike Map, f returns a Try[B] directly, avoiding nested

IsCancelled returns true if the promise has been canceled. This is a thread-safe check that can be called from any goroutine. Once a promise is cance

JSONHTTPClient returns the underlying JSON HTTP client.

ReadModuleInfo finds information about the module. If module is not found fallbacks to the default.

Subtract will return objects from current set that didn't occur in the input.

ToURL relies on String method.

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

addAcceptJSONHeader adds the Accept: application/json header to the given headers.

addHeaders adds the given headers to the request.

unmarshal the write response.

In case an empty ModuleID is provided we fall back to the default root module id.