protobuffs

package module
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 25, 2023 License: GPL-3.0 Imports: 8 Imported by: 2

README

一个模块间的RPC，PROTOBUFFER定义

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Alarm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alarm.Alarm",
	HandlerType: (*AlarmServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Alarm",
			Handler:    _Alarm_Alarm_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/alarm.proto",
}

Alarm_ServiceDesc is the grpc.ServiceDesc for Alarm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Crm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "crm.Crm",
	HandlerType: (*CrmServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UserOnlineChange",
			Handler:    _Crm_UserOnlineChange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/crm.proto",
}

Crm_ServiceDesc is the grpc.ServiceDesc for Crm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DIm_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "im.DIm",
	HandlerType: (*DImServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryOnline",
			Handler:    _DIm_QueryOnline_Handler,
		},
		{
			MethodName: "QueryAllOnline",
			Handler:    _DIm_QueryAllOnline_Handler,
		},
		{
			MethodName: "SendMsg",
			Handler:    _DIm_SendMsg_Handler,
		},
		{
			MethodName: "SendMsgAll",
			Handler:    _DIm_SendMsgAll_Handler,
		},
		{
			MethodName: "GetUserList",
			Handler:    _DIm_GetUserList_Handler,
		},
		{
			MethodName: "GetAllUserList",
			Handler:    _DIm_GetAllUserList_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/im.proto",
}

DIm_ServiceDesc is the grpc.ServiceDesc for DIm service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DRes_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dres.DRes",
	HandlerType: (*DResServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DoCommand",
			Handler:    _DRes_DoCommand_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/res.proto",
}

DRes_ServiceDesc is the grpc.ServiceDesc for DRes service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_protos_alarm_proto protoreflect.FileDescriptor
View Source 
var File_protos_common_proto protoreflect.FileDescriptor
View Source 
var File_protos_crm_proto protoreflect.FileDescriptor
View Source 
var File_protos_im_proto protoreflect.FileDescriptor
View Source 
var File_protos_monitor_proto protoreflect.FileDescriptor
View Source 
var File_protos_res_proto protoreflect.FileDescriptor
View Source 
var Monitor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "monitor.Monitor",
	HandlerType: (*MonitorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DoCommand",
			Handler:    _Monitor_DoCommand_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/monitor.proto",
}

Monitor_ServiceDesc is the grpc.ServiceDesc for Monitor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAlarmServer 

func RegisterAlarmServer(s grpc.ServiceRegistrar, srv AlarmServer)

func RegisterCrmServer 

func RegisterCrmServer(s grpc.ServiceRegistrar, srv CrmServer)

func RegisterDImServer 

func RegisterDImServer(s grpc.ServiceRegistrar, srv DImServer)

func RegisterDResServer 

func RegisterDResServer(s grpc.ServiceRegistrar, srv DResServer)

func RegisterMonitorServer added in v0.1.12 

func RegisterMonitorServer(s grpc.ServiceRegistrar, srv MonitorServer)

Types

type AlarmClient 

type AlarmClient interface {
	Alarm(ctx context.Context, in *AlarmReq, opts ...grpc.CallOption) (*Response, error)
}

AlarmClient is the client API for Alarm 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.

func NewAlarmClient 

func NewAlarmClient(cc grpc.ClientConnInterface) AlarmClient

type AlarmContent 

type AlarmContent struct {
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	Text    string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"` //简单描述
	// contains filtered or unexported fields
}

func (*AlarmContent) Descriptor deprecated 

func (*AlarmContent) Descriptor() ([]byte, []int)

Deprecated: Use AlarmContent.ProtoReflect.Descriptor instead.

func (*AlarmContent) GetSubject 

func (x *AlarmContent) GetSubject() string

func (*AlarmContent) GetText 

func (x *AlarmContent) GetText() string

func (*AlarmContent) ProtoMessage 

func (*AlarmContent) ProtoMessage()

func (*AlarmContent) ProtoReflect 

func (x *AlarmContent) ProtoReflect() protoreflect.Message

func (*AlarmContent) Reset 

func (x *AlarmContent) Reset()

func (*AlarmContent) String 

func (x *AlarmContent) String() string

type AlarmInfo 

