Documentation ¶
Index ¶
- Variables
- func RegisterAnswerServer(s grpc.ServiceRegistrar, srv AnswerServer)
- type AnswerClient
- type AnswerServer
- type Client
- func (c *Client) GroupCastSignal(ctx context.Context, Action xproto.SignalType, Target string, Body []byte) error
- func (c *Client) PushCommonMsg(ctx context.Context, key, From string, body []byte) (int64, uint64, error)
- func (c *Client) PushNoticeMsg(ctx context.Context, Seq string, ChannelType int32, From, Target string, ...) (int64, error)
- func (c *Client) UniCastSignal(ctx context.Context, Action xproto.SignalType, Target string, Body []byte) error
- type GroupCastSignalReply
- func (*GroupCastSignalReply) Descriptor() ([]byte, []int)deprecated
- func (x *GroupCastSignalReply) GetMid() int64
- func (*GroupCastSignalReply) ProtoMessage()
- func (x *GroupCastSignalReply) ProtoReflect() protoreflect.Message
- func (x *GroupCastSignalReply) Reset()
- func (x *GroupCastSignalReply) String() string
- type GroupCastSignalReq
- func (*GroupCastSignalReq) Descriptor() ([]byte, []int)deprecated
- func (x *GroupCastSignalReq) GetBody() []byte
- func (x *GroupCastSignalReq) GetTarget() string
- func (x *GroupCastSignalReq) GetType() proto.SignalType
- func (*GroupCastSignalReq) ProtoMessage()
- func (x *GroupCastSignalReq) ProtoReflect() protoreflect.Message
- func (x *GroupCastSignalReq) Reset()
- func (x *GroupCastSignalReq) String() string
- type PushCommonMsgReply
- func (*PushCommonMsgReply) Descriptor() ([]byte, []int)deprecated
- func (x *PushCommonMsgReply) GetMid() int64
- func (x *PushCommonMsgReply) GetTime() uint64
- func (*PushCommonMsgReply) ProtoMessage()
- func (x *PushCommonMsgReply) ProtoReflect() protoreflect.Message
- func (x *PushCommonMsgReply) Reset()
- func (x *PushCommonMsgReply) String() string
- type PushCommonMsgReq
- func (*PushCommonMsgReq) Descriptor() ([]byte, []int)deprecated
- func (x *PushCommonMsgReq) GetBody() []byte
- func (x *PushCommonMsgReq) GetFrom() string
- func (x *PushCommonMsgReq) GetKey() string
- func (*PushCommonMsgReq) ProtoMessage()
- func (x *PushCommonMsgReq) ProtoReflect() protoreflect.Message
- func (x *PushCommonMsgReq) Reset()
- func (x *PushCommonMsgReq) String() string
- type PushNoticeMsgReply
- type PushNoticeMsgReq
- func (*PushNoticeMsgReq) Descriptor() ([]byte, []int)deprecated
- func (x *PushNoticeMsgReq) GetChannelType() int32
- func (x *PushNoticeMsgReq) GetData() []byte
- func (x *PushNoticeMsgReq) GetFrom() string
- func (x *PushNoticeMsgReq) GetSeq() string
- func (x *PushNoticeMsgReq) GetTarget() string
- func (*PushNoticeMsgReq) ProtoMessage()
- func (x *PushNoticeMsgReq) ProtoReflect() protoreflect.Message
- func (x *PushNoticeMsgReq) Reset()
- func (x *PushNoticeMsgReq) String() string
- type UniCastSignalReply
- type UniCastSignalReq
- func (*UniCastSignalReq) Descriptor() ([]byte, []int)deprecated
- func (x *UniCastSignalReq) GetBody() []byte
- func (x *UniCastSignalReq) GetTarget() string
- func (x *UniCastSignalReq) GetType() proto.SignalType
- func (*UniCastSignalReq) ProtoMessage()
- func (x *UniCastSignalReq) ProtoReflect() protoreflect.Message
- func (x *UniCastSignalReq) Reset()
- func (x *UniCastSignalReq) String() string
- type UnimplementedAnswerServer
- func (UnimplementedAnswerServer) GroupCastSignal(context.Context, *GroupCastSignalReq) (*GroupCastSignalReply, error)
- func (UnimplementedAnswerServer) PushCommonMsg(context.Context, *PushCommonMsgReq) (*PushCommonMsgReply, error)
- func (UnimplementedAnswerServer) PushNoticeMsg(context.Context, *PushNoticeMsgReq) (*PushNoticeMsgReply, error)
- func (UnimplementedAnswerServer) UniCastSignal(context.Context, *UniCastSignalReq) (*UniCastSignalReply, error)
- type UnsafeAnswerServer
Constants ¶
This section is empty.
Variables ¶
var Answer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "dtalk.answer.Answer", HandlerType: (*AnswerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PushCommonMsg", Handler: _Answer_PushCommonMsg_Handler, }, { MethodName: "PushNoticeMsg", Handler: _Answer_PushNoticeMsg_Handler, }, { MethodName: "UniCastSignal", Handler: _Answer_UniCastSignal_Handler, }, { MethodName: "GroupCastSignal", Handler: _Answer_GroupCastSignal_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "answer.proto", }
Answer_ServiceDesc is the grpc.ServiceDesc for Answer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_answer_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAnswerServer ¶
func RegisterAnswerServer(s grpc.ServiceRegistrar, srv AnswerServer)
Types ¶
type AnswerClient ¶
type AnswerClient interface { PushCommonMsg(ctx context.Context, in *PushCommonMsgReq, opts ...grpc.CallOption) (*PushCommonMsgReply, error) PushNoticeMsg(ctx context.Context, in *PushNoticeMsgReq, opts ...grpc.CallOption) (*PushNoticeMsgReply, error) UniCastSignal(ctx context.Context, in *UniCastSignalReq, opts ...grpc.CallOption) (*UniCastSignalReply, error) GroupCastSignal(ctx context.Context, in *GroupCastSignalReq, opts ...grpc.CallOption) (*GroupCastSignalReply, error) }
AnswerClient is the client API for Answer 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 NewAnswerClient ¶
func NewAnswerClient(cc grpc.ClientConnInterface) AnswerClient
type AnswerServer ¶
type AnswerServer interface { PushCommonMsg(context.Context, *PushCommonMsgReq) (*PushCommonMsgReply, error) PushNoticeMsg(context.Context, *PushNoticeMsgReq) (*PushNoticeMsgReply, error) UniCastSignal(context.Context, *UniCastSignalReq) (*UniCastSignalReply, error) GroupCastSignal(context.Context, *GroupCastSignalReq) (*GroupCastSignalReply, error) // contains filtered or unexported methods }
AnswerServer is the server API for Answer service. All implementations must embed UnimplementedAnswerServer for forward compatibility
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) GroupCastSignal ¶
func (*Client) PushCommonMsg ¶
func (*Client) PushNoticeMsg ¶
func (*Client) UniCastSignal ¶
type GroupCastSignalReply ¶
type GroupCastSignalReply struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` // contains filtered or unexported fields }
func (*GroupCastSignalReply) Descriptor
deprecated
func (*GroupCastSignalReply) Descriptor() ([]byte, []int)
Deprecated: Use GroupCastSignalReply.ProtoReflect.Descriptor instead.
func (*GroupCastSignalReply) GetMid ¶
func (x *GroupCastSignalReply) GetMid() int64
func (*GroupCastSignalReply) ProtoMessage ¶
func (*GroupCastSignalReply) ProtoMessage()
func (*GroupCastSignalReply) ProtoReflect ¶
func (x *GroupCastSignalReply) ProtoReflect() protoreflect.Message
func (*GroupCastSignalReply) Reset ¶
func (x *GroupCastSignalReply) Reset()
func (*GroupCastSignalReply) String ¶
func (x *GroupCastSignalReply) String() string
type GroupCastSignalReq ¶
type GroupCastSignalReq struct { Type proto.SignalType `protobuf:"varint,1,opt,name=type,proto3,enum=imparse.signal.SignalType" json:"type,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*GroupCastSignalReq) Descriptor
deprecated
func (*GroupCastSignalReq) Descriptor() ([]byte, []int)
Deprecated: Use GroupCastSignalReq.ProtoReflect.Descriptor instead.
func (*GroupCastSignalReq) GetBody ¶
func (x *GroupCastSignalReq) GetBody() []byte
func (*GroupCastSignalReq) GetTarget ¶
func (x *GroupCastSignalReq) GetTarget() string
func (*GroupCastSignalReq) GetType ¶
func (x *GroupCastSignalReq) GetType() proto.SignalType
func (*GroupCastSignalReq) ProtoMessage ¶
func (*GroupCastSignalReq) ProtoMessage()
func (*GroupCastSignalReq) ProtoReflect ¶
func (x *GroupCastSignalReq) ProtoReflect() protoreflect.Message
func (*GroupCastSignalReq) Reset ¶
func (x *GroupCastSignalReq) Reset()
func (*GroupCastSignalReq) String ¶
func (x *GroupCastSignalReq) String() string
type PushCommonMsgReply ¶
type PushCommonMsgReply struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Time uint64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*PushCommonMsgReply) Descriptor
deprecated
func (*PushCommonMsgReply) Descriptor() ([]byte, []int)
Deprecated: Use PushCommonMsgReply.ProtoReflect.Descriptor instead.
func (*PushCommonMsgReply) GetMid ¶
func (x *PushCommonMsgReply) GetMid() int64
func (*PushCommonMsgReply) GetTime ¶
func (x *PushCommonMsgReply) GetTime() uint64
func (*PushCommonMsgReply) ProtoMessage ¶
func (*PushCommonMsgReply) ProtoMessage()
func (*PushCommonMsgReply) ProtoReflect ¶
func (x *PushCommonMsgReply) ProtoReflect() protoreflect.Message
func (*PushCommonMsgReply) Reset ¶
func (x *PushCommonMsgReply) Reset()
func (*PushCommonMsgReply) String ¶
func (x *PushCommonMsgReply) String() string
type PushCommonMsgReq ¶
type PushCommonMsgReq struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*PushCommonMsgReq) Descriptor
deprecated
func (*PushCommonMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use PushCommonMsgReq.ProtoReflect.Descriptor instead.
func (*PushCommonMsgReq) GetBody ¶
func (x *PushCommonMsgReq) GetBody() []byte
func (*PushCommonMsgReq) GetFrom ¶
func (x *PushCommonMsgReq) GetFrom() string
func (*PushCommonMsgReq) GetKey ¶
func (x *PushCommonMsgReq) GetKey() string
func (*PushCommonMsgReq) ProtoMessage ¶
func (*PushCommonMsgReq) ProtoMessage()
func (*PushCommonMsgReq) ProtoReflect ¶
func (x *PushCommonMsgReq) ProtoReflect() protoreflect.Message
func (*PushCommonMsgReq) Reset ¶
func (x *PushCommonMsgReq) Reset()
func (*PushCommonMsgReq) String ¶
func (x *PushCommonMsgReq) String() string
type PushNoticeMsgReply ¶
type PushNoticeMsgReply struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` // contains filtered or unexported fields }
func (*PushNoticeMsgReply) Descriptor
deprecated
func (*PushNoticeMsgReply) Descriptor() ([]byte, []int)
Deprecated: Use PushNoticeMsgReply.ProtoReflect.Descriptor instead.
func (*PushNoticeMsgReply) GetMid ¶
func (x *PushNoticeMsgReply) GetMid() int64
func (*PushNoticeMsgReply) ProtoMessage ¶
func (*PushNoticeMsgReply) ProtoMessage()
func (*PushNoticeMsgReply) ProtoReflect ¶
func (x *PushNoticeMsgReply) ProtoReflect() protoreflect.Message
func (*PushNoticeMsgReply) Reset ¶
func (x *PushNoticeMsgReply) Reset()
func (*PushNoticeMsgReply) String ¶
func (x *PushNoticeMsgReply) String() string
type PushNoticeMsgReq ¶
type PushNoticeMsgReq struct { Seq string `protobuf:"bytes,1,opt,name=seq,proto3" json:"seq,omitempty"` ChannelType int32 `protobuf:"varint,2,opt,name=channelType,proto3" json:"channelType,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*PushNoticeMsgReq) Descriptor
deprecated
func (*PushNoticeMsgReq) Descriptor() ([]byte, []int)
Deprecated: Use PushNoticeMsgReq.ProtoReflect.Descriptor instead.
func (*PushNoticeMsgReq) GetChannelType ¶
func (x *PushNoticeMsgReq) GetChannelType() int32
func (*PushNoticeMsgReq) GetData ¶
func (x *PushNoticeMsgReq) GetData() []byte
func (*PushNoticeMsgReq) GetFrom ¶
func (x *PushNoticeMsgReq) GetFrom() string
func (*PushNoticeMsgReq) GetSeq ¶
func (x *PushNoticeMsgReq) GetSeq() string
func (*PushNoticeMsgReq) GetTarget ¶
func (x *PushNoticeMsgReq) GetTarget() string
func (*PushNoticeMsgReq) ProtoMessage ¶
func (*PushNoticeMsgReq) ProtoMessage()
func (*PushNoticeMsgReq) ProtoReflect ¶
func (x *PushNoticeMsgReq) ProtoReflect() protoreflect.Message
func (*PushNoticeMsgReq) Reset ¶
func (x *PushNoticeMsgReq) Reset()
func (*PushNoticeMsgReq) String ¶
func (x *PushNoticeMsgReq) String() string
type UniCastSignalReply ¶
type UniCastSignalReply struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` // contains filtered or unexported fields }
func (*UniCastSignalReply) Descriptor
deprecated
func (*UniCastSignalReply) Descriptor() ([]byte, []int)
Deprecated: Use UniCastSignalReply.ProtoReflect.Descriptor instead.
func (*UniCastSignalReply) GetMid ¶
func (x *UniCastSignalReply) GetMid() int64
func (*UniCastSignalReply) ProtoMessage ¶
func (*UniCastSignalReply) ProtoMessage()
func (*UniCastSignalReply) ProtoReflect ¶
func (x *UniCastSignalReply) ProtoReflect() protoreflect.Message
func (*UniCastSignalReply) Reset ¶
func (x *UniCastSignalReply) Reset()
func (*UniCastSignalReply) String ¶
func (x *UniCastSignalReply) String() string
type UniCastSignalReq ¶
type UniCastSignalReq struct { Type proto.SignalType `protobuf:"varint,1,opt,name=type,proto3,enum=imparse.signal.SignalType" json:"type,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*UniCastSignalReq) Descriptor
deprecated
func (*UniCastSignalReq) Descriptor() ([]byte, []int)
Deprecated: Use UniCastSignalReq.ProtoReflect.Descriptor instead.
func (*UniCastSignalReq) GetBody ¶
func (x *UniCastSignalReq) GetBody() []byte
func (*UniCastSignalReq) GetTarget ¶
func (x *UniCastSignalReq) GetTarget() string
func (*UniCastSignalReq) GetType ¶
func (x *UniCastSignalReq) GetType() proto.SignalType
func (*UniCastSignalReq) ProtoMessage ¶
func (*UniCastSignalReq) ProtoMessage()
func (*UniCastSignalReq) ProtoReflect ¶
func (x *UniCastSignalReq) ProtoReflect() protoreflect.Message
func (*UniCastSignalReq) Reset ¶
func (x *UniCastSignalReq) Reset()
func (*UniCastSignalReq) String ¶
func (x *UniCastSignalReq) String() string
type UnimplementedAnswerServer ¶
type UnimplementedAnswerServer struct { }
UnimplementedAnswerServer must be embedded to have forward compatible implementations.
func (UnimplementedAnswerServer) GroupCastSignal ¶
func (UnimplementedAnswerServer) GroupCastSignal(context.Context, *GroupCastSignalReq) (*GroupCastSignalReply, error)
func (UnimplementedAnswerServer) PushCommonMsg ¶
func (UnimplementedAnswerServer) PushCommonMsg(context.Context, *PushCommonMsgReq) (*PushCommonMsgReply, error)
func (UnimplementedAnswerServer) PushNoticeMsg ¶
func (UnimplementedAnswerServer) PushNoticeMsg(context.Context, *PushNoticeMsgReq) (*PushNoticeMsgReply, error)
func (UnimplementedAnswerServer) UniCastSignal ¶
func (UnimplementedAnswerServer) UniCastSignal(context.Context, *UniCastSignalReq) (*UniCastSignalReply, error)
type UnsafeAnswerServer ¶
type UnsafeAnswerServer interface {
// contains filtered or unexported methods
}
UnsafeAnswerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnswerServer will result in compilation errors.