Functions — github.com/rudderlabs/rudder-server

hub / github.com/rudderlabs/rudder-server / functions

Functions7,867 in github.com/rudderlabs/rudder-server

⨍ Functions 7,867◇ Types & classes 1,912

Equal compares two Response structs and returns true if they are equal regardless of the order of elements in the Events and FailedEvents slices. Matc

processor/types/types.go:318

↓ 2,799 callersMethodRun

(ctx context.Context)

jobsdb/bench/bench.go:16

↓ 2,250 callersMethodErrorf

(format string, args ...any)

jobsdb/jobsdb_test.go:2641

↓ 1,808 callersMethodNew

(destination *backendconfig.DestinationT)

router/factory.go:33

↓ 1,442 callersMethodSet

Set stores keys in the database with a TTL

services/dedup/types/types.go:20

↓ 1,290 callersMethodError

(a ...any)

controlplane/manager.go:29

↓ 928 callersMethodString

()

warehouse/internal/model/source.go:10

↓ 854 callersMethodNow

()

router/batchrouter/asyncdestinationmanager/snowpipestreaming/snowpipestreaming.go:152

↓ 802 callersMethodHelper

()

integration_test/partitionmigration/webhook_test.go:14

↓ 795 callersMethodSet

(tableName string, schema whutils.ModelTableSchema, now time.Time)

router/batchrouter/asyncdestinationmanager/bqstreamallevents/types.go:112

↓ 780 callersMethodAdd

Add adds the given suppressions to the repository

enterprise/suppress-user/repository.go:23

↓ 675 callersMethodLoad

Load retrieves the OAuth token associated with the given key.

services/oauth/v2/cache.go:15

↓ 632 callersMethodNew

(destType string)

router/batchrouter/factory.go:24

↓ 548 callersMethodSetenv

(key, value string)

jobsdb/jobsdb_test.go:2643

↓ 537 callersMethodLog

(...any)

jobsdb/jobsdb_test.go:2644

↓ 519 callersMethodLogf

(format string, args ...any)

integration_test/partitionmigration/webhook_test.go:15

↓ 475 callersMethodLen

Len returns the number of entries in the cache.

backend-config/dynamicconfig/types.go:24

↓ 377 callersMethodGo

(function func())

rruntime/goroutine-factory.go:38

↓ 368 callersMethodGet

Get returns a map of keys that exist in the database

services/dedup/types/types.go:18

↓ 368 callersMethodScan

(dest ...any)

warehouse/integrations/middleware/sqlquerywrapper/sql.go:73

↓ 321 callersMethodExecContext

(ctx context.Context, query string, args ...any)

warehouse/integrations/redshift/redshift.go:596

↓ 310 callersMethodSetup

()

app/app.go:32

↓ 300 callersMethodUnlock

Unlock releases a lock

jobsdb/internal/lock/lock.go:92

↓ 291 callersMethodErrorf

(format string, args ...any)

services/streammanager/kafka/kafkamanager.go:170

↓ 281 callersMethodChild

(_ string)

testhelper/log/log.go:53

↓ 280 callersMethodCleanup

(func())

jobsdb/jobsdb_test.go:2646

↓ 277 callersMethodClose

Close closes the database connection

services/dedup/types/types.go:22

↓ 266 callersMethodWithConfigOption

WithConfigOption sets a config option for the source

testhelper/backendconfigtest/source_builder.go:51

↓ 262 callersMethodDone

()

utils/misc/waitgroup.go:25

↓ 255 callersMethodCount

()

integration_test/retl_test/sut.go:46

↓ 243 callersMethodStore

Store stores the provided jobs to the database

jobsdb/jobsdb.go:92

↓ 236 callersMethodErr

(err error)

utils/misc/waitgroup.go:29

↓ 229 callersMethodWait

()

services/transformer/features.go:35

↓ 223 callersMethodTransform

(ctx context.Context, events []types.TransformerEvent)

processor/transformer/clients.go:25

↓ 222 callersMethodName

()

integration_test/retl_test/sut.go:39

↓ 219 callersMethodNewReader

(r io.Reader)

utils/sysUtils/compress.go:26

↓ 218 callersMethodWarnn

