MCPcopy Create free account

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

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

↓ 4 callersFunctionconstructURL
(base string, path ...string)
providers/intercom/url.go:10
↓ 4 callersMethodconstructURL
(objName string)
providers/linkedin/internal/ads/utils.go:127
↓ 4 callersFunctioncreateURLWithQuery
(key string, values []string)
providers/dynamicscrm/url_test.go:54
↓ 4 callersFunctioncustomFieldMetadataKey
customFieldMetadataKey is the connector field name for a PhoneBurner custom field: the provider display_name / custom_fields[].name lowercased with sp
providers/phoneburner/custom.go:54
↓ 4 callersFunctiondeepCopyRecord
deepCopyRecord creates an independent copy of a record. This ensures that modifications to the returned record do not affect the original, and vice ve
memstore/storage.go:313
↓ 4 callersFunctiondeleteRecord
deleteRecord exercises the Delete code path. Top-level vs company-scoped routing is decided inside the connector based on objectName.
test/gusto/write/main.go:164
↓ 4 callersMethoddeleteToSFAPI
(ctx context.Context, path string, entity string)
providers/salesforce/events.go:433
↓ 4 callersMethodemailHeader
emailHeader is required for all REST API calls. https://developer.copper.com/introduction/requests.html#headers
providers/copper/connector.go:116
↓ 4 callersFunctionescapeSOQLString
escapeSOQLString escapes a value for safe inclusion in a SOQL string literal. Backslashes must be escaped before single quotes.
providers/salesforce/events.go:662
↓ 4 callersFunctionextractFieldsFromTable
(doc *goquery.Document, objectName, sectionName string, isReadOnly bool, )
scripts/scraper/salesforce/pardot/main.go:97
↓ 4 callersFunctionextractRecords
(optional bool, jsonPath string, nestedPath ...string)
common/parse.go:306
↓ 4 callersMethodfindByID
(identifier string)
providers/google/internal/mail/messages.go:325
↓ 4 callersFunctionflattenSchema
flattenSchema recursively merges all properties from allOf, oneOf, anyOf into a single Schema.
tools/fileconv/api3/models.go:216
↓ 4 callersFunctionformatAPIName
nolint:varnamelen
providers/zoho/subscribe.go:758
↓ 4 callersMethodfulfill
fulfill is the internal method that actually completes the promise. This is the core mechanism for promise completion. It: - Stores the result (value
internal/future/promise.go:68
↓ 4 callersFunctiongenerateTestECKey
(t *testing.T)
providers/netsuite/m2m/m2m_test.go:19
↓ 4 callersMethodgetAPIURL
(object string)
providers/closecrm/connector.go:49
↓ 4 callersMethodgetAPIURL
(object string)
providers/asana/connector.go:50
↓ 4 callersMethodgetDiscoveryEndpoint
()
providers/shopify/connector.go:94
↓ 4 callersMethodgetModuleURL
URL format for providers.ModuleAtlassianJira follows structure applicable to Oauth2 Atlassian apps: https://developer.atlassian.com/cloud/jira/platfor
providers/atlassian/connector.go:90
↓ 4 callersMethodgetModuleURL
Gateway access to URLs.
providers/salesforce/connector.go:203
↓ 4 callersMethodgetModuleURL
()
providers/salesforce/internal/crm/metadata/adapter.go:34
↓ 4 callersFunctiongetProviderEventName
(subscriptionEvent common.SubscriptionEventType)
providers/outreach/subscribe.go:498
↓ 4 callersMethodgetReadURL
(objectName string)
providers/gong/connector.go:66
↓ 4 callersMethodgetURL
(objectName string)
providers/constantcontact/connector.go:56
↓ 4 callersMethodgetURL
(objectName string)
providers/google/internal/calendar/adapter.go:80
↓ 4 callersMethodgetURL
nolint:lll Every endpoint belongs to the company REST API resource. Therefore, supported objects exist only within the scope of the company. https://l
providers/dynamicsbusiness/url.go:37
↓ 4 callersMethodgetURL
(objectName string)
providers/stripe/connector.go:55
↓ 4 callersMethodgetURL
(objectName string)
providers/salesforce/internal/pardot/adapter.go:106
↓ 4 callersMethodgetURL
(objectName string)
providers/microsoft/connector.go:127
↓ 4 callersFunctionhandlerReturningError
creates error responder which always returns the same error for any http.Response.
common/interpreter/error_test.go:145
↓ 4 callersFunctioninterpretPhoneBurnerEnvelopeError
(response *common.JSONHTTPResponse)
providers/phoneburner/read.go:247
↓ 4 callersFunctionisDuplicateDeveloperName
isDuplicateDeveloperName reports whether err is a 400 response whose body contains the DUPLICATE_DEVELOPER_NAME Salesforce error code.
providers/salesforce/events.go:537
↓ 4 callersMethodisPardotModule
()
providers/salesforce/connector.go:213
↓ 4 callersMethodisUnauthorized
(rsp *http.Response)
common/oauth.go:244
↓ 4 callersFunctionlogRequestWithBody
512 KB
common/printable.go:23
↓ 4 callersFunctionlookupQuotaField
lookupQuotaField finds the checkbox field name for an object using case and plurality insensitive matching. Returns the field name and true if found.
providers/salesforce/subscribe.go:859
↓ 4 callersFunctionmakeNextRecordsURL
makeNextRecordsURL constructs the next page URL based on GetResponse pagination. GetResponse uses response headers (TotalCount, TotalPages, CurrentPag
providers/getresponse/handler.go:156
↓ 4 callersFunctionnewAssociation
(toID string, associationTypeID int)
test/hubspot/batch/update/contact-with-associations/main.go:136
↓ 4 callersFunctionnewPath
(id string, zoom ...string)
providers/iterable/write.go:91
↓ 4 callersMethodnewRequest
( ctx context.Context, method string, url *urlbuilder.URL, body io.Reader, )
providers/procore/utils.go:28
↓ 4 callersFunctionnextRecordsURL
(requestURL *urlbuilder.URL, objectName string)
providers/phoneburner/read.go:332
↓ 4 callersFunctionobjectPath
objectPath resolves an object name to its ServiceNow REST API path. Unknown objects are rejected so callers can't reach arbitrary endpoints.
providers/servicenow/objects.go:118
↓ 4 callersFunctionparseRestletError
(resp *restletResponse)
providers/netsuite/internal/restlet/errors.go:14
↓ 4 callersFunctionparseTime
(s string)
providers/quickbooks/read_test.go:16
↓ 4 callersMethodpostToSFAPI
(ctx context.Context, body any, path string, entity string)
providers/salesforce/events.go:390
↓ 4 callersFunctionprettyPrint
(v any)
test/acculynx/subscribe/subscribe.go:137
↓ 4 callersFunctionprintJSON
printJSON prints data as formatted JSON
test/memstore/metadata/metadata.go:289
↓ 4 callersFunctionqueryHTML
(sourceURL string)
scripts/scraper/salesloft/metadata/main.go:248
↓ 4 callersFunctionreadArrayKey
(m map[string]any, key, objectName string)
providers/goto/internal/gotocore/utils.go:72
↓ 4 callersFunctionreadNodeArray
(node *ajson.Node, jsonPath string, nestedPath ...string)
providers/goto/internal/gotocore/read.go:141
↓ 4 callersFunctionreadObjects
( ctx context.Context, conn connectors.ReadConnector, objectName string, fields datautils.StringSet, since t
test/utils/testscenario/crud.go:216
↓ 4 callersMethodreadRecords
readRecords performs a GET request to the specified URL and parses the response. Optional headers can be provided (e.g., for connected account authent
providers/stripe/read.go:226
↓ 4 callersMethodrecordsFunc
recordsFunc resolves the records-array key from the schema's responseKey. Most AccuLynx list responses wrap as {..., items: [...]}; the exception is a
providers/acculynx/read.go:241
↓ 4 callersFunctionremoveObject
(ctx context.Context, conn ConnectorCRUD, objectName string, objectID string)
test/utils/testscenario/crud.go:284
↓ 4 callersFunctionresolveObjectPath
(path string, companyID string)
providers/breezy/paths.go:24
↓ 4 callersMethodresolveToken
============================================================================= Token resolution =======================================================
providers/bigquery/read.go:235
↓ 4 callersMethodrollbackQuotaOptimizationFields
(ctx context.Context, req *SubscriptionRequest)
providers/salesforce/subscribe_rollback.go:200
↓ 4 callersFunctionrunFallback
(obj string, res *common.ListObjectMetadataResult, )
providers/marketo/metadata.go:117
↓ 4 callersFunctionsearchObjectRecord
(res *common.ReadResult, key, value string)
test/utils/testscenario/crud.go:249
↓ 4 callersFunctionsubstituteStruct
substituteStruct applies substitutions to all string fields in the struct pointed to by input. It handles nested structs, pointers, slices, arrays, ma
common/substitutions/substitutions.go:11
↓ 4 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string, since, until time.Time)
test/lever/read/main.go:46
↓ 4 callersFunctiontestRead
(ctx context.Context, conn *kaseya.Connector, objectName string, fields []string)
test/kaseyavsax/read/main.go:46
↓ 4 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string, since time.Time)
test/instantlyai/read/read.go:46
↓ 4 callersMethodupsertQuotaOptimizationFields
upsertQuotaOptimizationFields creates the quota-optimization checkbox custom field for each object that the caller has both (a) subscribed to via para
providers/salesforce/subscribe.go:971
↓ 4 callersMethodvalidate
()
providers/snowflake/auth.go:28
↓ 3 callersMethodAddDifference
(diff string)
test/utils/testutils/comparison.go:65
↓ 3 callersMethodAsFloat
AsFloat is a helper function that extracts a float from the map. This function will convert number values such as int, uint, and float to float64. By
common/stringMap.go:66
↓ 3 callersMethodBatchWrite
BatchWrite performs a batch create, update, or upsert operation. Each record in params.Records is processed according to params.Type. The returned Bat
connectors.go:125
↓ 3 callersFunctionBuildUntilTimestampFilterGroup
BuildUntilTimestampFilterGroup filters records modified until and including the given time.
providers/hubspot/search.go:192
↓ 3 callersMethodBulkQuery
BulkQuery launches async Query job for bulk reading. Design your SOQL query string you want to execute. Have a look at Salesforce documentation to kn
providers/salesforce/bulk-query.go:21
↓ 3 callersFunctionChainedMarshaller
ChainedMarshaller wraps a base marshaller with one or more row processors.
common/readhelper/marshall.go:12
↓ 3 callersMethodCheckDeployStatus
CheckDeployStatus checks the status of an async deployment once and returns the result. The caller is responsible for polling in a loop until DeployRe
providers/salesforce/apex.go:298
↓ 3 callersFunctionCombine
Combine combines multiple futures into a single future that completes when all inputs complete. This is useful for waiting on multiple independent as
internal/future/future.go:660
↓ 3 callersMethodCombine
Combine merges schemas such that the "other" takes precedence when ObjectName matches.
internal/metadatadef/definition.go:38
↓ 3 callersFunctionCombineContextNoShortCircuit
CombineContextNoShortCircuit is the context-aware version of CombineNoShortCircuit. Waits for ALL futures with context support, collecting all result
internal/future/future.go:906
↓ 3 callersFunctionCombineContextNoShortCircuitWithExecutor
CombineContextNoShortCircuitWithExecutor combines futures with context support without short-circuiting using a custom executor. This is identical to
internal/future/future.go:921
↓ 3 callersFunctionCombineNoShortCircuitWithExecutor
CombineNoShortCircuitWithExecutor combines multiple futures without short-circuiting using a custom executor. This is identical to CombineNoShortCirc
internal/future/future.go:831
↓ 3 callersFunctionCombineWithExecutor
CombineWithExecutor combines multiple futures using a custom executor. This is identical to Combine but allows you to specify a custom executor for t
internal/future/future.go:675
↓ 3 callersFunctionContentText
ContentText is a setup handler, which configures server to use Plain Text.
test/utils/mockutils/mockserver/handlers.go:27
↓ 3 callersFunctionCreateOauth2TokenHeaderAttachment
CreateOauth2TokenHeaderAttachment builds and returns a custom token header configuration for OAuth2 authentication, if the provider defines one. By d
providers/utils.go:952
↓ 3 callersMethodDeepCopy
DeepCopy creates a deep copy of the map using `goutils.Clone`. Internally this uses `encoding/gob`, so all concrete key/value types must be registere
internal/datautils/maps.go:62
↓ 3 callersMethodDeleteEventChannel
(ctx context.Context, channelId string)
providers/salesforce/events.go:183
↓ 3 callersMethodDeployMetadataZip
DeployMetadataZip initiates a deploy of a zip package to the connected Salesforce org via the Metadata API with testLevel=NoTestRun. Returns the async
providers/salesforce/apex.go:273
↓ 3 callersMethodDiff
Diff is a difference between 2 sets. Every object that is not within intersection will be returned.
internal/datautils/set.go:58
↓ 3 callersFunctionEnsureContentType
EnsureContentType ensures that the content type matches the given pattern. If errOnMissing is true, an error is returned if the content type is missin
common/json.go:231
↓ 3 callersMethodEquals
Equals reports whether the given Go value and a JSON-encoded expected representation are structurally equivalent. It returns true if both JSON docume
test/utils/mockutils/jsonComparator.go:43
↓ 3 callersMethodEqualsIgnoreOrder
(other *XML)
common/xquery/equality.go:9
↓ 3 callersMethodError
()
common/errorclass_test.go:189
↓ 3 callersMethodErrorClass
()
common/errorclass.go:69
↓ 3 callersMethodEventTimeStampNano
EventTimeStampNano parses AccuLynx's RFC3339Nano eventDateTime and returns nanoseconds since epoch.
providers/acculynx/subscriptionEvent.go:194
↓ 3 callersMethodEventType
EventType maps the topic suffix to Create / Update / Other. AccuLynx has no delete topics.
providers/acculynx/subscriptionEvent.go:118
↓ 3 callersMethodFindArrayFieldName
(moduleID common.ModuleID, objectName string)
internal/staticschema/core.go:327
↓ 3 callersFunctionFlatMap
FlatMap transforms a Future[A] into a Future[B] by applying a function that returns a Future[B]. This is the "monadic bind" operation for futures. It
internal/future/future.go:539
↓ 3 callersFunctionFlatMapWithExecutor
FlatMapWithExecutor transforms a Future[A] into a Future[B] using a custom executor. This is identical to FlatMap but allows you to specify a custom
internal/future/future.go:557
↓ 3 callersFunctionGenerateApexHandlerClassName
GenerateApexHandlerClassName returns the Apex handler class name paired with a trigger. The trigger delegates its full logic to <TriggerName>_Handler.
providers/salesforce/internal/crm/metadata/apextrigger.go:77
↓ 3 callersMethodGet
Get makes a GET request to the given URL and returns the response body as a JSON object. If the response is not a 2xx, an error is returned. If the re
common/json.go:64
↓ 3 callersMethodGetBody
()
common/printable.go:435
↓ 3 callersMethodGetBuckets
GetBuckets returns names of lists, buckets they are in. Example: veggies: cucumber, tomato; fruits: pineapple; Will return veggies and fruits.
internal/datautils/lists.go:46
↓ 3 callersFunctionGetCalendlyConnector
(ctx context.Context)
test/calendly/connector.go:15
← previousnext →701–800 of 8,532, ranked by callers