Types & classes — github.com/rudderlabs/rudder-server

CodeHub MCPcopy Index your code

hub / github.com/rudderlabs/rudder-server / types & classes

Types & classes1,912 in github.com/rudderlabs/rudder-server

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

↓ 186 callersTypeAliascustomValKey

customValKey represents custom value as key

jobsdb/jobsdb_update.go:126

↓ 181 callersTypeAliasjobStateKey

jobStateKey represents job state as key (failed, succeeded, etc)

jobsdb/jobsdb_update.go:129

↓ 169 callersTypeAliasparameterFiltersKey

parameterFiltersKey represents a list of job parameter filters (stringified) as key

jobsdb/jobsdb_update.go:132

↓ 116 callersTypeAliasworkspaceIDKey

workspaceIDKey represents workspace id as key

jobsdb/jobsdb_update.go:123

↓ 115 callersTypeAliaspartitionIDKey

partitionIDKey represents partition id as key

jobsdb/jobsdb_update.go:120

↓ 58 callersTypeAliasdestConfSetting

warehouse/internal/model/settings.go:8

↓ 31 callersTypeAliasSourceIDT

processor/processor.go:301

↓ 10 callersStructTx

Tx is a wrapper around sql.Tx that supports registering and executing post-commit actions (success listeners), post-rollback actions (failure listener

utils/tx/tx.go:8

↓ 5 callersTypeAliasSourceID

Custom type definitions for deeply nested map

processor/processor.go:70

↓ 5 callersTypeAliassourceJobStatus

warehouse/internal/model/source.go:35

↓ 4 callersTypeAliasparameterName

jobsdb/jobsdb.go:188

↓ 3 callersTypeAliasCacheType

services/debugger/cache/cache.go:11

↓ 3 callersTypeAliasDestinationID

Custom type definitions for deeply nested map

processor/processor.go:69

↓ 3 callersStructhandler

services/rsources/http/http.go:36

↓ 3 callersStructscenario

services/oauth/v2/oauth_breaker_test.go:31

↓ 3 callersTypeAliastableNameT

warehouse/router/upload.go:55

↓ 2 callersTypeAliasConsentProviderKey

Custom type definitions for deeply nested map

processor/processor.go:71

↓ 2 callersTypeAliasDefaultString

DefaultString is a utility type for providing default values using one-liners in otherwise multi-line scenarios. E.g. this v := misc.DefaultString(

utils/misc/default_string.go:16

↓ 2 callersTypeAliasMode

router/isolation/isolation.go:17

↓ 2 callersStructpayload

cmd/devtool/commands/webhook.go:71

↓ 1 callersTypeAliasJobFailedRecordsV2

services/rsources/rsources.go:156

↓ 1 callersTypeAliasJobType

services/notifier/notifier.go:36

↓ 1 callersTypeAliasMode

utils/types/servermode/servermode.go:5

↓ 1 callersTypeAliasMode

processor/isolation/isolation.go:10

↓ 1 callersTypeAliasMode

router/batchrouter/isolation/isolation.go:12

↓ 1 callersTypeAliasRoute

Route contains the HTTP path and query string for the service.

enterprise/reporting/client/client.go:43

↓ 1 callersTypeAliasType

utils/types/deployment/deployment.go:12

↓ 1 callersTypeAliasmode

services/dedup/db.go:16

↓ 1 callersStructoperation

utils/misc/retry_test.go:72

↓ 1 callersTypeAliaspayloadColumnType

jobsdb/jobsdb.go:57

↓ 1 callersStructpickupThrottlers

router/throttler/factory.go:277

↓ 1 callersTypeAliassourceJobType

warehouse/internal/model/source.go:14

suppression-backup-service/api/api.go:19

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

InterfaceAPIClient

go:generate mockgen -source=service.go -destination=mock_service.go -package=service github.com/rudderlabs/rudder-server/regulation-worker/internal/se

regulation-worker/internal/service/service.go:20

router/batchrouter/asyncdestinationmanager/marketo-bulk-upload/apiService.go:32

router/batchrouter/asyncdestinationmanager/salesforce-bulk-upload/types.go:76

StructAPIManager

regulation-worker/internal/delete/api/api.go:40

StructAPIReqErr

regulation-worker/internal/model/model.go:59

InterfaceAPIServiceInterface

router/batchrouter/asyncdestinationmanager/salesforce-bulk-upload/types.go:36

StructAbortingForwarder

AbortingForwarder is a forwarder which aborts all jobs instead of forwarding them

schema-forwarder/internal/forwarder/abortingforwarder.go:20

backend-config/types.go:139

StructAccountConfig

router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/model/model.go:19

StructAccountDefinition

backend-config/types.go:147

StructActionFileInfo

router/batchrouter/asyncdestinationmanager/bing-ads/audience/types.go:51

StructActionFileInfo

router/batchrouter/asyncdestinationmanager/bing-ads/offline-conversions/types.go:42

StructActionFileInfo

router/batchrouter/asyncdestinationmanager/lytics_bulk_upload/types.go:51

InterfaceAdaptiveAlgorithm

router/throttler/internal/pickup/adaptive/algorithm/algorithm.go:11

StructAdaptiveLimiterConfig

utils/payload/limiter_config.go:10

FuncTypeAdaptiveLimiterFunc

func(int64) int64

utils/payload/limiter_setup.go:15

warehouse/admin/admin.go:35

Admin is an implementation of the Authorizer interface for data-plane admin endpoints.

services/controlplane/identity/identity.go:82

admin/admin.go:58

StructAdminClient

services/controlplane/client.go:68

InterfaceAggregator

enterprise/reporting/flusher/aggregator/aggregator.go:10

services/alerta/client.go:34

InterfaceAlertManager

AlertManager interface

services/alert/alertmanager.go:30

InterfaceAlertSender

services/alerta/client.go:80

InterfaceAlgorithm

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

enterprise/reporting/flusher/aggregator/types.go:30

router/batchrouter/asyncdestinationmanager/snowpipestreaming/internal/model/model.go:88

StructAllowTransformerEventParams

processor/eventfilter/eventfilter.go:87

StructAlterTableResponse

warehouse/internal/model/upload.go:146

warehouse/api/http.go:69

App represents a rudder-server application

warehouse/app.go:51

InterfaceAppHandler

AppHandler starts the app

app/apphandlers/setup.go:27

InterfaceAppendResult

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

warehouse/archive/archiver.go:54

InterfaceAsyncDestinationManager

router/batchrouter/asyncdestinationmanager/common/common.go:22

StructAsyncDestinationStruct

router/batchrouter/asyncdestinationmanager/common/common.go:104

StructAsyncInit

AsyncInit is a helper object to wait for multiple asynchronous initialization events.

utils/misc/asyncinit.go:19

router/batchrouter/asyncdestinationmanager/common/common.go:85

StructAsyncPoll

router/batchrouter/asyncdestinationmanager/common/common.go:80

StructAsyncTestHelper

AsyncTestHelper provides synchronization methods to test goroutines. Example: var ( asyncHelper testutils.AsyncTestHelper ) BeforeEach(func() {

utils/tests/async-helper.go:28

InterfaceAsyncUploadAndTransformManager

router/batchrouter/asyncdestinationmanager/common/common.go:17

StructAsyncUploadOutput

router/batchrouter/asyncdestinationmanager/common/common.go:64

StructAsyncUploadT

router/batchrouter/asyncdestinationmanager/common/common.go:90

InterfaceAugmenter

Augmenter is an extension point for adding the appropriate authorization information to oauth requests.

services/oauth/v2/extensions/augmenter.go:21

InterfaceAuthIdentityProvider

services/oauth/v2/types.go:35

controlplane/auth.go:9

StructAuthRequestContext

AuthRequestContext contains the authenticated source information for a request.

gateway/types/types.go:22

InterfaceAuthorizer

Authorizer abstracts how data-plane can be authorized by the control-plane.

services/controlplane/identity/identity.go:6

StructAzureSynapse

warehouse/integrations/azure-synapse/azure-synapse.go:86

InterfaceBQClient

services/streammanager/bqstream/bqstreammanager.go:36

StructBQStreamProducer

services/streammanager/bqstream/bqstreammanager.go:41

InterfaceBackendConfig

backend-config/backend-config.go:74

StructBackendConfigManager

BackendConfigManager is used to handle the backend configuration in the Warehouse

warehouse/bcm/backend_config.go:63

StructBadgerEventSampler

enterprise/reporting/event_sampler/badger_event_sampler.go:24

Barrier is an abstraction for applying event ordering guarantees in the router. Events for the same key need to be processed in order, thus when an e

router/internal/eventorder/eventorder.go:112

StructBarrierKey

router/internal/eventorder/eventorder.go:132

StructBaseForwarder

schema-forwarder/internal/forwarder/baseforwarder.go:20

StructBasicAuth

warehouse/client/controlplane/client.go:22

StructBasicAuthMock

utils/tests/oauth-cp-requests.go:58

regulation-worker/internal/delete/batch/batch.go:42

BatchKey represents a key in a batch

services/dedup/types/types.go:8

StructBatchManager

regulation-worker/internal/delete/batch/batch.go:315

StructBatchRouterEvent

warehouse/utils/types/types.go:9

StructBatchedJobs

router/batchrouter/types.go:59

jobsdb/bench/bench.go:15

next →1–100 of 1,912, ranked by callers