-
Notifications
You must be signed in to change notification settings - Fork 0
/
request.go
34 lines (29 loc) · 1 KB
/
request.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
package grpcc
import (
"google.golang.org/grpc"
"github.com/pubgo/lava/lava"
)
var _ lava.Request = (*request)(nil)
type request struct {
resp grpc.ClientStream
reply interface{}
ct string
opts []grpc.CallOption
method string
service string
req interface{}
cc *grpc.ClientConn
invoker grpc.UnaryInvoker
streamer grpc.Streamer
desc *grpc.StreamDesc
header *lava.RequestHeader
}
func (r *request) Operation() string { return r.method }
func (r *request) Kind() string { return Name }
func (r *request) Client() bool { return true }
func (r *request) Service() string { return r.service }
func (r *request) Endpoint() string { return r.method }
func (r *request) ContentType() string { return r.ct }
func (r *request) Header() *lava.RequestHeader { return r.header }
func (r *request) Payload() interface{} { return r.req }
func (r *request) Stream() bool { return r.desc != nil }