Involved Source Filesbolt3.gobolt4.gobolt_logging.gochunker.go
Package bolt contains implementations of the database functionality.
dechunker.gohydrator.go
* Copyright (c) "Neo4j"
* Neo4j Sweden AB [http://neo4j.com]
*
* This file is part of Neo4j.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
messages.go
* Copyright (c) "Neo4j"
* Neo4j Sweden AB [http://neo4j.com]
*
* This file is part of Neo4j.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
parseroutingtable.gopath.go
* Copyright (c) "Neo4j"
* Neo4j Sweden AB [http://neo4j.com]
*
* This file is part of Neo4j.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
Package-Level Type Names (total 21, none are exported)
Only need to keep track of current stream. Client keeps track of other
open streams and a key in each stream is used to validate if it belongs to
current bolt connection or not.
curr*streamkeyint64numint
Adds a new open stream and sets it as current.
There should NOT be a current stream .
Detaches the current stream from being current and
removes it from set of open streams it is no longer open.
The stream should be either in failed state or completed.
Checks that the handle represents a stream but not necessarily a stream belonging
to this set of open streams.
( T) isSafe(s *stream) error
Streams can be paused when they have received a "has_more" response from server
Pauses the current stream
Removes the stream by disabling its key and removing it from the count of streams.
If the stream is current the current is set to nil.
(*T) reset()
When resuming a stream a new PULL message needs to be sent.
dechunkMessage takes a buffer to be reused and returns the reusable buffer
(might have been reallocated to handle growth), the message buffer and
error.
If a non-default connection read timeout configuration hint is passed, the dechunker resets the connection read
deadline as well after successfully reading a chunk (NOOP messages included)
The pages are generated with Goldsv0.4.2. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds.
