MCPcopy Create free account

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

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

↓ 2 callersMethodWithIDs
(identifiers []string)
providers/salesforce/internal/crm/core/soql.go:66
↓ 2 callersFunctionWithLoggerEnabled
WithLoggerEnabled returns a new context with the logger explicitly enabled or disabled. If the key is not set, the logger will be enabled by default.
common/logging/logging.go:16
↓ 2 callersFunctionWithMetadata
WithMetadata sets authentication metadata expected by connector.
providers/docusign/params.go:55
↓ 2 callersFunctionWithMetadata
(metadata map[string]string)
providers/dynamicscrm/params.go:68
↓ 2 callersFunctionWithOAuthDebug
WithOAuthDebug sets a debug function to be called on every request and response, after the response has been received from the downstream API.
common/oauth.go:85
↓ 2 callersFunctionWithOAuthIsUnauthorizedHandler
WithOAuthIsUnauthorizedHandler sets the function to call whenever the response is unauthorized (not necessarily 401). This is useful for handling the
common/oauth.go:105
↓ 2 callersFunctionWithOAuthUnauthorizedHandler
WithOAuthUnauthorizedHandler sets the function to call whenever the response is 401 unauthorized. This is useful for handling the case where the serve
common/oauth.go:94
↓ 2 callersFunctionWithQueryParamClient
WithQueryParamClient sets the http client to use for the connector. Its usage is optional.
common/query.go:125
↓ 2 callersFunctionWithRawSchemas
WithRawSchemas configures the connector with raw JSON schema definitions. The schemas are provided as byte slices that will be parsed during connector
memstore/params.go:72
↓ 2 callersFunctionWithRequestModifier
WithRequestModifier adds a request modifier to the context. The request modifier will be called with the request before it is sent. This allows the ca
common/request.go:19
↓ 2 callersFunctionWithVerboseLogging
WithVerboseLogging returns a new context with the logger configured to be verbose or not. If the key is not set, the logger will *NOT* be verbose by d
common/logging/logging.go:27
↓ 2 callersFunctionWithWorkspace
WithWorkspace sets the regional API base URL for the Gong connector. This is extracted from the OAuth token response field "api_base_url". US tenants
providers/gong/params.go:27
↓ 2 callersMethodWorkspace
()
providers/salesforce/subscriptionEvent.go:160
↓ 2 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/linkedin/platform/write/write.go:91
↓ 2 callersFunctionaddAcceptXMLHeader
(headers []Header)
common/xml.go:114
↓ 2 callersFunctionaddFieldForAssociation
addFieldForAssociation adds a field or subquery for an associated object.
providers/salesforce/internal/crm/associations/select.go:42
↓ 2 callersFunctionaddMeetingsQueryParams
addMeetingsQueryParams adds query parameters to enrich the meetings API response with additional data fields. These parameters ensure we retrieve comp
providers/fathom/utils.go:10
↓ 2 callersFunctionaddQueryParams
(url *urlbuilder.URL, params common.ReadParams, page int64)
providers/aha/handlers.go:103
↓ 2 callersFunctionadvanceOffset
(u *urlbuilder.URL, paramName string, increment int)
providers/acculynx/read.go:502
↓ 2 callersFunctionanalyzeValue
(value any)
providers/procore/utils.go:80
↓ 2 callersFunctionanalyzeValue
(value any)
providers/happyfox/handlers.go:77
↓ 2 callersFunctionanalyzeValue
(value any)
providers/acuityscheduling/utils.go:9
↓ 2 callersMethodapolloMarshaledData
(objectName string)
providers/apollo/parse.go:124
↓ 2 callersFunctionapplyEventsQueryParams
applyEventsQueryParams sets the events.list query params shared by the primary-calendar (buildReadURL) and all-calendars (buildEventsURLForCalendar) r
providers/google/internal/calendar/operations.go:82
↓ 2 callersFunctionapplyHistoryDateWindow
applyHistoryDateWindow pushes Since/Until into AccuLynx's server-side startDate/endDate filter for /jobs/{id}/history. Without this, an unbounded read
providers/acculynx/incremental.go:132
↓ 2 callersFunctionapplyIgnoreRules
(entity any, rules []FieldIgnoreRule)
test/utils/mockutils/mockcond/body.go:128
↓ 2 callersFunctionapplyIncrementalQuery
(url *urlbuilder.URL, since time.Time)
providers/dynamicsbusiness/requests.go:104
↓ 2 callersFunctionapplyJobsIncrementalFilter
applyJobsIncrementalFilter adds the provider-side ModifiedDate filter to /jobs when Since or Until is set. AccuLynx accepts dates in YYYY-MM-DD format
providers/acculynx/incremental.go:110
↓ 2 callersFunctionapplyPagination
(url *urlbuilder.URL, objectName string, params common.ReadParams)
providers/acculynx/read.go:134
↓ 2 callersMethodarrayFieldName
(objectName string)
providers/acculynx/read.go:245
↓ 2 callersMethodasMap
()
providers/housecallPro/subscriptionEvent.go:197
↓ 2 callersFunctionassertMapStringAny
(val any)
providers/outreach/parse.go:192
↓ 2 callersFunctionassertQueryParamPresent
(t *testing.T, u *urlbuilder.URL, key string)
providers/acculynx/incremental_test.go:136
↓ 2 callersFunctionassertZipContainsFiles
assertZipContainsFiles verifies that the zip data contains exactly the expected files.
providers/salesforce/internal/crm/metadata/apextrigger_test.go:670
↓ 2 callersFunctionboolPtr
(b bool)
test/salesloft/write-delete/main.go:146
↓ 2 callersMethodbuildDynamicTableQuery
buildDynamicTableQuery builds the SQL query for reading from a dynamic table. Returns the query string and args for prepared statement execution.
providers/snowflake/read.go:360
↓ 2 callersMethodbuildModuleURL
(params common.ReadParams, apiVersion string, objTransformer objectNameTransformer, fldTransformer fieldsTran
providers/zoho/url.go:47
↓ 2 callersFunctionbuildQuotaEnrichedFields
buildQuotaEnrichedFields returns the enriched fields needed for the quota optimization filter expression. The checkbox field must be included as an en
providers/salesforce/subscribe.go:892
↓ 2 callersFunctionbuildQuotaFilterExpression
buildQuotaFilterExpression builds a CDC filter expression for an object based on its quota optimization checkbox field. The expression allows all non-
providers/salesforce/subscribe.go:876
↓ 2 callersMethodbuildReadURL
(config common.ReadParams)
providers/salesloft/read.go:65
↓ 2 callersFunctionbuildRestletURL
(baseURL, scriptURL, scriptId, deployId string)
providers/netsuite/internal/restlet/adapter.go:128
↓ 2 callersMethodbuildStreamQuery
buildStreamQuery builds the SQL query for reading from a stream. Returns the query string and args for prepared statement execution.
providers/snowflake/read.go:330
↓ 2 callersMethodbuildURL
(objectName string, pageSize string)
providers/chilipiper/url.go:10
↓ 2 callersMethodbuildURL
(objectName string)
providers/justcall/handlers.go:140
↓ 2 callersFunctionbuildUpdatedSubscribeResult
buildUpdatedSubscribeResult merges three sources into a single SubscribeResult reflecting current Salesforce state: - prevState's residual ECMs/Trigg
providers/salesforce/subscribe.go:802
↓ 2 callersMethodbulkOperation
( ctx context.Context, params BulkOperationParams, jobBody map[string]any, )
providers/salesforce/bulk.go:326
↓ 2 callersFunctioncallContentSelector
callContentSelector returns the contentSelector used for POST /v2/calls/extensive. parties and media are always requested. content, interaction, and c
providers/gong/params.go:112
↓ 2 callersMethodcallMetaData
callMetaData returns the callData.metaData sub-object, where Gong puts the call identity, workspace, and timing fields.
providers/gong/subscriptionEvent.go:161
↓ 2 callersFunctioncheckErrorInResponse
checkErrorInResponse checks if there are any errors in the GraphQL response.
providers/braintree/errors.go:54
↓ 2 callersFunctioncheckSearchResultsLimit
checkSearchResultsLimit checks if the NextPage token exceeds HubSpot's search results limit. HubSpot's search API returns a 400 error if you try to pa
providers/hubspot/search.go:310
↓ 2 callersFunctionchildElements
(n *xq.Node)
common/xquery/equality.go:154
↓ 2 callersFunctionclaimsChallengeReason
claimsChallengeReason detects CAE (insufficient_claims) and step-up (interaction_required) challenges in WWW-Authenticate. These are not retryable — a
providers/microsoft/errors.go:87
↓ 2 callersFunctioncleanDefinitions
(def string)
scripts/openapi/marketo/metadata/metadata.go:100
↓ 2 callersFunctioncleanTrailingSlashes
(link string)
common/urlbuilder/url.go:245
↓ 2 callersMethodclientIdHeader
()
providers/connectwise/internal/subscriber/strategy.go:57
↓ 2 callersFunctioncompare
(field any, value string)
test/constantcontact/write-delete/main.go:161
↓ 2 callersFunctioncompare
(field any, value string)
test/salesloft/write-delete/main.go:150
↓ 2 callersFunctioncompare
(field any, value string)
test/intercom/write-delete/main.go:171
↓ 2 callersFunctioncompareHTTPURLs
(expected string, actual string, index *int)
test/utils/testconn/comparator.go:343
↓ 2 callersFunctionconstructDefinitions
(file string, length int)
scripts/openapi/marketo/metadata/metadata.go:62
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/breakcold/delete/delete.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/snapchatads/delete/main.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/loxo/delete/main.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/pinterest/delete/main.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/lever/delete/main.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/instantlyai/delete/delete.go:93
↓ 2 callersFunctionconstructResponse
unmarshal the delete response.
test/blackbaud/delete/main.go:93
↓ 2 callersFunctionconstructTestConnector
(serverURL string)
providers/teamleader/read_test.go:82
↓ 2 callersFunctionconstructTestConnector
(server *httptest.Server, moduleID common.ModuleID, metadata map[string]string, )
providers/linkedin/write_test.go:167
↓ 2 callersFunctionconstructTestConnector
(server *httptest.Server)
providers/fourfour/metadata_test.go:108
↓ 2 callersFunctionconstructTestConnector
(serverURL string)
providers/granola/metadata_test.go:210
↓ 2 callersFunctionconstructTestConnector
(serverURL string)
providers/outplay/metadata_test.go:322
↓ 2 callersFunctionconstructTestConnector
(serverURL string)
providers/ringcentral/handlers_test.go:160
↓ 2 callersFunctionconstructTestPlatformConnector
(server *httptest.Server)
providers/linkedin/write_test.go:159
↓ 2 callersFunctionconstructTestReadConnector
(baseURL, companyID string)
providers/gusto/read_test.go:328
↓ 2 callersFunctionconstructURL
(base string, path ...string)
providers/kit/url.go:10
↓ 2 callersFunctionconstructor
(params common.ConnectorParams)
providers/gusto/connector.go:47
↓ 2 callersFunctioncontactReadFieldsQueryForAPI
contactReadFieldsQueryForAPI builds the `fields` query parameter for GET contacts. GetResponse only returns customFieldValues when that property is re
providers/getresponse/custom.go:277
↓ 2 callersFunctionconvertFieldsToDotNotation
convertFieldsToDotNotation converts bracket notation fields to dot notation. Example: $['audit']['createdby'] -> audit.createdby.
providers/sageintacct/utils.go:173
↓ 2 callersFunctionconvertIDToString
convertIDToString converts various ID types to string.
providers/getresponse/handler.go:423
↓ 2 callersFunctionconvertSQLValue
convertSQLValue converts SQL types to standard Go types.
providers/snowflake/utils.go:167
↓ 2 callersFunctioncreateAndFindRecord
( ctx context.Context, conn ConnectorCRUD, objectName string, createPayload CP, suite CRDTestSuite, )
test/utils/testscenario/crd.go:94
↓ 2 callersFunctioncreateClientAuthParams
(provider string, registry scanning.Registry)
scripts/utils/proxyserv/common.go:36
↓ 2 callersFunctioncreateKeyNotFoundErr
(key string)
internal/jsonquery/errors.go:32
↓ 2 callersFunctioncreateOAuth2AuthCodeHTTPClient
( //nolint:ireturn ctx context.Context, client *http.Client, dbg bool, unauth UnauthorizedHandler, isUnau
providers/utils.go:506
↓ 2 callersFunctioncreateObject
( ctx context.Context, conn connectors.WriteConnector, objectName string, payload *CP, )
test/utils/testscenario/crud.go:197
↓ 2 callersFunctioncreateParams
(opts []Option)
tools/fileconv/api3/parameters.go:147
↓ 2 callersFunctioncreateProviderCreds
( providerName string, withRequiredAccessToken bool, filePath string, customFields []Field, )
common/scanning/credscanning/provider.go:52
↓ 2 callersFunctioncreateQueryStringHash
createQueryStringHash computes the SHA256 hash of the canonical request string.
providers/atlassian/jwt.go:63
↓ 2 callersMethodcreateSubscription
(ctx context.Context, request *Request, subscriptionEvents datautils.Map[common.ObjectName, common.ObjectEve
providers/connectwise/internal/subscriber/create.go:33
↓ 2 callersFunctioncreateUnprocessableItem
(identifier string)
providers/hubspot/internal/batch/write.go:322
↓ 2 callersFunctioncustomFieldDisplayName
(fieldName string)
providers/salesforce/subscribe.go:913
↓ 2 callersMethodcustomMarshaller
getMarshaledData retrieves records and unnests the custom fields of apollo custom objects.
providers/apollo/parse.go:88
↓ 2 callersFunctiondeepCopyRecords
deepCopyRecords creates independent copies of a slice of records. Each record in the slice is deep copied to ensure modifications to the returned slic
memstore/storage.go:338
↓ 2 callersMethoddefaultModuleOrRoot
()
providers/utils.go:250
↓ 2 callersFunctiondeleteByID
(ctx context.Context, conn *revenuecat.Connector, objectName, recordID string)
test/revenuecat/customers/write-delete/main.go:76
↓ 2 callersFunctiondeleteByID
(ctx context.Context, conn *revenuecat.Connector, objectName, recordID string)
test/revenuecat/apps/write-delete/main.go:103
↓ 2 callersFunctiondeleteByID
(ctx context.Context, conn *revenuecat.Connector, objectName, recordID string)
test/revenuecat/products/write-delete/main.go:113
↓ 2 callersFunctiondeleteByID
(ctx context.Context, conn *revenuecat.Connector, objectName, recordID string)
test/revenuecat/entitlements/write-delete/main.go:99
↓ 2 callersFunctiondeleteByID
(ctx context.Context, conn *revenuecat.Connector, objectName, recordID string)
test/revenuecat/offerings/write-delete/main.go:99
← previousnext →1,401–1,500 of 8,532, ranked by callers