forked from lyft/protoc-gen-star
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathservice.go
79 lines (62 loc) · 2.01 KB
/
service.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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package pgs
import (
"github.com/golang/protobuf/proto"
"github.com/golang/protobuf/protoc-gen-go/descriptor"
)
// Service describes an proto service
type Service interface {
Entity
// Descriptor returns the underlying proto descriptor for this service
Descriptor() *descriptor.ServiceDescriptorProto
// Methods returns each rpc method exposed by this service
Methods() []Method
setFile(f File)
addMethod(m Method)
}
type service struct {
desc *descriptor.ServiceDescriptorProto
methods []Method
file File
comments string
}
func (s *service) Name() Name { return Name(s.desc.GetName()) }
func (s *service) FullyQualifiedName() string { return fullyQualifiedName(s.file, s) }
func (s *service) Syntax() Syntax { return s.file.Syntax() }
func (s *service) Package() Package { return s.file.Package() }
func (s *service) File() File { return s.file }
func (s *service) BuildTarget() bool { return s.file.BuildTarget() }
func (s *service) Comments() string { return s.comments }
func (s *service) Descriptor() *descriptor.ServiceDescriptorProto { return s.desc }
func (s *service) Extension(desc *proto.ExtensionDesc, ext interface{}) (bool, error) {
return extension(s.desc.GetOptions(), desc, &ext)
}
func (s *service) Imports() (i []Package) {
for _, m := range s.methods {
i = append(i, m.Imports()...)
}
return
}
func (s *service) Methods() []Method {
m := make([]Method, len(s.methods))
copy(m, s.methods)
return m
}
func (s *service) setFile(f File) { s.file = f }
func (s *service) addMethod(m Method) {
m.setService(s)
s.methods = append(s.methods, m)
}
func (s *service) accept(v Visitor) (err error) {
if v == nil {
return
}
if v, err = v.VisitService(s); err != nil || v == nil {
return
}
for _, m := range s.methods {
if err = m.accept(v); err != nil {
return
}
}
return
}