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
Method
SetupChannels
SetupChannels registers status chan internally. Done chan is ignored
common/sync/merger/tree-diff.go:290
Method
SetupCmd
(cmd *model.Command)
common/sync/task/sync.go:236
Method
SetupDecryptMode
(workingKey []byte, stream io.Reader)
common/crypto/materials.go:525
Function
ShortCacheDAO
(db boltdb.DB)
broker/activity/dao/bolt/bolt.go:59
Function
ShouldWarnPublicBind
ShouldWarnPublicBind browses all interfaces addresses and detect if some are considered public. This is used when the bind_address is not specified an
common/utils/net/ips.go:160
Method
Shutdown
(ctx context.Context)
common/telemetry/tracing/exporters.go:23
Method
Shutdown
(ctx context.Context)
common/telemetry/tracing/exporters.go:38
Method
Shutdown
(ctx context.Context)
common/telemetry/tracing/jaeger/jaeger.go:158
Method
Shutdown
Shutdown closes channels
common/sync/task/sync.go:150
Method
Shutdown
Shutdown implements Shutdowner
common/sync/endpoints/snapshot/boltdb.go:413
Method
Shutdown
()
common/sync/endpoints/bus/pubsub.go:597
Method
Shutdown
Shutdown saves any gateway metadata to disk if necessary and reload upon next restart.
gateway/data/gw/gateway-pydio.go:235
Method
Sibling
Sibling of a specific path
common/proto/tree/node.go:659
Method
Size
()
common/service/frontend/http-union.go:204
Method
Size
Size gets length in bytes for regular files; system-dependent for others
common/sync/endpoints/s3/file_info.go:46
Method
SkipFilterToTarget
(skip bool)
common/sync/merger/patch-abstract.go:182
Method
SkipRecomputeEtagByCopy
SkipRecomputeEtagByCopy sets a special behavior to avoir recomputing etags by in-place copying objects on storages that do not support this feature
common/sync/endpoints/s3/client-s3.go:114
Method
SkipRecomputeEtagByCopy
SkipRecomputeEtagByCopy sets a special behavior to avoir recomputing etags by in-place copying objects on storages that do not support this feature
common/sync/endpoints/s3/multi-bucket.go:406
Function
SkipTestConcurrentReceivesGetAllTheMessages
(t *testing.T)
common/broker/grpcpubsub/broker_test.go:161
Function
SkipTestController
(t *testing.T)
common/storage/sql/gorm_test.go:50
Function
SkipTestController
SkipTestController TODO may need some rewrite
common/storage/boltdb/boltdb_test.go:25
Function
SkipTestDBPool
(t *testing.T)
common/storage/sql/gorm_test.go:136
Function
SkipTestGenerateJsonLanguagesFiles
(t *testing.T)
common/forms/protos/proto-to-form_test.go:89
Function
SkipTestIndexLongNode
(t *testing.T)
data/source/index/grpc/handler_test.go:662
Function
SkipTestManagerConnection
(t *testing.T)
common/runtime/manager/manager_test.go:156
Function
SkipTestMassiveQueries
(t *testing.T)
broker/activity/dao/dao_test.go:845
Function
SkipTestObjectHandler_StartMinioServer
SkipTestObjectHandler_StartMinioServer - skipped for now, it does not stop when context is done
data/source/objects/grpc/handler_test.go:18
Function
SkipTestRandomCaptures
(t *testing.T)
common/sync/merger/tree-patch_test.go:488
Function
SkipTestStore_Watch
Skipping for now as store.Watch always returns an error!
common/utils/kv/values_test.go:264
Function
SkipTestTaskLogs
(t *testing.T)
scheduler/tasks/task_test.go:110
Method
Slice
()
common/utils/kv/values.go:165
Method
Slice
()
common/utils/configx/config.go:444
Method
Slice
()
common/storage/sql/index/factory.go:43
Method
Slice
()
common/config/refpool.go:458
Method
Slice
Slice value
common/config/vault.go:274
Method
Slice
()
common/config/viper/viper.go:337
Method
SoftwareKeyManager
()
idm/oauth/dao-registry.go:177
Function
SoundManager
* The SoundManager constructor. * * @constructor * @param {string} smURL Optional: Path to SWF files * @param {string} smID Optional: The ID to us
frontend/assets/editor.soundmanager/sm/shared/soundmanager2.js:49
Function
Source
Source option for a service
common/service/options.go:161
Method
Source
Source returns the operation source from the attached Patch
common/sync/merger/merger.go:164
Function
Stage
()
frontend/assets/gui.ajax/res/js/ui/Components/chat/LKRoom.js:14
Method
Stamp
Stamp set the last modified date on this patch
common/sync/merger/merger.go:218
Method
Stamp
(t time.Time)
common/sync/merger/patch-abstract.go:71
Method
Start
Missing associated documentation comment in .proto file.
python/cells_registry_pb2_grpc.py:73
Method
Start
(request, target, options=(), channel_credentials=None, call_c
python/cells_registry_pb2_grpc.py:197
Method
Start
Missing associated documentation comment in .proto file.
python/cells_service_pb2_grpc.py:32
Method
Start
(request, target, options=(), channel_credentials=None, call_c
python/cells_service_pb2_grpc.py:68
Method
Start
(oo ...RegisterOption)
common/registry/items.go:75
Method
Start
(i Item)
common/registry/graph.go:51
Method
Start
(item registry.Item)
common/registry/service/client.go:129
Method
Start
(oo ...registry.RegisterOption)
common/registry/util/service.go:78
Method
Start
(item registry.Item)
common/registry/config/config.go:286
Method
Start
()
common/telemetry/metrics/timer.go:70
Method
Start
(ctx context.Context, in *Item, opts ...grpc.CallOption)
common/proto/registry/cells-registry_grpc.pb.go:71
Method
Start
(context.Context, *Item)
common/proto/registry/cells-registry_grpc.pb.go:193
Method
Start
(context.Context, *Item)
common/proto/registry/cells-registry_grpc.pb.go:211
Method
Start
(ctx context.Context, in *StartRequest, opts ...grpc.CallOption)
common/proto/service/cells-service_grpc.pb.go:33
Method
Start
(context.Context, *StartRequest)
common/proto/service/cells-service_grpc.pb.go:55
Method
Start
(context.Context, *StartRequest)
common/proto/service/cells-service_grpc.pb.go:64
Method
Start
Start runs service and update registry as required
common/service/service.go:184
Method
Start
()
common/server/generic/generic.go:45
Method
Start
Start starts listening for Patch channel
common/sync/proc/processor-locker.go:57
Method
Start
()
common/sync/filters/echo-filter.go:57
Method
Start
(ctx context.Context, item *pb.Item)
discovery/registry/handler.go:84
Method
Start
(ctx context.Context)
gateway/data/service.go:180
Method
StartSession
StartSession opens a new indexation session and returns it
common/sync/model/endpoints.go:238
Method
StartSession
StartSession starts an indexation session.
common/sync/endpoints/cells/remote-streamer.go:90
Method
StartSession
(ctx context.Context, rootNode tree.N, silent bool)
common/sync/endpoints/index/index-endpoint.go:190
Method
StartSession
StartSession forwards session management to underlying snapshot
common/sync/endpoints/filesystem/client-fs.go:152
Method
StartSession
(ctx context.Context, rootNode tree.N, silent bool)
common/sync/endpoints/snapshot/boltdb.go:235
Method
StartSession
(ctx context.Context, rootNode tree.N, silent bool)
common/sync/endpoints/bus/pubsub_test.go:531
Method
StartSession
StartSession overrides AbstractPatch method to handle source and/or target as session provider
common/sync/merger/bidirectional-patch.go:122
Method
StartSession
(rootNode tree.N)
common/sync/merger/patch-abstract.go:150
Method
Stat
()
common/service/frontend/http-union.go:188
Method
Stat
Stat creates an os.FileInfo from the internal router.ReadNode() method
gateway/dav/filesystem.go:220
Method
StatAdminTree
(req *restful.Request, resp *restful.Response)
data/tree/rest/rest.go:226
Method
StatObject
(ctx context.Context, bucketName, objectName string, opts models.ReadMeta)
common/nodes/objects/mock/client.go:104
Method
StatObject
(ctx context.Context, bucketName, objectName string, opts models.ReadMeta)
common/nodes/objects/mc/folders-hidden.go:36
Method
StatObject
(ctx context.Context, bucketName, objectName string, opts models.ReadMeta)
common/nodes/objects/mc/client.go:172
Method
Stats
()
data/source/sync/grpc/syncer-flat.go:160
Method
Stats
(ctx context.Context)
broker/log/repository.go:106
Method
Stats
Stats method - TODO
common/storage/mongodb/indexer.go:435
Method
Stats
()
common/storage/boltdb/boltdb.go:316
Method
Stats
Stats returns statistics about current indexer
common/storage/indexer/indexer.go:87
Method
Stats
func (s *Indexer) WatchStatus() (registry.StatusWatcher, error) { if s.debouncer == nil { s.debouncer = debounce.New(5 * time.Second) s.statusInp
common/storage/bleve/indexer.go:161
Method
Stats
()
common/sync/task/sync-run_test.go:40
Method
Stats
()
common/sync/model/stater.go:45
Method
Stats
()
common/sync/endpoints/memory/mem_db.go:307
Method
Status
Status notify of a new ProcessStatus
common/sync/model/status.go:83
Method
Status
()
common/sync/model/status.go:133
Method
Status
(s model.Status)
common/sync/filters/events-batcher.go:299
Method
Status
(status model.Status)
common/sync/merger/operation.go:242
Method
Stop
Missing associated documentation comment in .proto file.
python/cells_registry_pb2_grpc.py:79
Method
Stop
(request, target, options=(), channel_credentials=None, call_c
python/cells_registry_pb2_grpc.py:214
Method
Stop
Missing associated documentation comment in .proto file.
python/cells_service_pb2_grpc.py:38
Method
Stop
(request, target, options=(), channel_credentials=None, call_c
python/cells_service_pb2_grpc.py:85
Method
Stop
()
common/client/resolver.go:126
Method
Stop
()
common/client/http/resolver.go:103
Method
Stop
()
common/client/grpc/health.go:37
Method
Stop
()
common/client/grpc/health.go:94
← previous
next →
17,501–17,600 of 22,850, ranked by callers