Function TestStatisticsInfo

pkg/controller/rtctrl/statistics_test.go:31–77

(t *testing.T)

)

func TestStatisticsInfo(t *testing.T) {
	cmid := "commit-xxx"
	funcName := "test"
	reqid := id.GetRequestID()
	now := time.Now().UnixNano()
	ver := "1"
	timeout := int64(3)
	reqinfo := RequestInfo{
		RequestID:         reqid,
		InvokeStartTimeNS: now,
		InvokeStartTimeMS: now / int64(time.Millisecond),
		SyncChannel:       make(chan struct{}, 1),
		TimeoutChannel:    make(chan struct{}, 1),
		Status:            StatusSuccess,
		Input: &InvocationInput{
			RequestID: reqid,
			Configuration: &api.FunctionConfiguration{
				CommitID: &cmid,
				FunctionConfiguration: lambda.FunctionConfiguration{
					Version:      &ver,
					Timeout:      &timeout,
					FunctionName: &funcName,
				},
			},
			User: &api.User{
				ID: "xxx",
			},
			WithStreamMode: true,
			Request: &api.InvokeProxyRequest{
				Headers: make(map[string]string, 0),
				Body:    []byte("{}"),
			},
			Response:      api.NewInvokeProxyResponse(),
			EnableMetrics: false,
			Logger:        logs.NewLogger().WithField("request_id", reqid),
		},
		Output: &InvocationOutput{Output: &InvocationResponse{}, Statistic: &InvocationStatistic{}},
	}
	info := statisticsInfo(&reqinfo)
	if info == nil {
		t.Error("statistics info should not be nil")
		return
	}
	if err := info.Decode(info.Encode()); err != nil {
		t.Errorf("encode/decode statistic info failed: %s", err)
	}
}