type AlarmInfo struct {
	Appid     string          `protobuf:"bytes,1,opt,name=appid,proto3" json:"appid,omitempty"` // 应用
	Type      int32           `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`  // @see alaram.Type
	No        string          `protobuf:"bytes,3,opt,name=no,proto3" json:"no,omitempty"`       //警告单号
	Time      string          `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`   //时间
	System    *AlarmSystem    `protobuf:"bytes,5,opt,name=system,proto3" json:"system,omitempty"`
	Content   *AlarmContent   `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Situation *AlarmSituation `protobuf:"bytes,7,opt,name=situation,proto3" json:"situation,omitempty"`
	To        string          `protobuf:"bytes,8,opt,name=to,proto3" json:"to,omitempty"` //发给谁
	// contains filtered or unexported fields
}

func (*AlarmInfo) Descriptor deprecated 

func (*AlarmInfo) Descriptor() ([]byte, []int)

Deprecated: Use AlarmInfo.ProtoReflect.Descriptor instead.

func (*AlarmInfo) GetAppid 

func (x *AlarmInfo) GetAppid() string

func (*AlarmInfo) GetContent 

func (x *AlarmInfo) GetContent() *AlarmContent

func (*AlarmInfo) GetNo 

func (x *AlarmInfo) GetNo() string

func (*AlarmInfo) GetSituation 

func (x *AlarmInfo) GetSituation() *AlarmSituation

func (*AlarmInfo) GetSystem 

func (x *AlarmInfo) GetSystem() *AlarmSystem

func (*AlarmInfo) GetTime 

func (x *AlarmInfo) GetTime() string

func (*AlarmInfo) GetTo 

func (x *AlarmInfo) GetTo() string

func (*AlarmInfo) GetType 

func (x *AlarmInfo) GetType() int32

func (*AlarmInfo) ProtoMessage 

func (*AlarmInfo) ProtoMessage()

func (*AlarmInfo) ProtoReflect 

func (x *AlarmInfo) ProtoReflect() protoreflect.Message

func (*AlarmInfo) Reset 

func (x *AlarmInfo) Reset()

func (*AlarmInfo) String 

func (x *AlarmInfo) String() string

type AlarmReq 

type AlarmReq struct {
	Head  *Request   `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Alarm *AlarmInfo `protobuf:"bytes,2,opt,name=alarm,proto3" json:"alarm,omitempty"`
	// contains filtered or unexported fields
}

func (*AlarmReq) Descriptor deprecated 

func (*AlarmReq) Descriptor() ([]byte, []int)

Deprecated: Use AlarmReq.ProtoReflect.Descriptor instead.

func (*AlarmReq) GetAlarm 

func (x *AlarmReq) GetAlarm() *AlarmInfo

func (*AlarmReq) GetHead 

func (x *AlarmReq) GetHead() *Request

func (*AlarmReq) ProtoMessage 

func (*AlarmReq) ProtoMessage()

func (*AlarmReq) ProtoReflect 

func (x *AlarmReq) ProtoReflect() protoreflect.Message

func (*AlarmReq) Reset 

func (x *AlarmReq) Reset()

func (*AlarmReq) String 

func (x *AlarmReq) String() string

type AlarmServer 

type AlarmServer interface {
	Alarm(context.Context, *AlarmReq) (*Response, error)
	// contains filtered or unexported methods
}

AlarmServer is the server API for Alarm service. All implementations must embed UnimplementedAlarmServer for forward compatibility

type AlarmSituation 

type AlarmSituation struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`    //错误码
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`     //模块名
	Detail string `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` //具体错误
	Level  int32  `protobuf:"varint,4,opt,name=level,proto3" json:"level,omitempty"`  //错误级别
	// contains filtered or unexported fields
}

func (*AlarmSituation) Descriptor deprecated 

func (*AlarmSituation) Descriptor() ([]byte, []int)

Deprecated: Use AlarmSituation.ProtoReflect.Descriptor instead.

func (*AlarmSituation) GetCode 

func (x *AlarmSituation) GetCode() int32

func (*AlarmSituation) GetDetail 

func (x *AlarmSituation) GetDetail() string

func (*AlarmSituation) GetLevel 

func (x *AlarmSituation) GetLevel() int32

func (*AlarmSituation) GetName 

func (x *AlarmSituation) GetName() string

func (*AlarmSituation) ProtoMessage 

func (*AlarmSituation) ProtoMessage()

func (*AlarmSituation) ProtoReflect 

