MCPcopy Create free account

hub / github.com/chrislusf/glow / types & classes

Types & classes101 in github.com/chrislusf/glow

⨍ Functions 522◇ Types & classes 101
↓ 4 callersTypeAliasControlFlag
util/constants.go:5
↓ 3 callersInterfaceObject
driver/scheduler/market/cda_market.go:22
↓ 3 callersInterfaceRequirement
driver/scheduler/market/cda_market.go:24
↓ 1 callersTypeAliasByAvailableResources
resource/service_discovery/master/master_allocation.go:134
↓ 1 callersTypeAliasByRequestedResources
resource/service_discovery/master/master_allocation.go:142
↓ 1 callersTypeAliasControlMessage_Type
driver/cmd/control_message.pb.go:36
↓ 1 callersTypeAliasbyFormatTime
byFormatTime sorts by newest time formatted in the name.
netchan/store/rotating_file_store.go:422
StructAgentExecutorStatus
agent/local_executor_status.go:10
StructAgentInformation
resource/topology.go:8
StructAgentServer
agent/agent_server.go:41
StructAgentServerOption
agent/agent_server.go:27
StructAllocation
resource/resource.go:69
StructAllocationRequest
resource/resource.go:74
StructAllocationResult
resource/resource.go:78
StructAttachment
examples/mongodb_source/mongodb_source.go:15
StructCertFiles
netchan/cert_files.go:14
StructChannelInformation
resource/service_discovery/master/handler_channels.go:11
StructChannelStatus
driver/cmd/control_message.pb.go:416
StructChannelStatus
util/executor_status.go:7
StructComputeRequest
resource/resource.go:57
StructComputeResource
resource/resource.go:11
StructComputeResource
driver/cmd/control_message.pb.go:216
InterfaceContextRunner
flow/context_run.go:28
StructControlMessage
driver/cmd/control_message.pb.go:96
StructDataCenter
resource/topology.go:23
StructDataResource
resource/resource.go:52
InterfaceDataStore
netchan/store/data_store.go:9
StructDataset
flow/dataset.go:11
StructDatasetShard
flow/dataset_shard.go:10
StructDatasetShardLocator
driver/scheduler/shard_location.go:11
StructDeleteDatasetShardRequest
driver/cmd/control_message.pb.go:520
StructDeleteDatasetShardResponse
driver/cmd/control_message.pb.go:536
StructDemand
driver/scheduler/market/cda_market.go:26
StructDriverOption
driver/context_driver.go:20
StructExecutorStatus
util/executor_status.go:30
StructFileHash
driver/rsync/http_server.go:21
TypeAliasFileId
examples/mongodb_source/mongodb_source.go:23
StructFlowContext
flow/context.go:12
StructFlowContextDriver
driver/context_driver.go:58
StructFlowGraph
driver/plan/group_plot.go:11
StructGetStatusRequest
driver/cmd/control_message.pb.go:400
StructGetStatusResponse
driver/cmd/control_message.pb.go:456
StructHeartBeater
resource/service_discovery/client/heartbeater.go:13
StructItem
An Item is something we manage in a priority queue.
util/priority_queue.go:9
StructKeyValue
key value can not use reflect.Value which can not be serailize/deserialze
flow/dataset.go:43
StructKeyValueValue
flow/dataset.go:48
StructKeyValues
flow/dataset.go:54
StructKeyValuesValues
flow/dataset.go:59
StructListFileResult
driver/rsync/fetch_url.go:15
StructLocalDatasetShardsManager
agent/local_dataset_shards_manager.go:10
StructLocalExecutorManager
agent/local_executor_manager.go:8
StructLocalFileDataStore
netchan/store/data_store.go:15
StructLocalStatusReportRequest
driver/cmd/control_message.pb.go:552
StructLocalStatusReportResponse
driver/cmd/control_message.pb.go:592
StructLocation
resource/resource.go:62
StructMarket
driver/scheduler/market/cda_market.go:36
StructMasterResource
resource/service_discovery/master/master_resources.go:19
StructMessage
on wire io reader writer actual transmitted: size(4), bytes(n), flag(1), actual typed queue or channel: bytes(n), flag(1)
util/read_write.go:11
StructNameServiceProxy
resource/service_discovery/client/name_service_agent.go:13
StructNamedChannelMap
resource/service_discovery/master/master.go:15
StructNetChan
driver/cmd/control_message.pb.go:192
StructPost
examples/stack_analysis/stack_analysis.go:45
StructPost
examples/mongodb_source/mongodb_source.go:27
TypeAliasPostId
examples/mongodb_source/mongodb_source.go:25
StructPriorityQueue
A PriorityQueue implements heap.Interface and holds Items.
util/priority_queue.go:17
StructRack
resource/topology.go:15
StructReceiveChannel
netchan/receiver/receiver_channel.go:15
StructReleaseTaskGroupInputs
driver/scheduler/scheduler_events.go:19
StructRemoteExecutorStatus
driver/executor_status.go:13
StructRemoteExecutorStatus
driver/scheduler/scheduler.go:25
StructResourceOffer
resource/resource.go:47
StructResourceUpdateEvent
seconds
resource/service_discovery/master/master_resources.go:14
StructRotatingFileStore
netchan/store/rotating_file_store.go:27
StructRsyncServer
driver/rsync/http_server.go:27
StructScheduler
driver/scheduler/scheduler.go:14
StructSchedulerOption
driver/scheduler/scheduler.go:36
StructSegment
netchan/store/rotating_file_store.go:20
StructSourcePost
* - **posts**.xml - Id - PostTypeId - 1: Question - 2: Answer - ParentID (only present if PostTypeId is 2)
examples/stack_analysis/stack_analysis.go:39
StructStartRequest
driver/cmd/control_message.pb.go:248
StructStartResponse
driver/cmd/control_message.pb.go:320
StructStep
flow/step.go:7
StructStepGroup
driver/plan/group.go:18
StructStopRequest
driver/cmd/control_message.pb.go:360
StructStopResponse
driver/cmd/control_message.pb.go:376
StructStrangeType
netchan/encode_decode_test.go:13
StructSubStrangeType
netchan/encode_decode_test.go:8
StructSubmitTaskGroup
driver/scheduler/scheduler_events.go:12
StructSupply
driver/scheduler/market/cda_market.go:32
StructTask
flow/step_task.go:12
StructTaskGroup
driver/plan/group.go:10
StructTaskOption
driver/task_option.go:10
InterfaceTaskRunner
flow/context_run.go:35
StructTaskRunner
TaskRunner groups the data structures that describe a group of tasks that is run remotely on an glow agent.
driver/task_runner.go:22
StructTeamMaster
resource/service_discovery/master/master.go:31
StructTopology
resource/topology.go:31
StructUser
examples/mongodb_source/mongodb_source.go:38
StructUserPosts
examples/mongodb_source/mongodb_source.go:45
StructWordSentence
examples/invert_file/invert_file.go:13
StructlogInfo
logInfo is a convenience struct to return the filename and its embedded timestamp.
netchan/store/rotating_file_store.go:416
Structresult
flow/dataset_map_test.go:53
next →1–100 of 101, ranked by callers