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
↓ 2 callers
Function
NewConnector
(params common.ConnectorParams)
providers/braze/connector.go:36
↓ 2 callers
Function
NewConnector
(params common.ConnectorParams)
providers/aha/connector.go:28
↓ 2 callers
Function
NewConnector
(opts ...Option)
providers/docusign/connector.go:14
↓ 2 callers
Function
NewConnector
(params common.ConnectorParams)
providers/blueshift/connector.go:29
↓ 2 callers
Function
NewConnector
(params common.ConnectorParams)
providers/dixa/connector.go:47
↓ 2 callers
Function
NewConnector
(params common.ConnectorParams)
providers/clickup/connector.go:25
↓ 2 callers
Function
NewConnector
(ctx context.Context)
test/g2/connector.go:13
↓ 2 callers
Function
NewConnector
(ctx context.Context)
test/talkdesk/connector.go:16
↓ 2 callers
Function
NewConnectorForProvider
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 callers
Function
NewConnectorForProvider
NewConnectorForProvider creates a new Microsoft connector under the given provider name. This allows twin providers like MicrosoftClientCredentials to
providers/microsoft/connector.go:64
↓ 2 callers
Function
NewDelegateReader
NewDelegateReader creates a new DelegateReader with the provided read function.
internal/components/reader/delegate.go:20
↓ 2 callers
Function
NewDemoConnector
NewDemoConnector creates a new Gusto connector for the sandbox/demo environment.
providers/gusto/connector.go:43
↓ 2 callers
Function
NewExtendedMetadata
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 callers
Function
NewJSONProviderCredentials
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 callers
Function
NewLevelFileLocator
NewLevelFileLocator creates locator, which is capable of resolving full path to files located relative to the call stack.
tools/fileconv/files.go:36
↓ 2 callers
Function
NewModelURLRegistry
()
tools/scrapper/models.go:36
↓ 2 callers
Function
NewPayloadItem
(record common.Record)
providers/hubspot/internal/batch/create.go:88
↓ 2 callers
Function
NewProviderContext
( provider providers.Provider, module common.ModuleID, workspace string, metadata map[string]string, )
internal/components/provider.go:20
↓ 2 callers
Function
NewReadPayload
(params common.ReadParams)
providers/aws/internal/core/requests.go:26
↓ 2 callers
Function
NewSandboxConnector
(params common.ConnectorParams)
providers/procore/connector.go:44
↓ 2 callers
Function
NewSandboxConnector
(params common.ConnectorParams)
providers/quickbooks/connector.go:61
↓ 2 callers
Function
NewStrategy
(hubspotCRMClient *common.JSONHTTPClient, providerInfo *providers.ProviderInfo)
providers/hubspot/internal/associations/strategy.go:15
↓ 2 callers
Function
NewStrategy
NewStrategy constructs a Strategy with required dependencies.
providers/connectwise/internal/subscriber/strategy.go:29
↓ 2 callers
Function
NewStrategy
NewStrategy constructs a Strategy with required dependencies.
providers/microsoft/internal/subscriber/strategy.go:33
↓ 2 callers
Function
NewVerifier
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 callers
Method
NonNil
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 callers
Method
Observe
(tok *oauth2.Token)
common/oauth.go:372
↓ 2 callers
Method
Origin
()
common/urlbuilder/url.go:142
↓ 2 callers
Method
Parent
()
common/xquery/queries.go:78
↓ 2 callers
Method
ParseJSON
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 callers
Function
ParseJSONPath
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 callers
Method
Post
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 callers
Function
PrintObjectsWithMultipleArrays
()
tools/fileconv/api3/stats.go:22
↓ 2 callers
Function
PrintObjectsWithNoArrays
()
tools/fileconv/api3/stats.go:42
↓ 2 callers
Method
Provider
()
providers/stripe/connector.go:47
↓ 2 callers
Method
Provider
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 callers
Function
QueryLoadableHTML
QueryLoadableHTML this method can panic. Uses browser internally to wait for all HTML parts to be fully loaded.
tools/scrapper/utils.go:22
↓ 2 callers
Method
RawEventName
()
providers/housecallPro/subscriptionEvent.go:133
↓ 2 callers
Method
RawEventName
()
providers/hubspot/subscriptionEvent.go:110
↓ 2 callers
Method
RawEventName
()
providers/slack/internal/webhook/message.go:48
↓ 2 callers
Function
ReadCatalog
ReadCatalog is used to get the catalog.
providers/utils.go:68
↓ 2 callers
Function
RegistryValueToString
(value V)
common/substitutions/registry.go:36
↓ 2 callers
Function
RetrieveInstanceTimezone
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 callers
Method
Run
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-query_test.go:108
↓ 2 callers
Method
Run
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-write_test.go:214
↓ 2 callers
Method
Run
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-delete_test.go:70
↓ 2 callers
Method
RunEventRelay
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 callers
Method
SaveIndex
(index *ModelURLRegistry)
tools/scrapper/files.go:46
↓ 2 callers
Function
SegmentSubscriptionEvents
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 callers
Function
SeparateCamelCaseWords
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 callers
Method
SetErrorHandler
(handler common.ErrorHandler)
internal/components/transport.go:75
↓ 2 callers
Method
ShallowCopy
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 callers
Method
String
()
common/printable.go:142
↓ 2 callers
Method
String
()
common/urlbuilder/url.go:150
↓ 2 callers
Function
StructToMap
StructToMap convert a struct to a map of string to any.
internal/datautils/maps.go:151
↓ 2 callers
Method
Subscribe
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 callers
Method
SubsetData
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 callers
Method
SubsetFields
SubsetFields checks that expected ReadResult.Fields is a subset of actual ReadResult.Fields
test/utils/mockutils/readResult.go:79
↓ 2 callers
Function
ToAnySlice
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 callers
Method
ToMetadataMap
()
providers/snowflake/objects.go:86
↓ 2 callers
Method
ToWriteResult
()
providers/hubspot/internal/batch/write.go:362
↓ 2 callers
Method
Token
Token creates a signed JWT assertion and exchanges it for an access token.
providers/salesforce/jwt/jwt.go:144
↓ 2 callers
Method
TokenWithContext
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 callers
Method
Truncate
(size int64)
common/printable.go:303
↓ 2 callers
Method
TypedSubscriptionResult
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 callers
Method
UnmarshalJSON
nolint:cyclop
common/xml.go:194
↓ 2 callers
Method
Unsubscribe
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 callers
Method
ValidateParams
(withRequiredFields bool)
common/validation.go:38
↓ 2 callers
Method
WithApiKeyQueryParamClient
WithApiKeyQueryParamClient option sets up client that utilises API Key authentication. Passed via Query Param.
common/paramsbuilder/client.go:90
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/apollo/params.go:47
↓ 2 callers
Function
WithAuthenticatedClient
WithAuthenticatedClient configures the connector with a pre-authenticated HTTP client.
providers/zoho/params.go:46
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/chilipiper/params.go:46
↓ 2 callers
Function
WithAuthenticatedClient
WithAuthenticatedClient sets the http client to use for the connector. Its usage is optional.
providers/closecrm/params.go:46
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/attio/params.go:52
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/asana/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/constantcontact/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/pipedrive/params.go:46
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/salesloft/params.go:51
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/instantly/params.go:52
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/freshdesk/params.go:54
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/customerapp/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/gong/params.go:59
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/outreach/params.go:44
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/iterable/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/kit/params.go:49
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/klaviyo/params.go:45
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/keap/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/intercom/params.go:49
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/stripe/params.go:53
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/smartlead/params.go:47
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/zoom/params.go:48
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/dynamicscrm/params.go:56
↓ 2 callers
Function
WithAuthenticatedClient
(client common.AuthenticatedHTTPClient)
providers/marketo/params.go:56
↓ 2 callers
Function
WithClient
(ctx context.Context, client *http.Client, config *clientcredentials.Config, )
providers/marketo/params.go:39
↓ 2 callers
Function
WithClient
WithClient wraps an HTTP client in a JSONHTTPClient.
memstore/params.go:56
↓ 2 callers
Function
WithCustomDynamicHeaders
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 callers
Function
WithCustomUnauthorizedHandler
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 callers
Function
WithHeaderIsUnauthorizedHandler
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 callers
Function
WithHeaderUnauthorizedHandler
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 callers
Function
WithHeaders
WithHeaders sets the headers to use for the connector. Its usage is optional.
common/header.go:51
← previous
next →
1,301–1,400 of 8,532, ranked by callers