Functions — github.com/pydio/cells

CodeHub MCPcopy Create free account

hub / github.com/pydio/cells / functions

Functions22,850 in github.com/pydio/cells

⨍ Functions 22,850◇ Types & classes 3,951

common/registry/watcher.go:187

common/registry/graph.go:55

common/registry/registry.go:86

common/registry/registry.go:106

common/registry/service/watcher.go:83

(item registry.Item)

common/registry/service/client.go:137

common/registry/util/watcher-chan.go:64

(oo ...registry.RegisterOption)

common/registry/util/service.go:82

common/registry/util/watcher-interval.go:66

common/registry/util/watcher-interval.go:112

(item registry.Item)

common/registry/config/config.go:290

common/registry/config/config.go:621

common/utils/kv/etcd/store.go:451

common/utils/fork/process.go:113

common/utils/watch/watch.go:294

common/utils/watch/combine.go:60

common/utils/openurl/watch.go:131

Stop reports time elapsed since the stopwatch start to the recorder.

common/telemetry/metrics/timer.go:46

common/telemetry/metrics/prometheus/targets.go:133

(ctx context.Context, in *Item, opts ...grpc.CallOption)

common/proto/registry/cells-registry_grpc.pb.go:80

(context.Context, *Item)

common/proto/registry/cells-registry_grpc.pb.go:194

(context.Context, *Item)

common/proto/registry/cells-registry_grpc.pb.go:214

(ctx context.Context, in *StopRequest, opts ...grpc.CallOption)

common/proto/service/cells-service_grpc.pb.go:42

(context.Context, *StopRequest)

common/proto/service/cells-service_grpc.pb.go:56

(context.Context, *StopRequest)

common/proto/service/cells-service_grpc.pb.go:67

Stop shutdown service and clean registry

common/service/service.go:270

common/server/server.go:47

(oo ...registry.RegisterOption)

common/server/server.go:203

common/server/http/http.go:113

common/server/grpc/grpc.go:237

common/server/generic/generic.go:46

common/server/generic/generic.go:91

common/server/fork/fork.go:118

common/server/caddy/embed/server.go:150

common/server/caddy/embed/mux.go:61

common/server/caddy/api/server.go:119

Stop closes internal channels

common/sync/model/command.go:68

common/sync/endpoints/index/index-streamer.go:87

Stop closes Patch Channel and Interrupt Channel

common/sync/proc/processor-locker.go:62

common/sync/filters/echo-filter.go:61

common/config/refpool.go:513

common/config/sql/sql.go:306

common/config/service/remote.go:312

common/config/mock/mock.go:460

(ctx context.Context, item *pb.Item)

discovery/registry/handler.go:92

gateway/data/service.go:244

common/runtime/manager/manager.go:1290

MethodStorageInfo

StorageInfo is not relevant to S3 backend.

gateway/data/gw/gateway-pydio.go:241

MethodStorageStats

StorageStats returns statistics about storage

data/source/objects/grpc/handler.go:199

MethodStorageStats

(ctx context.Context, in *StorageStatsRequest, opts ...grpc.CallOption)

common/proto/object/cells-object_grpc.pb.go:42

MethodStorageStats

(context.Context, *StorageStatsRequest)

common/proto/object/cells-object_grpc.pb.go:56

MethodStorageStats

(context.Context, *StorageStatsRequest)

common/proto/object/cells-object_grpc.pb.go:67

FunctionStorageUrlAsProvider

(storageURL string)

cmd/cells-fuse/fs/parser.go:56

(accessToken string, token *auth.PersonalAccessToken, _ bool)

idm/oauth/dao/sql/mem.go:56

(accessToken string, token *auth.PersonalAccessToken, update bool)

idm/oauth/dao/sql/pat-sql.go:156

(key string, val interface{})

common/storage/sql/index/gorm-cache.go:33

(c *transport.SdkConfig, token string, expiry time.Duration)

common/sync/endpoints/cells/transport/oidc/tokens.go:63

MethodStoreLastUserInbox

(ctx context.Context, userId string, boxName BoxName, activityId string)

broker/activity/cache.go:199

MethodStoreLastUserInbox

(ctx context.Context, userId string, boxName activity.BoxName, activityId string)

broker/activity/dao/mongo/mongo.go:288

MethodStoreLastUserInbox

(ctx context.Context, userId string, boxName activity.BoxName, activityId string)

broker/activity/dao/bolt/bolt.go:393

MethodStoreNewTags

StoreNewTags checks if there are new values and update the list in the docstore accordingly

idm/meta/tags-values.go:81

MethodStorePolicyGroup

Missing associated documentation comment in .proto file.

python/cells_idm_pb2_grpc.py:1072

MethodStorePolicyGroup

