Function TestRuntime

kayak/runtime_test.go:232–552

(t *testing.T)

}

func TestRuntime(t *testing.T) {
	Convey("runtime test", t, func(c C) {
		lvl := log.GetLevel()
		log.SetLevel(log.DebugLevel)
		defer log.SetLevel(lvl)

		db1, err := newSQLiteStorage("test1.db")
		So(err, ShouldBeNil)
		defer func() {
			db1.Close()
			os.Remove("test1.db")
		}()
		db2, err := newSQLiteStorage("test2.db")
		So(err, ShouldBeNil)
		defer func() {
			db2.Close()
			os.Remove("test2.db")
		}()

		node1 := proto.NodeID("000005aa62048f85da4ae9698ed59c14ec0d48a88a07c15a32265634e7e64ade")
		node2 := proto.NodeID("000005f4f22c06f76c43c4f48d5a7ec1309cc94030cbf9ebae814172884ac8b5")

		peers := &proto.Peers{
			PeersHeader: proto.PeersHeader{
				Leader: node1,
				Servers: []proto.NodeID{
					node1,
					node2,
				},
			},
		}

		privKey, _, err := asymmetric.GenSecp256k1KeyPair()
		So(err, ShouldBeNil)
		err = peers.Sign(privKey)
		So(err, ShouldBeNil)

		wal1 := kl.NewMemWal()
		defer wal1.Close()
		cfg1 := &kt.RuntimeConfig{
			Handler:          db1,
			PrepareThreshold: 1.0,
			CommitThreshold:  1.0,
			PrepareTimeout:   time.Second,
			CommitTimeout:    10 * time.Second,
			LogWaitTimeout:   10 * time.Second,
			Peers:            peers,
			Wal:              wal1,
			NodeID:           node1,
			ServiceName:      "Test",
			ApplyMethodName:  "Apply",
		}
		rt1, err := kayak.NewRuntime(cfg1)
		So(err, ShouldBeNil)

		wal2 := kl.NewMemWal()
		defer wal2.Close()
		cfg2 := &kt.RuntimeConfig{