MCPcopy Create free account

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

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

↓ 7 callersFunctionvalidateSubscribeRequest
(params common.SubscribeParams)
providers/acculynx/subscribe.go:300
↓ 6 callersMethodAbsPathTo
(filename string)
tools/fileconv/files.go:12
↓ 6 callersFunctionAddJSONContentTypeIfNotPresent
AddJSONContentTypeIfNotPresent adds the Content-Type header if it is not already present.
common/http.go:654
↓ 6 callersFunctionAddSuffixIfNotExists
AddSuffixIfNotExists appends the suffix to the provided string.
common/json.go:218
↓ 6 callersMethodApplyToRequest
(req *http.Request)
common/http.go:88
↓ 6 callersMethodAttr
(name string)
common/xquery/queries.go:86
↓ 6 callersMethodBoolPtr
BoolPtr adds a boolean pointer to the hash. Nil pointers are represented as {0, 0}, true as {1, 1}, and false as {1, 0}. This three-way distinction en
memstore/hashing.go:123
↓ 6 callersFunctionBuildRequest
( ctx context.Context, baseURL, serviceDomain, serviceSigningName string, command Command, payload any, )
providers/aws/internal/core/requests.go:37
↓ 6 callersFunctionCreateDataMarshallerWithAssociations
( ctx context.Context, filler Filler, objectName string, associatedObjects []string, )
providers/hubspot/internal/associations/marshaller.go:11
↓ 6 callersMethodEvaluateCondition
(w http.ResponseWriter, r *http.Request)
test/utils/mockutils/mockcond/conditions.go:7
↓ 6 callersMethodExecuteRequest
ExecuteRequest nolint:ireturn,cyclop
internal/components/operations/http.go:42
↓ 6 callersFunctionGetAttioConnector
(ctx context.Context)
test/attio/connector.go:14
↓ 6 callersMethodGetCaseInsensitive
(key string)
common/stringMap.go:43
↓ 6 callersFunctionGetConnector
(ctx context.Context)
test/lever/connector.go:15
↓ 6 callersFunctionGetHeyreachConnector
(ctx context.Context)
test/heyreach/connector.go:13
↓ 6 callersFunctionGetHighLevelStandardConnector
(ctx context.Context)
test/highlevelstandard/connector.go:21
↓ 6 callersFunctionGetHighLevelWhiteLabelConnector
(ctx context.Context)
test/highlevelwhitelabel/connector.go:21
↓ 6 callersFunctionGetJobberConnector
(ctx context.Context)
test/jobber/connector.go:15
↓ 6 callersFunctionGetLoxoConnector
(ctx context.Context)
test/loxo/connector.go:25
↓ 6 callersMethodGetTimestampColumn
GetTimestampColumn returns the field name used in incremental-read WHERE clauses (Since/Until) for the given object. The configured alternate column a
providers/salesforce/connector.go:164
↓ 6 callersMethodHTTPClient
()
providers/dynamicscrm/client.go:10
↓ 6 callersMethodHandleErrorResponse
(res *http.Response, body []byte)
common/interpreter/error.go:12
↓ 6 callersFunctionMapWithExecutor
MapWithExecutor transforms a Future[A] into a Future[B] using a custom executor. This is identical to Map but allows you to specify a custom executor
internal/future/future.go:416
↓ 6 callersFunctionMergeSets
(sets ...Set[T])
internal/datautils/merge.go:42
↓ 6 callersFunctionNew
New creates a new Future/Promise pair for manual async computation management. This function returns both the read-side (Future) and write-side (Prom
internal/future/future.go:92
↓ 6 callersFunctionNewConnector
NewConnector returns a new Salesforce connector.
providers/salesforce/connector.go:58
↓ 6 callersFunctionNewCustomAuthHTTPClient
NewCustomAuthHTTPClient returns a new http client, which will do generic header or query-param-based authentication. It does this by automatically add
common/custom.go:17
↓ 6 callersFunctionNewNestedIdField
NewNestedIdField creates an IdFieldQuery for an ID field nested within the record. The zoom path specifies the keys to traverse, and field is the fina
common/readhelper/id.go:42
↓ 6 callersFunctionNewTransport
NewTransport TODO: The JSON client by itself is not providing any functionality right now - this is to only provide continuity for the existing codeba
internal/components/transport.go:21
↓ 6 callersMethodPatch
Patch makes a PATCH request to the given URL and returns the response & response body. If the response is not a 2xx, an error is returned. If the resp
common/http.go:234
↓ 6 callersFunctionRun
(f func(ctx context.Context) error)
examples/utils/utils.go:12
↓ 6 callersMethodRun
Run provides a procedure to test connectors.ReadConnector
test/utils/testconn/proxy.go:19
↓ 6 callersMethodSetBaseURL
(newURL string)
providers/pipedrive/connector.go:99
↓ 6 callersFunctionSetupRecord
SetupRecord prepares a single record of the given object type in the provider, returning both the read representation of the record and a cleanup func
test/utils/testscenario/crd.go:68
↓ 6 callersMethodStringPtr
StringPtr adds a string pointer to the hash. Nil pointers are represented as byte 0, non-nil pointers as byte 1 followed by the string value. This ens
memstore/hashing.go:93
↓ 6 callersFunctionToAnySlice
ToAnySlice converts a slice of any type T to a slice of empty interface values ([]any). This is useful when you need to pass a typed slice to function
internal/datautils/slice.go:43
↓ 6 callersMethodToChannelContext
ToChannelContext is the context-aware version of Channel. This allows waiting for the future result with context support, enabling cancellation and t
internal/future/future.go:321
↓ 6 callersFunctionWithMediaType
WithMediaType picks which media type which should be used when searching schemas in API response. By default, schema is expected to be under "applicat
tools/fileconv/api3/parameters.go:213
↓ 6 callersFunctionWithModule
WithModule sets the Atlassian API module to use for the connector. It's required.
providers/atlassian/params.go:70
↓ 6 callersFunctionWithStructSchemas
WithStructSchemas configures the connector to derive schemas from Go structs. This is an alternative to providing raw JSON schemas in NewConnector. If
memstore/params.go:90
↓ 6 callersFunctionWithWorkspace
(workspaceRef string)
providers/salesforce/params.go:83
↓ 6 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/breakcold/write/write.go:192
↓ 6 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/fireflies/write/write.go:243
↓ 6 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/jobber/write/write.go:196
↓ 6 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/kit/write/main.go:192
↓ 6 callersFunctionWrite
(ctx context.Context, conn *ap.Connector, payload common.WriteParams)
test/instantlyai/write/write.go:185
↓ 6 callersMethodasMap
()
providers/hubspot/subscriptionEvent.go:178
↓ 6 callersFunctionbuildVersionedPathURL
(baseURL string, path string)
providers/breezy/paths.go:20
↓ 6 callersFunctioncleanup
( ctx context.Context, conn *salesforce.Connector, subscriptionResult *common.SubscriptionResult, registra
test/salesforce/subscribe/kept-quota-removed/main.go:211
↓ 6 callersFunctionconstructResponse
unmarshal the write response.
test/breakcold/write/write.go:202
↓ 6 callersFunctionconstructResponse
unmarshal the write response.
test/jobber/write/write.go:206
↓ 6 callersFunctionconstructResponse
unmarshal the write response.
test/kit/write/main.go:202
↓ 6 callersFunctionconstructResponse
unmarshal the write response.
test/instantlyai/write/write.go:195
↓ 6 callersFunctionconstructTestConnector
(serverURL string)
providers/zendesksupport/read_test.go:340
↓ 6 callersFunctionconstructTestMailConnector
(serverURL string)
providers/google/metadata_test.go:221
↓ 6 callersMethodcrmURL
(paths ...string)
providers/hubspot/url.go:150
↓ 6 callersFunctionextractAssociations
extractAssociations attaches related objects to rows for each requested association.
providers/housecallPro/associations.go:30
↓ 6 callersMethodgetAPIURL
(apiVersion string, suffix string)
providers/zoho/connector.go:142
↓ 6 callersMethodgetAPIURL
(objName string)
providers/marketo/connector.go:55
↓ 6 callersMethodgetApiURL
(arg string)
providers/outreach/connector.go:51
↓ 6 callersFunctionlogResponseWithBody
(logger *slog.Logger, res *http.Response, method, id, fullURL string, body []byte)
common/printable.go:91
↓ 6 callersFunctionlogResponseWithoutBody
(logger *slog.Logger, res *http.Response, method, id, fullURL string)
common/printable.go:64
↓ 6 callersFunctionmakeList
(options ...string)
scripts/scraper/salesforce/pardot/main.go:253
↓ 6 callersFunctiononly
only is for endpoints whose return values we don't reuse downstream.
test/gusto/write/main.go:469
↓ 6 callersFunctionprintJSON
printJSON prints data as formatted JSON
test/memstore/write/write.go:249
↓ 6 callersFunctionprintJSON
printJSON prints data as formatted JSON
test/memstore/read/read.go:277
↓ 6 callersFunctionprintResult
(name string, res *common.WriteResult)
test/justcall/write/main.go:191
↓ 6 callersFunctionqueryParam
(templateString string)
providers/salesforce/read_test.go:604
↓ 6 callersFunctiontestRead
(ctx context.Context, conn *ap.Connector, objectName string, fields []string, since, until time.Time)
test/fireflies/read/read.go:54
↓ 6 callersFunctiontestRead
(ctx context.Context, conn *aircall.Connector, objectName string)
test/aircall/read/main.go:161
↓ 6 callersFunctionvalidateSubEvent
(t *testing.T, err error, actual, expected V, methodName string)
providers/salesforce/subscriptionEvent_test.go:127
↓ 5 callersMethodAddFieldWithDisplayOnly
(fieldName string, displayName string)
common/types.go:770
↓ 5 callersMethodAddReader
(reader Reader)
common/scanning/registry.go:30
↓ 5 callersFunctionBuildLastModifiedFilterGroup
BuildLastModifiedFilterGroup filters records modified since the given time. If the time is zero, it returns an empty filter. For contacts, it uses the
providers/hubspot/search.go:173
↓ 5 callersFunctionCheckErrors
(t *testing.T, name string, expectedErrs []error, actualErr error)
test/utils/testutils/checks.go:100
↓ 5 callersMethodCloseIdleConnections
()
common/auth.go:22
↓ 5 callersMethodDeleteMetadata
(ctx context.Context, params *common.DeleteMetadataParams)
test/utils/testconn/connector.go:44
↓ 5 callersFunctionForEachWithErr
ForEachWithErr applies the provided mapper function to each element of the input slice. If the mapper returns an error for any element, the function r
internal/datautils/slice.go:77
↓ 5 callersMethodGetApiKeyHeader
(apiKey string)
providers/utils.go:888
↓ 5 callersMethodGetBool
(key string)
common/stringMap.go:120
↓ 5 callersMethodGetChild
()
common/xquery/queries.go:154
↓ 5 callersFunctionGetConnector
(ctx context.Context)
test/snapchatads/connector.go:15
↓ 5 callersFunctionGetKitConnector
(ctx context.Context)
test/kit/connector.go:14
↓ 5 callersMethodGetPostAuthInfo
(ctx context.Context)
mock/connector.go:181
↓ 5 callersMethodGetUpdatedFields
GetUpdatedFields returns a mapping of object names to their updated timestamp field names. The updated field is the field within each record that tra
memstore/storage.go:171
↓ 5 callersFunctionGetZohoConnector
(ctx context.Context, module common.ModuleID)
test/zoho/connector.go:16
↓ 5 callersMethodHTTPClient
()
providers/salesloft/client.go:10
↓ 5 callersFunctionInferValueTypeFromData
(value any)
common/type.go:18
↓ 5 callersMethodJSONHTTPClient
JSONHTTPClient returns the underlying JSON HTTP client.
providers/gong/client.go:6
↓ 5 callersMethodJSONHTTPClient
()
internal/components/transport.go:79
↓ 5 callersFunctionMakeMarshaledSelectedDataFunc
( selectFields SelectedFieldsFunc, rawTransformer common.RecordTransformer, )
common/readhelper/selector.go:28
↓ 5 callersFunctionMap
Map transforms a Future[A] into a Future[B] by applying a function to the successful result. This is a functional programming primitive for chaining
internal/future/future.go:400
↓ 5 callersFunctionNewApiKeyQueryParamAuthHTTPClient
NewApiKeyQueryParamAuthHTTPClient returns a new http client, with automatic API key authentication. Specifically this means that the client will autom
common/apiKey.go:26
↓ 5 callersFunctionNewBatchCreateParams
(objectName common.ObjectName)
providers/hubspot/internal/associations/models.go:103
↓ 5 callersFunctionNewConnector
(params common.ConnectorParams)
providers/snapchatads/connector.go:35
↓ 5 callersFunctionNewConnector
NewConnector creates a new AccuLynx connector.
providers/acculynx/connector.go:39
↓ 5 callersFunctionNewCustomCatalog
NewCustomCatalog allows to apply modifiers on the base catalog, to tweak its content. Just like the default catalog it supports reading data, resolves
providers/utils.go:47
↓ 5 callersFunctionNewHTTPOperation
( client common.AuthenticatedHTTPClient, handlers HTTPHandlers[RequestType, ResponseType], )
internal/components/operations/http.go:30
↓ 5 callersFunctionNewRegistry
()
common/scanning/registry.go:26
↓ 5 callersMethodObjectName
ObjectName derives the target object from the topic prefix (contact* → contacts, job* → jobs).
providers/acculynx/subscriptionEvent.go:138
← previousnext →401–500 of 8,532, ranked by callers