Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/amp-labs/connectors
/ functions
Functions
8,532 in github.com/amp-labs/connectors
⨍
Functions
8,532
◇
Types & classes
1,636
↓ 3 callers
Function
isZeroValue
isZeroValue checks if the expression represents a zero value.
tools/linters/modulelinter/modulelinter.go:457
↓ 3 callers
Function
jsonPostRequest
jsonPostRequest builds an HTTP POST request with a JSON body.
providers/slack/utils.go:13
↓ 3 callers
Function
mapObjectAlias
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 callers
Function
matchObjectNameToEndpointPath
(objectName string)
providers/pinterest/handlers.go:61
↓ 3 callers
Function
mustParseSchema
mustParseSchema is a helper function to parse JSON schema into InputSchema
test/memstore/connector.go:12
↓ 3 callers
Function
mustParseXML
(t *testing.T, xml string)
common/xquery/equality_test.go:162
↓ 3 callers
Function
newJSONResponse
(t *testing.T, body string)
providers/netsuite/internal/restlet/write_test.go:106
↓ 3 callers
Function
newRequestWithQuery
helper: create a request with the given ?q=... parameter
test/utils/mockutils/mockcond/permutation_test.go:81
↓ 3 callers
Function
newSnowflakeObjects
(paramsMap map[string]string)
providers/snowflake/objects.go:187
↓ 3 callers
Function
newStarRulePathResolver
( endpoints []string, pathMatchingCallback func(matched bool) bool, )
tools/fileconv/api3/strategy.go:99
↓ 3 callers
Function
nextPageFromPageCounter
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 callers
Function
nextPageFunc
(node *ajson.Node)
providers/salesforce/internal/pardot/incremental.go:28
↓ 3 callers
Function
nullInt64ToPtr
(ni sql.NullInt64)
providers/snowflake/metadata.go:181
↓ 3 callers
Method
objectURL
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 callers
Function
offsetPaginationOf
(objectName string)
providers/servicenow/parse.go:113
↓ 3 callers
Function
pagePaginationOf
(objectName string)
providers/servicenow/parse.go:172
↓ 3 callers
Function
pairedDateWindow
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 callers
Function
parseReadSessionToken
============================================================================= Token serialization ====================================================
providers/bigquery/read.go:840
↓ 3 callers
Function
parseSearchResults
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 callers
Method
performGetRequest
( ctx context.Context, url *urlbuilder.URL, )
providers/dynamicscrm/metadataRepository.go:176
↓ 3 callers
Function
prepareContactWriteRecordData
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 callers
Function
prettyPrint
(v any)
test/zoho/subscribe/subscribe.go:124
↓ 3 callers
Method
read
(ctx context.Context, config common.ReadParams, headers []common.Header, )
providers/zoho/read.go:30
↓ 3 callers
Function
recordsFunc
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 callers
Method
recordsFunc
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 callers
Function
redactSensitiveRequestHeaders
redactSensitiveRequestHeaders redacts sensitive headers from the given headers.
common/http.go:142
↓ 3 callers
Function
redactSensitiveResponseHeaders
(hdrs []Header)
common/http.go:171
↓ 3 callers
Method
removeSubscriptionsByIDs
( ctx context.Context, identifiers []int, )
providers/connectwise/internal/subscriber/delete.go:44
↓ 3 callers
Function
responseSchema
(objectName string)
providers/lemlist/supports.go:11
↓ 3 callers
Method
revisionHeader
()
providers/klaviyo/connector.go:78
↓ 3 callers
Method
rollbackApexTrigger
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 callers
Function
sanitizeError
sanitizeError removes internal fields like objectWriteTraceId and ids from error objects before returning them to customers.
providers/hubspot/internal/batch/write.go:290
↓ 3 callers
Method
searchCRM
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 callers
Function
sendMessage
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 callers
Method
sendRecordToSubscriber
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 callers
Method
setBaseURL
(newURL string)
providers/zendesksupport/connector.go:79
↓ 3 callers
Function
stringFromRecord
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 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/breakcold/read/read.go:40
↓ 3 callers
Function
testRead
(ctx context.Context, conn *pd.Connector, objectName string, fields []string)
test/podium/read/main.go:43
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/loxo/read/main.go:40
↓ 3 callers
Function
testRead
(ctx context.Context, conn *gr.Connector, objectName string, fields []string)
test/groove/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objectName string, fields []string)
test/jobber/read/read.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objectName string)
test/pinterest/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *zc.Connector, objectName string, fields []string)
test/zendeskchat/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *gor.Connector, objectName string, fields []string)
test/gorgias/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ll.Connector, objectName string, fields []string)
test/lemlist/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *fd.Connector, objectName string, fields []string)
test/freshdesk/read/main.go:43
↓ 3 callers
Function
testRead
(ctx context.Context, conn *dr.Connector, objectName string, fields []string)
test/drift/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *mx.Connector, objectName string, fields []string)
test/mixmax/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/highlevelstandard/read/main.go:40
↓ 3 callers
Function
testRead
(ctx context.Context, conn *fr.Connector, objectName string, fields []string)
test/front/read/main.go:43
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objName string, fields []string)
test/highlevelwhitelabel/read/main.go:40
↓ 3 callers
Function
testRead
(ctx context.Context, conn *dx.Connector, objectName string, fields []string)
test/dixa/read/main.go:42
↓ 3 callers
Function
testRead
(ctx context.Context, conn *ap.Connector, objectName string)
test/blackbaud/read/read.go:42
↓ 3 callers
Method
toCommonEvent
ToCommonEvent converts a provider event back to common event type.
providers/salesloft/subscribe.go:504
↓ 3 callers
Function
toModuleEventName
toModuleEventName converts a common event type into one or more Salesloft module events using the mapping.
providers/salesloft/subscribe.go:406
↓ 3 callers
Method
updateExistingSubscriptions
updateExistingSubscriptions reconciles the per-object Salesforce configuration for objects that remain subscribed across an UpdateSubscription call (i
providers/salesforce/subscribe.go:1103
↓ 2 callers
Method
Add
Add will add a list of values to the unique set. Repetitions will be omitted.
internal/datautils/set.go:32
↓ 2 callers
Method
AddDefaults
(defaults ...CatalogVariable)
common/substitutions/catalogreplacer/catalogVariable.go:47
↓ 2 callers
Method
AddEntry
(def *CreateDefinition)
providers/hubspot/internal/associations/models.go:67
↓ 2 callers
Method
ApexTriggerExists
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 callers
Method
ApplyToRequest
(vals *url.Values)
common/query.go:34
↓ 2 callers
Method
ArrayToObjects
(arr []*ajson.Node)
internal/jsonquery/converters.go:39
↓ 2 callers
Method
BatchCreate
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 callers
Method
BulkDelete
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 callers
Method
BulkRead
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 callers
Function
CheckError
(t *testing.T, name string, expectedErr error, actualErr error)
test/utils/testutils/checks.go:60
↓ 2 callers
Function
CombineContext
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 callers
Function
CombineContextWithExecutor
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 callers
Function
ComparatorSubsetRead
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 callers
Method
CompareWithoutResultArg
( actual, expected *common.SubscriptionResult, )
test/utils/mockutils/subscriptionResult.go:12
↓ 2 callers
Function
ConstructDestructiveApexTrigger
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 callers
Method
ConvertStrMap
()
common/substitutions/registry.go:17
↓ 2 callers
Function
CreateApiKeyClient
( ctx context.Context, info *providers.ProviderInfo, opts ApiKeyOptions, )
examples/utils/api_key.go:16
↓ 2 callers
Method
CreateEventChannelMember
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 callers
Method
CreateEventRelayConfig
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 callers
Method
CreateNamedCredential
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 callers
Function
CreateOAuth2AuthorizationCodeClient
( ctx context.Context, info *providers.ProviderInfo, opts OAuth2AuthCodeOptions, )
examples/utils/oauth2.go:25
↓ 2 callers
Method
CreateProxyOAuth2AuthCode
(ctx context.Context)
scripts/utils/proxyserv/oauthAuthCode.go:12
↓ 2 callers
Method
CustomFieldExists
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 callers
Function
CycleUntilComplete
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 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/breakcold/delete/delete.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/snapchatads/delete/main.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/loxo/delete/main.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/pinterest/delete/main.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/linkedin/ads/delete/delete.go:79
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/lever/delete/main.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/instantlyai/delete/delete.go:83
↓ 2 callers
Function
Delete
(ctx context.Context, conn *ap.Connector, payload common.DeleteParams)
test/blackbaud/delete/main.go:83
↓ 2 callers
Method
Delete
Delete removes a record.
memstore/connector.go:381
↓ 2 callers
Method
Delete
(ctx context.Context, url string, headers ...Header, )
common/http.go:267
↓ 2 callers
Method
Delete
(ctx context.Context, url string, headers ...Header)
common/json.go:129
↓ 2 callers
Method
DeleteEventRelayConfig
(ctx context.Context, cfgId string)
providers/salesforce/events.go:299
↓ 2 callers
Method
DeleteMetadata
(ctx context.Context, params *common.DeleteMetadataParams)
connectors.go:149
↓ 2 callers
Method
DeleteMetadata
( ctx context.Context, params *common.DeleteMetadataParams, )
providers/salesforce/metadata.go:25
↓ 2 callers
Method
DeployMetadataZipWithTests
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 callers
Function
DeriveSchemasFromStructs
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 callers
Method
DestinationResourceName
()
providers/salesforce/events.go:387
↓ 2 callers
Method
EmptySubscriptionParams
EmptySubscriptionParams returns an empty, provider-specific common.SubscribeParams instance. The returned common.SubscribeParams has the Request fiel
connectors.go:304
↓ 2 callers
Method
EmptySubscriptionResult
EmptySubscriptionResult returns an empty, provider-specific common.SubscriptionResult instance. The returned common.SubscriptionResult has the Result
connectors.go:310
← previous
next →
1,101–1,200 of 8,532, ranked by callers