func (x *AlarmSituation) ProtoReflect() protoreflect.Message

func (*AlarmSituation) Reset 

func (x *AlarmSituation) Reset()

func (*AlarmSituation) String 

func (x *AlarmSituation) String() string

type AlarmSystem 

type AlarmSystem struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` //服务IP
	Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` //json: cpu,memory...
	// contains filtered or unexported fields
}

func (*AlarmSystem) Descriptor deprecated 

func (*AlarmSystem) Descriptor() ([]byte, []int)

Deprecated: Use AlarmSystem.ProtoReflect.Descriptor instead.

func (*AlarmSystem) GetHost 

func (x *AlarmSystem) GetHost() string

func (*AlarmSystem) GetInfo 

func (x *AlarmSystem) GetInfo() string

func (*AlarmSystem) ProtoMessage 

func (*AlarmSystem) ProtoMessage()

func (*AlarmSystem) ProtoReflect 

func (x *AlarmSystem) ProtoReflect() protoreflect.Message

func (*AlarmSystem) Reset 

func (x *AlarmSystem) Reset()

func (*AlarmSystem) String 

func (x *AlarmSystem) String() string

type CommandReq 

type CommandReq struct {
	Head    *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Event   *Event   `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"` //
	// contains filtered or unexported fields
}

func (*CommandReq) Descriptor deprecated 

func (*CommandReq) Descriptor() ([]byte, []int)

Deprecated: Use CommandReq.ProtoReflect.Descriptor instead.

func (*CommandReq) GetEvent 

func (x *CommandReq) GetEvent() *Event

func (*CommandReq) GetHead 

func (x *CommandReq) GetHead() *Request

func (*CommandReq) GetSession 

func (x *CommandReq) GetSession() *Session

func (*CommandReq) ProtoMessage 

func (*CommandReq) ProtoMessage()

func (*CommandReq) ProtoReflect 

func (x *CommandReq) ProtoReflect() protoreflect.Message

func (*CommandReq) Reset 

func (x *CommandReq) Reset()

func (*CommandReq) String 

func (x *CommandReq) String() string

type CommonReply 

type CommonReply struct {
	Head  *Response `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Event *Event    `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonReply) Descriptor deprecated 

func (*CommonReply) Descriptor() ([]byte, []int)

Deprecated: Use CommonReply.ProtoReflect.Descriptor instead.

func (*CommonReply) GetEvent 

func (x *CommonReply) GetEvent() *Event

func (*CommonReply) GetHead 

func (x *CommonReply) GetHead() *Response

func (*CommonReply) ProtoMessage 

func (*CommonReply) ProtoMessage()

func (*CommonReply) ProtoReflect 

func (x *CommonReply) ProtoReflect() protoreflect.Message

func (*CommonReply) Reset 

func (x *CommonReply) Reset()

func (*CommonReply) String 

func (x *CommonReply) String() string

type CommonReq 

