organization_service.pb.go 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: organization_service.proto
  3. // package声明符,用来防止不同的消息类型有命名冲突
  4. package pb
  5. import (
  6. context "context"
  7. v1 "cp-organization-management-gateway/pb/v1"
  8. fmt "fmt"
  9. proto "github.com/golang/protobuf/proto"
  10. grpc "google.golang.org/grpc"
  11. codes "google.golang.org/grpc/codes"
  12. status "google.golang.org/grpc/status"
  13. math "math"
  14. )
  15. // Reference imports to suppress errors if they are not otherwise used.
  16. var _ = proto.Marshal
  17. var _ = fmt.Errorf
  18. var _ = math.Inf
  19. // This is a compile-time assertion to ensure that this generated file
  20. // is compatible with the proto package it is being compiled against.
  21. // A compilation error at this line likely means your copy of the
  22. // proto package needs to be updated.
  23. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  24. func init() {
  25. proto.RegisterFile("organization_service.proto", fileDescriptor_e19a463063c4fee0)
  26. }
  27. var fileDescriptor_e19a463063c4fee0 = []byte{
  28. // 536 bytes of a gzipped FileDescriptorProto
  29. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x55, 0x4d, 0x6f, 0xd3, 0x30,
  30. 0x18, 0x86, 0x0b, 0x20, 0x6b, 0x13, 0xe0, 0x7d, 0xb0, 0xb5, 0x74, 0x54, 0x43, 0xd5, 0x2e, 0x34,
  31. 0xd3, 0xe0, 0x80, 0xc4, 0x09, 0x46, 0x05, 0xaa, 0x34, 0x28, 0x2a, 0xaa, 0x84, 0x76, 0x60, 0x72,
  32. 0x9a, 0x97, 0x28, 0x52, 0x1b, 0x87, 0xc4, 0xed, 0x54, 0x8e, 0xfc, 0x59, 0xfe, 0x06, 0xf2, 0x67,
  33. 0xed, 0xc4, 0x6e, 0x77, 0xcc, 0xf3, 0x3c, 0xef, 0xf3, 0x7e, 0xd9, 0x0e, 0x6a, 0xd1, 0x32, 0x25,
  34. 0x79, 0xf6, 0x87, 0xb0, 0x8c, 0xe6, 0x37, 0x15, 0x94, 0xcb, 0x6c, 0x0a, 0x51, 0x51, 0x52, 0x46,
  35. 0x31, 0x2a, 0xe2, 0x48, 0x21, 0xad, 0x83, 0xe5, 0xc5, 0xb9, 0x2d, 0x95, 0x92, 0xd7, 0xff, 0x76,
  36. 0xd1, 0xce, 0xc8, 0x82, 0xf1, 0x0f, 0x84, 0x87, 0x79, 0xc6, 0x6c, 0x6c, 0x10, 0xe3, 0x6e, 0x54,
  37. 0xc4, 0x37, 0xcb, 0x8b, 0xa8, 0x49, 0x8d, 0xe1, 0xf7, 0x02, 0x2a, 0xd6, 0x3a, 0xd9, 0xa0, 0x28,
  38. 0x66, 0xab, 0xd3, 0x7b, 0xf8, 0x27, 0xda, 0xff, 0x58, 0x02, 0x61, 0xf0, 0x85, 0xe4, 0x24, 0x85,
  39. 0x39, 0xe4, 0x6c, 0x52, 0x41, 0x89, 0x4f, 0x55, 0xa4, 0x8f, 0xd4, 0xee, 0xdd, 0x8d, 0x1a, 0xe9,
  40. 0x9f, 0xa2, 0x67, 0x6b, 0xe2, 0xfb, 0xa2, 0x80, 0x92, 0xb3, 0x57, 0x59, 0xc5, 0x70, 0x4f, 0x85,
  41. 0x07, 0x78, 0x9d, 0xe5, 0xe5, 0x36, 0x99, 0x4c, 0x34, 0x47, 0xc7, 0x1e, 0xc5, 0xa4, 0x48, 0x08,
  42. 0x03, 0x7c, 0x16, 0xf6, 0x90, 0x0a, 0x9d, 0xac, 0xb7, 0x5d, 0x28, 0xd3, 0xfd, 0xbd, 0x8f, 0xba,
  43. 0x1e, 0xd1, 0x18, 0x2a, 0x60, 0xdf, 0x48, 0x55, 0xdd, 0xd2, 0x32, 0xc1, 0x51, 0xd8, 0xcd, 0x11,
  44. 0xea, 0xec, 0xaf, 0xee, 0xac, 0x97, 0x45, 0x8c, 0xd0, 0xe3, 0xb5, 0xf4, 0x8a, 0xa6, 0x59, 0x8e,
  45. 0x3b, 0x0d, 0x0b, 0x81, 0xeb, 0x0c, 0xed, 0x10, 0x2d, 0x0d, 0x3f, 0xa1, 0x9d, 0x71, 0x4c, 0xa6,
  46. 0x5f, 0x69, 0x02, 0x62, 0x45, 0x2d, 0x25, 0xb7, 0x41, 0x6d, 0x75, 0xe4, 0xe5, 0xa4, 0xcf, 0x10,
  47. 0xed, 0x72, 0xf8, 0x73, 0x49, 0x17, 0x85, 0x30, 0x6a, 0x5b, 0x62, 0x83, 0x6a, 0xa7, 0x63, 0x3f,
  48. 0x69, 0xf6, 0x6a, 0x67, 0xb8, 0x5c, 0x09, 0xc5, 0x48, 0x0c, 0xc5, 0xec, 0x35, 0xa8, 0xa8, 0xef,
  49. 0x75, 0x83, 0xd0, 0x99, 0x80, 0x60, 0x3e, 0x24, 0x89, 0x33, 0x01, 0x0d, 0xfa, 0x26, 0xb0, 0xe6,
  50. 0xcc, 0x6a, 0x0c, 0xac, 0x0e, 0x61, 0xa7, 0x2e, 0x77, 0x8f, 0x5e, 0x3b, 0x44, 0x37, 0x0b, 0x1b,
  51. 0xc0, 0xac, 0x59, 0xd8, 0x00, 0x66, 0xc1, 0xc2, 0x04, 0x27, 0x7d, 0xde, 0xa2, 0x87, 0xd7, 0x34,
  52. 0x07, 0xde, 0xdb, 0x81, 0x92, 0xa9, 0x6f, 0x1d, 0xbd, 0x57, 0x87, 0x9d, 0x40, 0x9e, 0xdb, 0x0e,
  53. 0xb4, 0xd2, 0xee, 0xd5, 0x61, 0x19, 0xf8, 0x1e, 0x21, 0x8e, 0xa8, 0x29, 0x1c, 0x59, 0x22, 0x77,
  54. 0x00, 0x87, 0x1e, 0x46, 0x3a, 0xbc, 0x43, 0x8f, 0x38, 0x28, 0x4e, 0x92, 0xad, 0xb2, 0x0f, 0xd1,
  55. 0x7e, 0x03, 0x37, 0xd9, 0xad, 0x87, 0x40, 0x67, 0x6f, 0xde, 0xfc, 0x43, 0x0f, 0x63, 0x1a, 0xe7,
  56. 0xa0, 0xdd, 0xb8, 0xfa, 0xae, 0x37, 0x6e, 0x60, 0x53, 0xb6, 0x79, 0xec, 0x6c, 0x7b, 0x5f, 0xd9,
  57. 0xf5, 0xe7, 0x4c, 0xc5, 0x0e, 0xf3, 0x5f, 0xd4, 0x89, 0xe5, 0x80, 0x2f, 0x56, 0xe2, 0x32, 0x76,
  58. 0x8c, 0x9e, 0x38, 0xf7, 0x9b, 0xef, 0xfa, 0xc4, 0x77, 0xf1, 0xad, 0xa5, 0x3f, 0x0f, 0xf2, 0xd2,
  59. 0x73, 0x82, 0x9e, 0x3a, 0x94, 0x68, 0xea, 0x85, 0x2f, 0xc8, 0xee, 0xae, 0x13, 0x16, 0x08, 0xdb,
  60. 0xcb, 0xb3, 0xeb, 0xde, 0xb4, 0xe8, 0xdb, 0xbf, 0xc0, 0xfe, 0xdc, 0x68, 0xfb, 0x29, 0x61, 0x70,
  61. 0x4b, 0x56, 0xe7, 0x45, 0x1c, 0x3f, 0x10, 0x7f, 0xc6, 0x37, 0xff, 0x03, 0x00, 0x00, 0xff, 0xff,
  62. 0xe5, 0xfd, 0x62, 0x8e, 0x5a, 0x07, 0x00, 0x00,
  63. }
  64. // Reference imports to suppress errors if they are not otherwise used.
  65. var _ context.Context
  66. var _ grpc.ClientConnInterface
  67. // This is a compile-time assertion to ensure that this generated file
  68. // is compatible with the grpc package it is being compiled against.
  69. const _ = grpc.SupportPackageIsVersion6
  70. // OrganizationClient is the client API for Organization service.
  71. //
  72. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  73. type OrganizationClient interface {
  74. // 初始化数据库
  75. InitOrganizationDb(ctx context.Context, in *v1.InitOrganizationDbRequest, opts ...grpc.CallOption) (*v1.InitOrganizationDbReply, error)
  76. // 创建机构账号
  77. CreateManagementUser(ctx context.Context, in *v1.CreateManagementUserRequest, opts ...grpc.CallOption) (*v1.CreateManagementUserReply, error)
  78. // 系统端获取超级管理员账户列表
  79. ManagementSuperUserList(ctx context.Context, in *v1.ManagementSuperUserListRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserListReply, error)
  80. // 系统端更新超级管理员用户信息
  81. ManagementSuperUserUpdate(ctx context.Context, in *v1.ManagementSuperUserUpdateRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserUpdateReply, error)
  82. // 系统端重置超级管理员密码
  83. ManagementSuperUserResetPassword(ctx context.Context, in *v1.ManagementSuperUserResetPasswordRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserResetPasswordReply, error)
  84. ManagementLogin(ctx context.Context, in *v1.ManagementLoginRequest, opts ...grpc.CallOption) (*v1.ManagementLoginReply, error)
  85. // 权限节点列表
  86. RbacNodeList(ctx context.Context, in *v1.RbacNodeListRequest, opts ...grpc.CallOption) (*v1.RbacNodeListReply, error)
  87. // 角色列表
  88. RbacGroupList(ctx context.Context, in *v1.RbacGroupListRequest, opts ...grpc.CallOption) (*v1.RbacGroupListReply, error)
  89. // 角色或用户下的权限节点列表
  90. RbacNodeListByGroupOrUser(ctx context.Context, in *v1.RbacNodeListByGroupOrUserRequest, opts ...grpc.CallOption) (*v1.RbacNodeListByGroupOrUserReply, error)
  91. // 添加角色
  92. RbacGroupAdd(ctx context.Context, in *v1.RbacGroupAddRequest, opts ...grpc.CallOption) (*v1.RbacGroupAddReply, error)
  93. // 修改角色
  94. RbacGroupUpdate(ctx context.Context, in *v1.RbacGroupUpdateRequest, opts ...grpc.CallOption) (*v1.RbacGroupUpdateReply, error)
  95. // 删除角色
  96. RbacGroupDel(ctx context.Context, in *v1.RbacGroupDelRequest, opts ...grpc.CallOption) (*v1.RbacGroupDelReply, error)
  97. // 添加区域
  98. ZoneAdd(ctx context.Context, in *v1.ZoneAddRequest, opts ...grpc.CallOption) (*v1.ZoneAddReply, error)
  99. // 删除区域
  100. ZoneDel(ctx context.Context, in *v1.ZoneDelRequest, opts ...grpc.CallOption) (*v1.ZoneDelReply, error)
  101. // 更新区域
  102. ZoneUpdate(ctx context.Context, in *v1.ZoneUpdateRequest, opts ...grpc.CallOption) (*v1.ZoneUpdateReply, error)
  103. // 区域列表
  104. ZoneList(ctx context.Context, in *v1.ZoneListRequest, opts ...grpc.CallOption) (*v1.ZoneListReply, error)
  105. // 用户管理
  106. UserUpdate(ctx context.Context, in *v1.UserUpdateRequest, opts ...grpc.CallOption) (*v1.UserUpdateReply, error)
  107. UserDel(ctx context.Context, in *v1.UserDelRequest, opts ...grpc.CallOption) (*v1.UserDelReply, error)
  108. UserList(ctx context.Context, in *v1.UserListRequest, opts ...grpc.CallOption) (*v1.UserListReply, error)
  109. UserInfo(ctx context.Context, in *v1.UserInfoRequest, opts ...grpc.CallOption) (*v1.UserInfoReply, error)
  110. // 添加系统操作日志
  111. ManagementLogAdd(ctx context.Context, in *v1.ManagementLogAddRequest, opts ...grpc.CallOption) (*v1.ManagementLogAddReply, error)
  112. // 系统操作日志列表
  113. ManagementLogList(ctx context.Context, in *v1.ManagementLogListRequest, opts ...grpc.CallOption) (*v1.ManagementLogListReply, error)
  114. }
  115. type organizationClient struct {
  116. cc grpc.ClientConnInterface
  117. }
  118. func NewOrganizationClient(cc grpc.ClientConnInterface) OrganizationClient {
  119. return &organizationClient{cc}
  120. }
  121. func (c *organizationClient) InitOrganizationDb(ctx context.Context, in *v1.InitOrganizationDbRequest, opts ...grpc.CallOption) (*v1.InitOrganizationDbReply, error) {
  122. out := new(v1.InitOrganizationDbReply)
  123. err := c.cc.Invoke(ctx, "/pb.service.Organization/InitOrganizationDb", in, out, opts...)
  124. if err != nil {
  125. return nil, err
  126. }
  127. return out, nil
  128. }
  129. func (c *organizationClient) CreateManagementUser(ctx context.Context, in *v1.CreateManagementUserRequest, opts ...grpc.CallOption) (*v1.CreateManagementUserReply, error) {
  130. out := new(v1.CreateManagementUserReply)
  131. err := c.cc.Invoke(ctx, "/pb.service.Organization/CreateManagementUser", in, out, opts...)
  132. if err != nil {
  133. return nil, err
  134. }
  135. return out, nil
  136. }
  137. func (c *organizationClient) ManagementSuperUserList(ctx context.Context, in *v1.ManagementSuperUserListRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserListReply, error) {
  138. out := new(v1.ManagementSuperUserListReply)
  139. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementSuperUserList", in, out, opts...)
  140. if err != nil {
  141. return nil, err
  142. }
  143. return out, nil
  144. }
  145. func (c *organizationClient) ManagementSuperUserUpdate(ctx context.Context, in *v1.ManagementSuperUserUpdateRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserUpdateReply, error) {
  146. out := new(v1.ManagementSuperUserUpdateReply)
  147. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementSuperUserUpdate", in, out, opts...)
  148. if err != nil {
  149. return nil, err
  150. }
  151. return out, nil
  152. }
  153. func (c *organizationClient) ManagementSuperUserResetPassword(ctx context.Context, in *v1.ManagementSuperUserResetPasswordRequest, opts ...grpc.CallOption) (*v1.ManagementSuperUserResetPasswordReply, error) {
  154. out := new(v1.ManagementSuperUserResetPasswordReply)
  155. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementSuperUserResetPassword", in, out, opts...)
  156. if err != nil {
  157. return nil, err
  158. }
  159. return out, nil
  160. }
  161. func (c *organizationClient) ManagementLogin(ctx context.Context, in *v1.ManagementLoginRequest, opts ...grpc.CallOption) (*v1.ManagementLoginReply, error) {
  162. out := new(v1.ManagementLoginReply)
  163. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementLogin", in, out, opts...)
  164. if err != nil {
  165. return nil, err
  166. }
  167. return out, nil
  168. }
  169. func (c *organizationClient) RbacNodeList(ctx context.Context, in *v1.RbacNodeListRequest, opts ...grpc.CallOption) (*v1.RbacNodeListReply, error) {
  170. out := new(v1.RbacNodeListReply)
  171. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacNodeList", in, out, opts...)
  172. if err != nil {
  173. return nil, err
  174. }
  175. return out, nil
  176. }
  177. func (c *organizationClient) RbacGroupList(ctx context.Context, in *v1.RbacGroupListRequest, opts ...grpc.CallOption) (*v1.RbacGroupListReply, error) {
  178. out := new(v1.RbacGroupListReply)
  179. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacGroupList", in, out, opts...)
  180. if err != nil {
  181. return nil, err
  182. }
  183. return out, nil
  184. }
  185. func (c *organizationClient) RbacNodeListByGroupOrUser(ctx context.Context, in *v1.RbacNodeListByGroupOrUserRequest, opts ...grpc.CallOption) (*v1.RbacNodeListByGroupOrUserReply, error) {
  186. out := new(v1.RbacNodeListByGroupOrUserReply)
  187. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacNodeListByGroupOrUser", in, out, opts...)
  188. if err != nil {
  189. return nil, err
  190. }
  191. return out, nil
  192. }
  193. func (c *organizationClient) RbacGroupAdd(ctx context.Context, in *v1.RbacGroupAddRequest, opts ...grpc.CallOption) (*v1.RbacGroupAddReply, error) {
  194. out := new(v1.RbacGroupAddReply)
  195. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacGroupAdd", in, out, opts...)
  196. if err != nil {
  197. return nil, err
  198. }
  199. return out, nil
  200. }
  201. func (c *organizationClient) RbacGroupUpdate(ctx context.Context, in *v1.RbacGroupUpdateRequest, opts ...grpc.CallOption) (*v1.RbacGroupUpdateReply, error) {
  202. out := new(v1.RbacGroupUpdateReply)
  203. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacGroupUpdate", in, out, opts...)
  204. if err != nil {
  205. return nil, err
  206. }
  207. return out, nil
  208. }
  209. func (c *organizationClient) RbacGroupDel(ctx context.Context, in *v1.RbacGroupDelRequest, opts ...grpc.CallOption) (*v1.RbacGroupDelReply, error) {
  210. out := new(v1.RbacGroupDelReply)
  211. err := c.cc.Invoke(ctx, "/pb.service.Organization/RbacGroupDel", in, out, opts...)
  212. if err != nil {
  213. return nil, err
  214. }
  215. return out, nil
  216. }
  217. func (c *organizationClient) ZoneAdd(ctx context.Context, in *v1.ZoneAddRequest, opts ...grpc.CallOption) (*v1.ZoneAddReply, error) {
  218. out := new(v1.ZoneAddReply)
  219. err := c.cc.Invoke(ctx, "/pb.service.Organization/ZoneAdd", in, out, opts...)
  220. if err != nil {
  221. return nil, err
  222. }
  223. return out, nil
  224. }
  225. func (c *organizationClient) ZoneDel(ctx context.Context, in *v1.ZoneDelRequest, opts ...grpc.CallOption) (*v1.ZoneDelReply, error) {
  226. out := new(v1.ZoneDelReply)
  227. err := c.cc.Invoke(ctx, "/pb.service.Organization/ZoneDel", in, out, opts...)
  228. if err != nil {
  229. return nil, err
  230. }
  231. return out, nil
  232. }
  233. func (c *organizationClient) ZoneUpdate(ctx context.Context, in *v1.ZoneUpdateRequest, opts ...grpc.CallOption) (*v1.ZoneUpdateReply, error) {
  234. out := new(v1.ZoneUpdateReply)
  235. err := c.cc.Invoke(ctx, "/pb.service.Organization/ZoneUpdate", in, out, opts...)
  236. if err != nil {
  237. return nil, err
  238. }
  239. return out, nil
  240. }
  241. func (c *organizationClient) ZoneList(ctx context.Context, in *v1.ZoneListRequest, opts ...grpc.CallOption) (*v1.ZoneListReply, error) {
  242. out := new(v1.ZoneListReply)
  243. err := c.cc.Invoke(ctx, "/pb.service.Organization/ZoneList", in, out, opts...)
  244. if err != nil {
  245. return nil, err
  246. }
  247. return out, nil
  248. }
  249. func (c *organizationClient) UserUpdate(ctx context.Context, in *v1.UserUpdateRequest, opts ...grpc.CallOption) (*v1.UserUpdateReply, error) {
  250. out := new(v1.UserUpdateReply)
  251. err := c.cc.Invoke(ctx, "/pb.service.Organization/UserUpdate", in, out, opts...)
  252. if err != nil {
  253. return nil, err
  254. }
  255. return out, nil
  256. }
  257. func (c *organizationClient) UserDel(ctx context.Context, in *v1.UserDelRequest, opts ...grpc.CallOption) (*v1.UserDelReply, error) {
  258. out := new(v1.UserDelReply)
  259. err := c.cc.Invoke(ctx, "/pb.service.Organization/UserDel", in, out, opts...)
  260. if err != nil {
  261. return nil, err
  262. }
  263. return out, nil
  264. }
  265. func (c *organizationClient) UserList(ctx context.Context, in *v1.UserListRequest, opts ...grpc.CallOption) (*v1.UserListReply, error) {
  266. out := new(v1.UserListReply)
  267. err := c.cc.Invoke(ctx, "/pb.service.Organization/UserList", in, out, opts...)
  268. if err != nil {
  269. return nil, err
  270. }
  271. return out, nil
  272. }
  273. func (c *organizationClient) UserInfo(ctx context.Context, in *v1.UserInfoRequest, opts ...grpc.CallOption) (*v1.UserInfoReply, error) {
  274. out := new(v1.UserInfoReply)
  275. err := c.cc.Invoke(ctx, "/pb.service.Organization/UserInfo", in, out, opts...)
  276. if err != nil {
  277. return nil, err
  278. }
  279. return out, nil
  280. }
  281. func (c *organizationClient) ManagementLogAdd(ctx context.Context, in *v1.ManagementLogAddRequest, opts ...grpc.CallOption) (*v1.ManagementLogAddReply, error) {
  282. out := new(v1.ManagementLogAddReply)
  283. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementLogAdd", in, out, opts...)
  284. if err != nil {
  285. return nil, err
  286. }
  287. return out, nil
  288. }
  289. func (c *organizationClient) ManagementLogList(ctx context.Context, in *v1.ManagementLogListRequest, opts ...grpc.CallOption) (*v1.ManagementLogListReply, error) {
  290. out := new(v1.ManagementLogListReply)
  291. err := c.cc.Invoke(ctx, "/pb.service.Organization/ManagementLogList", in, out, opts...)
  292. if err != nil {
  293. return nil, err
  294. }
  295. return out, nil
  296. }
  297. // OrganizationServer is the server API for Organization service.
  298. type OrganizationServer interface {
  299. // 初始化数据库
  300. InitOrganizationDb(context.Context, *v1.InitOrganizationDbRequest) (*v1.InitOrganizationDbReply, error)
  301. // 创建机构账号
  302. CreateManagementUser(context.Context, *v1.CreateManagementUserRequest) (*v1.CreateManagementUserReply, error)
  303. // 系统端获取超级管理员账户列表
  304. ManagementSuperUserList(context.Context, *v1.ManagementSuperUserListRequest) (*v1.ManagementSuperUserListReply, error)
  305. // 系统端更新超级管理员用户信息
  306. ManagementSuperUserUpdate(context.Context, *v1.ManagementSuperUserUpdateRequest) (*v1.ManagementSuperUserUpdateReply, error)
  307. // 系统端重置超级管理员密码
  308. ManagementSuperUserResetPassword(context.Context, *v1.ManagementSuperUserResetPasswordRequest) (*v1.ManagementSuperUserResetPasswordReply, error)
  309. ManagementLogin(context.Context, *v1.ManagementLoginRequest) (*v1.ManagementLoginReply, error)
  310. // 权限节点列表
  311. RbacNodeList(context.Context, *v1.RbacNodeListRequest) (*v1.RbacNodeListReply, error)
  312. // 角色列表
  313. RbacGroupList(context.Context, *v1.RbacGroupListRequest) (*v1.RbacGroupListReply, error)
  314. // 角色或用户下的权限节点列表
  315. RbacNodeListByGroupOrUser(context.Context, *v1.RbacNodeListByGroupOrUserRequest) (*v1.RbacNodeListByGroupOrUserReply, error)
  316. // 添加角色
  317. RbacGroupAdd(context.Context, *v1.RbacGroupAddRequest) (*v1.RbacGroupAddReply, error)
  318. // 修改角色
  319. RbacGroupUpdate(context.Context, *v1.RbacGroupUpdateRequest) (*v1.RbacGroupUpdateReply, error)
  320. // 删除角色
  321. RbacGroupDel(context.Context, *v1.RbacGroupDelRequest) (*v1.RbacGroupDelReply, error)
  322. // 添加区域
  323. ZoneAdd(context.Context, *v1.ZoneAddRequest) (*v1.ZoneAddReply, error)
  324. // 删除区域
  325. ZoneDel(context.Context, *v1.ZoneDelRequest) (*v1.ZoneDelReply, error)
  326. // 更新区域
  327. ZoneUpdate(context.Context, *v1.ZoneUpdateRequest) (*v1.ZoneUpdateReply, error)
  328. // 区域列表
  329. ZoneList(context.Context, *v1.ZoneListRequest) (*v1.ZoneListReply, error)
  330. // 用户管理
  331. UserUpdate(context.Context, *v1.UserUpdateRequest) (*v1.UserUpdateReply, error)
  332. UserDel(context.Context, *v1.UserDelRequest) (*v1.UserDelReply, error)
  333. UserList(context.Context, *v1.UserListRequest) (*v1.UserListReply, error)
  334. UserInfo(context.Context, *v1.UserInfoRequest) (*v1.UserInfoReply, error)
  335. // 添加系统操作日志
  336. ManagementLogAdd(context.Context, *v1.ManagementLogAddRequest) (*v1.ManagementLogAddReply, error)
  337. // 系统操作日志列表
  338. ManagementLogList(context.Context, *v1.ManagementLogListRequest) (*v1.ManagementLogListReply, error)
  339. }
  340. // UnimplementedOrganizationServer can be embedded to have forward compatible implementations.
  341. type UnimplementedOrganizationServer struct {
  342. }
  343. func (*UnimplementedOrganizationServer) InitOrganizationDb(ctx context.Context, req *v1.InitOrganizationDbRequest) (*v1.InitOrganizationDbReply, error) {
  344. return nil, status.Errorf(codes.Unimplemented, "method InitOrganizationDb not implemented")
  345. }
  346. func (*UnimplementedOrganizationServer) CreateManagementUser(ctx context.Context, req *v1.CreateManagementUserRequest) (*v1.CreateManagementUserReply, error) {
  347. return nil, status.Errorf(codes.Unimplemented, "method CreateManagementUser not implemented")
  348. }
  349. func (*UnimplementedOrganizationServer) ManagementSuperUserList(ctx context.Context, req *v1.ManagementSuperUserListRequest) (*v1.ManagementSuperUserListReply, error) {
  350. return nil, status.Errorf(codes.Unimplemented, "method ManagementSuperUserList not implemented")
  351. }
  352. func (*UnimplementedOrganizationServer) ManagementSuperUserUpdate(ctx context.Context, req *v1.ManagementSuperUserUpdateRequest) (*v1.ManagementSuperUserUpdateReply, error) {
  353. return nil, status.Errorf(codes.Unimplemented, "method ManagementSuperUserUpdate not implemented")
  354. }
  355. func (*UnimplementedOrganizationServer) ManagementSuperUserResetPassword(ctx context.Context, req *v1.ManagementSuperUserResetPasswordRequest) (*v1.ManagementSuperUserResetPasswordReply, error) {
  356. return nil, status.Errorf(codes.Unimplemented, "method ManagementSuperUserResetPassword not implemented")
  357. }
  358. func (*UnimplementedOrganizationServer) ManagementLogin(ctx context.Context, req *v1.ManagementLoginRequest) (*v1.ManagementLoginReply, error) {
  359. return nil, status.Errorf(codes.Unimplemented, "method ManagementLogin not implemented")
  360. }
  361. func (*UnimplementedOrganizationServer) RbacNodeList(ctx context.Context, req *v1.RbacNodeListRequest) (*v1.RbacNodeListReply, error) {
  362. return nil, status.Errorf(codes.Unimplemented, "method RbacNodeList not implemented")
  363. }
  364. func (*UnimplementedOrganizationServer) RbacGroupList(ctx context.Context, req *v1.RbacGroupListRequest) (*v1.RbacGroupListReply, error) {
  365. return nil, status.Errorf(codes.Unimplemented, "method RbacGroupList not implemented")
  366. }
  367. func (*UnimplementedOrganizationServer) RbacNodeListByGroupOrUser(ctx context.Context, req *v1.RbacNodeListByGroupOrUserRequest) (*v1.RbacNodeListByGroupOrUserReply, error) {
  368. return nil, status.Errorf(codes.Unimplemented, "method RbacNodeListByGroupOrUser not implemented")
  369. }
  370. func (*UnimplementedOrganizationServer) RbacGroupAdd(ctx context.Context, req *v1.RbacGroupAddRequest) (*v1.RbacGroupAddReply, error) {
  371. return nil, status.Errorf(codes.Unimplemented, "method RbacGroupAdd not implemented")
  372. }
  373. func (*UnimplementedOrganizationServer) RbacGroupUpdate(ctx context.Context, req *v1.RbacGroupUpdateRequest) (*v1.RbacGroupUpdateReply, error) {
  374. return nil, status.Errorf(codes.Unimplemented, "method RbacGroupUpdate not implemented")
  375. }
  376. func (*UnimplementedOrganizationServer) RbacGroupDel(ctx context.Context, req *v1.RbacGroupDelRequest) (*v1.RbacGroupDelReply, error) {
  377. return nil, status.Errorf(codes.Unimplemented, "method RbacGroupDel not implemented")
  378. }
  379. func (*UnimplementedOrganizationServer) ZoneAdd(ctx context.Context, req *v1.ZoneAddRequest) (*v1.ZoneAddReply, error) {
  380. return nil, status.Errorf(codes.Unimplemented, "method ZoneAdd not implemented")
  381. }
  382. func (*UnimplementedOrganizationServer) ZoneDel(ctx context.Context, req *v1.ZoneDelRequest) (*v1.ZoneDelReply, error) {
  383. return nil, status.Errorf(codes.Unimplemented, "method ZoneDel not implemented")
  384. }
  385. func (*UnimplementedOrganizationServer) ZoneUpdate(ctx context.Context, req *v1.ZoneUpdateRequest) (*v1.ZoneUpdateReply, error) {
  386. return nil, status.Errorf(codes.Unimplemented, "method ZoneUpdate not implemented")
  387. }
  388. func (*UnimplementedOrganizationServer) ZoneList(ctx context.Context, req *v1.ZoneListRequest) (*v1.ZoneListReply, error) {
  389. return nil, status.Errorf(codes.Unimplemented, "method ZoneList not implemented")
  390. }
  391. func (*UnimplementedOrganizationServer) UserUpdate(ctx context.Context, req *v1.UserUpdateRequest) (*v1.UserUpdateReply, error) {
  392. return nil, status.Errorf(codes.Unimplemented, "method UserUpdate not implemented")
  393. }
  394. func (*UnimplementedOrganizationServer) UserDel(ctx context.Context, req *v1.UserDelRequest) (*v1.UserDelReply, error) {
  395. return nil, status.Errorf(codes.Unimplemented, "method UserDel not implemented")
  396. }
  397. func (*UnimplementedOrganizationServer) UserList(ctx context.Context, req *v1.UserListRequest) (*v1.UserListReply, error) {
  398. return nil, status.Errorf(codes.Unimplemented, "method UserList not implemented")
  399. }
  400. func (*UnimplementedOrganizationServer) UserInfo(ctx context.Context, req *v1.UserInfoRequest) (*v1.UserInfoReply, error) {
  401. return nil, status.Errorf(codes.Unimplemented, "method UserInfo not implemented")
  402. }
  403. func (*UnimplementedOrganizationServer) ManagementLogAdd(ctx context.Context, req *v1.ManagementLogAddRequest) (*v1.ManagementLogAddReply, error) {
  404. return nil, status.Errorf(codes.Unimplemented, "method ManagementLogAdd not implemented")
  405. }
  406. func (*UnimplementedOrganizationServer) ManagementLogList(ctx context.Context, req *v1.ManagementLogListRequest) (*v1.ManagementLogListReply, error) {
  407. return nil, status.Errorf(codes.Unimplemented, "method ManagementLogList not implemented")
  408. }
  409. func RegisterOrganizationServer(s *grpc.Server, srv OrganizationServer) {
  410. s.RegisterService(&_Organization_serviceDesc, srv)
  411. }
  412. func _Organization_InitOrganizationDb_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  413. in := new(v1.InitOrganizationDbRequest)
  414. if err := dec(in); err != nil {
  415. return nil, err
  416. }
  417. if interceptor == nil {
  418. return srv.(OrganizationServer).InitOrganizationDb(ctx, in)
  419. }
  420. info := &grpc.UnaryServerInfo{
  421. Server: srv,
  422. FullMethod: "/pb.service.Organization/InitOrganizationDb",
  423. }
  424. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  425. return srv.(OrganizationServer).InitOrganizationDb(ctx, req.(*v1.InitOrganizationDbRequest))
  426. }
  427. return interceptor(ctx, in, info, handler)
  428. }
  429. func _Organization_CreateManagementUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  430. in := new(v1.CreateManagementUserRequest)
  431. if err := dec(in); err != nil {
  432. return nil, err
  433. }
  434. if interceptor == nil {
  435. return srv.(OrganizationServer).CreateManagementUser(ctx, in)
  436. }
  437. info := &grpc.UnaryServerInfo{
  438. Server: srv,
  439. FullMethod: "/pb.service.Organization/CreateManagementUser",
  440. }
  441. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  442. return srv.(OrganizationServer).CreateManagementUser(ctx, req.(*v1.CreateManagementUserRequest))
  443. }
  444. return interceptor(ctx, in, info, handler)
  445. }
  446. func _Organization_ManagementSuperUserList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  447. in := new(v1.ManagementSuperUserListRequest)
  448. if err := dec(in); err != nil {
  449. return nil, err
  450. }
  451. if interceptor == nil {
  452. return srv.(OrganizationServer).ManagementSuperUserList(ctx, in)
  453. }
  454. info := &grpc.UnaryServerInfo{
  455. Server: srv,
  456. FullMethod: "/pb.service.Organization/ManagementSuperUserList",
  457. }
  458. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  459. return srv.(OrganizationServer).ManagementSuperUserList(ctx, req.(*v1.ManagementSuperUserListRequest))
  460. }
  461. return interceptor(ctx, in, info, handler)
  462. }
  463. func _Organization_ManagementSuperUserUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  464. in := new(v1.ManagementSuperUserUpdateRequest)
  465. if err := dec(in); err != nil {
  466. return nil, err
  467. }
  468. if interceptor == nil {
  469. return srv.(OrganizationServer).ManagementSuperUserUpdate(ctx, in)
  470. }
  471. info := &grpc.UnaryServerInfo{
  472. Server: srv,
  473. FullMethod: "/pb.service.Organization/ManagementSuperUserUpdate",
  474. }
  475. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  476. return srv.(OrganizationServer).ManagementSuperUserUpdate(ctx, req.(*v1.ManagementSuperUserUpdateRequest))
  477. }
  478. return interceptor(ctx, in, info, handler)
  479. }
  480. func _Organization_ManagementSuperUserResetPassword_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  481. in := new(v1.ManagementSuperUserResetPasswordRequest)
  482. if err := dec(in); err != nil {
  483. return nil, err
  484. }
  485. if interceptor == nil {
  486. return srv.(OrganizationServer).ManagementSuperUserResetPassword(ctx, in)
  487. }
  488. info := &grpc.UnaryServerInfo{
  489. Server: srv,
  490. FullMethod: "/pb.service.Organization/ManagementSuperUserResetPassword",
  491. }
  492. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  493. return srv.(OrganizationServer).ManagementSuperUserResetPassword(ctx, req.(*v1.ManagementSuperUserResetPasswordRequest))
  494. }
  495. return interceptor(ctx, in, info, handler)
  496. }
  497. func _Organization_ManagementLogin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  498. in := new(v1.ManagementLoginRequest)
  499. if err := dec(in); err != nil {
  500. return nil, err
  501. }
  502. if interceptor == nil {
  503. return srv.(OrganizationServer).ManagementLogin(ctx, in)
  504. }
  505. info := &grpc.UnaryServerInfo{
  506. Server: srv,
  507. FullMethod: "/pb.service.Organization/ManagementLogin",
  508. }
  509. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  510. return srv.(OrganizationServer).ManagementLogin(ctx, req.(*v1.ManagementLoginRequest))
  511. }
  512. return interceptor(ctx, in, info, handler)
  513. }
  514. func _Organization_RbacNodeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  515. in := new(v1.RbacNodeListRequest)
  516. if err := dec(in); err != nil {
  517. return nil, err
  518. }
  519. if interceptor == nil {
  520. return srv.(OrganizationServer).RbacNodeList(ctx, in)
  521. }
  522. info := &grpc.UnaryServerInfo{
  523. Server: srv,
  524. FullMethod: "/pb.service.Organization/RbacNodeList",
  525. }
  526. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  527. return srv.(OrganizationServer).RbacNodeList(ctx, req.(*v1.RbacNodeListRequest))
  528. }
  529. return interceptor(ctx, in, info, handler)
  530. }
  531. func _Organization_RbacGroupList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  532. in := new(v1.RbacGroupListRequest)
  533. if err := dec(in); err != nil {
  534. return nil, err
  535. }
  536. if interceptor == nil {
  537. return srv.(OrganizationServer).RbacGroupList(ctx, in)
  538. }
  539. info := &grpc.UnaryServerInfo{
  540. Server: srv,
  541. FullMethod: "/pb.service.Organization/RbacGroupList",
  542. }
  543. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  544. return srv.(OrganizationServer).RbacGroupList(ctx, req.(*v1.RbacGroupListRequest))
  545. }
  546. return interceptor(ctx, in, info, handler)
  547. }
  548. func _Organization_RbacNodeListByGroupOrUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  549. in := new(v1.RbacNodeListByGroupOrUserRequest)
  550. if err := dec(in); err != nil {
  551. return nil, err
  552. }
  553. if interceptor == nil {
  554. return srv.(OrganizationServer).RbacNodeListByGroupOrUser(ctx, in)
  555. }
  556. info := &grpc.UnaryServerInfo{
  557. Server: srv,
  558. FullMethod: "/pb.service.Organization/RbacNodeListByGroupOrUser",
  559. }
  560. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  561. return srv.(OrganizationServer).RbacNodeListByGroupOrUser(ctx, req.(*v1.RbacNodeListByGroupOrUserRequest))
  562. }
  563. return interceptor(ctx, in, info, handler)
  564. }
  565. func _Organization_RbacGroupAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  566. in := new(v1.RbacGroupAddRequest)
  567. if err := dec(in); err != nil {
  568. return nil, err
  569. }
  570. if interceptor == nil {
  571. return srv.(OrganizationServer).RbacGroupAdd(ctx, in)
  572. }
  573. info := &grpc.UnaryServerInfo{
  574. Server: srv,
  575. FullMethod: "/pb.service.Organization/RbacGroupAdd",
  576. }
  577. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  578. return srv.(OrganizationServer).RbacGroupAdd(ctx, req.(*v1.RbacGroupAddRequest))
  579. }
  580. return interceptor(ctx, in, info, handler)
  581. }
  582. func _Organization_RbacGroupUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  583. in := new(v1.RbacGroupUpdateRequest)
  584. if err := dec(in); err != nil {
  585. return nil, err
  586. }
  587. if interceptor == nil {
  588. return srv.(OrganizationServer).RbacGroupUpdate(ctx, in)
  589. }
  590. info := &grpc.UnaryServerInfo{
  591. Server: srv,
  592. FullMethod: "/pb.service.Organization/RbacGroupUpdate",
  593. }
  594. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  595. return srv.(OrganizationServer).RbacGroupUpdate(ctx, req.(*v1.RbacGroupUpdateRequest))
  596. }
  597. return interceptor(ctx, in, info, handler)
  598. }
  599. func _Organization_RbacGroupDel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  600. in := new(v1.RbacGroupDelRequest)
  601. if err := dec(in); err != nil {
  602. return nil, err
  603. }
  604. if interceptor == nil {
  605. return srv.(OrganizationServer).RbacGroupDel(ctx, in)
  606. }
  607. info := &grpc.UnaryServerInfo{
  608. Server: srv,
  609. FullMethod: "/pb.service.Organization/RbacGroupDel",
  610. }
  611. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  612. return srv.(OrganizationServer).RbacGroupDel(ctx, req.(*v1.RbacGroupDelRequest))
  613. }
  614. return interceptor(ctx, in, info, handler)
  615. }
  616. func _Organization_ZoneAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  617. in := new(v1.ZoneAddRequest)
  618. if err := dec(in); err != nil {
  619. return nil, err
  620. }
  621. if interceptor == nil {
  622. return srv.(OrganizationServer).ZoneAdd(ctx, in)
  623. }
  624. info := &grpc.UnaryServerInfo{
  625. Server: srv,
  626. FullMethod: "/pb.service.Organization/ZoneAdd",
  627. }
  628. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  629. return srv.(OrganizationServer).ZoneAdd(ctx, req.(*v1.ZoneAddRequest))
  630. }
  631. return interceptor(ctx, in, info, handler)
  632. }
  633. func _Organization_ZoneDel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  634. in := new(v1.ZoneDelRequest)
  635. if err := dec(in); err != nil {
  636. return nil, err
  637. }
  638. if interceptor == nil {
  639. return srv.(OrganizationServer).ZoneDel(ctx, in)
  640. }
  641. info := &grpc.UnaryServerInfo{
  642. Server: srv,
  643. FullMethod: "/pb.service.Organization/ZoneDel",
  644. }
  645. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  646. return srv.(OrganizationServer).ZoneDel(ctx, req.(*v1.ZoneDelRequest))
  647. }
  648. return interceptor(ctx, in, info, handler)
  649. }
  650. func _Organization_ZoneUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  651. in := new(v1.ZoneUpdateRequest)
  652. if err := dec(in); err != nil {
  653. return nil, err
  654. }
  655. if interceptor == nil {
  656. return srv.(OrganizationServer).ZoneUpdate(ctx, in)
  657. }
  658. info := &grpc.UnaryServerInfo{
  659. Server: srv,
  660. FullMethod: "/pb.service.Organization/ZoneUpdate",
  661. }
  662. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  663. return srv.(OrganizationServer).ZoneUpdate(ctx, req.(*v1.ZoneUpdateRequest))
  664. }
  665. return interceptor(ctx, in, info, handler)
  666. }
  667. func _Organization_ZoneList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  668. in := new(v1.ZoneListRequest)
  669. if err := dec(in); err != nil {
  670. return nil, err
  671. }
  672. if interceptor == nil {
  673. return srv.(OrganizationServer).ZoneList(ctx, in)
  674. }
  675. info := &grpc.UnaryServerInfo{
  676. Server: srv,
  677. FullMethod: "/pb.service.Organization/ZoneList",
  678. }
  679. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  680. return srv.(OrganizationServer).ZoneList(ctx, req.(*v1.ZoneListRequest))
  681. }
  682. return interceptor(ctx, in, info, handler)
  683. }
  684. func _Organization_UserUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  685. in := new(v1.UserUpdateRequest)
  686. if err := dec(in); err != nil {
  687. return nil, err
  688. }
  689. if interceptor == nil {
  690. return srv.(OrganizationServer).UserUpdate(ctx, in)
  691. }
  692. info := &grpc.UnaryServerInfo{
  693. Server: srv,
  694. FullMethod: "/pb.service.Organization/UserUpdate",
  695. }
  696. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  697. return srv.(OrganizationServer).UserUpdate(ctx, req.(*v1.UserUpdateRequest))
  698. }
  699. return interceptor(ctx, in, info, handler)
  700. }
  701. func _Organization_UserDel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  702. in := new(v1.UserDelRequest)
  703. if err := dec(in); err != nil {
  704. return nil, err
  705. }
  706. if interceptor == nil {
  707. return srv.(OrganizationServer).UserDel(ctx, in)
  708. }
  709. info := &grpc.UnaryServerInfo{
  710. Server: srv,
  711. FullMethod: "/pb.service.Organization/UserDel",
  712. }
  713. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  714. return srv.(OrganizationServer).UserDel(ctx, req.(*v1.UserDelRequest))
  715. }
  716. return interceptor(ctx, in, info, handler)
  717. }
  718. func _Organization_UserList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  719. in := new(v1.UserListRequest)
  720. if err := dec(in); err != nil {
  721. return nil, err
  722. }
  723. if interceptor == nil {
  724. return srv.(OrganizationServer).UserList(ctx, in)
  725. }
  726. info := &grpc.UnaryServerInfo{
  727. Server: srv,
  728. FullMethod: "/pb.service.Organization/UserList",
  729. }
  730. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  731. return srv.(OrganizationServer).UserList(ctx, req.(*v1.UserListRequest))
  732. }
  733. return interceptor(ctx, in, info, handler)
  734. }
  735. func _Organization_UserInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  736. in := new(v1.UserInfoRequest)
  737. if err := dec(in); err != nil {
  738. return nil, err
  739. }
  740. if interceptor == nil {
  741. return srv.(OrganizationServer).UserInfo(ctx, in)
  742. }
  743. info := &grpc.UnaryServerInfo{
  744. Server: srv,
  745. FullMethod: "/pb.service.Organization/UserInfo",
  746. }
  747. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  748. return srv.(OrganizationServer).UserInfo(ctx, req.(*v1.UserInfoRequest))
  749. }
  750. return interceptor(ctx, in, info, handler)
  751. }
  752. func _Organization_ManagementLogAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  753. in := new(v1.ManagementLogAddRequest)
  754. if err := dec(in); err != nil {
  755. return nil, err
  756. }
  757. if interceptor == nil {
  758. return srv.(OrganizationServer).ManagementLogAdd(ctx, in)
  759. }
  760. info := &grpc.UnaryServerInfo{
  761. Server: srv,
  762. FullMethod: "/pb.service.Organization/ManagementLogAdd",
  763. }
  764. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  765. return srv.(OrganizationServer).ManagementLogAdd(ctx, req.(*v1.ManagementLogAddRequest))
  766. }
  767. return interceptor(ctx, in, info, handler)
  768. }
  769. func _Organization_ManagementLogList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  770. in := new(v1.ManagementLogListRequest)
  771. if err := dec(in); err != nil {
  772. return nil, err
  773. }
  774. if interceptor == nil {
  775. return srv.(OrganizationServer).ManagementLogList(ctx, in)
  776. }
  777. info := &grpc.UnaryServerInfo{
  778. Server: srv,
  779. FullMethod: "/pb.service.Organization/ManagementLogList",
  780. }
  781. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  782. return srv.(OrganizationServer).ManagementLogList(ctx, req.(*v1.ManagementLogListRequest))
  783. }
  784. return interceptor(ctx, in, info, handler)
  785. }
  786. var _Organization_serviceDesc = grpc.ServiceDesc{
  787. ServiceName: "pb.service.Organization",
  788. HandlerType: (*OrganizationServer)(nil),
  789. Methods: []grpc.MethodDesc{
  790. {
  791. MethodName: "InitOrganizationDb",
  792. Handler: _Organization_InitOrganizationDb_Handler,
  793. },
  794. {
  795. MethodName: "CreateManagementUser",
  796. Handler: _Organization_CreateManagementUser_Handler,
  797. },
  798. {
  799. MethodName: "ManagementSuperUserList",
  800. Handler: _Organization_ManagementSuperUserList_Handler,
  801. },
  802. {
  803. MethodName: "ManagementSuperUserUpdate",
  804. Handler: _Organization_ManagementSuperUserUpdate_Handler,
  805. },
  806. {
  807. MethodName: "ManagementSuperUserResetPassword",
  808. Handler: _Organization_ManagementSuperUserResetPassword_Handler,
  809. },
  810. {
  811. MethodName: "ManagementLogin",
  812. Handler: _Organization_ManagementLogin_Handler,
  813. },
  814. {
  815. MethodName: "RbacNodeList",
  816. Handler: _Organization_RbacNodeList_Handler,
  817. },
  818. {
  819. MethodName: "RbacGroupList",
  820. Handler: _Organization_RbacGroupList_Handler,
  821. },
  822. {
  823. MethodName: "RbacNodeListByGroupOrUser",
  824. Handler: _Organization_RbacNodeListByGroupOrUser_Handler,
  825. },
  826. {
  827. MethodName: "RbacGroupAdd",
  828. Handler: _Organization_RbacGroupAdd_Handler,
  829. },
  830. {
  831. MethodName: "RbacGroupUpdate",
  832. Handler: _Organization_RbacGroupUpdate_Handler,
  833. },
  834. {
  835. MethodName: "RbacGroupDel",
  836. Handler: _Organization_RbacGroupDel_Handler,
  837. },
  838. {
  839. MethodName: "ZoneAdd",
  840. Handler: _Organization_ZoneAdd_Handler,
  841. },
  842. {
  843. MethodName: "ZoneDel",
  844. Handler: _Organization_ZoneDel_Handler,
  845. },
  846. {
  847. MethodName: "ZoneUpdate",
  848. Handler: _Organization_ZoneUpdate_Handler,
  849. },
  850. {
  851. MethodName: "ZoneList",
  852. Handler: _Organization_ZoneList_Handler,
  853. },
  854. {
  855. MethodName: "UserUpdate",
  856. Handler: _Organization_UserUpdate_Handler,
  857. },
  858. {
  859. MethodName: "UserDel",
  860. Handler: _Organization_UserDel_Handler,
  861. },
  862. {
  863. MethodName: "UserList",
  864. Handler: _Organization_UserList_Handler,
  865. },
  866. {
  867. MethodName: "UserInfo",
  868. Handler: _Organization_UserInfo_Handler,
  869. },
  870. {
  871. MethodName: "ManagementLogAdd",
  872. Handler: _Organization_ManagementLogAdd_Handler,
  873. },
  874. {
  875. MethodName: "ManagementLogList",
  876. Handler: _Organization_ManagementLogList_Handler,
  877. },
  878. },
  879. Streams: []grpc.StreamDesc{},
  880. Metadata: "organization_service.proto",
  881. }