Function TestComputeMetrics

cmd/cql-minerd/various_metric_test.go:281–384

(t *testing.T)

}

func TestComputeMetrics(t *testing.T) {
	Convey("compute metrics", t, func() {
		priv, _, err := asymmetric.GenSecp256k1KeyPair()
		So(err, ShouldBeNil)

		var n proto.NodeID
		var a proto.AccountAddress

		r := &types.Request{
			Header: types.SignedRequestHeader{
				RequestHeader: types.RequestHeader{
					QueryType:    types.WriteQuery,
					NodeID:       n.ToRawNodeID().ToNodeID(),
					DatabaseID:   a.DatabaseID(),
					ConnectionID: 0,
					SeqNo:        1,
					Timestamp:    time.Now().UTC(),
					BatchCount:   1,
				},
			},
			Payload: types.RequestPayload{
				Queries: []types.Query{
					{
						Pattern: "INSERT INTO insert_table0  ( k, v1 ) VALUES(?, ?)",
						Args: []types.NamedArg{
							{
								Value: 1,
							},
							{
								Value: 2,
							},
						},
					},
				},
			},
		}

		err = r.Sign(priv)
		So(err, ShouldBeNil)

		buf, err := utils.EncodeMsgPack(r)
		So(err, ShouldBeNil)

		t.Logf("RequestSize: %v", len(buf.Bytes()))

		l := &kt.Log{
			LogHeader: kt.LogHeader{
				Index:    1,
				Version:  1,
				Type:     kt.LogPrepare,
				Producer: n.ToRawNodeID().ToNodeID(),
			},
			Data: buf.Bytes(),
		}

		buf2, err := utils.EncodeMsgPack(l)
		So(err, ShouldBeNil)