MCPcopy Create free account

hub / github.com/amp-labs/connectors / functions

Functions8,532 in github.com/amp-labs/connectors

↓ 3 callersMethodcatalog
()
providers/utils.go:57
↓ 3 callersFunctioncheckErr
(resp *writeResponse, recordId any, success bool)
providers/marketo/write.go:91
↓ 3 callersFunctioncheckErrorInResponse
This function uses to check whether the response(200 statuscode) contain error or not.
providers/jobber/errors.go:49
↓ 3 callersFunctioncleanupDelete
(ctx context.Context, conn interface { Delete(context.Context, common.DeleteParams) (*common.DeleteResult, er
test/shopify/orders/write-delete/main.go:185
↓ 3 callersMethodclientIdHeader
()
providers/connectwise/connector.go:121
↓ 3 callersFunctionconstructResponse
unmarshal the write response.
test/snapchatads/write/main.go:156
↓ 3 callersFunctionconstructResponse
unmarshal the write response.
test/avoma/write/main.go:147
↓ 3 callersFunctionconstructResponse
unmarshal the write response.
test/loxo/write/main.go:120
↓ 3 callersFunctionconstructTestAdapter
(t *testing.T, baseURL, accountID string)
providers/zoho/internal/mail/metadata_test.go:116
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/xero/metadata_test.go:231
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/apollo/metadata_test.go:87
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/procore/metadata_test.go:103
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/snapchatads/metadata_test.go:119
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/avoma/metadata_test.go:120
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/chilipiper/metadata_test.go:75
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/closecrm/metadata_test.go:89
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/claricopilot/metadata_test.go:95
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/attio/metadata_test.go:302
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/asana/metadata_test.go:158
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/acuityscheduling/metadata_test.go:167
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/sageintacct/metadata_test.go:191
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/paddle/metadata_test.go:132
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/fastspring/metadata_test.go:157
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/heyreach/metadata_test.go:171
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/freshdesk/metadata_test.go:89
↓ 3 callersFunctionconstructTestConnector
(serverURL string, moduleID common.ModuleID)
providers/google/metadata_test.go:225
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/dropboxsign/metadata_test.go:158
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/flatfile/metadata_test.go:91
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/fathom/metadata_test.go:161
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/helpscoutmailbox/connector_test.go:310
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/bentley/metadata_test.go:95
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/braintree/read_test.go:16
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/goto/metadata_test.go:101
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/quickbooks/metadata_test.go:432
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/chargebee/metadata_test.go:308
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/pylon/metadata_test.go:147
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/recurly/metadata_test.go:815
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/zoom/metadata_test.go:123
↓ 3 callersFunctionconstructTestConnector
(serverURL string)
providers/marketo/metadata_test.go:94
↓ 3 callersFunctionconstructTestConnectorGeneral
(serverURL string, module common.ModuleID)
providers/salesforce/read_test.go:574
↓ 3 callersFunctionconstructTestReadConnector
(baseURL, projectID string)
providers/revenuecat/read_test.go:239
↓ 3 callersFunctionconstructTestStrategy
(server *httptest.Server)
providers/connectwise/internal/subscriber/create_test.go:251
↓ 3 callersFunctionconstructURL
(base string, path ...string)
providers/dynamicsbusiness/url.go:16
↓ 3 callersFunctionconstructURL
(base string, path ...string)
providers/dynamicscrm/url.go:12
↓ 3 callersMethodconstructURL
(objName string)
providers/xero/utils.go:9
↓ 3 callersMethodconstructURL
(objName string)
providers/snapchatads/utils.go:30
↓ 3 callersMethodconstructURL
(objectName string)
providers/amplitude/utils.go:25
↓ 3 callersFunctionconstructor
(base *components.Connector)
providers/g2/connector.go:57
↓ 3 callersFunctioncontainsField
containsField checks if a field exists in the fields list (case-insensitive). e.g. containsField(["Id", "Name", "AccountId"], "accountid") -> true.
providers/salesforce/internal/crm/associations/relationships.go:41
↓ 3 callersFunctioncontainsSubstring
containsSubstring is a helper for checking if a string contains a substring.
providers/snowflake/read_test.go:368
↓ 3 callersMethodconvertTimestampsToInstanceTimezone
convertTimestampsToInstanceTimezone converts the Since and Until timestamps from UTC to the NetSuite instance's local timezone. This is necessary beca
providers/netsuite/connector.go:172
↓ 3 callersFunctioncreateBulkJobServer
This server knows how to respond to the following events: * Job created for certain request body. * CSV was uploaded using JobID. * Updated Job status
providers/salesforce/bulk-write_test.go:177
↓ 3 callersFunctioncreateURLWithQuery
(key string, values []string)
providers/intercom/url_test.go:51
↓ 3 callersFunctioncreateUnprocessableObjectError
(objectName string)
tools/fileconv/api3/models.go:506
↓ 3 callersFunctioncustomFieldDefinitionsServer
customFieldDefinitionsServer returns a mock server that responds to the company-settings/custom-fields endpoint with the given fixture, and 500s on an
providers/acculynx/metadata_test.go:218
↓ 3 callersFunctionenvNameFormat
(name string)
common/scanning/credscanning/fields.go:207
↓ 3 callersFunctionextractAlternateTimestampUsingObjects
extractAlternateTimestampUsingObjects walks the connector metadata for "<ObjectName>_timestampColumnCreateTime" entries and returns the set of objects
connector/new.go:370
↓ 3 callersFunctionextractIdFromRecord
extractIdFromRecord extracts the ID value from a record map using the provided IdFieldQuery. It traverses the zoom path (if any) to reach nested objec
common/readhelper/id.go:134
↓ 3 callersFunctionextractRecordsFromKeyPath
extractRecordsFromKeyPath builds the records-extraction func from a full key path (outer-to-inner). The last key is the array; the keys before it are
providers/zoho/internal/mail/objects.go:186
↓ 3 callersFunctionfindEventMapping
findEventMapping looks up the event mapping for a given object name using flexible matching. It first tries an exact key match, then checks the last "
providers/salesloft/subscribe.go:664
↓ 3 callersFunctionfindString
(s, substr string)
providers/salesforce/soql_test.go:166
↓ 3 callersFunctionfirstArrayElementTextField
(body *ajson.Node, arrayKey, fieldKey string)
providers/fastspring/write.go:214
↓ 3 callersFunctionfirstNonEmpty
(candidates ...string)
providers/netsuite/internal/restapi/metadata.go:87
↓ 3 callersFunctionflattenFields
flattenFields flattens nested field definitions into JSONPath bracket notation. For example, audit.createdByUser.key becomes a single field entry.
providers/sageintacct/utils.go:99
↓ 3 callersFunctiongeneratePlaceholderValue
generatePlaceholderValue generates a simple placeholder value when depth limit is reached.
memstore/connector.go:959
↓ 3 callersFunctiongenerateRandomSuffix
3 bytes = 6 hex characters generateRandomSuffix generates a random 6-character hex suffix for unique object naming. This prevents different connector
providers/snowflake/utils.go:85
↓ 3 callersFunctiongenerateTimestamp
generateTimestamp generates a timestamp based on the schema's updated field type. IMPORTANT: This function must be used in the Write logic to auto-ge
memstore/storage.go:856
↓ 3 callersMethodgenerateValueFromSchema
generateValueFromSchema generates a value from a schema definition.
memstore/connector.go:947
↓ 3 callersMethodgetAPIURL
(apiVersion, object string)
providers/pipedrive/internal/crm/adapter.go:30
↓ 3 callersMethodgetAPIURL
getAPIURL constructs a specific object's resource URL in the format `{{baseURL}}/{{version}}/{{objectName}}`.
providers/pipedrive/internal/legacy/adapter.go:30
↓ 3 callersMethodgetAPIURL
(objectName string)
providers/freshdesk/connector.go:49
↓ 3 callersMethodgetApiURL
(arg string)
providers/attio/connector.go:51
↓ 3 callersMethodgetApiURL
(arg string)
providers/kit/connector.go:56
↓ 3 callersFunctiongetConnector
(ctx context.Context, module common.ModuleID)
test/netsuitem2m/connector.go:39
↓ 3 callersFunctiongetGoogleConnector
(ctx context.Context, moduleID common.ModuleID)
test/google/connector.go:26
↓ 3 callersFunctiongetIDFromQuery
(query *jsonquery.Query)
providers/justcall/handlers.go:300
↓ 3 callersFunctiongetMarketoJSONReader
()
test/marketo/connector.go:60
↓ 3 callersFunctiongetNextRecordsURLDesk
(url *urlbuilder.URL)
providers/zoho/parse.go:55
↓ 3 callersFunctiongetObjectName
Singularize all objectname expect productsAndServices object.
providers/jobber/utils.go:80
↓ 3 callersFunctiongetObjectNodePath
(objName string)
providers/snapchatads/utils.go:40
↓ 3 callersMethodgetObjectURL
(objectName string)
providers/salesloft/connector.go:54
↓ 3 callersMethodgetOptionsForAttribute
( ctx context.Context, objectName naming.SingularString, attributeName string, )
providers/dynamicscrm/metadataRepository.go:150
↓ 3 callersMethodgetOptionsPerAttribute
()
providers/dynamicscrm/metadataRepository.go:264
↓ 3 callersMethodgetPagingToken
(ctx context.Context, since time.Time)
providers/marketo/url.go:235
↓ 3 callersFunctiongetPercentage
(i int, i2 int)
scripts/scraper/salesloft/metadata/main.go:214
↓ 3 callersMethodgetReadURL
(objectName string)
providers/zendesksupport/connector.go:57
↓ 3 callersMethodgetRecordIdentifierValue
(key string)
test/utils/testscenario/crud.go:171
↓ 3 callersFunctiongetResponseCollectionRecords
getResponseCollectionRecords parses node to get a list of records.
providers/slack/parse.go:38
↓ 3 callersMethodgetURL
(parts ...string)
providers/instantly/connector.go:58
↓ 3 callersMethodgetURL
(arg string)
providers/customerapp/connector.go:55
↓ 3 callersMethodgetURL
(path string)
providers/google/internal/contacts/adapter.go:89
↓ 3 callersMethodgetURL
(args ...string)
providers/keap/connector.go:82
↓ 3 callersMethodgetURL
(objectName string)
providers/intercom/connector.go:58
↓ 3 callersMethodgetURL
(arg string)
providers/smartlead/connector.go:55
↓ 3 callersMethodgetURL
(objectName string)
providers/connectwise/connector.go:112
↓ 3 callersMethodgetURL
(arg string)
providers/dynamicscrm/connector.go:65
↓ 3 callersMethodgetURLPath
(objectName string)
providers/cloudtalk/handlers.go:83
↓ 3 callersFunctiongetValues
(ctx context.Context)
common/logging/logging.go:145
↓ 3 callersFunctionin
(a string, b ...[]string)
providers/apollo/params.go:57
↓ 3 callersFunctionisSessionExpired
============================================================================= Session expiry detection ===============================================
providers/bigquery/read.go:427
← previousnext →1,001–1,100 of 8,532, ranked by callers