frame.go (9 lines): - line 754: // TODO: only compress frames which are big enough - line 793: // TODO: if we move the body buffer onto the frameHeader then we only need a single - line 851: // TODO: factor this out so the same code paths can be used to parse custom - line 946: // TODO: deduplicate this from parseMetadata - line 1271: // TODO: could just use a separate type for each target - line 1671: // TODO: can we replace BatchStatemt with batchStatement? As they prety much - line 1728: // TODO: move this check into the caller and set a flag on writeBatchFrame - line 1884: // TODO: how to handle this error, if it is a uuid, then sureley, problems? - line 2093: // TODO: handle null case correctly, session.go (8 lines): - line 151: // TODO: we should take a context in here at some point - line 198: //TODO: Return a typed error - line 646: // TODO: better error? - line 659: // TODO: it would be nice to mark hosts here but as we are not using the policies - line 1162: // TODO: delete - line 1230: // TODO: Remove this and handle this case - line 1997: // TODO: delete - line 2065: // Rows not used in batch observations // TODO - might be able to support it when using BatchCAS conn.go (7 lines): - line 626: // TODO: should we do something here? - line 647: // TODO: TCP level deadlines? or just query level deadlines? - line 676: // TODO: handle cassandra event frames, we shouldnt get any currently - line 1056: return 0, io.EOF // TODO: better error here? - line 1099: err: io.EOF, // TODO: better error here? - line 1185: // TODO: move tracer onto conn - line 1671: // TODO: should have this behind a flag connectionpool.go (4 lines): - line 272: host.Port(), // TODO: if port == 0 use pool.port? - line 399: // TODO: improve this as the following can happen - line 567: // TODO: provide a more robust connection retry mechanism, we should also - line 624: // TODO: track the number of errors per host and detect when a host is dead, ring.go (2 lines): - line 49: // TODO: we should store the ring metadata here also. - line 164: // TODO: update other things now metadata.go (2 lines): - line 277: // TODO retrieve concurrently - line 1526: // TODO handle '=>' used for DynamicCompositeType events.go (2 lines): - line 99: // TODO: probably need a warning to track if this threshold is too low - line 133: // TODO: debounce events topology.go (1 line): - line 234: // TODO: ensure we dont add the same host twice prepared_cache.go (1 line): - line 76: // TODO: we should just use a struct for the key in the map internal/ccm/ccm.go (1 line): - line 116: // TODO: parse into struct to manipulate internal/streams/streams.go (1 line): - line 153: // TODO: make this account for 0 stream being reserved marshal.go (1 line): - line 2269: // TODO: really should use a framer helpers.go (1 line): - line 167: // TODO: Cover with unit tests. control.go (1 line): - line 228: connCfg.ProtoVersion = 5 // TODO: define maxProtocol