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

IntegerOptional returns the integer at key if present. Examples: IntegerOptional("") // current node IntegerOptional("count")

CalculateQueryParamStats produces statistics on objects and their query parameters. queryParamRegistry - holds query parameter name to the list of obj

NewDenyPathStrategy produces a path matching strategy that will deny only those paths that matched the list. Others will be allowed. You can use star

Nil adds a nil marker (byte value 0) to the hash. Used to explicitly represent nil values in the hash computation.

ObjectRequired returns the object at key. Examples: ObjectRequired("") // current node ObjectRequired("user") // direct lookup New(node,

Find looks up the endpoint for the object. The resulting endpoint will have fully formed URL respecting object name and record id which could be empty

HTTPClient returns the underlying HTTP client. This is useful for proxy requests.

NewCompareResult creates a successful comparison result instance.

WithSchemas configures the connector with pre-parsed JSON schemas. Use this option when you have already parsed jsonschema.Schema objects. This is an

DoCtx runs the given functions in parallel and returns the first error encountered. If no error is encountered, it returns nil. In the event that an e

NewSetFromList creates a set from slice.

SetBaseURL fans the override out to any active module adapter so that unit tests pointing at a mock server reach the same host the top-level connector

Write creates or updates a record. nolint:cyclop,funlen,nestif // Complexity from create/update branching and ID/timestamp generation logic

Error packs every field into one string so the existing server-side log pattern `logger.Error("...", "error", err)` surfaces all diagnostic detail wit

NewOAuthHTTPClient returns a new http client, with automatic OAuth authentication. Specifically this means that the client will automatically refresh

TextWithDefault returns a string under the key regardless of JSON data type. If data is not a string it will be converted to such.

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

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

WithOAuthConfig sets the oauth config to use for the connector. It's required, unless a token source is provided.

WithOAuthToken sets the oauth token to use for the connector. It's required, unless a token source is provided.

Delete removes a record by its ID for the specified object type. Parameters: - objectName: The type of object containing the record (e.g., "contact",

nolint:gochecknoglobals FormatRFC3339inUTC will convert time to UTC respecting the time zone difference and only then apply time.RFC3339 format.

LookupArrayFieldName will give you the field name which holds the array of objects in provider response. Ex: CustomerSubscriptions is located under fi

Read reads a page of data from the connector. This can be called multiple times to read all the data. The caller is responsible for paging, by passing

WithAuthenticatedClient sets up an HTTP client that uses your implementation of authentication.

FromRawURL creates an independent copy of a net/url.URL as *urlbuilder.URL. Unlike direct pointer use, mutations to the returned URL—including path c

MakeMarshaledDataFunc constructs a MarshalFromNodeFunc that converts records into ReadResultRow slices. It applies an optional RecordTransformer to ea

BodyBytes returns a check that expects the request body to match the provided template bytes. If ignore rules are provided, they are applied when com

NewIdField creates an IdFieldQuery for a flat ID field at the root level. This is the common case where the ID is directly accessible as record[field]

SaveSchemas is useful method when creating or updating static schema file. Deprecated. Use FlushSchemas. Common URL path stored as a module path will

FromMap converts golang map into Map resolving generic types on its own. Example: Given: dictionary = make(map[string]string) Then statements are

RecordDataToMap converts WriteParams.RecordData into a map[string]any. When possible use WriteParams.GetRecord instead. If RecordData is already a m

SetUnitTestBaseURL should be used for setting up unit tests. To better handle diverse Module vs Provider BaseURLs use SetUnitTestMockServerBaseURL. De

Text provides inner text of this node.

CapitalizeFirstLetterEveryWord makes all words start with capital except some prepositions.

JSONHTTPClient returns the underlying JSON HTTP client.

LookupURLPath will give you the URL path for the object located under the module. NOTE: empty module id is treated as root module. Deprecated. Use Fi

ObjectNames provides a registry of object names grouped by module.

Run provides a procedure to test connectors.ObjectMetadataConnector

IsUpdate reports whether the write operation is an update rather than a Create. Write is considered an update when a non-empty RecordId is provided.

AddFieldMetadata updates Fields and FieldsMap fields ensuring data consistency.

CheckOutputWithError verifies both output values and returned errors produced by a test case. Special handling: - If expectedErr is nil, any actual e

CustomMappingObjectCheck builds ObjectArrayLocator using mapping, which knows exceptions and patterns to determine response field name. Ex: CustomM

MakeRecordsFunc returns a function that extracts an array of record nodes from a JSON document. The jsonPath defines where the records array resides.

Merge combines another CompareResult into the receiver. Updates OK status (true only if both were true) and concatenates all Diff messages. Ignores n

String adds a string value to the hash. The string is written as UTF-8 bytes.

AddOne will add single value to the unique set.

ContentMIME is a setup handler, which configures custom media type.

Hashable adds a hashable type to the hash computation. Nil values are represented as byte 0, non-nil values as byte 1 followed by the result of callin

MakeIdentityFilterFunc returns a RecordsFilterFunc that allows all records to pass through unchanged. It delegates pagination control entirely to the

NewHTTPError creates a new error with the given HTTP status.

PageSizeWithDefaultStr returns the user-specified page size from params, converted to a string. If params.PageSize is empty value, defaultPageSize is

Read retrieves records for an object with pagination and filtering. nolint:cyclop,funlen,gocognit // Complexity from pagination, filtering, field sel

Success fulfills the promise with a successful value. Use this when the async computation succeeded and you have a value to provide. Example: fut,

write writes bytes to the hash and accumulates any errors. Errors are rare with standard hash implementations but are tracked for completeness.

MakeTimeFilterFunc returns a RecordsFilterFunc that filters records based on timestamp boundaries. It uses the provided TimeOrder to determine whether

NewTimeBoundary constructs a TimeBoundary using the provided options. By default, both Since and Until are inclusive. Examples: b := NewTimeBounda

ParseResultFiltered parses the response from a provider into a ReadResult. A 2xx return type is assumed. The sizeFunc returns the total number of reco

Provider returns the connector provider.

WithOauthClient option that sets up client that utilises Oauth2 authentication.

NewObjectMetadata constructs ObjectMetadata. This will automatically infer fields map from field metadata map. This construct exists for such convenie

WithArrayItemAutoSelection enables automatic selection of the array field in API responses if it is the only array type present. Default: Disabled. U