MCPcopy Create free account

hub / github.com/chrislusf/glow / functions

Functions522 in github.com/chrislusf/glow

⨍ Functions 522◇ Types & classes 101
MethodProtoMessage
()
driver/cmd/control_message.pb.go:113
MethodProtoMessage
()
driver/cmd/control_message.pb.go:200
MethodProtoMessage
()
driver/cmd/control_message.pb.go:225
MethodProtoMessage
()
driver/cmd/control_message.pb.go:262
MethodProtoMessage
()
driver/cmd/control_message.pb.go:330
MethodProtoMessage
()
driver/cmd/control_message.pb.go:367
MethodProtoMessage
()
driver/cmd/control_message.pb.go:384
MethodProtoMessage
()
driver/cmd/control_message.pb.go:407
MethodProtoMessage
()
driver/cmd/control_message.pb.go:426
MethodProtoMessage
()
driver/cmd/control_message.pb.go:469
MethodProtoMessage
()
driver/cmd/control_message.pb.go:527
MethodProtoMessage
()
driver/cmd/control_message.pb.go:543
MethodProtoMessage
()
driver/cmd/control_message.pb.go:562
MethodProtoMessage
()
driver/cmd/control_message.pb.go:599
FunctionReadUint64
(r io.Reader)
util/read_write.go:91
FunctionReady
()
flow/context_run.go:40
MethodReduceByUserDefinedKey
(lessThanFunc interface{}, reducer interface{})
flow/dataset_reduce.go:80
FunctionRegisterContextRunner
Invoked by driver task runner
flow/context_run.go:21
FunctionRegisterTaskRunner
(r TaskRunner)
flow/context_run.go:24
FunctionRemoteDirectCommand
(tlsConfig *tls.Config, server string, command *cmd.ControlMessage)
driver/scheduler/command_execution.go:116
MethodReset
()
driver/cmd/control_message.pb.go:111
MethodReset
()
driver/cmd/control_message.pb.go:198
MethodReset
()
driver/cmd/control_message.pb.go:223
MethodReset
()
driver/cmd/control_message.pb.go:260
MethodReset
()
driver/cmd/control_message.pb.go:328
MethodReset
()
driver/cmd/control_message.pb.go:365
MethodReset
()
driver/cmd/control_message.pb.go:382
MethodReset
()
driver/cmd/control_message.pb.go:405
MethodReset
()
driver/cmd/control_message.pb.go:424
MethodReset
()
driver/cmd/control_message.pb.go:467
MethodReset
()
driver/cmd/control_message.pb.go:525
MethodReset
()
driver/cmd/control_message.pb.go:541
MethodReset
()
driver/cmd/control_message.pb.go:560
MethodReset
()
driver/cmd/control_message.pb.go:597
MethodRotate
Rotate causes RotatingFileStore to close the existing log file and immediately create a new one. This is a helper function for applications that want
netchan/store/rotating_file_store.go:182
MethodRun
(*FlowContext)
flow/context_run.go:29
MethodRun
()
flow/context_run.go:57
MethodRun
driver runs on local, controlling all tasks
driver/context_driver.go:91
MethodRun
if this should not run, return false
driver/task_runner.go:41
FunctionRunMaster
(tlsConfig *tls.Config, listenOn string)
resource/service_discovery/master/master.go:42
MethodSaveBytesToFile
(fname string)
flow/dataset_output.go:30
MethodScore
(r market.Requirement, bid float64, obj market.Object)
driver/scheduler/scheduler_score.go:9
FunctionSource
Source lists files under a hdfs folder, and process all files This is provided more as an example. You can copy the code and customize any way you wan
source/hdfs/hdfs.go:16
MethodStartChannelHeartBeat
(killChan chan bool, chanName string)
resource/service_discovery/client/heartbeater.go:30
MethodStop
()
agent/agent_server.go:138
MethodString
()
driver/cmd/control_message.pb.go:84
MethodString
()
driver/cmd/control_message.pb.go:112
MethodString
()
driver/cmd/control_message.pb.go:224
MethodString
()
driver/cmd/control_message.pb.go:261
MethodString
()
driver/cmd/control_message.pb.go:329
MethodString
()
driver/cmd/control_message.pb.go:366
MethodString
()
driver/cmd/control_message.pb.go:383
MethodString
()
driver/cmd/control_message.pb.go:406
MethodString
()
driver/cmd/control_message.pb.go:425
MethodString
()
driver/cmd/control_message.pb.go:468
MethodString
()
driver/cmd/control_message.pb.go:526
MethodString
()
driver/cmd/control_message.pb.go:542
MethodString
()
driver/cmd/control_message.pb.go:561
MethodString
()
driver/cmd/control_message.pb.go:598
MethodSwap
(i, j int)
netchan/store/rotating_file_store.go:428
MethodSwap
(i, j int)
resource/service_discovery/master/master_allocation.go:137
MethodSwap
(i, j int)
resource/service_discovery/master/master_allocation.go:145
MethodSwap
(i, j int)
util/priority_queue.go:52
FunctionTestAllocation1
(t *testing.T)
resource/service_discovery/master/master_allocation_test.go:10
FunctionTestAllocation2
(t *testing.T)
resource/service_discovery/master/master_allocation_test.go:123
FunctionTestAllocation3
(t *testing.T)
resource/service_discovery/master/master_allocation_test.go:185
FunctionTestBytesToUint64
(t *testing.T)
util/bytes_test.go:8
FunctionTestCleanPath
(t *testing.T)
util/dirpath_test.go:8
FunctionTestCoGroupMap
(t *testing.T)
flow/dataset_map_test.go:39
FunctionTestCollectOutput
(t *testing.T)
flow/dataset_output_test.go:8
FunctionTestDialWithTlsConfig
(t *testing.T)
util/network_util_test.go:24
FunctionTestDialWithoutTlsConfig
(t *testing.T)
util/network_util_test.go:62
FunctionTestDownloadUrl
(t *testing.T)
util/http_util_test.go:73
FunctionTestError
(t *testing.T)
util/http_handler_test.go:32
FunctionTestGet
(t *testing.T)
util/http_util_test.go:60
FunctionTestGroupByKeyMap
(t *testing.T)
flow/dataset_map_test.go:23
FunctionTestGuessFunctionOutputType
(t *testing.T)
flow/utils_test.go:8
FunctionTestGuessKey
(t *testing.T)
flow/utils_test.go:17
FunctionTestJson
(t *testing.T)
util/http_handler_test.go:12
FunctionTestMapSingleParameter
(t *testing.T)
flow/dataset_map_test.go:8
FunctionTestMarket
(t *testing.T)
driver/scheduler/market/cda_market_test.go:8
FunctionTestMergeChannel
(t *testing.T)
util/channel_util_test.go:13
FunctionTestNewDataset
(t *testing.T)
flow/dataset_test.go:8
FunctionTestNormal
Tests registration is needed to encode/decode objects with gob.
netchan/encode_decode_test.go:44
FunctionTestNormalHttpCopy
(t *testing.T)
driver/rsync/http_server_test.go:12
FunctionTestPost
(t *testing.T)
util/http_util_test.go:42
FunctionTestReadBytes
(t *testing.T)
util/read_write_test.go:9
FunctionTestRunFlowInStandAloneMode
(t *testing.T)
flow/context_run_test.go:8
FunctionTestSetupHttpClient
(t *testing.T)
util/http_util_test.go:12
FunctionTestSortedData
(t *testing.T)
util/priority_queue_test.go:10
FunctionTestStruct
(t *testing.T)
netchan/encode_decode_test.go:19
FunctionTestWriteBytes
(t *testing.T)
util/read_write_test.go:19
FunctionTestWriteData
(t *testing.T)
util/read_write_test.go:33
FunctionTextFile
(location string, lines chan string)
source/hdfs/hdfs.go:62
MethodTimeTaken
()
util/executor_status.go:42
FunctionUint8toBytes
(b []byte, v uint8)
util/bytes.go:43
MethodUnmarshalJSON
(data []byte)
driver/cmd/control_message.pb.go:87
MethodWrite
Write implements io.Writer. If a write would cause the log file to be larger than MaxMegaByte, the file is closed, renamed to include a timestamp of
netchan/store/rotating_file_store.go:128
FunctionWriteUint64
(w io.Writer, number uint64)
util/read_write.go:85
FunctiondoubleIt
(v reflect.Value)
util/channel_util_test.go:9
← previousnext →401–500 of 522, ranked by callers