(msg string, fields ...logger.Field)

router/throttler/internal/pickup/adaptive/types.go:19

↓ 216 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

regulation-worker/internal/service/mock_service.go:94

↓ 212 callersMethodReadAll

(r io.Reader)

utils/sysUtils/io.go:58

↓ 211 callersMethodWriteHeader

(status int)

gateway/handle_http_pixel.go:149

↓ 193 callersMethodRUnlock

RUnlock releases a read lock

jobsdb/internal/lock/lock.go:74

↓ 186 callersFunctiongetMetadata

(eventType, destinationType string)

processor/internal/transformer/destination_transformer/embedded/warehouse/transformer_test.go:658

↓ 185 callersMethodError

(args ...any)

services/streammanager/kafka/kafkamanager.go:169

↓ 184 callersMethodClose

()

warehouse/encoding/encoding.go:43

↓ 182 callersMethodReset

(context.Context)

warehouse/source/types.go:83

↓ 179 callersMethodClose

()

router/batchrouter/asyncdestinationmanager/bqstreamallevents/types.go:93

↓ 178 callersMethodSetup

(ctx context.Context, warehouse model.Warehouse, uploader warehouseutils.Uploader)

warehouse/integrations/manager/manager.go:29

↓ 173 callersMethodRLock

RLock acquires a read lock

jobsdb/internal/lock/lock.go:57

↓ 172 callersMethodNewRequest

(method, url string, body io.Reader)

utils/sysUtils/http.go:27

↓ 171 callersFunctionmakeEvent

makeEvent creates a TransformerEvent for backwards compatibility testing with minimal required fields.

integration_test/pytransformer_contract/bc_helpers_test.go:201

↓ 169 callersMethodBuild

()

internal/enricher/geolocation_test.go:513

↓ 169 callersMethodLogf

(format string, args ...any)

jobsdb/jobsdb_test.go:2645

↓ 157 callersMethodGet

(tableName string, now time.Time)

router/batchrouter/asyncdestinationmanager/bqstreamallevents/types.go:109

↓ 154 callersMethodRun

()

enterprise/reporting/flusher/cron_runner.go:17

↓ 150 callersMethodErrorf

(format string, a ...any)

controlplane/manager.go:30

↓ 144 callersMethodQueryRow

(query string, args ...any)

jobsdb/jobsdb_utils.go:19

↓ 141 callersMethodCleanup

(ctx context.Context)

warehouse/integrations/manager/manager.go:39

↓ 137 callersMethodQueryRowContext

(ctx context.Context, query string, args ...any)

warehouse/integrations/middleware/sqlquerywrapper/sql.go:194

↓ 137 callersMethodWrite

()

warehouse/encoding/encoding.go:65

↓ 136 callersMethodOpen

(name string)

utils/sysUtils/os.go:28

↓ 136 callersFunctionWithNow

(now func() time.Time)

warehouse/internal/repo/options.go:11

↓ 128 callersFunctiongetDestination

(destinationType string, config map[string]any)

processor/internal/transformer/destination_transformer/embedded/warehouse/transformer_test.go:647

↓ 126 callersMethodHeader

()

gateway/handle_http_pixel.go:145

↓ 126 callersMethodRun

Run starts a gRPC server for accepting jobs from source nodes and watches for moved migration jobs assigned to this target node

cluster/migrator/processor/targetnode/targetnode_migrator.go:37

↓ 124 callersMethodClose

()

internal/pulsar/pulsar.go:29

↓ 123 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

mocks/app/mock_app.go:39

↓ 123 callersMethodStart

lifecycle management

jobsdb/jobsdb.go:180

↓ 122 callersMethodExec

(string, ...any)

jobsdb/jobsdb_tx.go:102

↓ 119 callersMethodSetDataField

(key string, value any)

processor/internal/transformer/destination_transformer/embedded/warehouse/testhelper/outputbuilder.go:11

↓ 119 callersMethodTearDown

TearDown stops the background goroutines, waits until they finish and closes the database.

jobsdb/jobsdb_lifecycle.go:321

↓ 117 callersMethodDo

(req *http.Request)

utils/sysUtils/httpclient.go:10

↓ 112 callersMethodCreateTable

