MCPcopy Create free account

hub / github.com/chrislusf/glow / functions

Functions522 in github.com/chrislusf/glow

⨍ Functions 522◇ Types & classes 101
↓ 1 callersMethodreceiveTopicFrom
(target string)
netchan/receiver/receiver_channel.go:60
↓ 1 callersMethodremoteExecuteOnLocation
(flowContext *flow.FlowContext, taskGroup *plan.TaskGroup, allocation resource.Allocation, wg *sync.WaitGroup)
driver/scheduler/scheduler_execute.go:19
↓ 1 callersMethodreportLocalExecutorStatus
()
driver/task_runner.go:181
↓ 1 callersFunctionsendKeyValues
(outChan reflect.Value, key interface{}, valueType reflect.Type, values []interface{})
flow/dataset_cogroup.go:154
↓ 1 callersFunctionsendMapOutputs
the value over the outChan is always reflect.Value but the inner values are always actual interface{} object
flow/dataset_map.go:143
↓ 1 callersMethodsendToExternalOutputChans
(t reflect.Value)
flow/dataset_run.go:70
↓ 1 callersMethodsetupInputChannels
(fc *flow.FlowContext, task *flow.Task, location resource.Location, waitGroup *sync.WaitGroup)
driver/scheduler/scheduler_execute.go:78
↓ 1 callersMethodsetupOutputChannels
(shards []*flow.DatasetShard, waitGroup *sync.WaitGroup)
driver/scheduler/scheduler_execute.go:101
↓ 1 callersFunctiontestBasicMapReduce
()
examples/word_count/word_count.go:48
↓ 1 callersFunctiontestInputOutputChannels
()
examples/word_count/word_count.go:140
↓ 1 callersFunctiontestJoin
()
examples/word_count/word_count.go:106
↓ 1 callersFunctiontestPartitionAndSort
()
examples/word_count/word_count.go:69
↓ 1 callersFunctiontestSaveToFile
()
examples/word_count/word_count.go:230
↓ 1 callersFunctiontestSelfJoin
()
examples/word_count/word_count.go:87
↓ 1 callersFunctiontestUnrolledStaticLoop
()
examples/word_count/word_count.go:189
↓ 1 callersMethodtimeFromName
timeFromName extracts the formatted time from the filename by stripping off the filename's prefix and extension. This prevents someone's filename from
netchan/store/rotating_file_store.go:379
↓ 1 callersFunctiontranslateToStepGroups
group local steps into one step group
driver/plan/group.go:76
↓ 1 callersFunctiontranslateToTaskGroups
group local tasks into one task group
driver/plan/group.go:118
↓ 1 callersMethodupdateChannelHandler
put agent information list under a path
resource/service_discovery/master/handler_channels.go:46
↓ 1 callersMethodwaitForInputDatasetShardLocations
(task *flow.Task)
driver/scheduler/shard_location.go:58
MethodAddInputChan
(ch chan reflect.Value)
flow/step_task.go:65
MethodAddParent
(parent *TaskGroup)
driver/plan/group.go:174
FunctionAddToValues
(values url.Values, c *ComputeResource, allocated *ComputeResource)
resource/resource.go:101
FunctionCleanObject
(v reflect.Value, currentType, expectedType reflect.Type)
netchan/convert.go:8
FunctionConnectRawReadChannelToTyped
(c chan []byte, out chan reflect.Value, t reflect.Type, wg *sync.WaitGroup)
netchan/channels.go:25
FunctionConnectTypedWriteChannelToRaw
(writeChan reflect.Value, c chan []byte, wg *sync.WaitGroup)
netchan/channels.go:48
FunctionDefaultFloat32Comparator
(a, b float32)
flow/dataset_join_utils.go:28
FunctionDefaultFloat64Comparator
(a, b float64)
flow/dataset_join_utils.go:18
FunctionDefaultStringComparator
(a, b string)
flow/dataset_join_utils.go:8
MethodDestroy
()
netchan/store/rotating_file_store.go:332
MethodDestroy
()
netchan/store/data_store.go:46
MethodFetch
Requirement is TaskGroup Object is Agent's Location
driver/scheduler/scheduler_fetch.go:19
FunctionFindTarget
(name string, leader string)
netchan/receiver/receiver_channel.go:22
MethodGetArgs
()
driver/cmd/control_message.pb.go:271
MethodGetCpuLevel
()
driver/cmd/control_message.pb.go:234
MethodGetDeleteDatasetShardRequest
()
driver/cmd/control_message.pb.go:164
MethodGetDeleteDatasetShardResponse
()
driver/cmd/control_message.pb.go:171
FunctionGetDirectReadChannel
(tlsConfig *tls.Config, name, location string, chanBufferSize int)
netchan/channels.go:16
FunctionGetDirectSendChannel
(tlsConfig *tls.Config, name string, location string, wg *sync.WaitGroup)
netchan/channels.go:21
MethodGetEnvs
()
driver/cmd/control_message.pb.go:278
MethodGetError
()
driver/cmd/control_message.pb.go:339
MethodGetError
()
driver/cmd/control_message.pb.go:393
MethodGetError
()
driver/cmd/control_message.pb.go:478
MethodGetError
()
driver/cmd/control_message.pb.go:545
MethodGetError
()
driver/cmd/control_message.pb.go:571
MethodGetError
()
driver/cmd/control_message.pb.go:601
MethodGetGetStatusRequest
()
driver/cmd/control_message.pb.go:150
MethodGetInputStatuses
()
driver/cmd/control_message.pb.go:578
MethodGetLocalStatusReportRequest
()
driver/cmd/control_message.pb.go:178
MethodGetLocalStatusReportResponse
()
driver/cmd/control_message.pb.go:185
MethodGetName
()
driver/cmd/control_message.pb.go:529
MethodGetOutputStatuses
()
driver/cmd/control_message.pb.go:585
MethodGetOutputs
()
driver/cmd/control_message.pb.go:353
MethodGetPid
()
driver/cmd/control_message.pb.go:332
MethodGetPort
()
driver/cmd/control_message.pb.go:313
MethodGetServer
()
driver/cmd/control_message.pb.go:202
MethodGetStartRequest
()
driver/cmd/control_message.pb.go:122
MethodGetStartRequestHash
()
driver/cmd/control_message.pb.go:386
MethodGetStartRequestHash
()
driver/cmd/control_message.pb.go:409
MethodGetStartRequestHash
()
driver/cmd/control_message.pb.go:471
MethodGetStartRequestHash
()
driver/cmd/control_message.pb.go:564
MethodGetStartResponse
()
driver/cmd/control_message.pb.go:129
MethodGetStartTime
()
driver/cmd/control_message.pb.go:506
MethodGetStderr
()
driver/cmd/control_message.pb.go:346
MethodGetStopRequest
()
driver/cmd/control_message.pb.go:136
MethodGetStopResponse
()
driver/cmd/control_message.pb.go:143
MethodGetStopTime
()
driver/cmd/control_message.pb.go:513
FunctionGroupTasks
(fc *flow.FlowContext)
driver/plan/group.go:24
FunctionHash
(bytes []byte)
util/hash.go:7
MethodIsDriverMode
()
driver/context_driver.go:69
MethodIsDriverPlotMode
()
driver/context_driver.go:73
MethodIsTaskMode
()
driver/task_runner.go:36
MethodLen
()
netchan/store/rotating_file_store.go:432
MethodLen
()
resource/service_discovery/master/master_allocation.go:144
MethodLess
(i, j int)
netchan/store/rotating_file_store.go:424
MethodLess
(i, j int)
resource/service_discovery/master/master_allocation.go:138
MethodLess
(i, j int)
resource/service_discovery/master/master_allocation.go:146
MethodLess
(i, j int)
util/priority_queue.go:46
FunctionMergeChannel
(cs []chan reflect.Value)
util/channel_util.go:8
MethodName
()
flow/dataset_shard.go:37
FunctionNewAgentServer
(option *AgentServerOption)
agent/agent_server.go:53
FunctionNewChannelStatus
()
util/executor_status.go:14
FunctionNewComputeResourceFromRequest
(r *http.Request)
resource/resource.go:110
FunctionNewDataCenter
(name string)
resource/topology.go:44
FunctionNewDirectSendChannel
(tlsConfig *tls.Config, name string, target string, wg *sync.WaitGroup)
netchan/sender/sender_channel.go:12
FunctionNewGetStatusRequest
(requestId uint32)
driver/scheduler/command_execution.go:49
FunctionNewHeartBeater
(ip string, localPort int, leader string)
resource/service_discovery/client/heartbeater.go:20
FunctionNewLocalFileDataStore
(dir, name string)
netchan/store/data_store.go:21
FunctionNewNameServiceProxy
(leaders ...string)
resource/service_discovery/client/name_service_agent.go:17
FunctionNewRack
(name string)
resource/topology.go:51
FunctionNewReceiveChannel
(tlsConfig *tls.Config, name string, offset uint64)
netchan/receiver/receiver_channel.go:39
FunctionNewScheduler
(leader string, option *SchedulerOption)
driver/scheduler/scheduler.go:48
FunctionNewStopRequest
(requestId uint32)
driver/scheduler/command_execution.go:58
FunctionNewTopology
()
resource/topology.go:38
FunctionOnInterrupt
(fn func(), onExitFunc func())
flow/signal_handling_windows.go:11
FunctionOnInterrupt
(fn func(), onExitFunc func())
flow/signal_handling_notsupported.go:5
FunctionOnInterrupt
(fn func(), onExitFunc func())
flow/signal_handling_linux.go:11
MethodOnInterrupt
()
flow/context_on_interrupt.go:7
MethodPlot
(fc *flow.FlowContext)
driver/context_driver.go:85
FunctionPlotGraph
(taskGroups []*TaskGroup, fc *flow.FlowContext)
driver/plan/group_plot.go:17
← previousnext →301–400 of 522, ranked by callers