Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterOnebotApiMessageGRPCServiceServer(s *grpc.Server, srv OnebotApiMessageGRPCServiceServer)
- type ChannelApiMessageClient
- func (cli *ChannelApiMessageClient) DeleteMsg(id int64) error
- func (cli *ChannelApiMessageClient) GetForwardMsg(id int64) (*model.ForwardMessageDataResult, error)
- func (cli *ChannelApiMessageClient) GetGroupMsgHistory(message_seq int64, groupId int64) (*model.MessagesResult, error)
- func (cli *ChannelApiMessageClient) GetMsg(id int64) (*model.MessageDataResult, error)
- func (cli *ChannelApiMessageClient) MarkMsgAsRead(id int64) error
- func (cli *ChannelApiMessageClient) SendGroupForwardMsg(groupId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
- func (cli *ChannelApiMessageClient) SendGroupMsg(msg *model.GroupMsg) (*model.SendMessageResult, error)
- func (cli *ChannelApiMessageClient) SendMsg(msg *model.MsgForSend) (*model.SendMessageResult, error)
- func (cli *ChannelApiMessageClient) SendPrivateForwardMsg(userId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
- func (cli *ChannelApiMessageClient) SendPrivateMsg(msg *model.PrivateMsg) (*model.SendMessageResult, error)
- type GetGroupMsgHistoryRequest
- func (*GetGroupMsgHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetGroupMsgHistoryRequest) GetGroupId() int64
- func (x *GetGroupMsgHistoryRequest) GetMessageSeq() int64
- func (*GetGroupMsgHistoryRequest) ProtoMessage()
- func (x *GetGroupMsgHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *GetGroupMsgHistoryRequest) Reset()
- func (x *GetGroupMsgHistoryRequest) String() string
- type OnebotApiMessageClient
- type OnebotApiMessageGRPCServiceClient
- type OnebotApiMessageGRPCServiceServer
- type SendGroupForwardMsgRequest
- func (*SendGroupForwardMsgRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendGroupForwardMsgRequest) GetGroupId() int64
- func (x *SendGroupForwardMsgRequest) GetMessages() []*model.MessageSegmentGRPC
- func (*SendGroupForwardMsgRequest) ProtoMessage()
- func (x *SendGroupForwardMsgRequest) ProtoReflect() protoreflect.Message
- func (x *SendGroupForwardMsgRequest) Reset()
- func (x *SendGroupForwardMsgRequest) String() string
- type SendPrivateForwardMsgGRPC
- func (*SendPrivateForwardMsgGRPC) Descriptor() ([]byte, []int)deprecated
- func (x *SendPrivateForwardMsgGRPC) GetMessages() []*model.MessageSegmentGRPC
- func (x *SendPrivateForwardMsgGRPC) GetUserId() int64
- func (*SendPrivateForwardMsgGRPC) ProtoMessage()
- func (x *SendPrivateForwardMsgGRPC) ProtoReflect() protoreflect.Message
- func (x *SendPrivateForwardMsgGRPC) Reset()
- func (x *SendPrivateForwardMsgGRPC) String() string
- type UnimplementedOnebotApiMessageGRPCServiceServer
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) DeleteMsg(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetForwardMsg(context.Context, *wrapperspb.Int64Value) (*model.ForwardMessageDataResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetGroupMsgHistory(context.Context, *GetGroupMsgHistoryRequest) (*model.MessagesResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetMsg(context.Context, *wrapperspb.Int64Value) (*model.MessageDataResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) MarkMsgAsRead(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupForwardMsg(context.Context, *SendGroupForwardMsgRequest) (*model.SendForwardMessageDataResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupMsg(context.Context, *model.GroupMsgGRPC) (*model.SendMessageResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendMsg(context.Context, *model.MsgForSendGRPC) (*model.SendMessageResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateForwardMsg(context.Context, *SendPrivateForwardMsgGRPC) (*model.SendForwardMessageDataResultGRPC, error)
- func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateMsg(context.Context, *model.PrivateMsgGRPC) (*model.SendMessageResultGRPC, error)
Constants ¶
const ( API_SEND_PRIVATE_MSG = "send_private_msg" API_SEND_GROUP_MSG = "send_group_msg" // API_SEND_MSG = "send_msg" API_GET_MSG = "get_msg" API_DELETE_MSG = "delete_msg" API_MARK_MSG_AS_READ = "mark_msg_as_read" API_GET_FORWARD_MSG = "get_forward_msg" API_SEND_GROUP_FORWARD_MSG = "send_group_forward_msg" API_SEND_PRIVATE_FORWARD_MSG = "send_private_forward_msg" API_GET_GROUP_MSG_HISTORY = "get_group_msg_history" )
Variables ¶
var File_api_message_proto protoreflect.FileDescriptor
Functions ¶
func RegisterOnebotApiMessageGRPCServiceServer ¶
func RegisterOnebotApiMessageGRPCServiceServer(s *grpc.Server, srv OnebotApiMessageGRPCServiceServer)
Types ¶
type ChannelApiMessageClient ¶
type ChannelApiMessageClient struct {
channel.ApiChannel
// contains filtered or unexported fields
}
func (*ChannelApiMessageClient) DeleteMsg ¶
func (cli *ChannelApiMessageClient) DeleteMsg(id int64) error
撤回消息 delete_msg
func (*ChannelApiMessageClient) GetForwardMsg ¶
func (cli *ChannelApiMessageClient) GetForwardMsg(id int64) (*model.ForwardMessageDataResult, error)
获取合并转发消息 get_forward_msg
func (*ChannelApiMessageClient) GetGroupMsgHistory ¶
func (cli *ChannelApiMessageClient) GetGroupMsgHistory(message_seq int64, groupId int64) (*model.MessagesResult, error)
获取群消息历史记录 get_group_msg_history
func (*ChannelApiMessageClient) GetMsg ¶
func (cli *ChannelApiMessageClient) GetMsg(id int64) (*model.MessageDataResult, error)
获取消息 get_msg
func (*ChannelApiMessageClient) MarkMsgAsRead ¶
func (cli *ChannelApiMessageClient) MarkMsgAsRead(id int64) error
标记消息已读 mark_msg_as_read
func (*ChannelApiMessageClient) SendGroupForwardMsg ¶
func (cli *ChannelApiMessageClient) SendGroupForwardMsg(groupId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
发送合并转发 ( 群聊 ) send_group_forward_msg
func (*ChannelApiMessageClient) SendGroupMsg ¶
func (cli *ChannelApiMessageClient) SendGroupMsg(msg *model.GroupMsg) (*model.SendMessageResult, error)
发送群消息 send_group_msg msg 消息
func (*ChannelApiMessageClient) SendMsg ¶
func (cli *ChannelApiMessageClient) SendMsg(msg *model.MsgForSend) (*model.SendMessageResult, error)
发送消息
func (*ChannelApiMessageClient) SendPrivateForwardMsg ¶
func (cli *ChannelApiMessageClient) SendPrivateForwardMsg(userId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
发送合并转发 ( 好友 ) send_private_forward_msg
func (*ChannelApiMessageClient) SendPrivateMsg ¶
func (cli *ChannelApiMessageClient) SendPrivateMsg(msg *model.PrivateMsg) (*model.SendMessageResult, error)
发送私信 send_private_msg msg 消息
type GetGroupMsgHistoryRequest ¶
type GetGroupMsgHistoryRequest struct {
GroupId int64 `protobuf:"varint,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
MessageSeq int64 `protobuf:"varint,2,opt,name=message_seq,json=messageSeq,proto3" json:"message_seq,omitempty"`
// contains filtered or unexported fields
}
func (*GetGroupMsgHistoryRequest) Descriptor
deprecated
func (*GetGroupMsgHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGroupMsgHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetGroupMsgHistoryRequest) GetGroupId ¶
func (x *GetGroupMsgHistoryRequest) GetGroupId() int64
func (*GetGroupMsgHistoryRequest) GetMessageSeq ¶
func (x *GetGroupMsgHistoryRequest) GetMessageSeq() int64
func (*GetGroupMsgHistoryRequest) ProtoMessage ¶
func (*GetGroupMsgHistoryRequest) ProtoMessage()
func (*GetGroupMsgHistoryRequest) ProtoReflect ¶
func (x *GetGroupMsgHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetGroupMsgHistoryRequest) Reset ¶
func (x *GetGroupMsgHistoryRequest) Reset()
func (*GetGroupMsgHistoryRequest) String ¶
func (x *GetGroupMsgHistoryRequest) String() string
type OnebotApiMessageClient ¶
type OnebotApiMessageClient interface {
// 发送私信
// send_private_msg
// msg 消息
SendPrivateMsg(msg *model.PrivateMsg) (*model.SendMessageResult, error)
// 发送群消息
// send_group_msg
// msg 消息
SendGroupMsg(msg *model.GroupMsg) (*model.SendMessageResult, error)
// 发送消息
SendMsg(msg *model.MsgForSend) (*model.SendMessageResult, error)
// 获取消息
// get_msg
GetMsg(id int64) (*model.MessageDataResult, error)
// 撤回消息
// delete_msg
DeleteMsg(id int64) error
// 标记消息已读
// mark_msg_as_read
MarkMsgAsRead(id int64) error
// 获取合并转发消息
// get_forward_msg
GetForwardMsg(id int64) (*model.ForwardMessageDataResult, error)
// 发送合并转发 ( 群聊 )
// send_group_forward_msg
SendGroupForwardMsg(groupId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
// 发送合并转发 ( 好友 )
// send_private_forward_msg
SendPrivateForwardMsg(userId int64, messages []*model.MessageSegment) (*model.SendForwardMessageDataResult, error)
// 获取群消息历史记录
// get_group_msg_history
GetGroupMsgHistory(message_seq, groupId int64) (*model.MessagesResult, error)
}
func NewChannelApiMessageClient ¶
func NewChannelApiMessageClient(channel channel.ApiChannel, conf *config.OnebotApiConfig) (OnebotApiMessageClient, error)
type OnebotApiMessageGRPCServiceClient ¶
type OnebotApiMessageGRPCServiceClient interface {
// 发送私信
// send_private_msg
// msg 消息
SendPrivateMsg(ctx context.Context, in *model.PrivateMsgGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
// 发送群消息
// send_group_msg
// msg 消息
SendGroupMsg(ctx context.Context, in *model.GroupMsgGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
// 发送消息
SendMsg(ctx context.Context, in *model.MsgForSendGRPC, opts ...grpc.CallOption) (*model.SendMessageResultGRPC, error)
// 获取消息
// get_msg
GetMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*model.MessageDataResultGRPC, error)
// 撤回消息
// delete_msg
DeleteMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
// 标记消息已读
// mark_msg_as_read
MarkMsgAsRead(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*emptypb.Empty, error)
// 获取合并转发消息
// get_forward_msg
GetForwardMsg(ctx context.Context, in *wrapperspb.Int64Value, opts ...grpc.CallOption) (*model.ForwardMessageDataResultGRPC, error)
// 发送合并转发 ( 群聊 )
// send_group_forward_msg
SendGroupForwardMsg(ctx context.Context, in *SendGroupForwardMsgRequest, opts ...grpc.CallOption) (*model.SendForwardMessageDataResultGRPC, error)
// 发送合并转发 ( 好友 )
// send_private_forward_msg
SendPrivateForwardMsg(ctx context.Context, in *SendPrivateForwardMsgGRPC, opts ...grpc.CallOption) (*model.SendForwardMessageDataResultGRPC, error)
// 获取群消息历史记录
// get_group_msg_history
GetGroupMsgHistory(ctx context.Context, in *GetGroupMsgHistoryRequest, opts ...grpc.CallOption) (*model.MessagesResultGRPC, error)
}
OnebotApiMessageGRPCServiceClient is the client API for OnebotApiMessageGRPCService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOnebotApiMessageGRPCServiceClient ¶
func NewOnebotApiMessageGRPCServiceClient(cc grpc.ClientConnInterface) OnebotApiMessageGRPCServiceClient
type OnebotApiMessageGRPCServiceServer ¶
type OnebotApiMessageGRPCServiceServer interface {
// 发送私信
// send_private_msg
// msg 消息
SendPrivateMsg(context.Context, *model.PrivateMsgGRPC) (*model.SendMessageResultGRPC, error)
// 发送群消息
// send_group_msg
// msg 消息
SendGroupMsg(context.Context, *model.GroupMsgGRPC) (*model.SendMessageResultGRPC, error)
// 发送消息
SendMsg(context.Context, *model.MsgForSendGRPC) (*model.SendMessageResultGRPC, error)
// 获取消息
// get_msg
GetMsg(context.Context, *wrapperspb.Int64Value) (*model.MessageDataResultGRPC, error)
// 撤回消息
// delete_msg
DeleteMsg(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
// 标记消息已读
// mark_msg_as_read
MarkMsgAsRead(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
// 获取合并转发消息
// get_forward_msg
GetForwardMsg(context.Context, *wrapperspb.Int64Value) (*model.ForwardMessageDataResultGRPC, error)
// 发送合并转发 ( 群聊 )
// send_group_forward_msg
SendGroupForwardMsg(context.Context, *SendGroupForwardMsgRequest) (*model.SendForwardMessageDataResultGRPC, error)
// 发送合并转发 ( 好友 )
// send_private_forward_msg
SendPrivateForwardMsg(context.Context, *SendPrivateForwardMsgGRPC) (*model.SendForwardMessageDataResultGRPC, error)
// 获取群消息历史记录
// get_group_msg_history
GetGroupMsgHistory(context.Context, *GetGroupMsgHistoryRequest) (*model.MessagesResultGRPC, error)
}
OnebotApiMessageGRPCServiceServer is the server API for OnebotApiMessageGRPCService service.
type SendGroupForwardMsgRequest ¶
type SendGroupForwardMsgRequest struct {
GroupId int64 `protobuf:"varint,1,opt,name=groupId,proto3" json:"groupId,omitempty"`
Messages []*model.MessageSegmentGRPC `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
// contains filtered or unexported fields
}
func (*SendGroupForwardMsgRequest) Descriptor
deprecated
func (*SendGroupForwardMsgRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendGroupForwardMsgRequest.ProtoReflect.Descriptor instead.
func (*SendGroupForwardMsgRequest) GetGroupId ¶
func (x *SendGroupForwardMsgRequest) GetGroupId() int64
func (*SendGroupForwardMsgRequest) GetMessages ¶
func (x *SendGroupForwardMsgRequest) GetMessages() []*model.MessageSegmentGRPC
func (*SendGroupForwardMsgRequest) ProtoMessage ¶
func (*SendGroupForwardMsgRequest) ProtoMessage()
func (*SendGroupForwardMsgRequest) ProtoReflect ¶
func (x *SendGroupForwardMsgRequest) ProtoReflect() protoreflect.Message
func (*SendGroupForwardMsgRequest) Reset ¶
func (x *SendGroupForwardMsgRequest) Reset()
func (*SendGroupForwardMsgRequest) String ¶
func (x *SendGroupForwardMsgRequest) String() string
type SendPrivateForwardMsgGRPC ¶
type SendPrivateForwardMsgGRPC struct {
UserId int64 `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"`
Messages []*model.MessageSegmentGRPC `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
// contains filtered or unexported fields
}
func (*SendPrivateForwardMsgGRPC) Descriptor
deprecated
func (*SendPrivateForwardMsgGRPC) Descriptor() ([]byte, []int)
Deprecated: Use SendPrivateForwardMsgGRPC.ProtoReflect.Descriptor instead.
func (*SendPrivateForwardMsgGRPC) GetMessages ¶
func (x *SendPrivateForwardMsgGRPC) GetMessages() []*model.MessageSegmentGRPC
func (*SendPrivateForwardMsgGRPC) GetUserId ¶
func (x *SendPrivateForwardMsgGRPC) GetUserId() int64
func (*SendPrivateForwardMsgGRPC) ProtoMessage ¶
func (*SendPrivateForwardMsgGRPC) ProtoMessage()
func (*SendPrivateForwardMsgGRPC) ProtoReflect ¶
func (x *SendPrivateForwardMsgGRPC) ProtoReflect() protoreflect.Message
func (*SendPrivateForwardMsgGRPC) Reset ¶
func (x *SendPrivateForwardMsgGRPC) Reset()
func (*SendPrivateForwardMsgGRPC) String ¶
func (x *SendPrivateForwardMsgGRPC) String() string
type UnimplementedOnebotApiMessageGRPCServiceServer ¶
type UnimplementedOnebotApiMessageGRPCServiceServer struct {
}
UnimplementedOnebotApiMessageGRPCServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedOnebotApiMessageGRPCServiceServer) DeleteMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) DeleteMsg(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetForwardMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetForwardMsg(context.Context, *wrapperspb.Int64Value) (*model.ForwardMessageDataResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetGroupMsgHistory ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetGroupMsgHistory(context.Context, *GetGroupMsgHistoryRequest) (*model.MessagesResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) GetMsg(context.Context, *wrapperspb.Int64Value) (*model.MessageDataResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) MarkMsgAsRead ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) MarkMsgAsRead(context.Context, *wrapperspb.Int64Value) (*emptypb.Empty, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupForwardMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupForwardMsg(context.Context, *SendGroupForwardMsgRequest) (*model.SendForwardMessageDataResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendGroupMsg(context.Context, *model.GroupMsgGRPC) (*model.SendMessageResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendMsg(context.Context, *model.MsgForSendGRPC) (*model.SendMessageResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateForwardMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateForwardMsg(context.Context, *SendPrivateForwardMsgGRPC) (*model.SendForwardMessageDataResultGRPC, error)
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateMsg ¶
func (*UnimplementedOnebotApiMessageGRPCServiceServer) SendPrivateMsg(context.Context, *model.PrivateMsgGRPC) (*model.SendMessageResultGRPC, error)