(request, target, options=(), channel_credentials=None, call_c

python/cells_idm_pb2_grpc.py:1155

MethodStorePolicyGroup

(ctx context.Context, group *idm.PolicyGroup)

idm/policy/defaults_test.go:296

MethodStorePolicyGroup

(ctx context.Context, request *idm.StorePolicyGroupRequest)

idm/policy/grpc/handler.go:240

MethodStorePolicyGroup

StorePolicyGroup first upserts policies (and fail fast) before upserting the passed policy group and recreating corresponding relations.

idm/policy/dao/sql/sql.go:179

MethodStorePolicyGroup

(ctx context.Context, in *StorePolicyGroupRequest, opts ...grpc.CallOption)

common/proto/idm/cells-idm_grpc.pb.go:1777

MethodStorePolicyGroup

(context.Context, *StorePolicyGroupRequest)

common/proto/idm/cells-idm_grpc.pb.go:1835

MethodStorePolicyGroup

(context.Context, *StorePolicyGroupRequest)

common/proto/idm/cells-idm_grpc.pb.go:1852

MethodStoreVersion

Missing associated documentation comment in .proto file.

python/cells_tree_pb2_grpc.py:1140

MethodStoreVersion

(request, target, options=(), channel_credentials=None, call_c

python/cells_tree_pb2_grpc.py:1245

MethodStoreVersion

(ctx context.Context, request *tree.StoreVersionRequest)

data/versions/grpc/handler.go:193

MethodStoreVersion

(ctx context.Context, nodeUuid string, revision *tree.ContentRevision)

data/versions/dao/mongo/mongo.go:155

MethodStoreVersion

StoreVersion stores a version in the node bucket.

data/versions/dao/bolt/bolt.go:152

MethodStoreVersion

(ctx context.Context, in *StoreVersionRequest, opts ...grpc.CallOption)

common/proto/tree/cells-tree_grpc.pb.go:1441

MethodStoreVersion

(context.Context, *StoreVersionRequest)

common/proto/tree/cells-tree_grpc.pb.go:1546

MethodStoreVersion

(context.Context, *StoreVersionRequest)

common/proto/tree/cells-tree_grpc.pb.go:1562

Stream returns a collection of activities

broker/activity/rest/handler.go:73

MethodStreamACL

Stream version of Search ACL

python/cells_idm_pb2_grpc.py:692

MethodStreamACL

(request_iterator, target, options=(), channel_credentials=None,

python/cells_idm_pb2_grpc.py:821

MethodStreamACL

(ctx context.Context, opts ...grpc.CallOption)

common/proto/idm/cells-idm_grpc.pb.go:941

MethodStreamACL

Stream version of Search ACL

common/proto/idm/cells-idm_grpc.pb.go:983

MethodStreamACL

(grpc.BidiStreamingServer[SearchACLRequest, SearchACLResponse])

common/proto/idm/cells-idm_grpc.pb.go:1008

MethodStreamActivities

(request *proto.StreamActivitiesRequest, stream proto.ActivityService_StreamActivitiesServer)

broker/activity/grpc/handler.go:75

MethodStreamActivities

(ctx context.Context, in *StreamActivitiesRequest, opts ...grpc.CallOption)

common/proto/activity/cells-activitystream_grpc.pb.go:72

MethodStreamActivities

(*StreamActivitiesRequest, ActivityService_StreamActivitiesServer)

common/proto/activity/cells-activitystream_grpc.pb.go:177

MethodStreamActivities

(*StreamActivitiesRequest, ActivityService_StreamActivitiesServer)

common/proto/activity/cells-activitystream_grpc.pb.go:193

MethodStreamChanges

Missing associated documentation comment in .proto file.

python/cells_tree_pb2_grpc.py:223

MethodStreamChanges

(request, target, options=(), channel_credentials=None, call_c

python/cells_tree_pb2_grpc.py:249

MethodStreamChanges

(req *tree.StreamChangesRequest, streamer tree.NodeChangesStreamer_StreamChangesServer)

data/tree/grpc/handler.go:700

MethodStreamChanges

(ctx context.Context, in *StreamChangesRequest, opts ...grpc.CallOption)

common/proto/tree/cells-tree_grpc.pb.go:300

MethodStreamChanges

(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer)

common/proto/tree/cells-tree_grpc.pb.go:336

MethodStreamChanges

(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer)

common/proto/tree/cells-tree_grpc.pb.go:344

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/tracer.go:92

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/handler-mock.go:248

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/abstract/handler-abstract.go:118

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/abstract/handler-abstract-filter.go:199

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/core/handler-exec.go:481

MethodStreamChanges

StreamChanges optionally replaces ETag value with the custom x-cells-hash metadata

common/nodes/put/handler-hash.go:219

MethodStreamChanges

(ctx context.Context, in *tree.StreamChangesRequest, opts ...grpc.CallOption)

common/nodes/compose/client.go:162

← previous next →17,601–17,700 of 22,850, ranked by callers