summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
Diffstat (limited to 'pkg')
-rw-r--r--pkg/events/grpc_event.go39
1 files changed, 39 insertions, 0 deletions
diff --git a/pkg/events/grpc_event.go b/pkg/events/grpc_event.go
new file mode 100644
index 00000000..31ff4957
--- /dev/null
+++ b/pkg/events/grpc_event.go
@@ -0,0 +1,39 @@
+package events
+
+import (
+ "time"
+
+ "google.golang.org/grpc"
+)
+
+const (
+ // EventUnaryCallOk represents success unary call response
+ EventUnaryCallOk G = iota + 13000
+
+ // EventUnaryCallErr raised when unary call ended with error
+ EventUnaryCallErr
+)
+
+type G int64
+
+func (ev G) String() string {
+ switch ev {
+ case EventUnaryCallOk:
+ return "EventUnaryCallOk"
+ case EventUnaryCallErr:
+ return "EventUnaryCallErr"
+ }
+ return UnknownEventType
+}
+
+// JobEvent represent job event.
+type GRPCEvent struct {
+ Event G
+ // Info contains unary call info.
+ Info *grpc.UnaryServerInfo
+ // Error associated with event.
+ Error error
+ // event timings
+ Start time.Time
+ Elapsed time.Duration
+}