Function TestPeerImplementation

topologytest/peer_test.go:462–604

(t *testing.T)

}

func TestPeerImplementation(t *testing.T) {
	testCases := []struct {
		name       string
		peerOption PeerOptions
	}{
		{
			name: "cbs",
			peerOption: PeerOptions{
				Type:     PeerTypeCouchbaseServer,
				BucketID: PeerBucketID1,
			},
		},
		{
			name: "sg",
			peerOption: PeerOptions{
				Type:     PeerTypeSyncGateway,
				BucketID: PeerBucketID1,
			},
		},
		{
			name: "cbl",
			peerOption: PeerOptions{
				Type: PeerTypeCouchbaseLite,
			},
		},
	}
	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			opts := map[string]PeerOptions{tc.name: tc.peerOption}
			// couchbase lite peer can't exist separately from sync gateway peer, CBG-4433
			if tc.peerOption.Type == PeerTypeCouchbaseLite {
				opts["sg"] = PeerOptions{Type: PeerTypeSyncGateway, BucketID: PeerBucketID1}
			}
			peers := createPeers(t, opts)
			peer := peers[tc.name]
			var replications Replications
			// couchbase lite peer can't exist separately from sync gateway peer, CBG-4433
			if peer.Type() == PeerTypeCouchbaseLite {
				pullReplication := peer.CreateReplication(peers["sg"], PeerReplicationConfig{
					direction: PeerReplicationDirectionPull,
				})
				pullReplication.Start()
				defer pullReplication.Stop()

				replications = append(replications, pullReplication)
				pushReplication := peer.CreateReplication(peers["sg"], PeerReplicationConfig{
					direction: PeerReplicationDirectionPush,
				})
				pushReplication.Start()
				defer pushReplication.Stop()
				replications = append(replications, pushReplication)
			}
			topology := Topology{
				peers:        peers,
				replications: replications,
			}

			docID := t.Name()