Function createTestFunction

server/function_store_test.go:72–99

(name string)

}

func createTestFunction(name string) *model.Function {
	return &model.Function{
		Runtime: model.RuntimeConfig{
			Type: common.WASMRuntime,
			Config: map[string]interface{}{
				common.RuntimeArchiveConfigKey: "../bin/example_basic.wasm",
			},
		},
		Sources: []model.TubeConfig{
			{
				Type: common.MemoryTubeType,
				Config: (&contube.SourceQueueConfig{
					Topics:  []string{"input"},
					SubName: "test",
				}).ToConfigMap(),
			},
		},
		Sink: model.TubeConfig{
			Type: common.MemoryTubeType,
			Config: (&contube.SinkQueueConfig{
				Topic: "output",
			}).ToConfigMap(),
		},
		Name:     name,
		Replicas: 1,
		Config:   map[string]string{},
	}
}

const yamlSeparator string = "---\n"