MCPcopy Create free account

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

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

↓ 3 callersFunctionisZeroValue
isZeroValue checks if the expression represents a zero value.
tools/linters/modulelinter/modulelinter.go:457
↓ 3 callersFunctionjsonPostRequest
jsonPostRequest builds an HTTP POST request with a JSON body.
providers/slack/utils.go:13
↓ 3 callersFunctionmapObjectAlias
In future kases will be renamed to projects. The API still doesn't recognize "projects" as REST resource name. https://developer.capsulecrm.com/v2/mod
providers/capsule/url.go:45
↓ 3 callersFunctionmatchObjectNameToEndpointPath
(objectName string)
providers/pinterest/handlers.go:61
↓ 3 callersFunctionmustParseSchema
mustParseSchema is a helper function to parse JSON schema into InputSchema
test/memstore/connector.go:12
↓ 3 callersFunctionmustParseXML
(t *testing.T, xml string)
common/xquery/equality_test.go:162
↓ 3 callersFunctionnewJSONResponse
(t *testing.T, body string)
providers/netsuite/internal/restlet/write_test.go:106
↓ 3 callersFunctionnewRequestWithQuery
helper: create a request with the given ?q=... parameter
test/utils/mockutils/mockcond/permutation_test.go:81
↓ 3 callersFunctionnewSnowflakeObjects
(paramsMap map[string]string)
providers/snowflake/objects.go:187
↓ 3 callersFunctionnewStarRulePathResolver
( endpoints []string, pathMatchingCallback func(matched bool) bool, )
tools/fileconv/api3/strategy.go:99
↓ 3 callersFunctionnextPageFromPageCounter
nextPageFromPageCounter increments the page query param when the current page was full (records >= per). Returns "" when the page is partial (no more
providers/gusto/read.go:364
↓ 3 callersFunctionnextPageFunc
(node *ajson.Node)
providers/salesforce/internal/pardot/incremental.go:28
↓ 3 callersFunctionnullInt64ToPtr
(ni sql.NullInt64)
providers/snowflake/metadata.go:181
↓ 3 callersMethodobjectURL
objectURL resolves an object's base URL from its path, accounting for account-scoped endpoints that need the post-auth account id in their path.
providers/zoho/internal/mail/metadata.go:95
↓ 3 callersFunctionoffsetPaginationOf
(objectName string)
providers/servicenow/parse.go:113
↓ 3 callersFunctionpagePaginationOf
(objectName string)
providers/servicenow/parse.go:172
↓ 3 callersFunctionpairedDateWindow
pairedDateWindow normalizes a Since/Until pair so both bounds are always present. AccuLynx returns HTTP 400 ("Start Date and End Date do not have the
providers/acculynx/incremental.go:155
↓ 3 callersFunctionparseReadSessionToken
============================================================================= Token serialization ====================================================
providers/bigquery/read.go:840
↓ 3 callersFunctionparseSearchResults
parseSearchResults parses a RESTlet search response envelope into a ReadResult. Shared by both Read and Search since they use the same RESTlet search
providers/netsuite/internal/restlet/read.go:100
↓ 3 callersMethodperformGetRequest
( ctx context.Context, url *urlbuilder.URL, )
providers/dynamicscrm/metadataRepository.go:176
↓ 3 callersFunctionprepareContactWriteRecordData
prepareContactWriteRecordData shapes RecordData for POST /v3/contacts. Callers may set custom fields using connector keys cf_<customFieldId>; this con
providers/getresponse/custom.go:309
↓ 3 callersFunctionprettyPrint
(v any)
test/zoho/subscribe/subscribe.go:124
↓ 3 callersMethodread
(ctx context.Context, config common.ReadParams, headers []common.Header, )
providers/zoho/read.go:30
↓ 3 callersFunctionrecordsFunc
recordsFunc returns the record extractor matching the object's response shape. Every shape resolves to common.ExtractRecordsFromPath — including the b
providers/servicenow/parse.go:67
↓ 3 callersMethodrecordsFunc
recordsFunc returns the records extractor for the given object. All Gusto list endpoints return a bare JSON array at the root (no wrapper object), so
providers/gusto/read.go:228
↓ 3 callersFunctionredactSensitiveRequestHeaders
redactSensitiveRequestHeaders redacts sensitive headers from the given headers.
common/http.go:142
↓ 3 callersFunctionredactSensitiveResponseHeaders
(hdrs []Header)
common/http.go:171
↓ 3 callersMethodremoveSubscriptionsByIDs
( ctx context.Context, identifiers []int, )
providers/connectwise/internal/subscriber/delete.go:44
↓ 3 callersFunctionresponseSchema
(objectName string)
providers/lemlist/supports.go:11
↓ 3 callersMethodrevisionHeader
()
providers/klaviyo/connector.go:78
↓ 3 callersMethodrollbackApexTrigger
rollbackApexTrigger deploys a destructive changes package that removes both the apex trigger and its companion Test_<TriggerName> class so the org is
providers/salesforce/apex.go:478
↓ 3 callersFunctionsanitizeError
sanitizeError removes internal fields like objectWriteTraceId and ids from error objects before returning them to customers.
providers/hubspot/internal/batch/write.go:290
↓ 3 callersMethodsearchCRM
searchCRM is intended for objects outside HubSpot's ObjectAPI. For objects within ObjectAPI, refer to the ReadUsingSearchAPI method. https://developer
providers/hubspot/search.go:112
↓ 3 callersFunctionsendMessage
sendMessage sends a webhookMessageResult to the channel if possible, or discards it if the context is canceled or done. This is useful when the provi
test/utils/testscenario/webhook.go:223
↓ 3 callersMethodsendRecordToSubscriber
sendRecordToSubscriber asynchronously notifies an observer of a storage action. The observer function is invoked in a separate goroutine to prevent bl
memstore/storage.go:724
↓ 3 callersMethodsetBaseURL
(newURL string)
providers/zendesksupport/connector.go:79
↓ 3 callersFunctionstringFromRecord
stringFromRecord pulls a parent-id from RecordData and removes it from the map so it is not echoed back into the request body.
providers/acculynx/write.go:235
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/breakcold/read/read.go:40
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *pd.Connector, objectName string, fields []string)
test/podium/read/main.go:43
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/loxo/read/main.go:40
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *gr.Connector, objectName string, fields []string)
test/groove/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objectName string, fields []string)
test/jobber/read/read.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objectName string)
test/pinterest/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *zc.Connector, objectName string, fields []string)
test/zendeskchat/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *gor.Connector, objectName string, fields []string)
test/gorgias/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ll.Connector, objectName string, fields []string)
test/lemlist/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *fd.Connector, objectName string, fields []string)
test/freshdesk/read/main.go:43
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *dr.Connector, objectName string, fields []string)
test/drift/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *mx.Connector, objectName string, fields []string)
test/mixmax/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/highlevelstandard/read/main.go:40
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *fr.Connector, objectName string, fields []string)
test/front/read/main.go:43
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/highlevelwhitelabel/read/main.go:40
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *dx.Connector, objectName string, fields []string)
test/dixa/read/main.go:42
↓ 3 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objectName string)
test/blackbaud/read/read.go:42
↓ 3 callersMethodtoCommonEvent
ToCommonEvent converts a provider event back to common event type.
providers/salesloft/subscribe.go:504
↓ 3 callersFunctiontoModuleEventName
toModuleEventName converts a common event type into one or more Salesloft module events using the mapping.
providers/salesloft/subscribe.go:406
↓ 3 callersMethodupdateExistingSubscriptions
updateExistingSubscriptions reconciles the per-object Salesforce configuration for objects that remain subscribed across an UpdateSubscription call (i
providers/salesforce/subscribe.go:1103
↓ 2 callersMethodAdd
Add will add a list of values to the unique set. Repetitions will be omitted.
internal/datautils/set.go:32
↓ 2 callersMethodAddDefaults
(defaults ...CatalogVariable)
common/substitutions/catalogreplacer/catalogVariable.go:47
↓ 2 callersMethodAddEntry
(def *CreateDefinition)
providers/hubspot/internal/associations/models.go:67
↓ 2 callersMethodApexTriggerExists
ApexTriggerExists reports whether an apex trigger with the given Name exists in Salesforce. Implementation queries the Tooling API ApexTrigger sobject
providers/salesforce/apex.go:102
↓ 2 callersMethodApplyToRequest
(vals *url.Values)
common/query.go:34
↓ 2 callersMethodArrayToObjects
(arr []*ajson.Node)
internal/jsonquery/converters.go:39
↓ 2 callersMethodBatchCreate
BatchCreate creates many associations from one object type to many other object types. Each association is represented as a pair of identifiers: on
providers/hubspot/internal/associations/create.go:23
↓ 2 callersMethodBulkDelete
BulkDelete launches async Bulk Job to delete records. https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/create_job.htm Aft
providers/salesforce/bulk-delete.go:18
↓ 2 callersMethodBulkRead
BulkRead launches async Query job for bulk reading. It is similar to BulkQuery. Check it for more info. Usage example: BulkRead(ctx, common.ReadPar
providers/salesforce/bulk-read.go:19
↓ 2 callersFunctionCheckError
(t *testing.T, name string, expectedErr error, actualErr error)
test/utils/testutils/checks.go:60
↓ 2 callersFunctionCombineContext
CombineContext is the context-aware version of Combine. Identical to Combine but with context support, allowing cancellation while waiting. Behavior
internal/future/future.go:733
↓ 2 callersFunctionCombineContextWithExecutor
CombineContextWithExecutor combines multiple futures with context support using a custom executor. This is identical to CombineContext but allows you
internal/future/future.go:748
↓ 2 callersFunctionComparatorSubsetRead
ComparatorSubsetRead ensures that a subset of fields or raw data is present in the response. This is convenient for cases where the returned data is l
test/utils/testconn/comparator.go:31
↓ 2 callersMethodCompareWithoutResultArg
( actual, expected *common.SubscriptionResult, )
test/utils/mockutils/subscriptionResult.go:12
↓ 2 callersFunctionConstructDestructiveApexTrigger
ConstructDestructiveApexTrigger builds a zipped destructive changes package to delete the trigger, its handler class, and its companion test class fro
providers/salesforce/internal/crm/metadata/apextrigger.go:167
↓ 2 callersMethodConvertStrMap
()
common/substitutions/registry.go:17
↓ 2 callersFunctionCreateApiKeyClient
( ctx context.Context, info *providers.ProviderInfo, opts ApiKeyOptions, )
examples/utils/api_key.go:16
↓ 2 callersMethodCreateEventChannelMember
CreateEventChannelMember nolint: lll https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_platformeventc
providers/salesforce/events.go:190
↓ 2 callersMethodCreateEventRelayConfig
CreateEventRelayConfig . nolint: lll https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_eventrelayconf
providers/salesforce/events.go:281
↓ 2 callersMethodCreateNamedCredential
CreateNamedCredential nolint: lll https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_namedcredential.h
providers/salesforce/events.go:367
↓ 2 callersFunctionCreateOAuth2AuthorizationCodeClient
( ctx context.Context, info *providers.ProviderInfo, opts OAuth2AuthCodeOptions, )
examples/utils/oauth2.go:25
↓ 2 callersMethodCreateProxyOAuth2AuthCode
(ctx context.Context)
scripts/utils/proxyserv/oauthAuthCode.go:12
↓ 2 callersMethodCustomFieldExists
CustomFieldExists reports whether a custom field with the given API name (must include the __c suffix) exists on the named Salesforce object. Impleme
providers/salesforce/events.go:476
↓ 2 callersFunctionCycleUntilComplete
CycleUntilComplete will invoke producer function every interval. Once the producer gives non-nil value the cycle will come to an end. Either due to co
test/utils/retry.go:14
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/breakcold/delete/delete.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/snapchatads/delete/main.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/loxo/delete/main.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/pinterest/delete/main.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/linkedin/ads/delete/delete.go:79
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/lever/delete/main.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/instantlyai/delete/delete.go:83
↓ 2 callersFunctionDelete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/blackbaud/delete/main.go:83
↓ 2 callersMethodDelete
Delete removes a record.
memstore/connector.go:381
↓ 2 callersMethodDelete
(ctx context.Context, url string, headers ...Header, )
common/http.go:267
↓ 2 callersMethodDelete
(ctx context.Context, url string, headers ...Header)
common/json.go:129
↓ 2 callersMethodDeleteEventRelayConfig
(ctx context.Context, cfgId string)
providers/salesforce/events.go:299
↓ 2 callersMethodDeleteMetadata
(ctx context.Context, params *common.DeleteMetadataParams)
connectors.go:149
↓ 2 callersMethodDeleteMetadata
( ctx context.Context, params *common.DeleteMetadataParams, )
providers/salesforce/metadata.go:25
↓ 2 callersMethodDeployMetadataZipWithTests
DeployMetadataZipWithTests initiates a deploy of a zip package using the supplied Salesforce Metadata API testLevel. When testLevel is RunSpecifiedTes
providers/salesforce/apex.go:286
↓ 2 callersFunctionDeriveSchemasFromStructs
DeriveSchemasFromStructs converts Go structs to JSON Schema bytes for use with NewConnector. This function provides a developer-friendly API for defi
memstore/schema.go:204
↓ 2 callersMethodDestinationResourceName
()
providers/salesforce/events.go:387
↓ 2 callersMethodEmptySubscriptionParams
EmptySubscriptionParams returns an empty, provider-specific common.SubscribeParams instance. The returned common.SubscribeParams has the Request fiel
connectors.go:304
↓ 2 callersMethodEmptySubscriptionResult
EmptySubscriptionResult returns an empty, provider-specific common.SubscriptionResult instance. The returned common.SubscriptionResult has the Result
connectors.go:310
← previousnext →1,101–1,200 of 8,532, ranked by callers