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
↓ 4 callers
Function
NewConnector
(opts ...Option)
providers/marketo/connector.go:15
↓ 4 callers
Function
NewConnector
(ctx context.Context)
test/callrail/connector.go:13
↓ 4 callers
Function
NewConnector
(ctx context.Context)
test/slack/connector.go:20
↓ 4 callers
Function
NewDelegateSchemaProvider
NewDelegateSchemaProvider creates a new DelegateSchemaProvider with the provided list function.
internal/components/schema/delegate.go:19
↓ 4 callers
Function
NewExtendedMetadataFileManager
( schemas []byte, locator fileconv.FileLocator, )
tools/scrapper/files.go:20
↓ 4 callers
Function
NewHeaderAuthHTTPClient
nolint:gochecknoglobals NewHeaderAuthHTTPClient returns a new http client, which will do generic header-based authentication. It does this by automati
common/header.go:18
↓ 4 callers
Function
NewServer
NewServer is syntactic sugar for creating test server.
test/utils/mockutils/mockserver/dummy.go:18
↓ 4 callers
Function
NewStrategy
(client *common.JSONHTTPClient, providerInfo *providers.ProviderInfo)
providers/microsoft/internal/batch/strategy.go:16
↓ 4 callers
Function
NewWebhookRouter
()
test/microsoft/subscription/webhook.go:10
↓ 4 callers
Method
ObjectName
()
providers/salesforce/subscriptionEvent.go:149
↓ 4 callers
Function
ParseECPrivateKey
nolint:gochecknoglobals ParseECPrivateKey parses an EC private key from either raw PEM or base64-encoded PEM. Supports both SEC 1 (BEGIN EC PRIVATE KE
providers/netsuite/m2m/m2m.go:36
↓ 4 callers
Method
Path
()
common/module.go:39
↓ 4 callers
Function
PermuteJSONBody
PermuteJSONBody returns a Condition expecting the request body to match a template where array ordering may vary. The template may contain one or mor
test/utils/mockutils/mockcond/body.go:78
↓ 4 callers
Method
RawXML
RawXML returns raw data of the whole XML node.
common/xquery/queries.go:99
↓ 4 callers
Method
Read
(ctx context.Context, params common.ReadParams)
mock/connector.go:142
↓ 4 callers
Method
RemoveQueryParam
(name string)
common/urlbuilder/url.go:118
↓ 4 callers
Function
RemoveSuffix
(objName string, suffixLength int)
providers/salesforce/register.go:244
↓ 4 callers
Method
RunScheduledMaintenance
RunScheduledMaintenance performs provider-specific maintenance for an existing subscription. The params argument represents the desired subscription
connectors.go:378
↓ 4 callers
Method
RunWithContext
RunWithContext provides a procedure to test connectors.DeleteMetadataConnector.
test/utils/testconn/delete-metadata.go:22
↓ 4 callers
Function
SearchThroughPages
SearchThroughPages searches records from a connector page by page. It continues advancing pagination until no more pages remain. This is useful in tes
test/utils/testscenario/read-all.go:48
↓ 4 callers
Method
SetDataNode
SetDataNode will attach tree found under the node to current xml as a First element. If this xml object cannot accept then nodes nothing happens. Retu
common/xquery/queries.go:131
↓ 4 callers
Function
SingleItemDuplicatesResolver
SingleItemDuplicatesResolver processes each endpoint individually.
tools/fileconv/api3/parameters.go:115
↓ 4 callers
Method
Start
(ctx context.Context, port int)
scripts/utils/proxyserv/proxy.go:42
↓ 4 callers
Method
String
()
common/naming/singular.go:27
↓ 4 callers
Method
SubscriptionEventList
SubscriptionEventList collapses the event response into the list of messages. In case of an error returns ErrSubscriptionEventList.
common/types.go:854
↓ 4 callers
Method
ToChannel
ToChannel returns a channel that will receive the result when the future completes. This allows integration with select statements and channel-based
internal/future/future.go:304
↓ 4 callers
Method
Token
Token creates a signed JWT assertion and exchanges it for an access token.
providers/netsuite/m2m/m2m.go:82
↓ 4 callers
Function
TransformWriteHeaders
(headers []WriteHeader, mode HeaderMode)
common/types.go:496
↓ 4 callers
Method
UpdatedFields
()
providers/salesforce/subscriptionEvent.go:192
↓ 4 callers
Method
VerifyWebhookMessage
VerifyWebhookMessage validates the authenticity of an incoming webhook request. The method should verify that the HTTP request was sent by the provid
connectors.go:237
↓ 4 callers
Function
WithCustomHeaders
WithCustomHeaders sets the headers to use for the connector. Its usage is optional.
common/custom.go:50
↓ 4 callers
Function
WithMetadata
(metadata map[string]string)
providers/salesforce/params.go:95
↓ 4 callers
Function
WithModule
(module common.ModuleID)
providers/pipedrive/params.go:52
↓ 4 callers
Function
WithParameterFilterGetMethod
WithParameterFilterGetMethod adds custom callback to decide if GET operation should be included based on parameters definitions.
tools/fileconv/api3/parameters.go:205
↓ 4 callers
Method
WithRequest
WithRequest adds a request to the batch. Requirements: - requestIdentifier must be unique within the batch. - URL must be a valid Graph endpoint. No
providers/microsoft/internal/batch/params.go:39
↓ 4 callers
Function
WithWorkspace
(workspaceRef string)
providers/atlassian/params.go:63
↓ 4 callers
Function
WithWorkspace
(workspaceRef string)
providers/zendesksupport/params.go:55
↓ 4 callers
Function
WithWorkspace
WithWorkspace sets the marketo API instance to use for the connector. It's required.
providers/marketo/params.go:50
↓ 4 callers
Method
Workspace
Workspace returns an empty string because AccuLynx subscriptions are consumer-URL routed: each installation registers a unique, immutable consumerUrl,
providers/acculynx/subscriptionEvent.go:162
↓ 4 callers
Function
Write
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/pinterest/write/main.go:147
↓ 4 callers
Function
Write
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/heyreach/write/main.go:173
↓ 4 callers
Function
Write
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/lever/write/main.go:141
↓ 4 callers
Method
advanceWindow
============================================================================= Window management ======================================================
providers/bigquery/read.go:388
↓ 4 callers
Function
applyTimeFilter
applyTimeFilter adds the mandatory time-range query params for endpoints that require them. Caller-supplied since/until win when non-zero; otherwise a
providers/goto/internal/gotocore/handlers.go:42
↓ 4 callers
Method
buildObjectURL
(objectName string)
providers/goto/internal/gotocore/utils.go:12
↓ 4 callers
Function
buildPartialUpdateResult
buildPartialUpdateResult assembles a SubscriptionResult that describes the current Salesforce state at the point an error was hit during UpdateSubscri
providers/salesforce/subscribe.go:686
↓ 4 callers
Method
buildURL
(config common.ReadParams)
providers/kit/read.go:52
↓ 4 callers
Function
check
(t *testing.T, err error)
common/naming/singular_test.go:172
↓ 4 callers
Function
cloneResponse
(r *http.Response)
common/oauth.go:294
↓ 4 callers
Function
constructResponse
unmarshal the write response.
test/pinterest/write/main.go:157
↓ 4 callers
Function
constructResponse
unmarshal the write response.
test/heyreach/write/main.go:183
↓ 4 callers
Function
constructResponse
unmarshal the write response.
test/lever/write/main.go:151
↓ 4 callers
Function
constructTestAdsConnector
(server *httptest.Server)
providers/linkedin/write_test.go:163
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/breakcold/metadata_test.go:93
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/salesflare/metadata_test.go:110
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/supersend/metadata_test.go:331
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/campaignmonitor/metadata_test.go:73
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/atlassian/read_test.go:223
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/loxo/metadata_test.go:120
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/zoho/metadata_test.go:129
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/okta/metadata_test.go:302
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/capsule/metadata_test.go:147
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/cloudtalk/metadata_test.go:57
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/pinterest/metadata_test.go:110
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/constantcontact/read_test.go:145
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/pipeliner/read_test.go:171
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/instantly/read_test.go:215
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/lever/metadata_test.go:100
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/customerapp/read_test.go:128
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/dynamicsbusiness/metadata_test.go:82
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/aws/metadata_test.go:98
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/gong/read_test.go:526
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/salesfinity/metadata_test.go:409
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/insightly/metadata_test.go:257
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/odoo/metadata_test.go:536
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/outreach/metadata_test.go:154
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/webex/metadata_test.go:227
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/phoneburner/metadata_test.go:206
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/iterable/read_test.go:126
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/aircall/metadata_test.go:92
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/kit/metadata_test.go:249
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/highlevelstandard/metadata_test.go:136
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/justcall/read_test.go:426
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/getresponse/metadata_test.go:113
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/klaviyo/read_test.go:168
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/copper/metadata_test.go:187
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/keap/read_test.go:257
↓ 4 callers
Function
constructTestConnector
(server *httptest.Server)
providers/slack/metadata_test.go:144
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/breezy/metadata_test.go:185
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/intercom/read_test.go:287
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/highlevelwhitelabel/metadata_test.go:136
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/shopify/metadata_test.go:141
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/stripe/read_test.go:424
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/instantlyai/metadata_test.go:241
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/smartlead/read_test.go:123
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/teamwork/metadata_test.go:77
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/dynamicscrm/read_test.go:142
↓ 4 callers
Function
constructTestConnector
(serverURL string)
providers/nutshell/metadata_test.go:95
↓ 4 callers
Function
constructTestContactsConnector
(serverURL string)
providers/google/metadata_test.go:217
↓ 4 callers
Function
constructTestWriteConnector
(baseURL, companyID string)
providers/gusto/write_test.go:323
← previous
next →
601–700 of 8,532, ranked by callers