Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/pydio/cells
/ functions
Functions
22,850 in github.com/pydio/cells
⨍
Functions
22,850
◇
Types & classes
3,951
↓ 2 callers
Function
NewSharesHandler
NewSharesHandler simply creates a new SharesHandler.
idm/share/rest/handler.go:54
↓ 2 callers
Function
NewStore
(ctx context.Context, values kv.Values, cli *clientv3.Client, prefix string, ttl int)
common/utils/kv/etcd/store.go:46
↓ 2 callers
Method
NewStream
(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption)
common/proto/broker/cells-message_grpc.stub.pb.go:36
↓ 2 callers
Function
NewTaskServiceClient
(cc grpc.ClientConnInterface)
common/proto/jobs/cells-jobs_grpc.pb.go:490
↓ 2 callers
Function
NewTestPoolWithDataSources
NewTestPoolWithDataSources will provide a list of LoadedSource with preset mock data
common/nodes/pool.go:140
↓ 2 callers
Function
NewTreeNode
NewTreeNode creates an ITreeNode with a path, and optionally more node info for creation
common/proto/tree/node.go:858
↓ 2 callers
Function
NewTreeServer
NewTreeServer factory.
data/source/index/grpc/handler.go:76
↓ 2 callers
Function
NewUnionHttpFs
(boxes ...service.PluginBox)
common/service/frontend/http-union.go:78
↓ 2 callers
Function
NewUpdateServiceClient
(cc grpc.ClientConnInterface)
common/proto/update/cells-update_grpc.pb.go:29
↓ 2 callers
Function
NewVault
NewVault creates a new vault with a standard config wrappedStore and a vault wrappedStore
common/config/vault.go:40
↓ 2 callers
Function
NewVaultCipher
(master string)
common/crypto/vault.go:7
↓ 2 callers
Method
Next
(p []byte)
common/utils/hasher/block-hash.go:59
↓ 2 callers
Method
Node
()
common/sync/model/status.go:157
↓ 2 callers
Method
NodeInTarget
NodeInTarget tries to find the node in the attached Patch target
common/sync/merger/merger.go:170
↓ 2 callers
Function
NodeRequiresChecksum
NodeRequiresChecksum checks whether the current checksum is usable as index ETag or not. This part is linked to the **structured datasource**, and we
common/sync/model/funcs.go:74
↓ 2 callers
Method
OAuth2Config
()
idm/oauth/dao-registry.go:232
↓ 2 callers
Function
Oa
(i)
frontend/assets/uploader.uppy/resources/uppy.min.js:11
↓ 2 callers
Method
Occurrences
Occurrences returns a slice of TaskParameters, each one containing the map of TaskParameter
scheduler/actions/task-parameters.go:46
↓ 2 callers
Function
Od
(v)
frontend/assets/uploader.uppy/resources/uppy.min.js:2
↓ 2 callers
Function
Od
(a,b,c,d)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:26
↓ 2 callers
Function
OnRegister
(fn func(*Item, *[]RegisterOption))
common/registry/func-wrapper.go:43
↓ 2 callers
Method
OnServe
(oo ...registry.RegisterOption)
common/service/service.go:83
↓ 2 callers
Method
Open
(name string)
common/utils/statics/statics.go:43
↓ 2 callers
Function
OpenAsyncQueue
OpenAsyncQueue calls OpenTopicURL with the URL parsed from urlstr. OpenTopic is safe to call from multiple goroutines.
common/broker/queue.go:199
↓ 2 callers
Method
OpenCore
(ctx context.Context, u *url.URL, level zapcore.LevelEnabler, svc otel.Service)
common/telemetry/log/mux.go:46
↓ 2 callers
Method
OpenDB
OpenDB Opens a DB connection
common/storage/sql/dsn.go:72
↓ 2 callers
Method
OpenSync
(ctx context.Context, u *url.URL)
common/telemetry/log/mux.go:51
↓ 2 callers
Method
Opener
(rootCtx context.Context, job *jobs.Job, queues ...chan RunnerFunc)
scheduler/tasks/dispatcher.go:112
↓ 2 callers
Function
Ov
(i)
frontend/assets/uploader.uppy/resources/uppy.min.js:19
↓ 2 callers
Method
OwnerResourcePolicies
OwnerResourcePolicies produces a set of policies given ownership to current context user, read/write to current context user, and write access to prof
idm/share/client-acls.go:578
↓ 2 callers
Function
P
(a)
frontend/assets/editor.ckeditor/res/ckeditor/samples/old/htmlwriter/assets/outputforflash/swfobject.js:9
↓ 2 callers
Method
Panic
(msg string, fields ...zap.Field)
common/telemetry/log/logger.go:45
↓ 2 callers
Method
ParentMPath
(levelKey string, mpathes ...string)
common/storage/sql/helper.go:45
↓ 2 callers
Method
Parse
()
common/storage/sql/dsn.go:111
↓ 2 callers
Method
ParseLastConnected
()
common/proto/idm/matchers.go:236
↓ 2 callers
Method
ParseLastUpdated
()
common/proto/idm/matchers.go:126
↓ 2 callers
Method
ParseStores
ParseStores interpret parameters as sync stores
common/etl/actions/etl-action.go:44
↓ 2 callers
Method
PasswordCredentialsCode
(context.Context, string, string, ...TokenOption)
common/auth/jwt.go:95
↓ 2 callers
Function
Pd
(a,b)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:28
↓ 2 callers
Function
Pe
(a,b,c,d)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:123
↓ 2 callers
Method
PerformCheck
(ctx context.Context, in *PerformCheckRequest, opts ...grpc.CallOption)
common/proto/install/cells-install_grpc.pb.go:23
↓ 2 callers
Method
PerformSearch
(ctx context.Context, searchRequest *tree.SearchRequest, firstLevelSearch, filterReserved bool, ensurePrefixes
data/search/rest/handler.go:181
↓ 2 callers
Method
PerformUserMetaUpdate
(ctx context.Context, input *idm.UpdateUserMetaRequest)
idm/meta/rest/handler.go:84
↓ 2 callers
Function
PersistSelection
PersistSelection transforms a list of nodes to a selection with a UUID
scheduler/jobs/userspace/userspace.go:940
↓ 2 callers
Function
Pf
(i,e)
frontend/assets/uploader.uppy/resources/uppy.min.js:12
↓ 2 callers
Method
Ping
()
idm/oauth/dao-registry.go:152
↓ 2 callers
Function
PipeChan
PipeChan builds a new dynamically sized channel
common/sync/endpoints/filesystem/notify.go:118
↓ 2 callers
Method
PluginEnabled
(status RequestStatus)
common/service/frontend/plugin.go:55
↓ 2 callers
Function
Pm
(i)
frontend/assets/uploader.uppy/resources/uppy.min.js:16
↓ 2 callers
Function
Pn
(i)
frontend/assets/uploader.uppy/resources/uppy.min.js:19
↓ 2 callers
Function
PreparePeriods
PreparePeriods computes the actual periods from definitions.
data/versions/pruner.go:155
↓ 2 callers
Function
PrettyPrint
(v interface{})
common/config/migrations/migrations_test.go:34
↓ 2 callers
Function
ProcessRootID
ProcessRootID retrieves a unique identifier for the current process
common/runtime/runtime.go:331
↓ 2 callers
Function
ProcessStartTags
ProcessStartTags returns a list of tags to be used for identifying processes
common/runtime/runtime.go:341
↓ 2 callers
Method
ProvidesMetadataNamespaces
ProvidesMetadataNamespaces returns a list of patterns to check on provider nodes MetaStore.
common/sync/model/endpoints.go:217
↓ 2 callers
Method
PruneTokens
(ctx context.Context, request *auth.PruneTokensRequest)
idm/oauth/grpc/token-handler.go:239
↓ 2 callers
Method
PublishPackage
(ctx context.Context, in *PublishPackageRequest, opts ...grpc.CallOption)
common/proto/update/cells-update_grpc.pb.go:145
↓ 2 callers
Method
Purge
Purge compares existing eTags to stored eTags and removes unnecessary ones
common/sync/endpoints/s3/checksum-mapper.go:68
↓ 2 callers
Method
PurgeActivities
(ctx context.Context, in *PurgeActivitiesRequest, opts ...grpc.CallOption)
common/proto/activity/cells-activitystream_grpc.pb.go:24
↓ 2 callers
Method
PutACL
(context.Context, *idm.ACL)
common/etl/models/stores.go:56
↓ 2 callers
Method
PutJob
JOBS STORE
scheduler/jobs/grpc/handler.go:80
↓ 2 callers
Method
PutLog
PutLog adds received log messages to the corresponding log repository.
common/proto/log/cells-log_grpc.pb.go:22
↓ 2 callers
Method
PutRole
(context.Context, *idm.Role)
common/etl/models/stores.go:54
↓ 2 callers
Method
PutShare
(context.Context, *SyncShare)
common/etl/models/stores.go:58
↓ 2 callers
Method
PutTaskStream
(ctx context.Context, opts ...grpc.CallOption)
common/proto/jobs/cells-jobs_grpc.pb.go:26
↓ 2 callers
Method
PutTasks
(task map[string]map[string]*jobs.Task)
scheduler/jobs/dao.go:45
↓ 2 callers
Function
Q
(a,b,c,f)
frontend/assets/editor.ckeditor/res/ckeditor/samples/old/htmlwriter/assets/outputforflash/swfobject.js:11
↓ 2 callers
Function
Qd
(a,b,c,d)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:29
↓ 2 callers
Function
Qe
(a,b,c,d,e)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:135
↓ 2 callers
Function
QuoteTo
QuoteTo is a shortcut to db.QuoteTo
common/storage/sql/helper.go:73
↓ 2 callers
Function
R
()
frontend/assets/uploader.uppy/resources/uppy.min.js:1
↓ 2 callers
Function
Re
(a)
frontend/assets/editor.ckeditor/res/ckeditor/samples/toolbarconfigurator/lib/codemirror/codemirror.js:128
↓ 2 callers
Method
ReadChildZip
ReadChildZip reads content of a file contained in a zip archive
common/nodes/archive/archive-reader.go:166
↓ 2 callers
Method
ReadLastUserInbox
(userId string, boxName activity.BoxName)
broker/activity/dao/bolt/bolt.go:376
↓ 2 callers
Method
ReadNodeStream
ReadNodeStream implements ReadNode as a bidirectional stream
data/meta/grpc/handler.go:229
↓ 2 callers
Method
ReceiveAllNodes
()
common/nodes/mocks/listnodestreamer.go:85
↓ 2 callers
Method
Record
Record a specific duration directly.
common/telemetry/metrics/timer.go:59
↓ 2 callers
Method
Recv
()
common/nodes/mocks/listnodestreamer.go:68
↓ 2 callers
Function
Register
(b Broker)
common/broker/broker.go:51
↓ 2 callers
Function
RegisterCustomValueDiffer
(differ diff.ValueDiffer)
common/config/diff.go:17
↓ 2 callers
Function
RegisterDataServices
(ctx context.Context, nodes ...*tree.Node)
common/server/stubs/datatest/start-data.go:40
↓ 2 callers
Function
RegisterJobMiddlewares
RegisterJobMiddlewares tries to extract defined middlewares and store them in cache
scheduler/tasks/middlewares.go:28
↓ 2 callers
Function
RegisterModifier
RegisterModifier registers a middleware
common/middleware/context.go:68
↓ 2 callers
Function
RegisterNodeChangesStreamerServer
(s grpc.ServiceRegistrar, srv NodeChangesStreamerServer)
common/proto/tree/cells-tree_grpc.pb.go:356
↓ 2 callers
Function
RegisterNodeReceiverStreamServer
(s grpc.ServiceRegistrar, srv NodeReceiverStreamServer)
common/proto/tree/cells-tree_grpc.pb.go:817
↓ 2 callers
Function
RegisterNodesFreeStringEvaluator
(f FreeStringEvaluator)
common/proto/jobs/init.go:50
↓ 2 callers
Function
RegisterProvider
(p Provider)
common/auth/jwt.go:445
↓ 2 callers
Function
RegisterReadyzServer
(s grpc.ServiceRegistrar, srv ReadyzServer)
common/proto/server/cells-server_grpc.pb.go:65
↓ 2 callers
Function
RegisterSearcherServer
(s grpc.ServiceRegistrar, srv SearcherServer)
common/proto/tree/cells-tree_grpc.pb.go:1271
↓ 2 callers
Function
RegisterStorageEndpointServer
(s grpc.ServiceRegistrar, srv StorageEndpointServer)
common/proto/storage/cells-storage_grpc.pb.go:79
↓ 2 callers
Method
RegistryForStatus
(ctx context.Context, status RequestStatus)
common/service/frontend/pool.go:93
↓ 2 callers
Method
Reload
Reload reads config and call underlying loaders for each aspect (logging, metrics, profiling, tracing)
common/telemetry/telemetry.go:122
↓ 2 callers
Method
RemoveBucket
(ctx context.Context, bucketName string)
common/nodes/objects.go:38
↓ 2 callers
Method
RequirePreCount
()
common/storage/indexer/indexer.go:54
↓ 2 callers
Method
Reset
(ctx context.Context)
common/sync/model/endpoints.go:275
↓ 2 callers
Method
Resolve
(ctx context.Context, optionalData ...map[string]interface{})
common/utils/openurl/template.go:33
↓ 2 callers
Function
ResolveProxy
ResolveProxy is used with custom resolvers to resolve a proxyConfig to a runtime-usable configuration. Resolvers are implemented by proxies to write c
common/config/routing/proxies.go:96
↓ 2 callers
Function
RestoreTask
(ctx context.Context, router nodes.Client, paths []string, languages ...string)
scheduler/jobs/userspace/userspace.go:834
↓ 2 callers
Method
Resync
(context.Context, log2.ZapLogger)
broker/log/dao.go:48
↓ 2 callers
Method
ResyncDirtyEtags
Clean Operations ****************
common/storage/sql/index/dao.go:101
← previous
next →
3,901–4,000 of 22,850, ranked by callers