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
↓ 1,487 callers
Function
Response
Response is used to configure server response with HTTP status and body data. Data is optional.
test/utils/mockutils/mockserver/handlers.go:48
↓ 1,379 callers
Method
Server
Server creates mock server.
test/utils/mockutils/mockserver/fixed.go:19
↓ 1,343 callers
Function
ContentJSON
ContentJSON is a setup handler, which configures server to use JSON.
test/utils/mockutils/mockserver/handlers.go:6
↓ 1,133 callers
Function
Path
Path returns a check expecting request URL path to match the template.
test/utils/mockutils/mockcond/request.go:8
↓ 1,026 callers
Function
DataFromFile
DataFromFile is used for server mocking. Files must be located under ./test directory relative to the test runner.
test/utils/testutils/fileReader.go:16
↓ 1,005 callers
Method
Fields
()
providers/hubspot/metadata.go:670
↓ 980 callers
Method
String
()
common/xml.go:123
↓ 811 callers
Method
Error
()
test/utils/testutils/checks.go:29
↓ 802 callers
Function
Fail
Fail logs the message and exits with code 1.
test/utils/fail.go:10
↓ 732 callers
Function
Dummy
Dummy server only talks about having a cup of tea. Acknowledges requests and does nothing else.
test/utils/mockutils/mockserver/dummy.go:10
↓ 688 callers
Method
Run
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/hubspot/search_test.go:452
↓ 609 callers
Method
Get
Get retrieves a single record by its ID for the specified object type. Parameters: - objectName: The type of object to retrieve (e.g., "contact", "ac
memstore/storage.go:87
↓ 601 callers
Method
Write
(ctx context.Context, params common.WriteParams)
test/utils/testconn/connector.go:54
↓ 565 callers
Method
WithQueryParam
(name, value string)
common/urlbuilder/url.go:95
↓ 550 callers
Function
New
New constructs query searching for key. Extra keys are preceding forming a zoom path.
internal/jsonquery/queries.go:81
↓ 537 callers
Function
DumpJSON
DumpJSON dumps the given value as JSON to the given writer.
test/utils/dump.go:11
↓ 530 callers
Function
New
New URL will be constructed given valid full url which may have query params.
common/urlbuilder/url.go:31
↓ 431 callers
Function
SetupLogging
SetupLogging sets up logging for the test suite.
test/utils/logging.go:9
↓ 415 callers
Function
QueryParam
(key string, value ...string)
test/utils/mockutils/mockcond/queries.go:8
↓ 368 callers
Method
Read
(ctx context.Context, params common.ReadParams)
test/utils/testconn/connector.go:49
↓ 351 callers
Method
Module
()
internal/components/provider.go:65
↓ 339 callers
Function
MethodPOST
()
test/utils/mockutils/mockcond/request.go:27
↓ 339 callers
Method
ProviderInfo
()
internal/components/provider.go:57
↓ 305 callers
Method
Has
(objectName string)
providers/aws/internal/core/object.go:50
↓ 263 callers
Method
Error
()
common/types.go:610
↓ 250 callers
Method
Add
Add objects into the named list. If the list didn't exist it will create it.
internal/datautils/lists.go:15
↓ 243 callers
Function
NewSet
NewSet creates a set from multiple values.
internal/datautils/set.go:16
↓ 235 callers
Function
SetInfo
SetInfo sets the information for a specific provider in the catalog. This is useful to enable experimental providers or to override the default provid
providers/utils.go:103
↓ 216 callers
Method
Contains
Contains checks whether a given timestamp falls within the Since/Until range defined in params, respecting the current TimeBoundary mode. If both Sin
common/readhelper/time.go:65
↓ 214 callers
Function
MustBeNil
MustBeNil - panics on non-empty error.
internal/goutils/utils.go:4
↓ 190 callers
Method
Body
Body returns JSON node. If it is empty the flag will indicate so. Empty response body is a special case and should be handled explicitly.
common/json.go:52
↓ 181 callers
Method
ObjectToMap
(node *ajson.Node)
internal/jsonquery/converters.go:54
↓ 173 callers
Function
StringError
StringError creates a StrError from a plain string. Instead of asserting exact error identity, the testing utilities will allow message-based compari
test/utils/testutils/checks.go:37
↓ 171 callers
Method
ListObjectMetadata
(ctx context.Context, objectNames []string)
test/salesforce/metadata/delete/main.go:97
↓ 165 callers
Method
ValidateParams
()
common/paramsbuilder/params.go:12
↓ 163 callers
Method
Assert
Assert compares two data structures using github.com/go-test/deep.Equal and records a formatted mismatch report for the specified data name. Returns t
test/utils/testutils/comparison.go:84
↓ 150 callers
Function
ResponseString
(status int, data string)
test/utils/mockutils/mockserver/handlers.go:63
↓ 149 callers
Function
ParseResult
ParseResult parses the response from a provider into a ReadResult. A 2xx return type is assumed. The sizeFunc returns the total number of records in t
common/parse.go:65
↓ 148 callers
Method
Run
(t *testing.T, builder testconn.ConnectorBuilder[*Connector])
providers/salesforce/bulk-read_test.go:97
↓ 145 callers
Method
AddPath
AddPath appends one or more path segments to the URL. Each provided string is treated as a path segment and joined to the underlying URL using url.UR
common/urlbuilder/url.go:207
↓ 143 callers
Function
wrapper
(input inputConstructorFunc[T])
connector/new.go:310
↓ 141 callers
Method
Run
Run executes the OAuth flow to get a token.
scripts/oauth/token.go:201
↓ 138 callers
Function
LoadPath
LoadPath will give path to creds.json. For provider called `dynamicsCRM` the file location will either be * value of DYNAMICS_CRM_CRED_FILE env var, o
common/scanning/credscanning/path.go:20
↓ 126 callers
Function
MustCreateProvCredJSON
(filePath string, withRequiredAccessToken bool, customFields ...credscanning.Field, )
test/utils/creds.go:13
↓ 124 callers
Function
Initialize
Initialize initializes a connector with the given provider and parameters by using Connector as a base type. It runs the constructor with the connecto
internal/components/connector.go:57
↓ 123 callers
Method
Set
(objectName, fieldName, label, machineFld string)
providers/apollo/connector.go:29
↓ 122 callers
Method
HTTPClient
()
providers/kit/client.go:10
↓ 121 callers
Function
Body
Body returns a check that expects the request body to match the provided template text. The body is compared as plain text, JSON, or XML. When JSON c
test/utils/mockutils/mockcond/body.go:43
↓ 118 callers
Method
Await
Await blocks until the future completes and returns the result. This is the primary way to retrieve the result of an async computation. Behavior: -
internal/future/future.go:236
↓ 117 callers
Method
Add
(displayName, url string)
tools/scrapper/models.go:42
↓ 112 callers
Function
NewEmptyEndpointRegistry
()
internal/components/support.go:41
↓ 111 callers
Function
Logger
Logger returns a logger. nolint:contextcheck,cyclop
common/logging/logging.go:85
↓ 111 callers
Function
NewHTTPReader
( client common.AuthenticatedHTTPClient, registry *components.EndpointRegistry, module common.ModuleID, li
internal/components/reader/http.go:22
↓ 106 callers
Function
NewClient
NewClient returns a new instance of an HTTP client. Using the shared http.DefaultClient in mock tests may cause CloseIdleConnections errors.
test/utils/mockutils/connector.go:24
↓ 105 callers
Function
MethodGET
()
test/utils/mockutils/mockcond/request.go:23
↓ 105 callers
Function
NewHTTPWriter
( client common.AuthenticatedHTTPClient, registry *components.EndpointRegistry, module common.ModuleID, li
internal/components/writer/http.go:21
↓ 97 callers
Method
StrWithDefault
(key string, defaultValue string)
internal/jsonquery/defaults.go:21
↓ 95 callers
Method
Unix
Unix returns the string representing the number of seconds elapsed since January 1, 1970.
internal/datautils/timing.go:32
↓ 94 callers
Function
MethodDELETE
()
test/utils/mockutils/mockcond/request.go:39
↓ 93 callers
Function
Go
Go creates a new Future and executes the given function in a new goroutine. This is the most common way to create a future. It's a convenience wrappe
internal/future/future.go:132
↓ 93 callers
Function
NewFaultyResponder
NewFaultyResponder creates error responder that will be used when provider responds with erroneous payload. - FormatSwitch will be used to select the
common/interpreter/responder.go:27
↓ 92 callers
Method
Name
()
providers/keap/read.go:154
↓ 92 callers
Function
ReplaceURLOrigin
(baseURL, mockServerOrigin string)
test/utils/mockutils/connector.go:12
↓ 89 callers
Function
NewDefaultMap
(dict Map[K, V], fallback func(K) V)
internal/datautils/maps.go:127
↓ 88 callers
Function
Header
(header http.Header)
test/utils/mockutils/mockcond/header.go:13
↓ 85 callers
Method
Is
Is matches common.ErrAccessToken so the server's existing auth-invalidated path handles claim challenges. Deliberately does NOT match ErrRetryable.
providers/microsoft/errors.go:192
↓ 82 callers
Function
ReadThroughPages
ReadThroughPages reads records from a connector page by page. It continues advancing pagination until no more pages remain. This is useful in tests to
test/utils/testscenario/read-all.go:16
↓ 78 callers
Method
MustLoadSchemas
MustLoadSchemas parses static schema file and returns Metadata for deep connector.
internal/staticschema/files.go:40
↓ 72 callers
Function
ExtractRecordsFromPath
(jsonPath string, nestedPath ...string)
common/parse.go:298
↓ 71 callers
Method
ArrayOptional
ArrayOptional returns the array at key if present. Examples: ArrayOptional("") // current node ArrayOptional("items") // dire
internal/jsonquery/queries.go:338
↓ 71 callers
Method
Write
(ctx context.Context, params WriteParams)
connectors.go:101
↓ 70 callers
Function
NewEndpointRegistry
(es EndpointRegistryInput)
internal/components/support.go:33
↓ 68 callers
Method
List
List retrieves records for the specified object type, optionally filtered by a time range based on the object's updated timestamp field. This method
memstore/storage.go:137
↓ 66 callers
Function
MethodPUT
()
test/utils/mockutils/mockcond/request.go:31
↓ 66 callers
Function
NewSiblingFileLocator
NewSiblingFileLocator creates locator, which is capable of resolving full path to files located under the same directory where this constructor was ca
tools/fileconv/files.go:28
↓ 63 callers
Function
NewMetadataFileManager
NewMetadataFileManager allows reading and writing schema.json. Use dedicated instances of NewReader or NewWriter. Deprecated.
tools/scrapper/files.go:32
↓ 60 callers
Function
CapitalizeFirstLetterEveryWord
(text string)
common/naming/formatting.go:11
↓ 59 callers
Method
ObjectOptional
ObjectOptional returns the object at key if present. Examples: ObjectOptional("") // current node ObjectOptional("user") // di
internal/jsonquery/queries.go:99
↓ 58 callers
Function
Apply
Apply will apply options to construct a ready to go set of parameters. This is a generalized constructor of parameters used to initialize any connecto
common/paramsbuilder/params.go:22
↓ 58 callers
Method
GetExplorer
(opts ...Option)
tools/fileconv/api3/manager.go:20
↓ 58 callers
Function
NewHTTPDeleter
( client common.AuthenticatedHTTPClient, registry *components.EndpointRegistry, module common.ModuleID, li
internal/components/deleter/http.go:20
↓ 58 callers
Function
NewObjectSchemaProvider
( client common.AuthenticatedHTTPClient, fetchType string, list operations.SingleObjectMetadataHandlers, )
internal/components/schema/object.go:31
↓ 56 callers
Function
NewFormatSwitch
(templates ...FormatTemplate)
common/interpreter/formatSwitch.go:19
↓ 55 callers
Method
AddDiff
AddDiff marks the comparison as failed and appends a custom failure message. This is the primary way to report simple failures like row count mismatc
test/utils/testutils/comparison.go:57
↓ 55 callers
Method
Delete
(ctx context.Context, params common.DeleteParams)
test/utils/testconn/connector.go:59
↓ 52 callers
Method
Post
Post makes a POST request to the given URL and returns the response & response body. If the response is not a 2xx, an error is returned. If the respon
common/http.go:213
↓ 52 callers
Method
StringOptional
StringOptional returns the string at key if present. Examples: StringOptional("") // current node StringOptional("name") // di
internal/jsonquery/queries.go:220
↓ 51 callers
Function
WithDisplayNamePostProcessors
WithDisplayNamePostProcessors will apply processors in the given order.
tools/fileconv/api3/parameters.go:191
↓ 50 callers
Method
GetOauthToken
GetOauthToken constructs Token group from creds file. Some connectors may implement Refresh tokens, when it happens expiry must be provided alongside.
common/scanning/credscanning/tokens.go:12
↓ 50 callers
Function
Method
Method returns a check expecting HTTP method name to match the template.
test/utils/mockutils/mockcond/request.go:17
↓ 49 callers
Function
NewOpenAPISchemaProvider
( module common.ModuleID, schemas *staticschema.Metadata[F, C], )
internal/components/schema/openapi.go:16
↓ 47 callers
Function
MethodPATCH
()
test/utils/mockutils/mockcond/request.go:35
↓ 47 callers
Method
ModuleInfo
()
internal/components/provider.go:61
↓ 47 callers
Function
NewConnector
NewConnector creates a new memstore connector instance. nolint:cyclop // Complexity inherent to initialization logic with multiple configuration path
memstore/connector.go:76
↓ 47 callers
Function
NewMetadata
NewMetadata constructs empty Metadata. To populate it with data use Metadata.Add method.
internal/staticschema/core.go:12
↓ 47 callers
Function
ReadInfo
ReadInfo reads the information from the catalog for specific provider. It also performs string substitution on the values in the config that are surro
providers/utils.go:116
↓ 47 callers
Method
StringRequired
StringRequired returns the string at key. Examples: StringRequired("") // current node StringRequired("name") // direct lookup New(node,
internal/jsonquery/queries.go:237
↓ 46 callers
Method
Error
Error returns any accumulated errors from hash operations. Returns nil if no errors occurred, a single error if only one occurred, or a joined error c
memstore/hashing.go:217
↓ 46 callers
Function
NewSingularString
(str string)
common/naming/singular.go:23
↓ 46 callers
Method
ReadObjectsGet
ReadObjectsGet is the same as ReadObjectsGet but retrieves schemas for endpoints that perform reading via GET. If you need schemas located under GET a
tools/fileconv/api3/queries.go:36
next →
1–100 of 8,532, ranked by callers