MCPcopy Create free account

hub / github.com/GoCollaborate/src / functions

Functions406 in github.com/GoCollaborate/src

⨍ Functions 406◇ Types & classes 79
MethodMount
(job *Job)
artifacts/task/background.go:14
FunctionNewBackground
()
artifacts/task/background.go:5
MethodNewCSVOperator
()
helpers/ioHelper/ioHelper.go:33
FunctionNewCard
Card is the network config of server
artifacts/card/card.go:9
FunctionNewCardMessage
()
artifacts/message/message.go:11
FunctionNewCardMessageFuture
(in *CardMessage)
artifacts/message/messageFuture.go:13
FunctionNewCardMessageWithOptions
(cluster string, from *card.Card, to *card.Card, cards map[string]*card.Card, timestamp int64, msgType CardMes
artifacts/message/message.go:17
FunctionNewCollaborator
Return an instance of Collaborator
collaborator/collaborator.go:38
FunctionNewCollection
()
artifacts/task/task.go:58
FunctionNewErrorResource
(errors ...*Error)
artifacts/restful/error.go:19
FunctionNewLogger
Return an instance of logger.
logger/logger.go:31
FunctionNewMaster
()
artifacts/master/master.go:22
FunctionNewRequest
()
artifacts/restful/restful.go:27
FunctionNewResponse
()
artifacts/restful/restful.go:31
FunctionNewServiceServerStub
(wk iworkable.Workable)
collaborator/server_stub.go:15
FunctionNewTaskContext
(ctx interface{})
artifacts/task/taskContext.go:15
FunctionNewTaskFuture
(in *Task)
artifacts/task/taskFuture.go:13
MethodPrev
()
artifacts/task/stage.go:9
MethodProceed
(tsks map[int]*task.Task)
artifacts/iworkable/iworkable.go:74
FunctionProfile
(w http.ResponseWriter, r *http.Request)
web/dashboard.go:17
MethodProtoMessage
()
artifacts/task/task.pb.go:36
MethodProtoMessage
()
artifacts/digest/digest.pb.go:36
MethodProtoMessage
()
artifacts/digest/digest.pb.go:50
MethodProtoMessage
()
artifacts/card/card.pb.go:40
MethodProtoMessage
()
artifacts/message/message.pb.go:38
MethodProtoMessage
()
artifacts/message/message.pb.go:50
MethodProtoMessage
()
artifacts/message/message.pb.go:102
MethodProtoMessage
()
artifacts/message/message.pb.go:154
MethodQuit
()
artifacts/worker/worker.go:63
FunctionRandStringBytesMaskImprSrc
(n int)
utils/random.go:15
FunctionRangePrint
(cards map[string]*card.Card)
helpers/cardHelper/cardHelper.go:31
FunctionReader
(r *http.Request)
artifacts/restful/restful.go:89
MethodReceive
()
artifacts/task/taskFuture.go:17
MethodReceive
()
artifacts/message/messageFuture.go:17
FunctionRecoverHandler
()
utils/network.go:47
MethodReduce
(sources map[int]*task.Task)
artifacts/ireducer/ireducer.go:8
MethodReduce
(sources map[int]*task.Task)
artifacts/ireducer/ireducer.go:18
MethodReduceTo
reduce the source from input set to the source of output set
helpers/taskHelper/mapop.go:20
FunctionReflectFuncName
(fun interface{})
utils/reflect.go:11
MethodReset
()
artifacts/task/task.pb.go:34
MethodReset
()
artifacts/digest/digest.pb.go:34
MethodReset
()
artifacts/digest/digest.pb.go:48
MethodReset
()
artifacts/card/card.pb.go:38
MethodReset
()
artifacts/message/message.pb.go:48
MethodReset
()
artifacts/message/message.pb.go:100
MethodReset
()
artifacts/message/message.pb.go:152
MethodReturn
(out *CardMessage)
artifacts/message/messageFuture.go:21
FunctionRoutes
(w http.ResponseWriter, r *http.Request)
web/dashboard.go:24
FunctionRun
(vars ...*cmd.SysVars)
collaborate.go:95
MethodSend
()
artifacts/restful/restful.go:83
FunctionSendErrorWith
(w http.ResponseWriter, errPayload restful.ErrorPayload, status int)
helpers/restfulHelper/restfulHelper.go:12
MethodSerializeToJSON
()
artifacts/iremote/iparamteterizable.go:4
MethodSerializeToJSON
()
artifacts/parameter/parameter.go:17
FunctionSet
(key string, val ...interface{})
collaborate.go:22
MethodSetCards
type Digest struct { Cards_ map[string]card.Card `json:"cards"` Ts_ int64 `json:"timestamp"` } func (dgst *Digest) Cards() map[str
artifacts/digest/digest.go:20
MethodSetJob
(j *task.Job)
store/store.go:158
MethodSetLocal
(key string, val *JobFunc)
store/store.go:173
MethodSetShared
(key string, val *JobFunc)
store/store.go:169
MethodSetTimeStamp
(ts int64)
artifacts/digest/digest.go:24
FunctionSlice
slice the data source of the map into N separate segments
helpers/taskHelper/partitioner.go:8
FunctionSortArrayInt
(origin []int)
utils/sort.go:7
FunctionSortArrayIntReverse
(origin []int)
utils/sort.go:13
MethodStacks
(stacks ...string)
artifacts/task/job.go:127
MethodStamp
()
artifacts/message/message.go:70
FunctionStats
(w http.ResponseWriter, r *http.Request)
web/dashboard.go:80
MethodString
()
artifacts/digest/digest.pb.go:35
MethodString
()
artifacts/digest/digest.pb.go:49
MethodString
()
artifacts/message/message.pb.go:49
MethodString
()
artifacts/message/message.pb.go:86
MethodString
()
artifacts/message/message.pb.go:101
MethodString
()
artifacts/message/message.pb.go:153
FunctionStripRouteToAPIRoute
(rt string)
utils/reflect.go:16
FunctionStripRouteToFunctName
(rt string)
utils/reflect.go:20
FunctionSupportXHTTPMethodOverride
Override method by checking its header One thing you can do is to "tunnel" HTTP Methods inside another HTTP Header. Basically you have a header that s
utils/network.go:35
MethodSyncDistribute
(sources []*task.Task)
artifacts/iremote/icollaboratable.go:8
MethodTasks
(tsks ...*Task)
artifacts/task/job.go:132
MethodToSeed
()
artifacts/card/card.go:50
MethodTodo
(todo func(sources map[int]*task.Task) (map[int]*task.Task, error))
artifacts/iexecutor/iexecutor.go:29
MethodType
(t ...string)
artifacts/iexecutor/iexecutor.go:10
MethodType
(t ...string)
artifacts/iexecutor/iexecutor.go:22
FunctionUnmarshalCards
(original []interface{})
helpers/cardHelper/cardHelper.go:8
FunctionUnmarshalParameters
(original []interface{})
helpers/parameterHelper/parameterHelper.go:7
FunctionUnmarshalStringArray
(original []interface{})
helpers/parameterHelper/parameterHelper.go:25
MethodUpdate
(dgst iremote.IDigest)
artifacts/message/message.go:65
MethodValidate
()
artifacts/iremote/iparamteterizable.go:5
FunctionVars
()
cmd/cmd.go:60
FunctionVarsJSONArrayStr
()
cmd/cmd.go:65
FunctionWithHeader
(key, value string)
utils/network.go:20
MethodWithHeader
(key, val string)
artifacts/restful/restful.go:71
MethodWithIncluded
(resources ...RestfulResource)
artifacts/restful/restful.go:120
MethodWithLinks
(links *Links)
artifacts/restful/restful.go:65
MethodWithResource
(resource RestfulResource)
artifacts/restful/restful.go:45
MethodWithResource
(resource RestfulResource)
artifacts/restful/restful.go:98
MethodWithResourceArr
(resources interface{})
artifacts/restful/restful.go:60
MethodWithResourceArr
(resources interface{})
artifacts/restful/restful.go:114
MethodWithResources
(resources ...RestfulResource)
artifacts/restful/restful.go:51
MethodWithResources
(resources ...RestfulResource)
artifacts/restful/restful.go:105
MethodWithStatus
(status int)
artifacts/restful/restful.go:77
FunctionWriter
(w http.ResponseWriter)
artifacts/restful/restful.go:35
Function_RPCService_Distribute_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
collaborator/services/rpc_services.pb.go:88
← previousnext →301–400 of 406, ranked by callers