MCPcopy Create free account

hub / github.com/GoCollaborate/src / functions

Functions406 in github.com/GoCollaborate/src

⨍ Functions 406◇ Types & classes 79
↓ 15 callersMethodLogError
(content interface{}, vars ...interface{})
logger/logger.go:68
↓ 15 callersMethodLogNormal
(content interface{}, vars ...interface{})
logger/logger.go:72
↓ 12 callersMethodGetCards
()
artifacts/iremote/idigest.go:8
↓ 10 callersMethodGetTimeStamp
()
artifacts/iremote/idigest.go:9
↓ 10 callersMethodLogWarning
(content interface{}, vars ...interface{})
logger/logger.go:64
↓ 9 callersMethodError
()
artifacts/task/taskFuture.go:40
↓ 9 callersMethodType
()
artifacts/iremote/imessage.go:6
↓ 8 callersMethodAdd
(f func(source *task.Collection, result *task.Collection, context *task.TaskContext) bool, id ...string)
store/store.go:83
↓ 8 callersMethodClose
()
artifacts/iworkable/iworkable.go:20
↓ 8 callersMethodGetDigest
()
collaborator/case.go:89
↓ 8 callersMethodGetFullIP
()
artifacts/card/card.go:26
↓ 8 callersMethodLogListPoint
(content ...interface{})
logger/logger.go:76
↓ 7 callersMethodSet
(key string, val interface{})
artifacts/task/taskContext.go:24
↓ 7 callersMethodSetStatus
(status constants.Header)
artifacts/message/message.go:51
↓ 6 callersMethodExecute
(sources map[int]*task.Task)
artifacts/iexecutor/iexecutor.go:8
↓ 5 callersMethodExchange
(ctx context.Context, in *message.CardMessage, opts ...grpc.CallOption)
collaborator/services/rpc_services.pb.go:48
↓ 5 callersMethodHandle
Start handling server routes.
collaborator/collaborator.go:188
↓ 5 callersMethodInit
(s *Stage)
artifacts/task/job.go:83
↓ 5 callersFunctionnow
()
logger/logger.go:124
↓ 4 callersMethodGetCluster
()
collaborator/case.go:85
↓ 4 callersMethodIsEqualTo
(another *Card)
artifacts/card/card.go:42
↓ 4 callersMethodLogProgress
(content interface{}, vars ...interface{})
logger/logger.go:60
↓ 4 callersMethodRecord
Record a hit
artifacts/stats/stats.go:92
↓ 4 callersMethodSetType
(msgType CardMessage_Type)
artifacts/message/message.go:56
↓ 4 callersMethodString
()
artifacts/card/card.pb.go:39
↓ 3 callersMethodDistribute
(ctx context.Context, in *task.TaskPayload, opts ...grpc.CallOption)
collaborator/services/rpc_services.pb.go:47
↓ 3 callersMethodDone
(*task.Task)
artifacts/iworkable/iworkable.go:16
↓ 3 callersMethodGet
(key string)
artifacts/task/taskContext.go:30
↓ 3 callersMethodLen
()
artifacts/task/job.go:29
↓ 3 callersMethodObserve
Specify the custom route to observe
artifacts/stats/stats.go:107
↓ 3 callersMethodPushBack
(back *Stage)
artifacts/task/job.go:94
↓ 3 callersMethodSetCards
(map[string]*card.Card)
artifacts/iremote/idigest.go:10
↓ 3 callersMethodSetTimeStamp
(int64)
artifacts/iremote/idigest.go:11
↓ 2 callersFunctionDecode
(payload *TaskPayload)
collaborator/services/task_service.go:22
↓ 2 callersMethodDelayExecute
Execute the tasks after satisfying some certain conditions.
collaborator/collaborator.go:484
↓ 2 callersFunctionEncode
(maps *map[int]*Task)
collaborator/services/task_service.go:9
↓ 2 callersMethodExchange
(in *message.CardMessage)
collaborator/client_stub.go:61
↓ 2 callersMethodExes
(i int)
artifacts/task/job.go:120
↓ 2 callersFunctionFromIOReader
(reader io.Reader)
helpers/ioHelper/ioHelper.go:66
↓ 2 callersMethodFront
()
artifacts/task/job.go:41
↓ 2 callersMethodGetExecutor
(name string)
store/store.go:151
↓ 2 callersMethodGetFullExposureAddress
()
artifacts/card/card.go:30
↓ 2 callersMethodGetLimiter
(name string)
store/store.go:209
↓ 2 callersMethodGetPort
()
artifacts/card/card.pb.go:50
↓ 2 callersMethodGetPriority
()
artifacts/task/task.go:33
↓ 2 callersMethodGetTo
()
artifacts/message/message.pb.go:119
↓ 2 callersMethodIsDone
()
artifacts/task/taskFuture.go:32
↓ 2 callersMethodIsSeed
()
artifacts/card/card.go:46
↓ 2 callersMethodJoin
Join a master to the collaborator network.
collaborator/collaborator.go:47
↓ 2 callersFunctionMakeStage
(prev *Stage, next *Stage, tset ...map[int]*Task)
artifacts/task/stage.go:17
↓ 2 callersMethodMap
(sources map[int]*task.Task)
artifacts/imapper/imapper.go:8
↓ 2 callersFunctionNewServiceClientStub
(endpoint string, port int32, secure ...bool)
collaborator/client_stub.go:18
↓ 2 callersMethodNext
()
artifacts/task/stage.go:13
↓ 2 callersMethodReceive
()
artifacts/restful/restful.go:129
↓ 2 callersMethodReturn
(out bool)
artifacts/task/taskFuture.go:21
↓ 2 callersMethodSetCluster
(cluster string)
artifacts/message/message.go:24
↓ 2 callersMethodSetFrom
(from *card.Card)
artifacts/message/message.go:29
↓ 2 callersMethodSetTimeStamp
(timestamp int64)
artifacts/message/message.go:46
↓ 2 callersMethodSetTo
(to *card.Card)
artifacts/message/message.go:35
↓ 2 callersMethodStart
()
artifacts/worker/worker.go:21
↓ 2 callersMethodString
()
artifacts/task/task.pb.go:35
↓ 2 callersMethodTodo
(todo func(sources map[int]*task.Task) (map[int]*task.Task, error))
artifacts/iexecutor/iexecutor.go:9
↓ 2 callersMethodUpdate
(dgst iremote.IDigest)
collaborator/case.go:93
↓ 2 callersMethoddelete
(id string)
store/store.go:232
↓ 2 callersFunctionprintProgress
(num interface{}, tol interface{})
collaborator/collaborator.go:504
↓ 2 callersFunctionvalueFloatX
(s string, v reflect.Value, x int)
helpers/ioHelper/ioHelper.go:254
↓ 2 callersFunctionvalueIntX
(s string, v reflect.Value, x int)
helpers/ioHelper/ioHelper.go:245
↓ 2 callersMethodwriteStream
()
collaborator/case.go:54
↓ 1 callersFunctionAbsPolicySumOfInt
()
artifacts/stats/stats.go:192
↓ 1 callersMethodAction
()
collaborator/case.go:62
↓ 1 callersFunctionAdaptHTTPWithStatus
make sure AdaptHTTPWithStatus is lastly added to the response writer, otherwise it would not work (ref: https://golang.org/pkg/net/http/#ResponseWrite
utils/adapter.go:28
↓ 1 callersMethodAddLocal
(methods []string, jobs ...func(w http.ResponseWriter, r *http.Request, bg *task.Background))
store/store.go:191
↓ 1 callersMethodAddShared
(methods []string, jobs ...func(w http.ResponseWriter, r *http.Request, bg *task.Background))
store/store.go:198
↓ 1 callersMethodAppend
(cs ...interface{})
artifacts/task/task.go:62
↓ 1 callersMethodBatchAttach
(amount int)
artifacts/master/master.go:93
↓ 1 callersMethodCall
(id string, source *task.Collection, result *task.Collection, context *task.TaskContext)
store/store.go:111
↓ 1 callersMethodCatchup
Catchup with peer servers.
collaborator/collaborator.go:109
↓ 1 callersMethodClean
Clean up the case, release terminated servers.
collaborator/collaborator.go:172
↓ 1 callersMethodClose
()
artifacts/task/taskFuture.go:25
↓ 1 callersMethodCurr
()
artifacts/task/job.go:37
↓ 1 callersFunctionDecode
The code below is inspired and adapted from radioinmyhead/csv (https://github.com/radioinmyhead/csv/blob/master/csv.go) Updates: - Float64 type suppor
helpers/ioHelper/ioHelper.go:86
↓ 1 callersFunctionDefaultAbstractArray
()
artifacts/stats/stats.go:188
↓ 1 callersMethodDistributeAsync
(source *map[int]*task.Task)
collaborator/client_stub.go:41
↓ 1 callersMethodDistributeSeq
Distribute tasks to peer servers, the tasks will be sequentially sent.
collaborator/collaborator.go:224
↓ 1 callersMethodDone
()
artifacts/message/messageFuture.go:32
↓ 1 callersMethodDoneMulti
(tsks map[int]*task.Task)
artifacts/iworkable/iworkable.go:17
↓ 1 callersMethodEnqueue
(ts map[int]*task.Task)
artifacts/iworkable/iworkable.go:15
↓ 1 callersMethodEnqueue
(ts map[int]*task.Task)
artifacts/master/master.go:26
↓ 1 callersMethodError
()
artifacts/message/messageFuture.go:36
↓ 1 callersFunctionFromBytes
(bs []byte)
helpers/ioHelper/ioHelper.go:62
↓ 1 callersFunctionFromFile
(f *os.File)
helpers/ioHelper/ioHelper.go:54
↓ 1 callersMethodGetFrom
()
artifacts/message/message.pb.go:112
↓ 1 callersMethodGetFullExposureCard
()
artifacts/card/card.go:34
↓ 1 callersFunctionGetLocalIP
()
utils/network.go:70
↓ 1 callersMethodGetPayload
()
artifacts/task/task.pb.go:39
↓ 1 callersMethodGetTs
()
artifacts/digest/digest.pb.go:60
↓ 1 callersMethodGetType
()
artifacts/task/task.go:28
↓ 1 callersMethodGetType
()
artifacts/task/task.go:36
↓ 1 callersMethodHAdd
(f func(source *task.Collection, result *task.Collection, context *task.TaskContext) bool)
store/store.go:98
↓ 1 callersMethodHandleLocal
Handle local Job routes.
collaborator/collaborator.go:296
next →1–100 of 406, ranked by callers