Update WIT contracts

Author: jlian

samples/wasm/python/schema/accumulate.wit

@@ -1,13 +1,13 @@
 // The interface of an accumulate operator.
 interface accumulate {
-	use types.{data-model,module-configuration};
+	use types.{data-model,error,module-configuration};
 
 	// An accumulate operator takes two arguments:
 	// 1) A staged area which stores previous accumulated result.
 	// 2) A sequence of messages to be accumulated.
 	// A new combined message that will be passed to next accumulate operation,
 	// or the next node in the execution graph when all messages finish combining.
-	process: func(staged: data-model, message: list<data-model>) -> data-model;
+	process: func(staged: data-model, message: list<data-model>) -> result<data-model, error>;
 
 	// The init function called on module load
 	init: func(configuration: module-configuration) -> bool;
@@ -18,4 +18,4 @@ world accumulate-impl {
 	import metrics;
 
 	export accumulate;
-}
+}

samples/wasm/python/schema/branch.wit

@@ -1,12 +1,12 @@
 // The interface of a branch operator.
 interface branch {
-	use types.{data-model,module-configuration};
+	use types.{data-model,error,module-configuration};
 	use hybrid-logical-clock.{hybrid-logical-clock};
 
 	// A branch node has two output branches in the execution graph.
 	// The operator returns `false` if the input message should be passed to the first branch,
 	// and `true` if it should be passed to the second branch.
-	process: func(timestamp: hybrid-logical-clock, message: data-model) -> bool;
+	process: func(timestamp: hybrid-logical-clock, message: data-model) -> result<bool, error>;
 
 	// The init function called on module load
 	init: func(configuration: module-configuration) -> bool;
@@ -18,4 +18,4 @@ world branch-impl {
 	import metrics;
 
 	export branch;
-}
+}

samples/wasm/python/schema/delay.wit

@@ -1,12 +1,12 @@
 // The interface of a delay operator.
 interface delay {
-	use types.{data-model,module-configuration};
+	use types.{data-model,error,module-configuration};
 	use hybrid-logical-clock.{hybrid-logical-clock};
 
 	// A delay node takes data input and timely logic timestamp and returns a new timestamp
 	// in the execution graph.
 	// The operator can use own logic to process and return a new timestamp for delay.
-	process: func(data: data-model, timestamp: hybrid-logical-clock) -> hybrid-logical-clock;
+	process: func(data: data-model, timestamp: hybrid-logical-clock) -> result<hybrid-logical-clock, error>;
 
 	// The init function called on module load
 	init: func(configuration: module-configuration) -> bool;
@@ -18,4 +18,4 @@ world delay-impl {
 	import metrics;
 
 	export delay;
-}
+}

samples/wasm/python/schema/filter.wit

@@ -1,11 +1,11 @@
 // The interface of a filter operator.
 interface filter {
-	use types.{data-model,module-configuration};
+	use types.{data-model,error,module-configuration};
 
 	// A filter operator returns `true` if the input message should be passed
 	// to the next node in the execution graph, and false if it should be
 	// dropped.
-	process: func(message: data-model) -> bool;
+	process: func(message: data-model) -> result<bool, error>;
 
 	// The init function called on module load
 	init: func(configuration: module-configuration) -> bool;
@@ -17,4 +17,4 @@ world filter-impl {
 	import metrics;
 
 	export filter;
-}
+}

samples/wasm/python/schema/hybrid_logical_clock.wit

@@ -10,4 +10,4 @@ interface hybrid-logical-clock {
         counter: u64,
         node-id: string,
     }
-}
+}

samples/wasm/python/schema/logger.wit

@@ -34,4 +34,4 @@ interface logger {
 }
 world logger-use {
     import logger;
-}
+}

samples/wasm/python/schema/map.wit

@@ -1,10 +1,10 @@
 // The interface of a map operator.
 interface map {
-	use types.{data-model,module-configuration};
+	use types.{data-model,error,module-configuration};
 
 	// A map operator takes a message and returns a new message
 	// that will be passed to the next node in the execution graph.
-	process: func(message: data-model) -> data-model;
+	process: func(message: data-model) -> result<data-model, error>;
 
 	// The init function called on module load
 	init: func(configuration: module-configuration) -> bool;
@@ -15,4 +15,4 @@ world map-impl {
 	import metrics;
 
 	export map;
-}
+}

samples/wasm/python/schema/metrics.wit

@@ -28,4 +28,4 @@ interface metrics {
 }
 world metrics-use {
 	import metrics;
-}
+}

samples/wasm/python/schema/processor.wit

@@ -1,4 +1,4 @@
-package tinykube-graph:processor@1.0.0;
+package wasm-graph:processor@1.1.0;
 
 interface types {
 	use hybrid-logical-clock.{timespec};
@@ -100,6 +100,11 @@ interface types {
 		properties: list<tuple<string, string>>,
 		module-schemas: list<module-schema>
 	}
+
+	record error
+	{
+		message: string,
+	}
 }
 
 world host {
@@ -110,8 +115,9 @@ world host {
 	import logger;
 	import metrics;
 	import command-invoker;
+	import schema-registry;
 }
 
 world test {
 	// import no interface so in test we can mock it
-}
+}

samples/wasm/python/schema/rpc.wit

@@ -60,4 +60,4 @@ interface command-invoker {
 world mrpc-use{
     import command-invoker;
     import rpc-types;
-}
+}