MCPcopy Index your code

hub / github.com/chrislusf/glow / functions

Functions522 in github.com/chrislusf/glow

⨍ Functions 522◇ Types & classes 101
↓ 2 callersFunctionDial
(tlsConfig *tls.Config, target string)
util/network_util.go:12
↓ 2 callersFunctionFromProto
(channelStatuses []*cmd.ChannelStatus)
driver/executor_status.go:31
↓ 2 callersMethodGetChannels
(name string)
resource/service_discovery/master/master.go:20
↓ 2 callersMethodGetDirectChannel
Not thread safe
netchan/receiver/receiver_channel.go:48
↓ 2 callersMethodGetInputStatuses
()
driver/cmd/control_message.pb.go:485
↓ 2 callersMethodGetOutputStatuses
()
driver/cmd/control_message.pb.go:492
↓ 2 callersMethodGetResource
()
driver/cmd/control_message.pb.go:292
↓ 2 callersMethodGetStartTime
()
driver/cmd/control_message.pb.go:435
↓ 2 callersMethodGetStopTime
()
driver/cmd/control_message.pb.go:442
↓ 2 callersMethodGroupByKey
()
flow/dataset_cogroup.go:7
↓ 2 callersMethodIsClosed
()
util/executor_status.go:38
↓ 2 callersMethodIsDriverMode
()
flow/context_run.go:30
↓ 2 callersMethodIsTaskMode
()
flow/context_run.go:37
↓ 2 callersFunctionJson
(w http.ResponseWriter, r *http.Request, httpStatus int, obj interface{})
util/http_handler.go:16
↓ 2 callersMethodLocalGroupByKey
(compareFunc interface{})
flow/dataset_cogroup.go:13
↓ 2 callersFunctionMergeChannelTo
(cs []chan reflect.Value, transformFn func(reflect.Value) reflect.Value, out chan reflect.Value)
util/channel_util.go:14
↓ 2 callersMethodMergeDatasets1ShardTo1Step
All dataset should have the same number of shards.
flow/context.go:130
↓ 2 callersFunctionNewDataset
(context *FlowContext, t reflect.Type)
flow/dataset.go:32
↓ 2 callersFunctionNewMessage
(flag ControlFlag, data []byte)
util/read_write.go:16
↓ 2 callersMethodOnInterrupt
( fc *flow.FlowContext, sched *scheduler.Scheduler)
driver/context_driver_on_interrupt.go:22
↓ 2 callersMethodReadAt
(data []byte, offset int64)
netchan/store/data_store.go:42
↓ 2 callersMethodReduce
Reduce runs on a dataset with data type V. Function f takes two arguments of type V and returns one type V. The function should be commutative and ass
flow/dataset_reduce.go:11
↓ 2 callersFunctionRemoteDirectExecute
(tlsConfig *tls.Config, server string, command *cmd.ControlMessage)
driver/scheduler/command_execution.go:76
↓ 2 callersMethodReportAdd
(delta int)
util/executor_status.go:22
↓ 2 callersMethodReportClose
()
util/executor_status.go:26
↓ 2 callersMethodReportStart
()
util/executor_status.go:18
↓ 2 callersMethodRun
()
flow/dataset_run.go:46
↓ 2 callersMethodRunDatasetInStandAloneMode
()
flow/dataset_run.go:10
↓ 2 callersMethodRunTask
source ->w:ds:r -> task -> w:ds:r source close next ds' w chan ds close its own r chan task closes its own channel to next ds' w:ds
flow/step_task.go:31
↓ 2 callersMethodSetChannels
(name string, chans []*ChannelInformation)
resource/service_discovery/master/master.go:25
↓ 2 callersMethodSetFetchFunction
(fn func([]Demand))
driver/scheduler/market/cda_market.go:56
↓ 2 callersMethodSetScoreFunction
(scorer func(Requirement, float64, Object) float64)
driver/scheduler/market/cda_market.go:51
↓ 2 callersMethodSetShardLocation
(name string, location resource.Location)
driver/scheduler/shard_location.go:36
↓ 2 callersMethodShowFlowStatus
( fc *flow.FlowContext, sched *scheduler.Scheduler)
driver/context_driver_on_interrupt.go:15
↓ 2 callersMethodStartRsyncServer
go start a http server locally that will respond predictably to ranged requests
driver/rsync/http_server.go:90
↓ 2 callersFunctionToProto
(channelStatuses []*util.ChannelStatus)
driver/executor_status.go:19
↓ 2 callersFunctionUint64toBytes
(b []byte, v uint64)
util/bytes.go:29
↓ 2 callersFunction_functionCallBasedOnInputType
(fn, input reflect.Value)
flow/dataset_map.go:96
↓ 2 callersFunctionacceptAndWrite
(listener net.Listener, text string)
util/network_util_test.go:12
↓ 2 callersMethodbeat
(fn func(url.Values) string)
resource/service_discovery/client/heartbeater.go:70
↓ 2 callersMethodclose
close closes the file if it is open.
netchan/store/rotating_file_store.go:168
↓ 2 callersMethoddoChannel
(chValue reflect.Value, chType reflect.Type)
flow/dataset_source.go:84
↓ 2 callersMethoddoDelete
(name string)
agent/local_dataset_shards_manager.go:28
↓ 2 callersMethodfindAgentInformation
(location resource.Location)
resource/service_discovery/master/master_resources.go:133
↓ 2 callersFunctionfindAncestorStepId
find mergeable parent step or itself if parent is not mergeable
driver/plan/group.go:48
↓ 2 callersFunctiongetLessThanComparator
(datasetType reflect.Type, key reflect.Value, functionPointer interface{})
flow/dataset_sort_comparator.go:50
↓ 2 callersMethodinput
(t *flow.Task, i, length int)
driver/plan/group_plot.go:134
↓ 2 callersFunctioniterate
(mongodbUrl, dbName, collectionName string, fn func(*mgo.Iter))
examples/mongodb_source/mongodb_source.go:54
↓ 2 callersMethodoutput
(ds *flow.Dataset)
driver/plan/group_plot.go:138
↓ 2 callersFunctionprintShardStatus
(shard *DatasetShard)
flow/context_on_interrupt.go:30
↓ 2 callersMethodreportLocalExecutorStatusOnce
()
driver/task_runner.go:170
↓ 2 callersMethodrunFlowContextInStandAloneMode
()
flow/context_run.go:68
↓ 2 callersFunctionsendKeyValue
(outChan reflect.Value, key, value interface{})
flow/dataset_join.go:116
↓ 2 callersFunctionsplitLocationToParts
(location string)
source/hdfs/hdfs.go:52
↓ 1 callersMethodAddAgent
(a *AgentInformation)
resource/topology.go:124
↓ 1 callersMethodAddDataCenter
(dc *DataCenter)
resource/topology.go:88
↓ 1 callersMethodAddLinkedNToOneStep
(input *Dataset, m int, output *Dataset)
flow/context.go:113
↓ 1 callersMethodAddOneToAllStep
the task should run on the source dataset shard input is nil for initial source dataset
flow/context.go:80
↓ 1 callersMethodAddOneToEveryNStep
(input *Dataset, n int, output *Dataset)
flow/context.go:96
↓ 1 callersMethodAddParent
(parent *StepGroup)
driver/plan/group.go:160
↓ 1 callersMethodAddRack
(rack *Rack)
resource/topology.go:117
↓ 1 callersMethodAddStep
(Step *flow.Step)
driver/plan/group.go:155
↓ 1 callersMethodAddTask
(task *flow.Task)
driver/plan/group.go:169
↓ 1 callersFunctionAssign
(leader string, request *resource.AllocationRequest)
driver/scheduler/scheduler_fetch.go:68
↓ 1 callersMethodBackgroundEventLoop
()
resource/service_discovery/master/master_resources.go:176
↓ 1 callersMethodBackgroundEvictionLoop
()
resource/service_discovery/master/master_resources.go:148
↓ 1 callersFunctionBytesToUint16
(b []byte)
util/bytes.go:23
↓ 1 callersFunctionCleanPath
(path string)
util/dirpath.go:20
↓ 1 callersMethodCleanup
(sched *scheduler.Scheduler, fc *flow.FlowContext)
driver/context_driver.go:166
↓ 1 callersMethodCloseOutputChannels
(fc *flow.FlowContext)
driver/context_driver.go:178
↓ 1 callersMethodCoGroupPartitionedSorted
CoGroupPartitionedSorted joins 2 datasets that are sharded by the same key and already locally sorted within each shard.
flow/dataset_cogroup.go:68
↓ 1 callersMethodContainsDataCenters
()
resource/topology.go:58
↓ 1 callersMethodCreateNamedDatasetShard
(name string)
agent/local_dataset_shards_manager.go:49
↓ 1 callersMethodDeleteNamedDatasetShard
(name string)
agent/local_dataset_shards_manager.go:40
↓ 1 callersMethodDistance
the distance is a relative value, similar to network lantency
resource/resource.go:88
↓ 1 callersFunctionDownloadUrl
(fileUrl string)
util/http_util.go:60
↓ 1 callersMethodDropAgent
(a *AgentInformation)
resource/topology.go:131
↓ 1 callersFunctionError
(w http.ResponseWriter, r *http.Request, httpStatus int, obj string)
util/http_handler.go:10
↓ 1 callersMethodEventLoop
* resources are leased to driver, expires every X miniute unless renewed. 1. request resource 2. release resource */
driver/scheduler/scheduler_events.go:30
↓ 1 callersMethodExecutableFileHash
()
driver/rsync/http_server.go:57
↓ 1 callersFunctionFetchFilesTo
(driverAddress string, dir string)
driver/rsync/fetch_url.go:32
↓ 1 callersFunctionFetchUrl
(fileUrl string, destFile string)
driver/rsync/fetch_url.go:59
↓ 1 callersMethodFetcherLoop
()
driver/scheduler/market/cda_market.go:79
↓ 1 callersFunctionGet
(url string)
util/http_util.go:44
↓ 1 callersMethodGetAgents
()
resource/topology.go:138
↓ 1 callersMethodGetCpuCount
()
driver/cmd/control_message.pb.go:227
↓ 1 callersMethodGetDataCenters
()
resource/topology.go:95
↓ 1 callersMethodGetDir
()
driver/cmd/control_message.pb.go:285
↓ 1 callersMethodGetGetStatusResponse
()
driver/cmd/control_message.pb.go:157
↓ 1 callersMethodGetHost
()
driver/cmd/control_message.pb.go:306
↓ 1 callersMethodGetLength
()
driver/cmd/control_message.pb.go:428
↓ 1 callersMethodGetMemory
()
driver/cmd/control_message.pb.go:241
↓ 1 callersMethodGetName
()
driver/cmd/control_message.pb.go:449
↓ 1 callersMethodGetPath
()
driver/cmd/control_message.pb.go:264
↓ 1 callersMethodGetPort
()
driver/cmd/control_message.pb.go:209
↓ 1 callersMethodGetRacks
()
resource/topology.go:106
↓ 1 callersMethodGetRequestTime
()
driver/cmd/control_message.pb.go:499
↓ 1 callersMethodGetType
()
driver/cmd/control_message.pb.go:115
↓ 1 callersMethodGreaterThanZero
()
resource/resource.go:35
↓ 1 callersMethodIsDriverPlotMode
()
flow/context_run.go:31
← previousnext →101–200 of 522, ranked by callers