MCPcopy Create free account

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

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

↓ 2 callersFunctionNewConnector
(params common.ConnectorParams)
providers/braze/connector.go:36
↓ 2 callersFunctionNewConnector
(params common.ConnectorParams)
providers/aha/connector.go:28
↓ 2 callersFunctionNewConnector
(opts ...Option)
providers/docusign/connector.go:14
↓ 2 callersFunctionNewConnector
(params common.ConnectorParams)
providers/blueshift/connector.go:29
↓ 2 callersFunctionNewConnector
(params common.ConnectorParams)
providers/dixa/connector.go:47
↓ 2 callersFunctionNewConnector
(params common.ConnectorParams)
providers/clickup/connector.go:25
↓ 2 callersFunctionNewConnector
(ctx context.Context)
test/g2/connector.go:13
↓ 2 callersFunctionNewConnector
(ctx context.Context)
test/talkdesk/connector.go:16
↓ 2 callersFunctionNewConnectorForProvider
NewConnectorForProvider creates a new Google connector under the given provider name. This allows twin providers like GoogleWorkspaceDelegation to reu
providers/google/connector.go:56
↓ 2 callersFunctionNewConnectorForProvider
NewConnectorForProvider creates a new Microsoft connector under the given provider name. This allows twin providers like MicrosoftClientCredentials to
providers/microsoft/connector.go:64
↓ 2 callersFunctionNewDelegateReader
NewDelegateReader creates a new DelegateReader with the provided read function.
internal/components/reader/delegate.go:20
↓ 2 callersFunctionNewDemoConnector
NewDemoConnector creates a new Gusto connector for the sandbox/demo environment.
providers/gusto/connector.go:43
↓ 2 callersFunctionNewExtendedMetadata
NewExtendedMetadata constructs empty Metadata. To populate it with data use Metadata.Add method. Metadata may include custom properties describing obj
internal/staticschema/core.go:18
↓ 2 callersFunctionNewJSONProviderCredentials
NewJSONProviderCredentials reads JSON fields that must be present for a provider. It performs validation and will tell you fields that are expected fo
common/scanning/credscanning/provider.go:31
↓ 2 callersFunctionNewLevelFileLocator
NewLevelFileLocator creates locator, which is capable of resolving full path to files located relative to the call stack.
tools/fileconv/files.go:36
↓ 2 callersFunctionNewModelURLRegistry
()
tools/scrapper/models.go:36
↓ 2 callersFunctionNewPayloadItem
(record common.Record)
providers/hubspot/internal/batch/create.go:88
↓ 2 callersFunctionNewProviderContext
( provider providers.Provider, module common.ModuleID, workspace string, metadata map[string]string, )
internal/components/provider.go:20
↓ 2 callersFunctionNewReadPayload
(params common.ReadParams)
providers/aws/internal/core/requests.go:26
↓ 2 callersFunctionNewSandboxConnector
(params common.ConnectorParams)
providers/procore/connector.go:44
↓ 2 callersFunctionNewSandboxConnector
(params common.ConnectorParams)
providers/quickbooks/connector.go:61
↓ 2 callersFunctionNewStrategy
(hubspotCRMClient *common.JSONHTTPClient, providerInfo *providers.ProviderInfo)
providers/hubspot/internal/associations/strategy.go:15
↓ 2 callersFunctionNewStrategy
NewStrategy constructs a Strategy with required dependencies.
providers/connectwise/internal/subscriber/strategy.go:29
↓ 2 callersFunctionNewStrategy
NewStrategy constructs a Strategy with required dependencies.
providers/microsoft/internal/subscriber/strategy.go:33
↓ 2 callersFunctionNewVerifier
NewVerifier constructs an event message verifier. The empty signingSecret won't trigger a failure to preserve backward compatibility. However, no even
providers/slack/internal/webhook/verifier.go:30
↓ 2 callersMethodNonNil
NonNil adds a non-nil marker (byte value 1) to the hash. Used to explicitly represent non-nil values in the hash computation.
memstore/hashing.go:69
↓ 2 callersMethodObserve
(tok *oauth2.Token)
common/oauth.go:372
↓ 2 callersMethodOrigin
()
common/urlbuilder/url.go:142
↓ 2 callersMethodParent
()
common/xquery/queries.go:78
↓ 2 callersMethodParseJSON
ParseJSON selects a template, populates it, and returns the result. If the error response is concise and clear, it’s used directly; otherwise, the ent
common/interpreter/formatSwitch.go:31
↓ 2 callersFunctionParseJSONPath
ParseJSONPath splits a JSONPath-like expression into path tokens. Supported tokens are object keys in bracket form and array wildcards: $['payload'
common/readhelper/selector.go:105
↓ 2 callersMethodPost
Post makes a POST request to the given URL and returns the response body as a JSON object. ReqBody must be JSON-serializable. If it is not, an error i
common/json.go:78
↓ 2 callersFunctionPrintObjectsWithMultipleArrays
()
tools/fileconv/api3/stats.go:22
↓ 2 callersFunctionPrintObjectsWithNoArrays
()
tools/fileconv/api3/stats.go:42
↓ 2 callersMethodProvider
()
providers/stripe/connector.go:47
↓ 2 callersMethodProvider
Provider returns the connector provider. For twin providers such as salesforceJWT that reuse this implementation with a different auth scheme, this re
providers/salesforce/connector.go:138
↓ 2 callersFunctionQueryLoadableHTML
QueryLoadableHTML this method can panic. Uses browser internally to wait for all HTML parts to be fully loaded.
tools/scrapper/utils.go:22
↓ 2 callersMethodRawEventName
()
providers/housecallPro/subscriptionEvent.go:133
↓ 2 callersMethodRawEventName
()
providers/hubspot/subscriptionEvent.go:110
↓ 2 callersMethodRawEventName
()
providers/slack/internal/webhook/message.go:48
↓ 2 callersFunctionReadCatalog
ReadCatalog is used to get the catalog.
providers/utils.go:68
↓ 2 callersFunctionRegistryValueToString
(value V)
common/substitutions/registry.go:36
↓ 2 callersFunctionRetrieveInstanceTimezone
RetrieveInstanceTimezone queries a NetSuite instance for its timezone using SuiteQL. Exported so the M2M connector can reuse this without duplicating
providers/netsuite/authmetadata.go:64
↓ 2 callersMethodRun
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-query_test.go:108
↓ 2 callersMethodRun
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-write_test.go:214
↓ 2 callersMethodRun
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-delete_test.go:70
↓ 2 callersMethodRunEventRelay
RunEventRelay nolint: lll https://developer.salesforce.com/docs/atlas.en-us.api_tooling.meta/api_tooling/tooling_api_objects_eventrelayconfig.htm?q=Ev
providers/salesforce/events.go:306
↓ 2 callersMethodSaveIndex
(index *ModelURLRegistry)
tools/scrapper/files.go:46
↓ 2 callersFunctionSegmentSubscriptionEvents
SegmentSubscriptionEvents compares previous (existing) and new (desired) object subscription events and categorizes them into EventSegments based on t
common/subscriptionhelper/event-segments.go:43
↓ 2 callersFunctionSeparateCamelCaseWords
SeparateCamelCaseWords converts camelCase or PascalCase into space-separated words by inserting a space before each uppercase letter that follows a lo
common/naming/formatting.go:47
↓ 2 callersMethodSetErrorHandler
(handler common.ErrorHandler)
internal/components/transport.go:75
↓ 2 callersMethodShallowCopy
ShallowCopy creates a shallow copy of the map. It copies the top-level keys and values, but does not clone nested or referenced objects. Use this when
internal/datautils/maps.go:31
↓ 2 callersMethodString
()
common/printable.go:142
↓ 2 callersMethodString
()
common/urlbuilder/url.go:150
↓ 2 callersFunctionStructToMap
StructToMap convert a struct to a map of string to any.
internal/datautils/maps.go:151
↓ 2 callersMethodSubscribe
Subscribe creates a Gmail watch subscription for the requested objects. The Gmail watch API (users.watch) accepts a single call with a set of label I
providers/google/internal/mail/subscribe.go:144
↓ 2 callersMethodSubsetData
SubsetData checks that expected WriteResult.Data is a subset of actual WriteResult.Data other fields are strictly compared.
test/utils/mockutils/writeResult.go:16
↓ 2 callersMethodSubsetFields
SubsetFields checks that expected ReadResult.Fields is a subset of actual ReadResult.Fields
test/utils/mockutils/readResult.go:79
↓ 2 callersFunctionToAnySlice
ToAnySlice converts a slice of any type T into a slice of empty interfaces ([]any). It preserves the length and order of the input slice, boxing each
internal/goutils/utils.go:36
↓ 2 callersMethodToMetadataMap
()
providers/snowflake/objects.go:86
↓ 2 callersMethodToWriteResult
()
providers/hubspot/internal/batch/write.go:362
↓ 2 callersMethodToken
Token creates a signed JWT assertion and exchanges it for an access token.
providers/salesforce/jwt/jwt.go:144
↓ 2 callersMethodTokenWithContext
TokenWithContext returns a token or an error. Token must be safe for concurrent use by multiple goroutines. The returned Token must not be modified. S
common/oauth.go:24
↓ 2 callersMethodTruncate
(size int64)
common/printable.go:303
↓ 2 callersMethodTypedSubscriptionResult
TypedSubscriptionResult extracts and casts subscription.Result into the concrete output type O. It provides a safe way to recover the typed result fr
internal/components/subscriptions.go:66
↓ 2 callersMethodUnmarshalJSON
nolint:cyclop
common/xml.go:194
↓ 2 callersMethodUnsubscribe
Unsubscribe removes an active subscription by its ID. Parameters: - id: The unique identifier of the subscription to remove Returns an error if no s
memstore/storage.go:215
↓ 2 callersMethodValidateParams
(withRequiredFields bool)
common/validation.go:38
↓ 2 callersMethodWithApiKeyQueryParamClient
WithApiKeyQueryParamClient option sets up client that utilises API Key authentication. Passed via Query Param.
common/paramsbuilder/client.go:90
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/apollo/params.go:47
↓ 2 callersFunctionWithAuthenticatedClient
WithAuthenticatedClient configures the connector with a pre-authenticated HTTP client.
providers/zoho/params.go:46
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/chilipiper/params.go:46
↓ 2 callersFunctionWithAuthenticatedClient
WithAuthenticatedClient sets the http client to use for the connector. Its usage is optional.
providers/closecrm/params.go:46
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/attio/params.go:52
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/asana/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/constantcontact/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/pipedrive/params.go:46
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/salesloft/params.go:51
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/instantly/params.go:52
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/freshdesk/params.go:54
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/customerapp/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/gong/params.go:59
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/outreach/params.go:44
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/iterable/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/kit/params.go:49
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/klaviyo/params.go:45
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/keap/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/intercom/params.go:49
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/stripe/params.go:53
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/smartlead/params.go:47
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/zoom/params.go:48
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/dynamicscrm/params.go:56
↓ 2 callersFunctionWithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/marketo/params.go:56
↓ 2 callersFunctionWithClient
(ctx context.Context, client *http.Client, config *clientcredentials.Config, )
providers/marketo/params.go:39
↓ 2 callersFunctionWithClient
WithClient wraps an HTTP client in a JSONHTTPClient.
memstore/params.go:56
↓ 2 callersFunctionWithCustomDynamicHeaders
WithCustomDynamicHeaders sets a function that will be called on every request to get additional headers to use. Use this for things like time-based to
common/custom.go:90
↓ 2 callersFunctionWithCustomUnauthorizedHandler
WithCustomUnauthorizedHandler sets the function to call whenever the response is 401 unauthorized. This is useful for handling the case where the serv
common/custom.go:66
↓ 2 callersFunctionWithHeaderIsUnauthorizedHandler
WithHeaderIsUnauthorizedHandler sets the function to call whenever the response is unauthorized (not necessarily 401). This is useful for handling the
common/header.go:72
↓ 2 callersFunctionWithHeaderUnauthorizedHandler
WithHeaderUnauthorizedHandler sets the function to call whenever the response is 401 unauthorized. This is useful for handling the case where the serv
common/header.go:60
↓ 2 callersFunctionWithHeaders
WithHeaders sets the headers to use for the connector. Its usage is optional.
common/header.go:51
← previousnext →1,301–1,400 of 8,532, ranked by callers