dataNode includes metastore, memstore and diskstore
| 54 | |
| 55 | // dataNode includes metastore, memstore and diskstore |
| 56 | type dataNode struct { |
| 57 | sync.RWMutex |
| 58 | |
| 59 | hostID string |
| 60 | startedAt time.Time |
| 61 | shardSet shard.ShardSet |
| 62 | clusterServices services.Services |
| 63 | |
| 64 | topo topology.Topology |
| 65 | enumReader mutatorsCom.EnumReader |
| 66 | metaStore metaCom.MetaStore |
| 67 | memStore memstore.MemStore |
| 68 | diskStore diskstore.DiskStore |
| 69 | |
| 70 | opts Options |
| 71 | logger common.Logger |
| 72 | metrics datanodeMetrics |
| 73 | handlers datanodeHandlers |
| 74 | |
| 75 | bootstrapManager BootstrapManager |
| 76 | redoLogManagerMaster *redolog.RedoLogManagerMaster |
| 77 | grpcServer *grpc.Server |
| 78 | |
| 79 | mapWatch topology.MapWatch |
| 80 | close chan struct{} |
| 81 | |
| 82 | readyCh chan struct{} |
| 83 | } |
| 84 | |
| 85 | type datanodeHandlers struct { |
| 86 | schemaHandler *api.SchemaHandler |
nothing calls this directly
no outgoing calls
no test coverage detected