Release/0.2.0

CHANGELOG.md

@@ -163,6 +163,33 @@ Minor release with initial benchmarks
 |-------------|---------|---------|---------------|
 | Hannah Howard | 1 | +1055/-39 | 17 |
 
+# go-graphsync 0.2.0
+
+Update to IPLD prime + several optimizations for performance
+
+### Changelog
+
+- github.com/ipfs/go-graphsync:
+  - style(imports): fix imports
+  - fix(selectorvalidator): memory optimization (#97) ([ipfs/go-graphsync#97](https://github.com/ipfs/go-graphsync/pull/97))
+  - Update [email protected] (#92) ([ipfs/go-graphsync#92](https://github.com/ipfs/go-graphsync/pull/92))
+  - refactor(metadata): use cbor-gen encoding (#96) ([ipfs/go-graphsync#96](https://github.com/ipfs/go-graphsync/pull/96))
+  - Release/v0.1.2 ([ipfs/go-graphsync#95](https://github.com/ipfs/go-graphsync/pull/95))
+  - Return Request context cancelled error (#93) ([ipfs/go-graphsync#93](https://github.com/ipfs/go-graphsync/pull/93))
+  - feat(benchmarks): add p2p stress test (#91) ([ipfs/go-graphsync#91](https://github.com/ipfs/go-graphsync/pull/91))
+- github.com/hannahhoward/cbor-gen-for (null -> v0.0.0-20200817222906-ea96cece81f1):
+  - add flag to select map encoding ([hannahhoward/cbor-gen-for#1](https://github.com/hannahhoward/cbor-gen-for/pull/1))
+
+### Contributors
+
+| Contributor | Commits | Lines ± | Files Changed |
+|-------------|---------|---------|---------------|
+| Eric Myhre | 1 | +2919/-121 | 39 |
+| Hannah Howard | 3 | +412/-103 | 15 |
+| hannahhoward | 1 | +31/-31 | 7 |
+| whyrusleeping | 1 | +31/-18 | 2 |
+| Aarsh Shah | 1 | +27/-1 | 3 |
+
 ### 🙌🏽 Want to contribute?
 
 Would you like to contribute to this repo and don’t know how? Here are a few places you can get started:

benchmarks/testnet/peernet.go

@@ -3,11 +3,11 @@ package testnet
 import (
 	"context"
 
-	gsnet "github.com/ipfs/go-graphsync/network"
-
 	"github.com/libp2p/go-libp2p-core/peer"
 	tnet "github.com/libp2p/go-libp2p-testing/net"
 	mockpeernet "github.com/libp2p/go-libp2p/p2p/net/mock"
+
+	gsnet "github.com/ipfs/go-graphsync/network"
 )
 
 type peernet struct {

ipldutil/ipldutil.go

@@ -36,8 +36,8 @@ func Traverse(ctx context.Context, loader ipld.Loader, chooser traversal.LinkTar
 	node := nb.Build()
 	return traversal.Progress{
 		Cfg: &traversal.Config{
-			Ctx:                        ctx,
-			LinkLoader:                 loader,
+			Ctx:                            ctx,
+			LinkLoader:                     loader,
 			LinkTargetNodePrototypeChooser: chooser,
 		},
 	}.WalkAdv(node, s, fn)

ipldutil/traverser.go

@@ -167,8 +167,8 @@ func (t *traverser) start() {
 		}
 		err = traversal.Progress{
 			Cfg: &traversal.Config{
-				Ctx:                        t.ctx,
-				LinkLoader:                 loader,
+				Ctx:                            t.ctx,
+				LinkLoader:                     loader,
 				LinkTargetNodePrototypeChooser: t.chooser,
 			},
 		}.WalkAdv(nd, sel, t.visitor)

metadata/metadata_test.go

@@ -7,11 +7,11 @@ import (
 
 	"github.com/ipld/go-ipld-prime/codec/dagcbor"
 	"github.com/ipld/go-ipld-prime/fluent"
+	cidlink "github.com/ipld/go-ipld-prime/linking/cid"
+	basicnode "github.com/ipld/go-ipld-prime/node/basic"
 	"github.com/stretchr/testify/require"
 
 	"github.com/ipfs/go-graphsync/testutil"
-	cidlink "github.com/ipld/go-ipld-prime/linking/cid"
-	basicnode "github.com/ipld/go-ipld-prime/node/basic"
 )
 
 func TestDecodeEncodeMetadata(t *testing.T) {

requestmanager/executor/executor.go

@@ -36,15 +36,15 @@ type ExecutionEnv struct {
 
 // RequestExecution are parameters for a single request execution
 type RequestExecution struct {
-	Ctx              context.Context
-	P                peer.ID
-	NetworkError     chan error
-	Request          gsmsg.GraphSyncRequest
-	LastResponse     *atomic.Value
-	DoNotSendCids    *cid.Set
+	Ctx                  context.Context
+	P                    peer.ID
+	NetworkError         chan error
+	Request              gsmsg.GraphSyncRequest
+	LastResponse         *atomic.Value
+	DoNotSendCids        *cid.Set
 	NodePrototypeChooser traversal.LinkTargetNodePrototypeChooser
-	ResumeMessages   chan []graphsync.ExtensionData
-	PauseMessages    chan struct{}
+	ResumeMessages       chan []graphsync.ExtensionData
+	PauseMessages        chan struct{}
 }
 
 // Start begins execution of a request in a go routine

requestmanager/executor/executor_test.go

@@ -430,13 +430,13 @@ func (ree *requestExecutionEnv) requestExecution() (chan graphsync.ResponseProgr
 		TerminateRequest: ree.terminateRequest,
 		Loader:           ree.fal.AsyncLoad,
 	}.Start(executor.RequestExecution{
-		Ctx:              ree.ctx,
-		P:                ree.p,
-		LastResponse:     &lastResponse,
-		Request:          ree.request,
-		DoNotSendCids:    ree.doNotSendCids,
+		Ctx:                  ree.ctx,
+		P:                    ree.p,
+		LastResponse:         &lastResponse,
+		Request:              ree.request,
+		DoNotSendCids:        ree.doNotSendCids,
 		NodePrototypeChooser: ree.nodeStyleChooser,
-		ResumeMessages:   ree.resumeMessages,
-		PauseMessages:    ree.pauseMessages,
+		ResumeMessages:       ree.resumeMessages,
+		PauseMessages:        ree.pauseMessages,
 	})
 }

requestmanager/requestmanager.go

@@ -338,15 +338,15 @@ func (nrm *newRequestMessage) setupRequest(requestID graphsync.RequestID, rm *Re
 		Loader:           rm.asyncLoader.AsyncLoad,
 	}.Start(
 		executor.RequestExecution{
-			Ctx:              ctx,
-			P:                p,
-			Request:          request,
-			NetworkError:     networkError,
-			LastResponse:     lastResponse,
-			DoNotSendCids:    doNotSendCids,
+			Ctx:                  ctx,
+			P:                    p,
+			Request:              request,
+			NetworkError:         networkError,
+			LastResponse:         lastResponse,
+			DoNotSendCids:        doNotSendCids,
 			NodePrototypeChooser: hooksResult.CustomChooser,
-			ResumeMessages:   resumeMessages,
-			PauseMessages:    pauseMessages,
+			ResumeMessages:       resumeMessages,
+			PauseMessages:        pauseMessages,
 		})
 	return incoming, incomingError
 }