(ctx context.Context, tableName string, columnMap model.TableSchema)

warehouse/integrations/manager/manager.go:32

↓ 110 callersMethodLen

()

router/batchrouter/asyncdestinationmanager/bqstreamallevents/types.go:108

↓ 110 callersMethodSleep

Sleep sleeps until at least 'delay' time has passed since the most recent JobReceivedAt time. If 'delay' time has already passed, it returns immediate

processor/internal/preprocessdelay/handle.go:43

↓ 109 callersFunctiongetTrackMetadata

(destinationType, sourceCategory string)

processor/internal/transformer/destination_transformer/embedded/warehouse/transformer_test.go:671

↓ 106 callersMethodDo

(*http.Request)

router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/api/api.go:34

↓ 105 callersMethodWithID

WithID sets the ID of the source

testhelper/backendconfigtest/source_builder.go:39

↓ 104 callersFunctionWithDBHandle

WithDBHandle uses dbHandle instead of opening the default database handle.

jobsdb/jobsdb_factory.go:30

↓ 102 callersFunctionNewForReadWrite

NewForReadWrite creates a JobsDB handle that owns both reads and writes.

jobsdb/jobsdb_factory.go:141

↓ 101 callersMethodLoadTable

(ctx context.Context, tableName string)

warehouse/integrations/manager/manager.go:35

↓ 100 callersMethodCommit

Commit commits a list of allowed keys to the deduplication service

services/dedup/types/types.go:32

↓ 100 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

services/rsources/mock_rsources.go:214

↓ 100 callersFunctiongenerateJobs

(num int, params jobParams)

services/rsources/stats_collector_test.go:485

↓ 100 callersMethodgetDSListSnapshot

* Utility function to return an ordered list of datasets (for tests) */

jobsdb/jobsdb_dataset.go:88

↓ 97 callersMethodGetUnprocessed

GetUnprocessed finds unprocessed jobs, i.e. new jobs whose state hasn't been marked in the database yet

jobsdb/jobsdb.go:125

↓ 96 callersFunctionWaitUntilReady

( ctx context.Context, t testing.TB, endpoint string, atMost, interval time.Duration, caller string, )

testhelper/health/checker.go:12

↓ 95 callersMethodCreateSchema

(ctx context.Context)

warehouse/integrations/manager/manager.go:31

↓ 91 callersMethodLogf

(format string, args ...any)

router/internal/eventorder/eventorder_simulation_test.go:331

↓ 89 callersMethodStore

Store stores new jobs to the jobsdb. If enableWriterQueue is true, this goes through writer worker pool.

jobsdb/jobsdb_store.go:228

↓ 87 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use.

warehouse/internal/mocks/utils/mock_uploader.go:41

↓ 87 callersMethodGetStringDestinationConfig

(conf *config.Config, key DestinationConfigSetting)

warehouse/internal/model/warehouse.go:30

↓ 86 callersMethodDecode

(m map[string]any)

router/batchrouter/asyncdestinationmanager/snowpipestreaming/types.go:152

↓ 83 callersMethodRemove

(name string)

utils/sysUtils/os.go:31

↓ 82 callersMethodBuild

Build builds the test tranformer server

testhelper/transformertest/builder.go:115

↓ 82 callersMethodErr

Err provides a way for wrapping packages to check for query errors without calling Scan.

warehouse/integrations/middleware/sqlquerywrapper/sql.go:81

↓ 81 callersFunctionNow

Now returns the current time in UTC.

utils/timeutil/timeutil.go:31

↓ 79 callersMethodQueryContext

(ctx context.Context, query string, args ...any)

warehouse/integrations/middleware/sqlquerywrapper/sql.go:168

↓ 78 callersMethodIdentifier

Identifier returns the jobsdb's identifier, a.k.a. table prefix

jobsdb/jobsdb.go:75

↓ 76 callersMethodWrite

(ctx context.Context, path string)

regulation-worker/internal/delete/batch/filehandler/local_file.go:12

↓ 74 callersFunctionMapLookup

MapLookup returns the value of the key in the map, or nil if the key is not present. If multiple keys are provided then it looks for nested maps recu

utils/misc/misc.go:841

next →1–100 of 7,867, ranked by callers