type CommonReq struct {
	Head  *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Event *Event   `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*CommonReq) Descriptor deprecated 

func (*CommonReq) Descriptor() ([]byte, []int)

Deprecated: Use CommonReq.ProtoReflect.Descriptor instead.

func (*CommonReq) GetEvent 

func (x *CommonReq) GetEvent() *Event

func (*CommonReq) GetHead 

func (x *CommonReq) GetHead() *Request

func (*CommonReq) ProtoMessage 

func (*CommonReq) ProtoMessage()

func (*CommonReq) ProtoReflect 

func (x *CommonReq) ProtoReflect() protoreflect.Message

func (*CommonReq) Reset 

func (x *CommonReq) Reset()

func (*CommonReq) String 

func (x *CommonReq) String() string

type CrmClient 

type CrmClient interface {
	// 用户在线状态变化
	UserOnlineChange(ctx context.Context, in *UserOnlineChangeReq, opts ...grpc.CallOption) (*Response, error)
}

CrmClient is the client API for Crm 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.

func NewCrmClient 

func NewCrmClient(cc grpc.ClientConnInterface) CrmClient

type CrmServer 

type CrmServer interface {
	// 用户在线状态变化
	UserOnlineChange(context.Context, *UserOnlineChangeReq) (*Response, error)
	// contains filtered or unexported methods
}

CrmServer is the server API for Crm service. All implementations must embed UnimplementedCrmServer for forward compatibility

type DImClient 

type DImClient interface {
	// 查询本地用户是否在线
	QueryOnline(ctx context.Context, in *SessionReq, opts ...grpc.CallOption) (*UserOnlineResponse, error)
	// 查询所有机器
	QueryAllOnline(ctx context.Context, in *SessionReq, opts ...grpc.CallOption) (*UserOnlineResponse, error)
	// 发送消息
	SendMsg(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*Response, error)
	// 给这台机器的房间内所有用户发送消息
	SendMsgAll(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*Response, error)
	// 获取本机器用户列表
	GetUserList(ctx context.Context, in *EventReq, opts ...grpc.CallOption) (*CommonReply, error)
	// 获取所有用户列表
	GetAllUserList(ctx context.Context, in *EventReq, opts ...grpc.CallOption) (*CommonReply, error)
}

DImClient is the client API for DIm 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.

func NewDImClient 

func NewDImClient(cc grpc.ClientConnInterface) DImClient

type DImServer 

type DImServer interface {
	// 查询本地用户是否在线
	QueryOnline(context.Context, *SessionReq) (*UserOnlineResponse, error)
	// 查询所有机器
	QueryAllOnline(context.Context, *SessionReq) (*UserOnlineResponse, error)
	// 发送消息
	SendMsg(context.Context, *MessageReq) (*Response, error)
	// 给这台机器的房间内所有用户发送消息
	SendMsgAll(context.Context, *MessageReq) (*Response, error)
	// 获取本机器用户列表
	GetUserList(context.Context, *EventReq) (*CommonReply, error)
	// 获取所有用户列表
	GetAllUserList(context.Context, *EventReq) (*CommonReply, error)
	// contains filtered or unexported methods
}

DImServer is the server API for DIm service. All implementations must embed UnimplementedDImServer for forward compatibility

type DResClient 

type DResClient interface {
	DoCommand(ctx context.Context, in *CommonReq, opts ...grpc.CallOption) (*CommonReply, error)
}

DResClient is the client API for DRes 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.

func NewDResClient 

func NewDResClient(cc grpc.ClientConnInterface) DResClient

type DResServer 

type DResServer interface {
	DoCommand(context.Context, *CommonReq) (*CommonReply, error)
	// contains filtered or unexported methods
}

DResServer is the server API for DRes service. All implementations must embed UnimplementedDResServer for forward compatibility

type Event 

type Event struct {
	EventType   int32  `protobuf:"varint,1,opt,name=eventType,proto3" json:"eventType,omitempty"`
	ContentType string `protobuf:"bytes,2,opt,name=contentType,proto3" json:"contentType,omitempty"` // ="", 默认json
	Content     string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Priority    int32  `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetContent 

func (x *Event) GetContent() string

func (*Event) GetContentType 

func (x *Event) GetContentType() string

func (*Event) GetEventType 

func (x *Event) GetEventType() int32

func (*Event) GetPriority added in v0.1.13 

func (x *Event) GetPriority() int32

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventReq 

type EventReq struct {
	Head    *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Event   *Event   `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*EventReq) Descriptor deprecated 

func (*EventReq) Descriptor() ([]byte, []int)

Deprecated: Use EventReq.ProtoReflect.Descriptor instead.

func (*EventReq) GetEvent 

func (x *EventReq) GetEvent() *Event

func (*EventReq) GetHead 

func (x *EventReq) GetHead() *Request

func (*EventReq) GetSession 

func (x *EventReq) GetSession() *Session

func (*EventReq) ProtoMessage 

func (*EventReq) ProtoMessage()

func (*EventReq) ProtoReflect 

func (x *EventReq) ProtoReflect() protoreflect.Message

func (*EventReq) Reset 

func (x *EventReq) Reset()

func (*EventReq) String 

func (x *EventReq) String() string

type MessageReq 

type MessageReq struct {
	Head    *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Event   *Event   `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	To      []*User  `protobuf:"bytes,4,rep,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageReq) Descriptor deprecated 

func (*MessageReq) Descriptor() ([]byte, []int)

Deprecated: Use MessageReq.ProtoReflect.Descriptor instead.

func (*MessageReq) GetEvent 

func (x *MessageReq) GetEvent() *Event

func (*MessageReq) GetHead 

func (x *MessageReq) GetHead() *Request

func (*MessageReq) GetSession 

func (x *MessageReq) GetSession() *Session

func (*MessageReq) GetTo 

func (x *MessageReq) GetTo() []*User

func (*MessageReq) ProtoMessage 

func (*MessageReq) ProtoMessage()

func (*MessageReq) ProtoReflect 

func (x *MessageReq) ProtoReflect() protoreflect.Message

func (*MessageReq) Reset 

func (x *MessageReq) Reset()

func (*MessageReq) String 

func (x *MessageReq) String() string

type MonitorClient added in v0.1.12 

type MonitorClient interface {
	DoCommand(ctx context.Context, in *CommonReq, opts ...grpc.CallOption) (*CommonReply, error)
}

MonitorClient is the client API for Monitor 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.

func NewMonitorClient added in v0.1.12 

func NewMonitorClient(cc grpc.ClientConnInterface) MonitorClient

type MonitorServer added in v0.1.12 

type MonitorServer interface {
	DoCommand(context.Context, *CommonReq) (*CommonReply, error)
	// contains filtered or unexported methods
}

MonitorServer is the server API for Monitor service. All implementations must embed UnimplementedMonitorServer for forward compatibility

type Request 

type Request struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Source  string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // app:api
	SeqId   string `protobuf:"bytes,3,opt,name=seqId,proto3" json:"seqId,omitempty"`
	Appid   string `protobuf:"bytes,4,opt,name=appid,proto3" json:"appid,omitempty"`
	TimeAt  int64  `protobuf:"varint,5,opt,name=timeAt,proto3" json:"timeAt,omitempty"` //请求时间
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetAppid 

func (x *Request) GetAppid() string

func (*Request) GetSeqId 

func (x *Request) GetSeqId() string

func (*Request) GetSource 

func (x *Request) GetSource() string

func (*Request) GetTimeAt added in v0.1.11 

func (x *Request) GetTimeAt() int64

func (*Request) GetVersion 

func (x *Request) GetVersion() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Version  string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Source   string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // app:api:srv
	SeqId    string `protobuf:"bytes,3,opt,name=seqId,proto3" json:"seqId,omitempty"`
	Errno    int32  `protobuf:"varint,4,opt,name=errno,proto3" json:"errno,omitempty"`
	Error    string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Code     int32  `protobuf:"varint,6,opt,name=code,proto3" json:"code,omitempty"`
	SubCode  int32  `protobuf:"varint,7,opt,name=subCode,proto3" json:"subCode,omitempty"`
	Desc     string `protobuf:"bytes,8,opt,name=desc,proto3" json:"desc,omitempty"`
	Msg      string `protobuf:"bytes,9,opt,name=msg,proto3" json:"msg,omitempty"`
	TimeAt   int64  `protobuf:"varint,10,opt,name=timeAt,proto3" json:"timeAt,omitempty"`     //服务收到请求的时间(ms)
	DiffAt   int64  `protobuf:"varint,11,opt,name=diffAt,proto3" json:"diffAt,omitempty"`     //客户端与服务端时间差值（ms)
	SpendAt  int64  `protobuf:"varint,12,opt,name=spendAt,proto3" json:"spendAt,omitempty"`   //从服务收到请求到响应完成，所花的时长(ms)
	ServerAt int64  `protobuf:"varint,13,opt,name=serverAt,proto3" json:"serverAt,omitempty"` //服务器时间，豪秒，用于检验对时(ms)
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode added in v0.1.11 

func (x *Response) GetCode() int32

func (*Response) GetDesc added in v0.1.11 

func (x *Response) GetDesc() string

func (*Response) GetDiffAt added in v0.1.11 

func (x *Response) GetDiffAt() int64

func (*Response) GetErrno 

func (x *Response) GetErrno() int32

func (*Response) GetError 

func (x *Response) GetError() string

func (*Response) GetMsg added in v0.1.11 

func (x *Response) GetMsg() string

func (*Response) GetSeqId 

func (x *Response) GetSeqId() string

func (*Response) GetServerAt added in v0.1.11 

func (x *Response) GetServerAt() int64

func (*Response) GetSource 

func (x *Response) GetSource() string

func (*Response) GetSpendAt added in v0.1.11 

func (x *Response) GetSpendAt() int64

func (*Response) GetSubCode added in v0.1.11 

func (x *Response) GetSubCode() int32

func (*Response) GetTimeAt added in v0.1.11 

func (x *Response) GetTimeAt() int64

func (*Response) GetVersion 

func (x *Response) GetVersion() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Session 

type Session struct {
	Uid     uint64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	AppId   string `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	Plat    int32  `protobuf:"varint,3,opt,name=plat,proto3" json:"plat,omitempty"`
	Token   string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	Type    int32  `protobuf:"varint,5,opt,name=type,proto3" json:"type,omitempty"`
	Account string `protobuf:"bytes,6,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

func (*Session) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAccount 

func (x *Session) GetAccount() string

func (*Session) GetAppId 

func (x *Session) GetAppId() string

func (*Session) GetPlat 

func (x *Session) GetPlat() int32

func (*Session) GetToken 

func (x *Session) GetToken() string

func (*Session) GetType 

func (x *Session) GetType() int32

func (*Session) GetUid 

func (x *Session) GetUid() uint64

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionReply 

type SessionReply struct {
	Head    *Response `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session  `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	Event   *Event    `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionReply) Descriptor deprecated 

func (*SessionReply) Descriptor() ([]byte, []int)

Deprecated: Use SessionReply.ProtoReflect.Descriptor instead.

func (*SessionReply) GetEvent 

func (x *SessionReply) GetEvent() *Event

func (*SessionReply) GetHead 

func (x *SessionReply) GetHead() *Response

func (*SessionReply) GetSession 

func (x *SessionReply) GetSession() *Session

func (*SessionReply) ProtoMessage 

func (*SessionReply) ProtoMessage()

func (*SessionReply) ProtoReflect 

func (x *SessionReply) ProtoReflect() protoreflect.Message

func (*SessionReply) Reset 

func (x *SessionReply) Reset()

func (*SessionReply) String 

func (x *SessionReply) String() string

type SessionReq 

type SessionReq struct {
	Head    *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionReq) Descriptor deprecated 

func (*SessionReq) Descriptor() ([]byte, []int)

Deprecated: Use SessionReq.ProtoReflect.Descriptor instead.

func (*SessionReq) GetHead 

func (x *SessionReq) GetHead() *Request

func (*SessionReq) GetSession 

func (x *SessionReq) GetSession() *Session

func (*SessionReq) ProtoMessage 

func (*SessionReq) ProtoMessage()

func (*SessionReq) ProtoReflect 

func (x *SessionReq) ProtoReflect() protoreflect.Message

func (*SessionReq) Reset 

func (x *SessionReq) Reset()

func (*SessionReq) String 

func (x *SessionReq) String() string

type UnimplementedAlarmServer 

type UnimplementedAlarmServer struct {
}

UnimplementedAlarmServer must be embedded to have forward compatible implementations.

func (UnimplementedAlarmServer) Alarm 

func (UnimplementedAlarmServer) Alarm(context.Context, *AlarmReq) (*Response, error)

type UnimplementedCrmServer 

type UnimplementedCrmServer struct {
}

UnimplementedCrmServer must be embedded to have forward compatible implementations.

func (UnimplementedCrmServer) UserOnlineChange 

func (UnimplementedCrmServer) UserOnlineChange(context.Context, *UserOnlineChangeReq) (*Response, error)

type UnimplementedDImServer 

type UnimplementedDImServer struct {
}

UnimplementedDImServer must be embedded to have forward compatible implementations.

func (UnimplementedDImServer) GetAllUserList 

func (UnimplementedDImServer) GetAllUserList(context.Context, *EventReq) (*CommonReply, error)

func (UnimplementedDImServer) GetUserList 

func (UnimplementedDImServer) GetUserList(context.Context, *EventReq) (*CommonReply, error)

func (UnimplementedDImServer) QueryAllOnline 

func (UnimplementedDImServer) QueryAllOnline(context.Context, *SessionReq) (*UserOnlineResponse, error)

func (UnimplementedDImServer) QueryOnline 

func (UnimplementedDImServer) QueryOnline(context.Context, *SessionReq) (*UserOnlineResponse, error)

func (UnimplementedDImServer) SendMsg 

func (UnimplementedDImServer) SendMsg(context.Context, *MessageReq) (*Response, error)

func (UnimplementedDImServer) SendMsgAll 

func (UnimplementedDImServer) SendMsgAll(context.Context, *MessageReq) (*Response, error)

type UnimplementedDResServer 

type UnimplementedDResServer struct {
}

UnimplementedDResServer must be embedded to have forward compatible implementations.

func (UnimplementedDResServer) DoCommand 

func (UnimplementedDResServer) DoCommand(context.Context, *CommonReq) (*CommonReply, error)

type UnimplementedMonitorServer added in v0.1.12 

type UnimplementedMonitorServer struct {
}

UnimplementedMonitorServer must be embedded to have forward compatible implementations.

func (UnimplementedMonitorServer) DoCommand added in v0.1.12 

func (UnimplementedMonitorServer) DoCommand(context.Context, *CommonReq) (*CommonReply, error)

type UnsafeAlarmServer 

type UnsafeAlarmServer interface {
	// contains filtered or unexported methods
}

UnsafeAlarmServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AlarmServer will result in compilation errors.

type UnsafeCrmServer 

type UnsafeCrmServer interface {
	// contains filtered or unexported methods
}

UnsafeCrmServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CrmServer will result in compilation errors.

type UnsafeDImServer 

type UnsafeDImServer interface {
	// contains filtered or unexported methods
}

UnsafeDImServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DImServer will result in compilation errors.

type UnsafeDResServer 

type UnsafeDResServer interface {
	// contains filtered or unexported methods
}

UnsafeDResServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DResServer will result in compilation errors.

type UnsafeMonitorServer added in v0.1.12 

type UnsafeMonitorServer interface {
	// contains filtered or unexported methods
}

UnsafeMonitorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MonitorServer will result in compilation errors.

type User 

type User struct {
	Uid     uint64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	AppId   string `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	Plat    int32  `protobuf:"varint,3,opt,name=plat,proto3" json:"plat,omitempty"`
	Account string `protobuf:"bytes,4,opt,name=account,proto3" json:"account,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

func (*User) Descriptor() ([]byte, []int)

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetAccount 

func (x *User) GetAccount() string

func (*User) GetAppId 

func (x *User) GetAppId() string

func (*User) GetPlat 

func (x *User) GetPlat() int32

func (*User) GetUid 

func (x *User) GetUid() uint64

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect 

func (x *User) ProtoReflect() protoreflect.Message

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type UserOnlineChangeReq 

type UserOnlineChangeReq struct {
	Head    *Request `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	State   int32    `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*UserOnlineChangeReq) Descriptor deprecated 

func (*UserOnlineChangeReq) Descriptor() ([]byte, []int)

Deprecated: Use UserOnlineChangeReq.ProtoReflect.Descriptor instead.

func (*UserOnlineChangeReq) GetHead 

func (x *UserOnlineChangeReq) GetHead() *Request

func (*UserOnlineChangeReq) GetSession 

func (x *UserOnlineChangeReq) GetSession() *Session

func (*UserOnlineChangeReq) GetState 

func (x *UserOnlineChangeReq) GetState() int32

func (*UserOnlineChangeReq) ProtoMessage 

func (*UserOnlineChangeReq) ProtoMessage()

func (*UserOnlineChangeReq) ProtoReflect 

func (x *UserOnlineChangeReq) ProtoReflect() protoreflect.Message

func (*UserOnlineChangeReq) Reset 

func (x *UserOnlineChangeReq) Reset()

func (*UserOnlineChangeReq) String 

func (x *UserOnlineChangeReq) String() string

type UserOnlineResponse 

type UserOnlineResponse struct {
	Head   *Response `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Online bool      `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*UserOnlineResponse) Descriptor deprecated 

func (*UserOnlineResponse) Descriptor() ([]byte, []int)

Deprecated: Use UserOnlineResponse.ProtoReflect.Descriptor instead.

func (*UserOnlineResponse) GetHead 

func (x *UserOnlineResponse) GetHead() *Response

func (*UserOnlineResponse) GetOnline 

func (x *UserOnlineResponse) GetOnline() bool

func (*UserOnlineResponse) ProtoMessage 

func (*UserOnlineResponse) ProtoMessage()

func (*UserOnlineResponse) ProtoReflect 

func (x *UserOnlineResponse) ProtoReflect() protoreflect.Message

func (*UserOnlineResponse) Reset 

func (x *UserOnlineResponse) Reset()

func (*UserOnlineResponse) String 

func (x *UserOnlineResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.