MCPcopy Create free account

hub / github.com/aclindsa/asink / functions

Functions126 in github.com/aclindsa/asink

⨍ Functions 126◇ Types & classes 32
↓ 22 callersMethodClose
()
asink/storage_local.go:55
↓ 17 callersMethodError
()
asink/process_events.go:34
↓ 6 callersFunctionProcessLocalEvent_Upper
(globals *AsinkGlobals, event *asink.Event)
asink/process_events.go:133
↓ 5 callersMethodWrite
(p []byte)
asink/storage_local.go:51
↓ 4 callersMethodIsUpdate
()
events.go:43
↓ 4 callersFunctionLockPath
locks the path to ensure nothing else inside asink is mucking with that file. 'local' determines the precedence of the lock - all local lock requester
asink/path_map.go:100
↓ 4 callersFunctionProcessRemoteEvent
(globals *AsinkGlobals, event *asink.Event)
asink/process_events.go:337
↓ 4 callersFunctionUnlockPath
unlocks the path, storing the updated event back to the database
asink/path_map.go:107
↓ 3 callersFunctionHashPassword
(pw string)
asinkd/users.go:27
↓ 3 callersFunctionStatOnline
()
asink/status.go:70
↓ 3 callersFunctionStatStartLocalUpdate
()
asink/status.go:40
↓ 3 callersFunctionStatStopDownload
()
asink/status.go:61
↓ 3 callersFunctionStatStopLocalUpdate
()
asink/status.go:43
↓ 3 callersMethodString
()
asinkd/user_admin.go:38
↓ 3 callersFunctiongetEvents
(w http.ResponseWriter, r *http.Request, user *User, nextEvent uint64)
asinkd/server.go:90
↓ 2 callersFunctionAuthenticatedRequest
(method, url, bodyType string, body io.Reader, username, password string)
asink/net.go:35
↓ 2 callersMethodDatabaseGetUser
(username string)
asinkd/database.go:213
↓ 2 callersFunctionErrorWasExit
(err error)
asink/process_events.go:58
↓ 2 callersMethodIsDelete
()
events.go:47
↓ 2 callersMethodIsSameEvent
(e2 *Event)
events.go:51
↓ 2 callersFunctionProcessLocalEvent
(globals *AsinkGlobals, event *asink.Event)
asink/process_events.go:100
↓ 2 callersFunctionProcessLocalEvent_Lower
(globals *AsinkGlobals, event *asink.Event)
asink/process_events.go:234
↓ 2 callersMethodSet
(value string)
asinkd/user_admin.go:28
↓ 2 callersFunctionStatOffline
()
asink/status.go:77
↓ 2 callersFunctiongetSocketFromArgs
(args []string)
asink/client.go:155
↓ 2 callersFunctionhandleConflict
handle a conflict by copying the loser event to another file
asink/process_events.go:78
↓ 2 callersFunctionprocessLocalEvent_Lower
(globals *AsinkGlobals, event *asink.Event, latestLocal *asink.Event)
asink/process_events.go:253
↓ 2 callersFunctionprocessLocalEvent_Upper
(globals *AsinkGlobals, event *asink.Event, latestLocal *asink.Event, absolutePath string)
asink/process_events.go:160
↓ 1 callersFunctionAuthenticateUser
(r *http.Request)
asinkd/server.go:215
↓ 1 callersFunctionAuthenticatedGet
(url string, username, password string)
asink/net.go:47
↓ 1 callersFunctionAuthenticatedPost
(url, bodyType string, body io.Reader, username, password string)
asink/net.go:50
↓ 1 callersFunctionCopyReaderToTmp
(src io.Reader, tmpdir string)
util/util.go:53
↓ 1 callersMethodDatabaseAddEvent
(e *asink.Event)
asink/database.go:59
↓ 1 callersMethodDatabaseAddEvents
(u *User, events []*asink.Event)
asinkd/database.go:71
↓ 1 callersMethodDatabaseAddUser
(u *User)
asinkd/database.go:128
↓ 1 callersMethodDatabaseDeleteUser
(u *User)
asinkd/database.go:233
↓ 1 callersMethodDatabaseGetAllFiles
Sends events down resultsChan for all files currently tracked in the database. nil will be sent to signify there are no more events. If an error occur
asink/database.go:173
↓ 1 callersMethodDatabaseLatestEventForPath
returns nil if no such event exists
asink/database.go:129
↓ 1 callersMethodDatabaseLatestRemoteEvent
returns nil if no such event exists
asink/database.go:150
↓ 1 callersMethodDatabaseRetrieveEvents
(firstId uint64, maxEvents uint, u *User)
asinkd/database.go:106
↓ 1 callersMethodDatabaseUpdateEvent
(e *asink.Event)
asink/database.go:91
↓ 1 callersMethodDatabaseUpdateUser
set attributes for the user with the same Id as *u
asinkd/database.go:173
↓ 1 callersFunctionErrorRequiresExit
(err error)
asink/process_events.go:67
↓ 1 callersMethodGet
Close() MUST be called on the returned io.ReadCloser
asink/storage.go:19
↓ 1 callersFunctionGetAndInitDB
()
asinkd/database.go:23
↓ 1 callersFunctionGetAndInitDB
(config *conf.ConfigFile)
asink/database.go:22
↓ 1 callersFunctionGetEvents
(globals *AsinkGlobals, events chan *asink.Event)
asink/net.go:133
↓ 1 callersFunctionGetStats
low bit is 1 if online, 0 if offline
asink/status.go:20
↓ 1 callersFunctionGetStorage
(config *conf.ConfigFile)
asink/storage.go:22
↓ 1 callersFunctionHashFile
(filename string)
asink/hash.go:14
↓ 1 callersFunctionNewDecrypter
(ciphertextReader io.ReadCloser, key string)
asink/encryption.go:20
↓ 1 callersFunctionNewEncrypter
(writer io.WriteCloser, key string)
asink/encryption.go:12
↓ 1 callersFunctionNewFTPStorage
(config *conf.ConfigFile)
asink/storage_ftp.go:26
↓ 1 callersFunctionNewGDriveStorage
(config *conf.ConfigFile)
asink/storage_gdrive.go:29
↓ 1 callersFunctionNewLocalStorage
(config *conf.ConfigFile)
asink/storage_local.go:22
↓ 1 callersFunctionNewNormalContext
(globals *AsinkGlobals, localChan chan *asink.Event, remoteChan chan *asink.Event, exitChan chan int)
asink/context_normal.go:22
↓ 1 callersFunctionNewStartupContext
(globals *AsinkGlobals, localChan chan *asink.Event, remoteChan chan *asink.Event, initialWalkComplete chan in
asink/context_startup.go:22
↓ 1 callersFunctionPathLocker
(db *AsinkDB)
asink/path_map.go:27
↓ 1 callersMethodPut
Close() MUST be called on the returned io.WriteCloser. When the upload is complete either nil or an error will be written to the 'done' channel.
asink/storage.go:17
↓ 1 callersMethodRun
()
asink/context_normal.go:72
↓ 1 callersMethodRun
()
asink/context_startup.go:32
↓ 1 callersFunctionSendEvent
(globals *AsinkGlobals, event *asink.Event)
asink/net.go:126
↓ 1 callersFunctionSendEvents
(globals *AsinkGlobals)
asink/net.go:93
↓ 1 callersFunctionStartRPC
(sock string, tornDown chan int, adb *AsinkDB)
asinkd/rpc_server.go:81
↓ 1 callersFunctionStartRPC
(sock string, tornDown chan int)
asink/rpc_server.go:27
↓ 1 callersFunctionStartWatching
(watchDir string, fileUpdates chan *asink.Event, initialWalkComplete chan int)
asink/watcher.go:16
↓ 1 callersFunctionStatStartDownload
()
asink/status.go:58
↓ 1 callersFunctionStatStartRemoteUpdate
()
asink/status.go:46
↓ 1 callersFunctionStatStartSending
()
asink/status.go:64
↓ 1 callersFunctionStatStartUpload
()
asink/status.go:52
↓ 1 callersFunctionStatStopRemoteUpdate
()
asink/status.go:49
↓ 1 callersFunctionStatStopSending
()
asink/status.go:67
↓ 1 callersFunctionStatStopUpload
()
asink/status.go:55
↓ 1 callersMethodValidPassword
(pw string)
asinkd/users.go:33
↓ 1 callersFunctionactuallySendEvents
(globals *AsinkGlobals, events []*asink.Event)
asink/net.go:54
↓ 1 callersFunctionaddPoller
(uid int64, channel *chan *asink.Event)
asinkd/longpolling.go:30
↓ 1 callersFunctionbroadcastToPollers
(uid int64, event *asink.Event)
asinkd/longpolling.go:64
↓ 1 callersFunctionexitChanWaiter
(waiterChan chan int)
exit.go:52
↓ 1 callersFunctionnewBoolIsSetFlag
(defaultValue bool)
asinkd/user_admin.go:22
↓ 1 callersFunctionputEvents
(w http.ResponseWriter, r *http.Request, user *User)
asinkd/server.go:131
↓ 1 callersMethodrunWorker
()
asink/context_normal.go:31
↓ 1 callersFunctionsetupCleanExitOnSignals
()
exit.go:26
MethodAddUser
(user *User, result *int)
asinkd/rpc_server.go:26
FunctionCopyToTmp
(src string, tmpdir string)
util/util.go:68
FunctionEnsureDirExists
(dir string)
util/util.go:15
FunctionErrorFileNotFound
(err error)
util/util.go:78
FunctionExit
(exitCode int)
exit.go:43
FunctionFileExistsAndHasPermissions
(file string, mode os.FileMode)
util/util.go:35
MethodGet
(hash string)
asink/storage_ftp.go:106
MethodGet
(hash string)
asink/storage_gdrive.go:131
MethodGet
(hash string)
asink/storage_local.go:78
MethodGetClientStatus
(code *int, result *string)
asink/rpc_server.go:22
FunctionGetStatus
(args []string)
asink/client.go:197
MethodIsAdmin
()
asinkd/users.go:37
MethodIsBoolFlag
()
asinkd/user_admin.go:40
MethodModifyUser
(args *UserModifierArgs, result *int)
asinkd/rpc_server.go:36
FunctionPrintVersion
(args []string)
asinkd/main.go:70
FunctionPrintVersion
(args []string)
asink/main.go:60
MethodPut
(hash string, done chan error)
asink/storage_ftp.go:60
MethodPut
(hash string, done chan error)
asink/storage_gdrive.go:110
next →1–100 of 126, ranked by callers