Function TestResource

pkg/controller/rtctrl/runtime_dispatcher_test.go:237–262

(t *testing.T)

}

func TestResource(t *testing.T) {
	rtMap := initRuntimeList(10)
	ors := rtMap.ResourceStatistics()
	t.Logf("resource %+v", ors)
	cmID := "commitID-test"
	mem := minMemory * 8
	input := &InvocationInput{
		Configuration: &api.FunctionConfiguration{
			CommitID:           &cmID,
			PodConcurrentQuota: 4,
			FunctionConfiguration: lambda.FunctionConfiguration{
				MemorySize: &mem,
			},
		},
		WithStreamMode: false,
	}
	rtinfo, _ := rtMap.OccupyColdRuntime(input)
	assert.NotEqual(t, rtinfo, nil)

	rs := rtMap.ResourceStatistics()
	assert.Equal(t, mem*bytefmt.Megabyte, rs.Marked.Memory-ors.Marked.Memory)
	t.Logf("rs = %s", rtinfo.Resource)
	rtMap.ReleaseMarkedResource(rtinfo.Resource.Copy())
	rs2 := rtMap.ResourceStatistics()
	assert.Equal(t, mem*bytefmt.Megabyte, rs.Marked.Memory-rs2.Marked.Memory)
}

func TestRuntimeDelete(t *testing.T) {
	rtMap := initRuntimeList(1)