Commit 53919eb0 by zhangjie

1. token的KEY改为配置文件可配,以便区分测试环境和生产环境

2. 硬件TCP连接服务剥离出去(未测试) 3. 重新整理GRPC文件名及包名
parent 47a84b63
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.26.0
// protoc v3.16.0
// source: grpc_k122Server/k122Server.proto
package k122Server
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type CacheAreaReq struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AreaID uint32 `protobuf:"varint,1,opt,name=AreaID,proto3" json:"AreaID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
Longitude int32 `protobuf:"varint,3,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
Latitude int32 `protobuf:"varint,4,opt,name=Latitude,proto3" json:"Latitude,omitempty"`
Status uint32 `protobuf:"varint,5,opt,name=Status,proto3" json:"Status,omitempty"`
CountyID uint32 `protobuf:"varint,6,opt,name=CountyID,proto3" json:"CountyID,omitempty"`
}
func (x *CacheAreaReq) Reset() {
*x = CacheAreaReq{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAreaReq) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAreaReq) ProtoMessage() {}
func (x *CacheAreaReq) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAreaReq.ProtoReflect.Descriptor instead.
func (*CacheAreaReq) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{0}
}
func (x *CacheAreaReq) GetAreaID() uint32 {
if x != nil {
return x.AreaID
}
return 0
}
func (x *CacheAreaReq) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CacheAreaReq) GetLongitude() int32 {
if x != nil {
return x.Longitude
}
return 0
}
func (x *CacheAreaReq) GetLatitude() int32 {
if x != nil {
return x.Latitude
}
return 0
}
func (x *CacheAreaReq) GetStatus() uint32 {
if x != nil {
return x.Status
}
return 0
}
func (x *CacheAreaReq) GetCountyID() uint32 {
if x != nil {
return x.CountyID
}
return 0
}
type CacheAreaServicePhoneReq struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AreaServiceID uint32 `protobuf:"varint,1,opt,name=AreaServiceID,proto3" json:"AreaServiceID,omitempty"`
AreaID uint32 `protobuf:"varint,2,opt,name=AreaID,proto3" json:"AreaID,omitempty"`
ServiceType uint32 `protobuf:"varint,3,opt,name=ServiceType,proto3" json:"ServiceType,omitempty"` //服务项目 1公话 2定位 3饮水 4POS .........
OperatorID uint32 `protobuf:"varint,4,opt,name=OperatorID,proto3" json:"OperatorID,omitempty"`
Status uint32 `protobuf:"varint,5,opt,name=Status,proto3" json:"Status,omitempty"` // 状态 0无内容1正式2测试3暂停4暂未开放
AllinPayID uint32 `protobuf:"varint,6,opt,name=AllinPayID,proto3" json:"AllinPayID,omitempty"` // 收款主体的adminID
Name string `protobuf:"bytes,7,opt,name=Name,proto3" json:"Name,omitempty"`
ServicePhone string `protobuf:"bytes,8,opt,name=ServicePhone,proto3" json:"ServicePhone,omitempty"` // 服务电话
ActivateCardFee int32 `protobuf:"varint,9,opt,name=ActivateCardFee,proto3" json:"ActivateCardFee,omitempty"` // 开卡费,修改时若不修改则传-1
ReplacementCardFee int32 `protobuf:"varint,10,opt,name=ReplacementCardFee,proto3" json:"ReplacementCardFee,omitempty"` // 补卡费,修改时若不修改则传-1
}
func (x *CacheAreaServicePhoneReq) Reset() {
*x = CacheAreaServicePhoneReq{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAreaServicePhoneReq) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAreaServicePhoneReq) ProtoMessage() {}
func (x *CacheAreaServicePhoneReq) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAreaServicePhoneReq.ProtoReflect.Descriptor instead.
func (*CacheAreaServicePhoneReq) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{1}
}
func (x *CacheAreaServicePhoneReq) GetAreaServiceID() uint32 {
if x != nil {
return x.AreaServiceID
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetAreaID() uint32 {
if x != nil {
return x.AreaID
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetServiceType() uint32 {
if x != nil {
return x.ServiceType
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetOperatorID() uint32 {
if x != nil {
return x.OperatorID
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetStatus() uint32 {
if x != nil {
return x.Status
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetAllinPayID() uint32 {
if x != nil {
return x.AllinPayID
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *CacheAreaServicePhoneReq) GetServicePhone() string {
if x != nil {
return x.ServicePhone
}
return ""
}
func (x *CacheAreaServicePhoneReq) GetActivateCardFee() int32 {
if x != nil {
return x.ActivateCardFee
}
return 0
}
func (x *CacheAreaServicePhoneReq) GetReplacementCardFee() int32 {
if x != nil {
return x.ReplacementCardFee
}
return 0
}
type PhonePaySplitMoneyStruct struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AdminID uint32 `protobuf:"varint,1,opt,name=AdminID,proto3" json:"AdminID,omitempty"`
Amount int32 `protobuf:"varint,2,opt,name=Amount,proto3" json:"Amount,omitempty"`
Remark string `protobuf:"bytes,3,opt,name=Remark,proto3" json:"Remark,omitempty"`
}
func (x *PhonePaySplitMoneyStruct) Reset() {
*x = PhonePaySplitMoneyStruct{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *PhonePaySplitMoneyStruct) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PhonePaySplitMoneyStruct) ProtoMessage() {}
func (x *PhonePaySplitMoneyStruct) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PhonePaySplitMoneyStruct.ProtoReflect.Descriptor instead.
func (*PhonePaySplitMoneyStruct) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{2}
}
func (x *PhonePaySplitMoneyStruct) GetAdminID() uint32 {
if x != nil {
return x.AdminID
}
return 0
}
func (x *PhonePaySplitMoneyStruct) GetAmount() int32 {
if x != nil {
return x.Amount
}
return 0
}
func (x *PhonePaySplitMoneyStruct) GetRemark() string {
if x != nil {
return x.Remark
}
return ""
}
type CachePhonePayList struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AreaServiceID uint32 `protobuf:"varint,1,opt,name=AreaServiceID,proto3" json:"AreaServiceID,omitempty"`
ID uint32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
Amount int32 `protobuf:"varint,3,opt,name=Amount,proto3" json:"Amount,omitempty"`
MonthMin uint32 `protobuf:"varint,4,opt,name=MonthMin,proto3" json:"MonthMin,omitempty"`
Expiry uint32 `protobuf:"varint,5,opt,name=Expiry,proto3" json:"Expiry,omitempty"` // 有效期(单位:月)
Describe string `protobuf:"bytes,6,opt,name=Describe,proto3" json:"Describe,omitempty"`
Status bool `protobuf:"varint,7,opt,name=Status,proto3" json:"Status,omitempty"`
SplitAmount []*PhonePaySplitMoneyStruct `protobuf:"bytes,8,rep,name=SplitAmount,proto3" json:"SplitAmount,omitempty"`
}
func (x *CachePhonePayList) Reset() {
*x = CachePhonePayList{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CachePhonePayList) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CachePhonePayList) ProtoMessage() {}
func (x *CachePhonePayList) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CachePhonePayList.ProtoReflect.Descriptor instead.
func (*CachePhonePayList) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{3}
}
func (x *CachePhonePayList) GetAreaServiceID() uint32 {
if x != nil {
return x.AreaServiceID
}
return 0
}
func (x *CachePhonePayList) GetID() uint32 {
if x != nil {
return x.ID
}
return 0
}
func (x *CachePhonePayList) GetAmount() int32 {
if x != nil {
return x.Amount
}
return 0
}
func (x *CachePhonePayList) GetMonthMin() uint32 {
if x != nil {
return x.MonthMin
}
return 0
}
func (x *CachePhonePayList) GetExpiry() uint32 {
if x != nil {
return x.Expiry
}
return 0
}
func (x *CachePhonePayList) GetDescribe() string {
if x != nil {
return x.Describe
}
return ""
}
func (x *CachePhonePayList) GetStatus() bool {
if x != nil {
return x.Status
}
return false
}
func (x *CachePhonePayList) GetSplitAmount() []*PhonePaySplitMoneyStruct {
if x != nil {
return x.SplitAmount
}
return nil
}
type CacheDelPhonePayListMsg struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AreaServiceID uint32 `protobuf:"varint,1,opt,name=AreaServiceID,proto3" json:"AreaServiceID,omitempty"`
ID uint32 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (x *CacheDelPhonePayListMsg) Reset() {
*x = CacheDelPhonePayListMsg{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheDelPhonePayListMsg) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheDelPhonePayListMsg) ProtoMessage() {}
func (x *CacheDelPhonePayListMsg) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheDelPhonePayListMsg.ProtoReflect.Descriptor instead.
func (*CacheDelPhonePayListMsg) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{4}
}
func (x *CacheDelPhonePayListMsg) GetAreaServiceID() uint32 {
if x != nil {
return x.AreaServiceID
}
return 0
}
func (x *CacheDelPhonePayListMsg) GetID() uint32 {
if x != nil {
return x.ID
}
return 0
}
type CacheUWeCustomerTestRole struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
TestRole bool `protobuf:"varint,2,opt,name=TestRole,proto3" json:"TestRole,omitempty"`
}
func (x *CacheUWeCustomerTestRole) Reset() {
*x = CacheUWeCustomerTestRole{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheUWeCustomerTestRole) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheUWeCustomerTestRole) ProtoMessage() {}
func (x *CacheUWeCustomerTestRole) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheUWeCustomerTestRole.ProtoReflect.Descriptor instead.
func (*CacheUWeCustomerTestRole) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{5}
}
func (x *CacheUWeCustomerTestRole) GetID() uint32 {
if x != nil {
return x.ID
}
return 0
}
func (x *CacheUWeCustomerTestRole) GetTestRole() bool {
if x != nil {
return x.TestRole
}
return false
}
type CacheAddNewSimStruct struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
SimID string `protobuf:"bytes,1,opt,name=SimID,proto3" json:"SimID,omitempty"`
AreaServiceID uint32 `protobuf:"varint,2,opt,name=AreaServiceID,proto3" json:"AreaServiceID,omitempty"`
Status uint32 `protobuf:"varint,3,opt,name=Status,proto3" json:"Status,omitempty"`
MonthTalkMinutes uint32 `protobuf:"varint,4,opt,name=MonthTalkMinutes,proto3" json:"MonthTalkMinutes,omitempty"`
MonthPackageMinutes uint32 `protobuf:"varint,5,opt,name=MonthPackageMinutes,proto3" json:"MonthPackageMinutes,omitempty"`
ExpiryAt string `protobuf:"bytes,6,opt,name=ExpiryAt,proto3" json:"ExpiryAt,omitempty"`
FamilyDeleteCount uint32 `protobuf:"varint,7,opt,name=FamilyDeleteCount,proto3" json:"FamilyDeleteCount,omitempty"`
Type uint32 `protobuf:"varint,8,opt,name=Type,proto3" json:"Type,omitempty"` // 0 测试卡(不调任何接口) 1 中移物联网(增删亲情号调接口) 其他预留
}
func (x *CacheAddNewSimStruct) Reset() {
*x = CacheAddNewSimStruct{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAddNewSimStruct) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAddNewSimStruct) ProtoMessage() {}
func (x *CacheAddNewSimStruct) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAddNewSimStruct.ProtoReflect.Descriptor instead.
func (*CacheAddNewSimStruct) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{6}
}
func (x *CacheAddNewSimStruct) GetSimID() string {
if x != nil {
return x.SimID
}
return ""
}
func (x *CacheAddNewSimStruct) GetAreaServiceID() uint32 {
if x != nil {
return x.AreaServiceID
}
return 0
}
func (x *CacheAddNewSimStruct) GetStatus() uint32 {
if x != nil {
return x.Status
}
return 0
}
func (x *CacheAddNewSimStruct) GetMonthTalkMinutes() uint32 {
if x != nil {
return x.MonthTalkMinutes
}
return 0
}
func (x *CacheAddNewSimStruct) GetMonthPackageMinutes() uint32 {
if x != nil {
return x.MonthPackageMinutes
}
return 0
}
func (x *CacheAddNewSimStruct) GetExpiryAt() string {
if x != nil {
return x.ExpiryAt
}
return ""
}
func (x *CacheAddNewSimStruct) GetFamilyDeleteCount() uint32 {
if x != nil {
return x.FamilyDeleteCount
}
return 0
}
func (x *CacheAddNewSimStruct) GetType() uint32 {
if x != nil {
return x.Type
}
return 0
}
type CacheAddNewSim struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Rows []*CacheAddNewSimStruct `protobuf:"bytes,1,rep,name=Rows,proto3" json:"Rows,omitempty"`
}
func (x *CacheAddNewSim) Reset() {
*x = CacheAddNewSim{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAddNewSim) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAddNewSim) ProtoMessage() {}
func (x *CacheAddNewSim) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAddNewSim.ProtoReflect.Descriptor instead.
func (*CacheAddNewSim) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{7}
}
func (x *CacheAddNewSim) GetRows() []*CacheAddNewSimStruct {
if x != nil {
return x.Rows
}
return nil
}
type CacheAddPhone20Struct struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
DevID uint32 `protobuf:"varint,1,opt,name=DevID,proto3" json:"DevID,omitempty"`
AreaServiceID uint32 `protobuf:"varint,2,opt,name=AreaServiceID,proto3" json:"AreaServiceID,omitempty"` // 不为0
AllowCallTime uint32 `protobuf:"varint,3,opt,name=AllowCallTime,proto3" json:"AllowCallTime,omitempty"`
PlaceUser string `protobuf:"bytes,4,opt,name=PlaceUser,proto3" json:"PlaceUser,omitempty"`
Status bool `protobuf:"varint,5,opt,name=Status,proto3" json:"Status,omitempty"`
}
func (x *CacheAddPhone20Struct) Reset() {
*x = CacheAddPhone20Struct{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAddPhone20Struct) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAddPhone20Struct) ProtoMessage() {}
func (x *CacheAddPhone20Struct) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[8]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAddPhone20Struct.ProtoReflect.Descriptor instead.
func (*CacheAddPhone20Struct) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{8}
}
func (x *CacheAddPhone20Struct) GetDevID() uint32 {
if x != nil {
return x.DevID
}
return 0
}
func (x *CacheAddPhone20Struct) GetAreaServiceID() uint32 {
if x != nil {
return x.AreaServiceID
}
return 0
}
func (x *CacheAddPhone20Struct) GetAllowCallTime() uint32 {
if x != nil {
return x.AllowCallTime
}
return 0
}
func (x *CacheAddPhone20Struct) GetPlaceUser() string {
if x != nil {
return x.PlaceUser
}
return ""
}
func (x *CacheAddPhone20Struct) GetStatus() bool {
if x != nil {
return x.Status
}
return false
}
type CacheAddPhone20 struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Rows []*CacheAddPhone20Struct `protobuf:"bytes,1,rep,name=Rows,proto3" json:"Rows,omitempty"`
}
func (x *CacheAddPhone20) Reset() {
*x = CacheAddPhone20{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAddPhone20) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAddPhone20) ProtoMessage() {}
func (x *CacheAddPhone20) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[9]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAddPhone20.ProtoReflect.Descriptor instead.
func (*CacheAddPhone20) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{9}
}
func (x *CacheAddPhone20) GetRows() []*CacheAddPhone20Struct {
if x != nil {
return x.Rows
}
return nil
}
type CacheAddDeviceUpdateFirmwareMapPhone20Struct struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
DevIDs []uint32 `protobuf:"varint,1,rep,packed,name=DevIDs,proto3" json:"DevIDs,omitempty"`
Firmware string `protobuf:"bytes,2,opt,name=Firmware,proto3" json:"Firmware,omitempty"`
}
func (x *CacheAddDeviceUpdateFirmwareMapPhone20Struct) Reset() {
*x = CacheAddDeviceUpdateFirmwareMapPhone20Struct{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *CacheAddDeviceUpdateFirmwareMapPhone20Struct) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CacheAddDeviceUpdateFirmwareMapPhone20Struct) ProtoMessage() {}
func (x *CacheAddDeviceUpdateFirmwareMapPhone20Struct) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[10]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CacheAddDeviceUpdateFirmwareMapPhone20Struct.ProtoReflect.Descriptor instead.
func (*CacheAddDeviceUpdateFirmwareMapPhone20Struct) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{10}
}
func (x *CacheAddDeviceUpdateFirmwareMapPhone20Struct) GetDevIDs() []uint32 {
if x != nil {
return x.DevIDs
}
return nil
}
func (x *CacheAddDeviceUpdateFirmwareMapPhone20Struct) GetFirmware() string {
if x != nil {
return x.Firmware
}
return ""
}
type Uint32S struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Uint32S []uint32 `protobuf:"varint,1,rep,packed,name=uint32s,proto3" json:"uint32s,omitempty"`
}
func (x *Uint32S) Reset() {
*x = Uint32S{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Uint32S) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Uint32S) ProtoMessage() {}
func (x *Uint32S) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[11]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Uint32S.ProtoReflect.Descriptor instead.
func (*Uint32S) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{11}
}
func (x *Uint32S) GetUint32S() []uint32 {
if x != nil {
return x.Uint32S
}
return nil
}
type Strings struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Strings []string `protobuf:"bytes,1,rep,name=strings,proto3" json:"strings,omitempty"`
}
func (x *Strings) Reset() {
*x = Strings{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Strings) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Strings) ProtoMessage() {}
func (x *Strings) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[12]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Strings.ProtoReflect.Descriptor instead.
func (*Strings) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{12}
}
func (x *Strings) GetStrings() []string {
if x != nil {
return x.Strings
}
return nil
}
type Empty struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
}
func (x *Empty) Reset() {
*x = Empty{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *Empty) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Empty) ProtoMessage() {}
func (x *Empty) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[13]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Empty.ProtoReflect.Descriptor instead.
func (*Empty) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{13}
}
type ReceiveTcpCallbackReq struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
}
func (x *ReceiveTcpCallbackReq) Reset() {
*x = ReceiveTcpCallbackReq{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ReceiveTcpCallbackReq) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ReceiveTcpCallbackReq) ProtoMessage() {}
func (x *ReceiveTcpCallbackReq) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[14]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ReceiveTcpCallbackReq.ProtoReflect.Descriptor instead.
func (*ReceiveTcpCallbackReq) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{14}
}
func (x *ReceiveTcpCallbackReq) GetData() []byte {
if x != nil {
return x.Data
}
return nil
}
type ReceiveTcpCallbackRes struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
DeviceID uint32 `protobuf:"varint,1,opt,name=DeviceID,proto3" json:"DeviceID,omitempty"`
SendData []byte `protobuf:"bytes,2,opt,name=SendData,proto3" json:"SendData,omitempty"`
}
func (x *ReceiveTcpCallbackRes) Reset() {
*x = ReceiveTcpCallbackRes{}
if protoimpl.UnsafeEnabled {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *ReceiveTcpCallbackRes) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ReceiveTcpCallbackRes) ProtoMessage() {}
func (x *ReceiveTcpCallbackRes) ProtoReflect() protoreflect.Message {
mi := &file_grpc_k122Server_k122Server_proto_msgTypes[15]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ReceiveTcpCallbackRes.ProtoReflect.Descriptor instead.
func (*ReceiveTcpCallbackRes) Descriptor() ([]byte, []int) {
return file_grpc_k122Server_k122Server_proto_rawDescGZIP(), []int{15}
}
func (x *ReceiveTcpCallbackRes) GetDeviceID() uint32 {
if x != nil {
return x.DeviceID
}
return 0
}
func (x *ReceiveTcpCallbackRes) GetSendData() []byte {
if x != nil {
return x.SendData
}
return nil
}
var File_grpc_k122Server_k122Server_proto protoreflect.FileDescriptor
var file_grpc_k122Server_k122Server_proto_rawDesc = []byte{
0x0a, 0x20, 0x67, 0x72, 0x70, 0x63, 0x5f, 0x6b, 0x31, 0x32, 0x32, 0x53, 0x65, 0x72, 0x76, 0x65,
0x72, 0x2f, 0x6b, 0x31, 0x32, 0x32, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x12, 0x07, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x22, 0xa8, 0x01, 0x0a, 0x0c,
0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x72, 0x65, 0x61, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06,
0x41, 0x72, 0x65, 0x61, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x41, 0x72,
0x65, 0x61, 0x49, 0x44, 0x12, 0x12, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x4c, 0x6f, 0x6e, 0x67,
0x69, 0x74, 0x75, 0x64, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x4c, 0x6f, 0x6e,
0x67, 0x69, 0x74, 0x75, 0x64, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x4c, 0x61, 0x74, 0x69, 0x74, 0x75,
0x64, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x4c, 0x61, 0x74, 0x69, 0x74, 0x75,
0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05, 0x20, 0x01,
0x28, 0x0d, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x43, 0x6f,
0x75, 0x6e, 0x74, 0x79, 0x49, 0x44, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x43, 0x6f,
0x75, 0x6e, 0x74, 0x79, 0x49, 0x44, 0x22, 0xe4, 0x02, 0x0a, 0x18, 0x43, 0x61, 0x63, 0x68, 0x65,
0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65,
0x52, 0x65, 0x71, 0x12, 0x24, 0x0a, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69,
0x63, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x41, 0x72, 0x65, 0x61,
0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x12, 0x16, 0x0a, 0x06, 0x41, 0x72, 0x65,
0x61, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x06, 0x41, 0x72, 0x65, 0x61, 0x49,
0x44, 0x12, 0x20, 0x0a, 0x0b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x54, 0x79, 0x70, 0x65,
0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x54,
0x79, 0x70, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x49,
0x44, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f,
0x72, 0x49, 0x44, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x41,
0x6c, 0x6c, 0x69, 0x6e, 0x50, 0x61, 0x79, 0x49, 0x44, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0d, 0x52,
0x0a, 0x41, 0x6c, 0x6c, 0x69, 0x6e, 0x50, 0x61, 0x79, 0x49, 0x44, 0x12, 0x12, 0x0a, 0x04, 0x4e,
0x61, 0x6d, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x12,
0x22, 0x0a, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x18,
0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x68,
0x6f, 0x6e, 0x65, 0x12, 0x28, 0x0a, 0x0f, 0x41, 0x63, 0x74, 0x69, 0x76, 0x61, 0x74, 0x65, 0x43,
0x61, 0x72, 0x64, 0x46, 0x65, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x41, 0x63,
0x74, 0x69, 0x76, 0x61, 0x74, 0x65, 0x43, 0x61, 0x72, 0x64, 0x46, 0x65, 0x65, 0x12, 0x2e, 0x0a,
0x12, 0x52, 0x65, 0x70, 0x6c, 0x61, 0x63, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x43, 0x61, 0x72, 0x64,
0x46, 0x65, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x05, 0x52, 0x12, 0x52, 0x65, 0x70, 0x6c, 0x61,
0x63, 0x65, 0x6d, 0x65, 0x6e, 0x74, 0x43, 0x61, 0x72, 0x64, 0x46, 0x65, 0x65, 0x22, 0x64, 0x0a,
0x18, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x4d, 0x6f,
0x6e, 0x65, 0x79, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x41, 0x64, 0x6d,
0x69, 0x6e, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x41, 0x64, 0x6d, 0x69,
0x6e, 0x49, 0x44, 0x12, 0x16, 0x0a, 0x06, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20,
0x01, 0x28, 0x05, 0x52, 0x06, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x52,
0x65, 0x6d, 0x61, 0x72, 0x6b, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x52, 0x65, 0x6d,
0x61, 0x72, 0x6b, 0x22, 0x8e, 0x02, 0x0a, 0x11, 0x43, 0x61, 0x63, 0x68, 0x65, 0x50, 0x68, 0x6f,
0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x41, 0x72, 0x65,
0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d,
0x52, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x12,
0x0e, 0x0a, 0x02, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x49, 0x44, 0x12,
0x16, 0x0a, 0x06, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52,
0x06, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x4d, 0x6f, 0x6e, 0x74, 0x68,
0x4d, 0x69, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x4d, 0x6f, 0x6e, 0x74, 0x68,
0x4d, 0x69, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x45, 0x78, 0x70, 0x69, 0x72, 0x79, 0x18, 0x05, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x06, 0x45, 0x78, 0x70, 0x69, 0x72, 0x79, 0x12, 0x1a, 0x0a, 0x08, 0x44,
0x65, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x44,
0x65, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75,
0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12,
0x43, 0x0a, 0x0b, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x08,
0x20, 0x03, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x50,
0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x4d, 0x6f, 0x6e, 0x65,
0x79, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x0b, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x41, 0x6d,
0x6f, 0x75, 0x6e, 0x74, 0x22, 0x4f, 0x0a, 0x17, 0x43, 0x61, 0x63, 0x68, 0x65, 0x44, 0x65, 0x6c,
0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x73, 0x67, 0x12,
0x24, 0x0a, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44,
0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76,
0x69, 0x63, 0x65, 0x49, 0x44, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28,
0x0d, 0x52, 0x02, 0x49, 0x44, 0x22, 0x46, 0x0a, 0x18, 0x43, 0x61, 0x63, 0x68, 0x65, 0x55, 0x57,
0x65, 0x43, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x65, 0x72, 0x54, 0x65, 0x73, 0x74, 0x52, 0x6f, 0x6c,
0x65, 0x12, 0x0e, 0x0a, 0x02, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x49,
0x44, 0x12, 0x1a, 0x0a, 0x08, 0x54, 0x65, 0x73, 0x74, 0x52, 0x6f, 0x6c, 0x65, 0x18, 0x02, 0x20,
0x01, 0x28, 0x08, 0x52, 0x08, 0x54, 0x65, 0x73, 0x74, 0x52, 0x6f, 0x6c, 0x65, 0x22, 0xa6, 0x02,
0x0a, 0x14, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x4e, 0x65, 0x77, 0x53, 0x69, 0x6d,
0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x53, 0x69, 0x6d, 0x49, 0x44, 0x18,
0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x53, 0x69, 0x6d, 0x49, 0x44, 0x12, 0x24, 0x0a, 0x0d,
0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x18, 0x02, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x49, 0x44, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01,
0x28, 0x0d, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x2a, 0x0a, 0x10, 0x4d, 0x6f,
0x6e, 0x74, 0x68, 0x54, 0x61, 0x6c, 0x6b, 0x4d, 0x69, 0x6e, 0x75, 0x74, 0x65, 0x73, 0x18, 0x04,
0x20, 0x01, 0x28, 0x0d, 0x52, 0x10, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x54, 0x61, 0x6c, 0x6b, 0x4d,
0x69, 0x6e, 0x75, 0x74, 0x65, 0x73, 0x12, 0x30, 0x0a, 0x13, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x50,
0x61, 0x63, 0x6b, 0x61, 0x67, 0x65, 0x4d, 0x69, 0x6e, 0x75, 0x74, 0x65, 0x73, 0x18, 0x05, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x13, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x50, 0x61, 0x63, 0x6b, 0x61, 0x67,
0x65, 0x4d, 0x69, 0x6e, 0x75, 0x74, 0x65, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x45, 0x78, 0x70, 0x69,
0x72, 0x79, 0x41, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x45, 0x78, 0x70, 0x69,
0x72, 0x79, 0x41, 0x74, 0x12, 0x2c, 0x0a, 0x11, 0x46, 0x61, 0x6d, 0x69, 0x6c, 0x79, 0x44, 0x65,
0x6c, 0x65, 0x74, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0d, 0x52,
0x11, 0x46, 0x61, 0x6d, 0x69, 0x6c, 0x79, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6f, 0x75,
0x6e, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0d,
0x52, 0x04, 0x54, 0x79, 0x70, 0x65, 0x22, 0x43, 0x0a, 0x0e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41,
0x64, 0x64, 0x4e, 0x65, 0x77, 0x53, 0x69, 0x6d, 0x12, 0x31, 0x0a, 0x04, 0x52, 0x6f, 0x77, 0x73,
0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63,
0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x4e, 0x65, 0x77, 0x53, 0x69, 0x6d, 0x53,
0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x04, 0x52, 0x6f, 0x77, 0x73, 0x22, 0xaf, 0x01, 0x0a, 0x15,
0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x53,
0x74, 0x72, 0x75, 0x63, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x44, 0x65, 0x76, 0x49, 0x44, 0x18, 0x01,
0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x44, 0x65, 0x76, 0x49, 0x44, 0x12, 0x24, 0x0a, 0x0d, 0x41,
0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01,
0x28, 0x0d, 0x52, 0x0d, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49,
0x44, 0x12, 0x24, 0x0a, 0x0d, 0x41, 0x6c, 0x6c, 0x6f, 0x77, 0x43, 0x61, 0x6c, 0x6c, 0x54, 0x69,
0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x41, 0x6c, 0x6c, 0x6f, 0x77, 0x43,
0x61, 0x6c, 0x6c, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x50, 0x6c, 0x61, 0x63, 0x65,
0x55, 0x73, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x50, 0x6c, 0x61, 0x63,
0x65, 0x55, 0x73, 0x65, 0x72, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18,
0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x22, 0x45, 0x0a,
0x0f, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30,
0x12, 0x32, 0x0a, 0x04, 0x52, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1e,
0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64,
0x64, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x53, 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x04,
0x52, 0x6f, 0x77, 0x73, 0x22, 0x62, 0x0a, 0x2c, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64,
0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46, 0x69, 0x72, 0x6d,
0x77, 0x61, 0x72, 0x65, 0x4d, 0x61, 0x70, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x53, 0x74,
0x72, 0x75, 0x63, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x44, 0x65, 0x76, 0x49, 0x44, 0x73, 0x18, 0x01,
0x20, 0x03, 0x28, 0x0d, 0x52, 0x06, 0x44, 0x65, 0x76, 0x49, 0x44, 0x73, 0x12, 0x1a, 0x0a, 0x08,
0x46, 0x69, 0x72, 0x6d, 0x77, 0x61, 0x72, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
0x46, 0x69, 0x72, 0x6d, 0x77, 0x61, 0x72, 0x65, 0x22, 0x23, 0x0a, 0x07, 0x55, 0x69, 0x6e, 0x74,
0x33, 0x32, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x75, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x73, 0x18, 0x01,
0x20, 0x03, 0x28, 0x0d, 0x52, 0x07, 0x75, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x73, 0x22, 0x23, 0x0a,
0x07, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x69,
0x6e, 0x67, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x73, 0x74, 0x72, 0x69, 0x6e,
0x67, 0x73, 0x22, 0x07, 0x0a, 0x05, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x2b, 0x0a, 0x15, 0x52,
0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x63, 0x70, 0x43, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63,
0x6b, 0x52, 0x65, 0x71, 0x12, 0x12, 0x0a, 0x04, 0x44, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01,
0x28, 0x0c, 0x52, 0x04, 0x44, 0x61, 0x74, 0x61, 0x22, 0x4f, 0x0a, 0x15, 0x52, 0x65, 0x63, 0x65,
0x69, 0x76, 0x65, 0x54, 0x63, 0x70, 0x43, 0x61, 0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x52, 0x65,
0x73, 0x12, 0x1a, 0x0a, 0x08, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x18, 0x01, 0x20,
0x01, 0x28, 0x0d, 0x52, 0x08, 0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x12, 0x1a, 0x0a,
0x08, 0x53, 0x65, 0x6e, 0x64, 0x44, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52,
0x08, 0x53, 0x65, 0x6e, 0x64, 0x44, 0x61, 0x74, 0x61, 0x32, 0xa4, 0x08, 0x0a, 0x0a, 0x47, 0x72,
0x70, 0x63, 0x32, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x12, 0x35, 0x0a, 0x0c, 0x43, 0x61, 0x63, 0x68,
0x65, 0x41, 0x64, 0x64, 0x41, 0x72, 0x65, 0x61, 0x12, 0x15, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72,
0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x72, 0x65, 0x61, 0x52, 0x65, 0x71, 0x1a,
0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12,
0x38, 0x0a, 0x0f, 0x43, 0x61, 0x63, 0x68, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x41, 0x72,
0x65, 0x61, 0x12, 0x15, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63,
0x68, 0x65, 0x41, 0x72, 0x65, 0x61, 0x52, 0x65, 0x71, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67,
0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x4d, 0x0a, 0x18, 0x43, 0x61, 0x63,
0x68, 0x65, 0x41, 0x64, 0x64, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x50, 0x68, 0x6f, 0x6e, 0x65, 0x12, 0x21, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e,
0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x50, 0x68, 0x6f, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72,
0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x50, 0x0a, 0x1b, 0x43, 0x61, 0x63, 0x68,
0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69,
0x63, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x12, 0x21, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70,
0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x72, 0x65, 0x61, 0x53, 0x65, 0x72, 0x76, 0x69,
0x63, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f,
0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x42, 0x0a, 0x14, 0x43, 0x61,
0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69,
0x73, 0x74, 0x12, 0x1a, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63,
0x68, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x1a, 0x0e,
0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x45,
0x0a, 0x17, 0x43, 0x61, 0x63, 0x68, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x50, 0x68, 0x6f,
0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1a, 0x2e, 0x6d, 0x79, 0x5f, 0x67,
0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61,
0x79, 0x4c, 0x69, 0x73, 0x74, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e,
0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x48, 0x0a, 0x14, 0x43, 0x61, 0x63, 0x68, 0x65, 0x44, 0x65,
0x6c, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x20, 0x2e,
0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x44, 0x65, 0x6c,
0x50, 0x68, 0x6f, 0x6e, 0x65, 0x50, 0x61, 0x79, 0x4c, 0x69, 0x73, 0x74, 0x4d, 0x73, 0x67, 0x1a,
0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12,
0x53, 0x0a, 0x1e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x55, 0x57,
0x65, 0x43, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x65, 0x72, 0x54, 0x65, 0x73, 0x74, 0x52, 0x6f, 0x6c,
0x65, 0x12, 0x21, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68,
0x65, 0x55, 0x57, 0x65, 0x43, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x65, 0x72, 0x54, 0x65, 0x73, 0x74,
0x52, 0x6f, 0x6c, 0x65, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45,
0x6d, 0x70, 0x74, 0x79, 0x12, 0x52, 0x0a, 0x25, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64,
0x53, 0x69, 0x6d, 0x49, 0x6e, 0x66, 0x6f, 0x4e, 0x6f, 0x42, 0x69, 0x6e, 0x64, 0x53, 0x74, 0x75,
0x64, 0x65, 0x6e, 0x74, 0x41, 0x6e, 0x64, 0x46, 0x61, 0x6d, 0x69, 0x6c, 0x79, 0x12, 0x17, 0x2e,
0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64,
0x4e, 0x65, 0x77, 0x53, 0x69, 0x6d, 0x1a, 0x10, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63,
0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x73, 0x12, 0x36, 0x0a, 0x12, 0x43, 0x61, 0x63, 0x68,
0x65, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x69, 0x6d, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x10,
0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x73,
0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
0x12, 0x56, 0x0a, 0x28, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x44, 0x65, 0x76, 0x50,
0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x57, 0x68, 0x65, 0x72, 0x65, 0x41, 0x72, 0x65, 0x61, 0x53,
0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x49, 0x44, 0x4e, 0x6f, 0x74, 0x30, 0x12, 0x18, 0x2e, 0x6d,
0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x50,
0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x1a, 0x10, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63,
0x2e, 0x55, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x73, 0x12, 0x39, 0x0a, 0x15, 0x43, 0x61, 0x63, 0x68,
0x65, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x44, 0x65, 0x76, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32,
0x30, 0x12, 0x10, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x55, 0x69, 0x6e, 0x74,
0x33, 0x32, 0x73, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d,
0x70, 0x74, 0x79, 0x12, 0x6f, 0x0a, 0x26, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64, 0x44,
0x65, 0x76, 0x69, 0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46, 0x69, 0x72, 0x6d, 0x77,
0x61, 0x72, 0x65, 0x4d, 0x61, 0x70, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x12, 0x35, 0x2e,
0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x43, 0x61, 0x63, 0x68, 0x65, 0x41, 0x64, 0x64,
0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46, 0x69, 0x72, 0x6d,
0x77, 0x61, 0x72, 0x65, 0x4d, 0x61, 0x70, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x53, 0x74,
0x72, 0x75, 0x63, 0x74, 0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45,
0x6d, 0x70, 0x74, 0x79, 0x12, 0x4a, 0x0a, 0x26, 0x43, 0x61, 0x63, 0x68, 0x65, 0x44, 0x65, 0x6c,
0x44, 0x65, 0x76, 0x69, 0x63, 0x65, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x46, 0x69, 0x72, 0x6d,
0x77, 0x61, 0x72, 0x65, 0x4d, 0x61, 0x70, 0x50, 0x68, 0x6f, 0x6e, 0x65, 0x32, 0x30, 0x12, 0x10,
0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x55, 0x69, 0x6e, 0x74, 0x33, 0x32, 0x73,
0x1a, 0x0e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79,
0x32, 0x64, 0x0a, 0x0c, 0x47, 0x72, 0x70, 0x63, 0x32, 0x54, 0x63, 0x70, 0x43, 0x6f, 0x6e, 0x6e,
0x12, 0x54, 0x0a, 0x12, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x63, 0x70, 0x43, 0x61,
0x6c, 0x6c, 0x62, 0x61, 0x63, 0x6b, 0x12, 0x1e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63,
0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x63, 0x70, 0x43, 0x61, 0x6c, 0x6c, 0x62,
0x61, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x1a, 0x1e, 0x2e, 0x6d, 0x79, 0x5f, 0x67, 0x72, 0x70, 0x63,
0x2e, 0x52, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x63, 0x70, 0x43, 0x61, 0x6c, 0x6c, 0x62,
0x61, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x42, 0x0e, 0x5a, 0x0c, 0x2e, 0x2f, 0x6b, 0x31, 0x32, 0x32,
0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_grpc_k122Server_k122Server_proto_rawDescOnce sync.Once
file_grpc_k122Server_k122Server_proto_rawDescData = file_grpc_k122Server_k122Server_proto_rawDesc
)
func file_grpc_k122Server_k122Server_proto_rawDescGZIP() []byte {
file_grpc_k122Server_k122Server_proto_rawDescOnce.Do(func() {
file_grpc_k122Server_k122Server_proto_rawDescData = protoimpl.X.CompressGZIP(file_grpc_k122Server_k122Server_proto_rawDescData)
})
return file_grpc_k122Server_k122Server_proto_rawDescData
}
var file_grpc_k122Server_k122Server_proto_msgTypes = make([]protoimpl.MessageInfo, 16)
var file_grpc_k122Server_k122Server_proto_goTypes = []interface{}{
(*CacheAreaReq)(nil), // 0: my_grpc.CacheAreaReq
(*CacheAreaServicePhoneReq)(nil), // 1: my_grpc.CacheAreaServicePhoneReq
(*PhonePaySplitMoneyStruct)(nil), // 2: my_grpc.PhonePaySplitMoneyStruct
(*CachePhonePayList)(nil), // 3: my_grpc.CachePhonePayList
(*CacheDelPhonePayListMsg)(nil), // 4: my_grpc.CacheDelPhonePayListMsg
(*CacheUWeCustomerTestRole)(nil), // 5: my_grpc.CacheUWeCustomerTestRole
(*CacheAddNewSimStruct)(nil), // 6: my_grpc.CacheAddNewSimStruct
(*CacheAddNewSim)(nil), // 7: my_grpc.CacheAddNewSim
(*CacheAddPhone20Struct)(nil), // 8: my_grpc.CacheAddPhone20Struct
(*CacheAddPhone20)(nil), // 9: my_grpc.CacheAddPhone20
(*CacheAddDeviceUpdateFirmwareMapPhone20Struct)(nil), // 10: my_grpc.CacheAddDeviceUpdateFirmwareMapPhone20Struct
(*Uint32S)(nil), // 11: my_grpc.Uint32s
(*Strings)(nil), // 12: my_grpc.Strings
(*Empty)(nil), // 13: my_grpc.Empty
(*ReceiveTcpCallbackReq)(nil), // 14: my_grpc.ReceiveTcpCallbackReq
(*ReceiveTcpCallbackRes)(nil), // 15: my_grpc.ReceiveTcpCallbackRes
}
var file_grpc_k122Server_k122Server_proto_depIdxs = []int32{
2, // 0: my_grpc.CachePhonePayList.SplitAmount:type_name -> my_grpc.PhonePaySplitMoneyStruct
6, // 1: my_grpc.CacheAddNewSim.Rows:type_name -> my_grpc.CacheAddNewSimStruct
8, // 2: my_grpc.CacheAddPhone20.Rows:type_name -> my_grpc.CacheAddPhone20Struct
0, // 3: my_grpc.Grpc2Admin.CacheAddArea:input_type -> my_grpc.CacheAreaReq
0, // 4: my_grpc.Grpc2Admin.CacheUpdateArea:input_type -> my_grpc.CacheAreaReq
1, // 5: my_grpc.Grpc2Admin.CacheAddAreaServicePhone:input_type -> my_grpc.CacheAreaServicePhoneReq
1, // 6: my_grpc.Grpc2Admin.CacheUpdateAreaServicePhone:input_type -> my_grpc.CacheAreaServicePhoneReq
3, // 7: my_grpc.Grpc2Admin.CacheAddPhonePayList:input_type -> my_grpc.CachePhonePayList
3, // 8: my_grpc.Grpc2Admin.CacheUpdatePhonePayList:input_type -> my_grpc.CachePhonePayList
4, // 9: my_grpc.Grpc2Admin.CacheDelPhonePayList:input_type -> my_grpc.CacheDelPhonePayListMsg
5, // 10: my_grpc.Grpc2Admin.CacheUpdateUWeCustomerTestRole:input_type -> my_grpc.CacheUWeCustomerTestRole
7, // 11: my_grpc.Grpc2Admin.CacheAddSimInfoNoBindStudentAndFamily:input_type -> my_grpc.CacheAddNewSim
12, // 12: my_grpc.Grpc2Admin.CacheDeleteSimInfo:input_type -> my_grpc.Strings
9, // 13: my_grpc.Grpc2Admin.CacheAddDevPhone20WhereAreaServiceIDNot0:input_type -> my_grpc.CacheAddPhone20
11, // 14: my_grpc.Grpc2Admin.CacheDeleteDevPhone20:input_type -> my_grpc.Uint32s
10, // 15: my_grpc.Grpc2Admin.CacheAddDeviceUpdateFirmwareMapPhone20:input_type -> my_grpc.CacheAddDeviceUpdateFirmwareMapPhone20Struct
11, // 16: my_grpc.Grpc2Admin.CacheDelDeviceUpdateFirmwareMapPhone20:input_type -> my_grpc.Uint32s
14, // 17: my_grpc.Grpc2TcpConn.ReceiveTcpCallback:input_type -> my_grpc.ReceiveTcpCallbackReq
13, // 18: my_grpc.Grpc2Admin.CacheAddArea:output_type -> my_grpc.Empty
13, // 19: my_grpc.Grpc2Admin.CacheUpdateArea:output_type -> my_grpc.Empty
13, // 20: my_grpc.Grpc2Admin.CacheAddAreaServicePhone:output_type -> my_grpc.Empty
13, // 21: my_grpc.Grpc2Admin.CacheUpdateAreaServicePhone:output_type -> my_grpc.Empty
13, // 22: my_grpc.Grpc2Admin.CacheAddPhonePayList:output_type -> my_grpc.Empty
13, // 23: my_grpc.Grpc2Admin.CacheUpdatePhonePayList:output_type -> my_grpc.Empty
13, // 24: my_grpc.Grpc2Admin.CacheDelPhonePayList:output_type -> my_grpc.Empty
13, // 25: my_grpc.Grpc2Admin.CacheUpdateUWeCustomerTestRole:output_type -> my_grpc.Empty
12, // 26: my_grpc.Grpc2Admin.CacheAddSimInfoNoBindStudentAndFamily:output_type -> my_grpc.Strings
13, // 27: my_grpc.Grpc2Admin.CacheDeleteSimInfo:output_type -> my_grpc.Empty
11, // 28: my_grpc.Grpc2Admin.CacheAddDevPhone20WhereAreaServiceIDNot0:output_type -> my_grpc.Uint32s
13, // 29: my_grpc.Grpc2Admin.CacheDeleteDevPhone20:output_type -> my_grpc.Empty
13, // 30: my_grpc.Grpc2Admin.CacheAddDeviceUpdateFirmwareMapPhone20:output_type -> my_grpc.Empty
13, // 31: my_grpc.Grpc2Admin.CacheDelDeviceUpdateFirmwareMapPhone20:output_type -> my_grpc.Empty
15, // 32: my_grpc.Grpc2TcpConn.ReceiveTcpCallback:output_type -> my_grpc.ReceiveTcpCallbackRes
18, // [18:33] is the sub-list for method output_type
3, // [3:18] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
}
func init() { file_grpc_k122Server_k122Server_proto_init() }
func file_grpc_k122Server_k122Server_proto_init() {
if File_grpc_k122Server_k122Server_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_grpc_k122Server_k122Server_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAreaReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAreaServicePhoneReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PhonePaySplitMoneyStruct); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CachePhonePayList); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheDelPhonePayListMsg); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheUWeCustomerTestRole); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAddNewSimStruct); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAddNewSim); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAddPhone20Struct); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAddPhone20); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*CacheAddDeviceUpdateFirmwareMapPhone20Struct); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Uint32S); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Strings); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Empty); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ReceiveTcpCallbackReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_grpc_k122Server_k122Server_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ReceiveTcpCallbackRes); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_grpc_k122Server_k122Server_proto_rawDesc,
NumEnums: 0,
NumMessages: 16,
NumExtensions: 0,
NumServices: 2,
},
GoTypes: file_grpc_k122Server_k122Server_proto_goTypes,
DependencyIndexes: file_grpc_k122Server_k122Server_proto_depIdxs,
MessageInfos: file_grpc_k122Server_k122Server_proto_msgTypes,
}.Build()
File_grpc_k122Server_k122Server_proto = out.File
file_grpc_k122Server_k122Server_proto_rawDesc = nil
file_grpc_k122Server_k122Server_proto_goTypes = nil
file_grpc_k122Server_k122Server_proto_depIdxs = nil
}
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package k122Server
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Grpc2AdminClient is the client API for Grpc2Admin service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type Grpc2AdminClient interface {
// area
CacheAddArea(ctx context.Context, in *CacheAreaReq, opts ...grpc.CallOption) (*Empty, error)
CacheUpdateArea(ctx context.Context, in *CacheAreaReq, opts ...grpc.CallOption) (*Empty, error)
// area_service
// rpc CacheAddAreaService(CacheAreaServiceReq) returns(Empty);
CacheAddAreaServicePhone(ctx context.Context, in *CacheAreaServicePhoneReq, opts ...grpc.CallOption) (*Empty, error)
// rpc CacheUpdateAreaService(CacheAreaServiceReq) returns(Empty);
CacheUpdateAreaServicePhone(ctx context.Context, in *CacheAreaServicePhoneReq, opts ...grpc.CallOption) (*Empty, error)
// phone_pay_list
CacheAddPhonePayList(ctx context.Context, in *CachePhonePayList, opts ...grpc.CallOption) (*Empty, error)
CacheUpdatePhonePayList(ctx context.Context, in *CachePhonePayList, opts ...grpc.CallOption) (*Empty, error)
CacheDelPhonePayList(ctx context.Context, in *CacheDelPhonePayListMsg, opts ...grpc.CallOption) (*Empty, error)
// we_customer
CacheUpdateUWeCustomerTestRole(ctx context.Context, in *CacheUWeCustomerTestRole, opts ...grpc.CallOption) (*Empty, error)
// sim_card_info
CacheAddSimInfoNoBindStudentAndFamily(ctx context.Context, in *CacheAddNewSim, opts ...grpc.CallOption) (*Strings, error)
CacheDeleteSimInfo(ctx context.Context, in *Strings, opts ...grpc.CallOption) (*Empty, error)
// dev_phone20
CacheAddDevPhone20WhereAreaServiceIDNot0(ctx context.Context, in *CacheAddPhone20, opts ...grpc.CallOption) (*Uint32S, error)
// rpc CheckDevPhone20Online(Uint32s) returns(BoolS); // 拿devIDs来查设备是否在线,返回boolS
// rpc GetDevPhone20OnlineList(Empty) returns(Uint32s); // 查询所有在线的ID,无序列表
CacheDeleteDevPhone20(ctx context.Context, in *Uint32S, opts ...grpc.CallOption) (*Empty, error)
// dev_firmware_phone20
CacheAddDeviceUpdateFirmwareMapPhone20(ctx context.Context, in *CacheAddDeviceUpdateFirmwareMapPhone20Struct, opts ...grpc.CallOption) (*Empty, error)
CacheDelDeviceUpdateFirmwareMapPhone20(ctx context.Context, in *Uint32S, opts ...grpc.CallOption) (*Empty, error)
}
type grpc2AdminClient struct {
cc grpc.ClientConnInterface
}
func NewGrpc2AdminClient(cc grpc.ClientConnInterface) Grpc2AdminClient {
return &grpc2AdminClient{cc}
}
func (c *grpc2AdminClient) CacheAddArea(ctx context.Context, in *CacheAreaReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddArea", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheUpdateArea(ctx context.Context, in *CacheAreaReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheUpdateArea", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheAddAreaServicePhone(ctx context.Context, in *CacheAreaServicePhoneReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddAreaServicePhone", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheUpdateAreaServicePhone(ctx context.Context, in *CacheAreaServicePhoneReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheUpdateAreaServicePhone", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheAddPhonePayList(ctx context.Context, in *CachePhonePayList, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddPhonePayList", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheUpdatePhonePayList(ctx context.Context, in *CachePhonePayList, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheUpdatePhonePayList", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheDelPhonePayList(ctx context.Context, in *CacheDelPhonePayListMsg, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheDelPhonePayList", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheUpdateUWeCustomerTestRole(ctx context.Context, in *CacheUWeCustomerTestRole, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheUpdateUWeCustomerTestRole", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheAddSimInfoNoBindStudentAndFamily(ctx context.Context, in *CacheAddNewSim, opts ...grpc.CallOption) (*Strings, error) {
out := new(Strings)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddSimInfoNoBindStudentAndFamily", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheDeleteSimInfo(ctx context.Context, in *Strings, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheDeleteSimInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheAddDevPhone20WhereAreaServiceIDNot0(ctx context.Context, in *CacheAddPhone20, opts ...grpc.CallOption) (*Uint32S, error) {
out := new(Uint32S)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddDevPhone20WhereAreaServiceIDNot0", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheDeleteDevPhone20(ctx context.Context, in *Uint32S, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheDeleteDevPhone20", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheAddDeviceUpdateFirmwareMapPhone20(ctx context.Context, in *CacheAddDeviceUpdateFirmwareMapPhone20Struct, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheAddDeviceUpdateFirmwareMapPhone20", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *grpc2AdminClient) CacheDelDeviceUpdateFirmwareMapPhone20(ctx context.Context, in *Uint32S, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2Admin/CacheDelDeviceUpdateFirmwareMapPhone20", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Grpc2AdminServer is the server API for Grpc2Admin service.
// All implementations must embed UnimplementedGrpc2AdminServer
// for forward compatibility
type Grpc2AdminServer interface {
// area
CacheAddArea(context.Context, *CacheAreaReq) (*Empty, error)
CacheUpdateArea(context.Context, *CacheAreaReq) (*Empty, error)
// area_service
// rpc CacheAddAreaService(CacheAreaServiceReq) returns(Empty);
CacheAddAreaServicePhone(context.Context, *CacheAreaServicePhoneReq) (*Empty, error)
// rpc CacheUpdateAreaService(CacheAreaServiceReq) returns(Empty);
CacheUpdateAreaServicePhone(context.Context, *CacheAreaServicePhoneReq) (*Empty, error)
// phone_pay_list
CacheAddPhonePayList(context.Context, *CachePhonePayList) (*Empty, error)
CacheUpdatePhonePayList(context.Context, *CachePhonePayList) (*Empty, error)
CacheDelPhonePayList(context.Context, *CacheDelPhonePayListMsg) (*Empty, error)
// we_customer
CacheUpdateUWeCustomerTestRole(context.Context, *CacheUWeCustomerTestRole) (*Empty, error)
// sim_card_info
CacheAddSimInfoNoBindStudentAndFamily(context.Context, *CacheAddNewSim) (*Strings, error)
CacheDeleteSimInfo(context.Context, *Strings) (*Empty, error)
// dev_phone20
CacheAddDevPhone20WhereAreaServiceIDNot0(context.Context, *CacheAddPhone20) (*Uint32S, error)
// rpc CheckDevPhone20Online(Uint32s) returns(BoolS); // 拿devIDs来查设备是否在线,返回boolS
// rpc GetDevPhone20OnlineList(Empty) returns(Uint32s); // 查询所有在线的ID,无序列表
CacheDeleteDevPhone20(context.Context, *Uint32S) (*Empty, error)
// dev_firmware_phone20
CacheAddDeviceUpdateFirmwareMapPhone20(context.Context, *CacheAddDeviceUpdateFirmwareMapPhone20Struct) (*Empty, error)
CacheDelDeviceUpdateFirmwareMapPhone20(context.Context, *Uint32S) (*Empty, error)
mustEmbedUnimplementedGrpc2AdminServer()
}
// UnimplementedGrpc2AdminServer must be embedded to have forward compatible implementations.
type UnimplementedGrpc2AdminServer struct {
}
func (UnimplementedGrpc2AdminServer) CacheAddArea(context.Context, *CacheAreaReq) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddArea not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheUpdateArea(context.Context, *CacheAreaReq) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheUpdateArea not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheAddAreaServicePhone(context.Context, *CacheAreaServicePhoneReq) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddAreaServicePhone not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheUpdateAreaServicePhone(context.Context, *CacheAreaServicePhoneReq) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheUpdateAreaServicePhone not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheAddPhonePayList(context.Context, *CachePhonePayList) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddPhonePayList not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheUpdatePhonePayList(context.Context, *CachePhonePayList) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheUpdatePhonePayList not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheDelPhonePayList(context.Context, *CacheDelPhonePayListMsg) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheDelPhonePayList not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheUpdateUWeCustomerTestRole(context.Context, *CacheUWeCustomerTestRole) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheUpdateUWeCustomerTestRole not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheAddSimInfoNoBindStudentAndFamily(context.Context, *CacheAddNewSim) (*Strings, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddSimInfoNoBindStudentAndFamily not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheDeleteSimInfo(context.Context, *Strings) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheDeleteSimInfo not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheAddDevPhone20WhereAreaServiceIDNot0(context.Context, *CacheAddPhone20) (*Uint32S, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddDevPhone20WhereAreaServiceIDNot0 not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheDeleteDevPhone20(context.Context, *Uint32S) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheDeleteDevPhone20 not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheAddDeviceUpdateFirmwareMapPhone20(context.Context, *CacheAddDeviceUpdateFirmwareMapPhone20Struct) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheAddDeviceUpdateFirmwareMapPhone20 not implemented")
}
func (UnimplementedGrpc2AdminServer) CacheDelDeviceUpdateFirmwareMapPhone20(context.Context, *Uint32S) (*Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method CacheDelDeviceUpdateFirmwareMapPhone20 not implemented")
}
func (UnimplementedGrpc2AdminServer) mustEmbedUnimplementedGrpc2AdminServer() {}
// UnsafeGrpc2AdminServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to Grpc2AdminServer will
// result in compilation errors.
type UnsafeGrpc2AdminServer interface {
mustEmbedUnimplementedGrpc2AdminServer()
}
func RegisterGrpc2AdminServer(s grpc.ServiceRegistrar, srv Grpc2AdminServer) {
s.RegisterService(&Grpc2Admin_ServiceDesc, srv)
}
func _Grpc2Admin_CacheAddArea_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAreaReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddArea(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddArea",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddArea(ctx, req.(*CacheAreaReq))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheUpdateArea_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAreaReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheUpdateArea(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheUpdateArea",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheUpdateArea(ctx, req.(*CacheAreaReq))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheAddAreaServicePhone_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAreaServicePhoneReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddAreaServicePhone(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddAreaServicePhone",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddAreaServicePhone(ctx, req.(*CacheAreaServicePhoneReq))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheUpdateAreaServicePhone_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAreaServicePhoneReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheUpdateAreaServicePhone(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheUpdateAreaServicePhone",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheUpdateAreaServicePhone(ctx, req.(*CacheAreaServicePhoneReq))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheAddPhonePayList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CachePhonePayList)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddPhonePayList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddPhonePayList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddPhonePayList(ctx, req.(*CachePhonePayList))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheUpdatePhonePayList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CachePhonePayList)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheUpdatePhonePayList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheUpdatePhonePayList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheUpdatePhonePayList(ctx, req.(*CachePhonePayList))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheDelPhonePayList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheDelPhonePayListMsg)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheDelPhonePayList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheDelPhonePayList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheDelPhonePayList(ctx, req.(*CacheDelPhonePayListMsg))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheUpdateUWeCustomerTestRole_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheUWeCustomerTestRole)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheUpdateUWeCustomerTestRole(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheUpdateUWeCustomerTestRole",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheUpdateUWeCustomerTestRole(ctx, req.(*CacheUWeCustomerTestRole))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheAddSimInfoNoBindStudentAndFamily_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAddNewSim)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddSimInfoNoBindStudentAndFamily(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddSimInfoNoBindStudentAndFamily",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddSimInfoNoBindStudentAndFamily(ctx, req.(*CacheAddNewSim))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheDeleteSimInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Strings)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheDeleteSimInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheDeleteSimInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheDeleteSimInfo(ctx, req.(*Strings))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheAddDevPhone20WhereAreaServiceIDNot0_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAddPhone20)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddDevPhone20WhereAreaServiceIDNot0(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddDevPhone20WhereAreaServiceIDNot0",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddDevPhone20WhereAreaServiceIDNot0(ctx, req.(*CacheAddPhone20))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheDeleteDevPhone20_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Uint32S)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheDeleteDevPhone20(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheDeleteDevPhone20",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheDeleteDevPhone20(ctx, req.(*Uint32S))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheAddDeviceUpdateFirmwareMapPhone20_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CacheAddDeviceUpdateFirmwareMapPhone20Struct)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheAddDeviceUpdateFirmwareMapPhone20(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheAddDeviceUpdateFirmwareMapPhone20",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheAddDeviceUpdateFirmwareMapPhone20(ctx, req.(*CacheAddDeviceUpdateFirmwareMapPhone20Struct))
}
return interceptor(ctx, in, info, handler)
}
func _Grpc2Admin_CacheDelDeviceUpdateFirmwareMapPhone20_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(Uint32S)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2AdminServer).CacheDelDeviceUpdateFirmwareMapPhone20(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2Admin/CacheDelDeviceUpdateFirmwareMapPhone20",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2AdminServer).CacheDelDeviceUpdateFirmwareMapPhone20(ctx, req.(*Uint32S))
}
return interceptor(ctx, in, info, handler)
}
// Grpc2Admin_ServiceDesc is the grpc.ServiceDesc for Grpc2Admin service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Grpc2Admin_ServiceDesc = grpc.ServiceDesc{
ServiceName: "my_grpc.Grpc2Admin",
HandlerType: (*Grpc2AdminServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CacheAddArea",
Handler: _Grpc2Admin_CacheAddArea_Handler,
},
{
MethodName: "CacheUpdateArea",
Handler: _Grpc2Admin_CacheUpdateArea_Handler,
},
{
MethodName: "CacheAddAreaServicePhone",
Handler: _Grpc2Admin_CacheAddAreaServicePhone_Handler,
},
{
MethodName: "CacheUpdateAreaServicePhone",
Handler: _Grpc2Admin_CacheUpdateAreaServicePhone_Handler,
},
{
MethodName: "CacheAddPhonePayList",
Handler: _Grpc2Admin_CacheAddPhonePayList_Handler,
},
{
MethodName: "CacheUpdatePhonePayList",
Handler: _Grpc2Admin_CacheUpdatePhonePayList_Handler,
},
{
MethodName: "CacheDelPhonePayList",
Handler: _Grpc2Admin_CacheDelPhonePayList_Handler,
},
{
MethodName: "CacheUpdateUWeCustomerTestRole",
Handler: _Grpc2Admin_CacheUpdateUWeCustomerTestRole_Handler,
},
{
MethodName: "CacheAddSimInfoNoBindStudentAndFamily",
Handler: _Grpc2Admin_CacheAddSimInfoNoBindStudentAndFamily_Handler,
},
{
MethodName: "CacheDeleteSimInfo",
Handler: _Grpc2Admin_CacheDeleteSimInfo_Handler,
},
{
MethodName: "CacheAddDevPhone20WhereAreaServiceIDNot0",
Handler: _Grpc2Admin_CacheAddDevPhone20WhereAreaServiceIDNot0_Handler,
},
{
MethodName: "CacheDeleteDevPhone20",
Handler: _Grpc2Admin_CacheDeleteDevPhone20_Handler,
},
{
MethodName: "CacheAddDeviceUpdateFirmwareMapPhone20",
Handler: _Grpc2Admin_CacheAddDeviceUpdateFirmwareMapPhone20_Handler,
},
{
MethodName: "CacheDelDeviceUpdateFirmwareMapPhone20",
Handler: _Grpc2Admin_CacheDelDeviceUpdateFirmwareMapPhone20_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "grpc_k122Server/k122Server.proto",
}
// Grpc2TcpConnClient is the client API for Grpc2TcpConn service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type Grpc2TcpConnClient interface {
ReceiveTcpCallback(ctx context.Context, in *ReceiveTcpCallbackReq, opts ...grpc.CallOption) (*ReceiveTcpCallbackRes, error)
}
type grpc2TcpConnClient struct {
cc grpc.ClientConnInterface
}
func NewGrpc2TcpConnClient(cc grpc.ClientConnInterface) Grpc2TcpConnClient {
return &grpc2TcpConnClient{cc}
}
func (c *grpc2TcpConnClient) ReceiveTcpCallback(ctx context.Context, in *ReceiveTcpCallbackReq, opts ...grpc.CallOption) (*ReceiveTcpCallbackRes, error) {
out := new(ReceiveTcpCallbackRes)
err := c.cc.Invoke(ctx, "/my_grpc.Grpc2TcpConn/ReceiveTcpCallback", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Grpc2TcpConnServer is the server API for Grpc2TcpConn service.
// All implementations must embed UnimplementedGrpc2TcpConnServer
// for forward compatibility
type Grpc2TcpConnServer interface {
ReceiveTcpCallback(context.Context, *ReceiveTcpCallbackReq) (*ReceiveTcpCallbackRes, error)
mustEmbedUnimplementedGrpc2TcpConnServer()
}
// UnimplementedGrpc2TcpConnServer must be embedded to have forward compatible implementations.
type UnimplementedGrpc2TcpConnServer struct {
}
func (UnimplementedGrpc2TcpConnServer) ReceiveTcpCallback(context.Context, *ReceiveTcpCallbackReq) (*ReceiveTcpCallbackRes, error) {
return nil, status.Errorf(codes.Unimplemented, "method ReceiveTcpCallback not implemented")
}
func (UnimplementedGrpc2TcpConnServer) mustEmbedUnimplementedGrpc2TcpConnServer() {}
// UnsafeGrpc2TcpConnServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to Grpc2TcpConnServer will
// result in compilation errors.
type UnsafeGrpc2TcpConnServer interface {
mustEmbedUnimplementedGrpc2TcpConnServer()
}
func RegisterGrpc2TcpConnServer(s grpc.ServiceRegistrar, srv Grpc2TcpConnServer) {
s.RegisterService(&Grpc2TcpConn_ServiceDesc, srv)
}
func _Grpc2TcpConn_ReceiveTcpCallback_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ReceiveTcpCallbackReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(Grpc2TcpConnServer).ReceiveTcpCallback(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/my_grpc.Grpc2TcpConn/ReceiveTcpCallback",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(Grpc2TcpConnServer).ReceiveTcpCallback(ctx, req.(*ReceiveTcpCallbackReq))
}
return interceptor(ctx, in, info, handler)
}
// Grpc2TcpConn_ServiceDesc is the grpc.ServiceDesc for Grpc2TcpConn service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Grpc2TcpConn_ServiceDesc = grpc.ServiceDesc{
ServiceName: "my_grpc.Grpc2TcpConn",
HandlerType: (*Grpc2TcpConnServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "ReceiveTcpCallback",
Handler: _Grpc2TcpConn_ReceiveTcpCallback_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "grpc_k122Server/k122Server.proto",
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment