events/grpc_event.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
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
}