v1

type ErrorReason int32

type GetGroupHistoryMessageReply struct {
	EntrySet []*TimelineEntry `protobuf:"bytes,1,rep,name=entry_set,json=entrySet,proto3" json:"entry_set,omitempty"`
	// contains filtered or unexported fields
}

type GetGroupHistoryMessageRequest struct {
	Group    string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	LastRead int64  `protobuf:"varint,3,opt,name=last_read,json=lastRead,proto3" json:"last_read,omitempty"`
	Count    int32  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type GetSingleHistoryMessageReply struct {
	EntrySet []*TimelineEntry `protobuf:"bytes,1,rep,name=entry_set,json=entrySet,proto3" json:"entry_set,omitempty"`
	// contains filtered or unexported fields
}

type GetSingleHistoryMessageRequest struct {
	From     string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To       string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	LastRead int64  `protobuf:"varint,3,opt,name=last_read,json=lastRead,proto3" json:"last_read,omitempty"`
	Count    int32  `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type SendGroupReply struct {
	FailedMembers []string `protobuf:"bytes,1,rep,name=failed_members,json=failedMembers,proto3" json:"failed_members,omitempty"`
	// contains filtered or unexported fields
}

type SendGroupRequest struct {
	GroupName    string   `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	GroupMembers []string `protobuf:"bytes,2,rep,name=group_members,json=groupMembers,proto3" json:"group_members,omitempty"`
	Message      string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type SendMessageReply struct {
	Sequence int64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

type SendMessageRequest struct {
	From    string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To      string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type SyncMessageReply struct {

	// 最新的消息序号
	LatestSeq int64 `protobuf:"varint,1,opt,name=latest_seq,json=latestSeq,proto3" json:"latest_seq,omitempty"`
	// entry_set 中最后的序号值
	EntrySetLastSeq int64 `protobuf:"varint,2,opt,name=entry_set_last_seq,json=entrySetLastSeq,proto3" json:"entry_set_last_seq,omitempty"`
	// 如果拉取到的结果为空，说明同步完成
	EntrySet []*TimelineEntry `protobuf:"bytes,3,rep,name=entry_set,json=entrySet,proto3" json:"entry_set,omitempty"`
	// contains filtered or unexported fields
}

type SyncMessageRequest struct {
	Member   string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	LastRead int64  `protobuf:"varint,2,opt,name=last_read,json=lastRead,proto3" json:"last_read,omitempty"`
	Count    int32  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

type TimelineClient interface {
	// c2c 发送消息请求
	Send(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageReply, error)
	// c2g 发送消息请求
	SendGroup(ctx context.Context, in *SendGroupRequest, opts ...grpc.CallOption) (*SendGroupReply, error)
	// 同步消息请求
	GetSyncMessage(ctx context.Context, in *SyncMessageRequest, opts ...grpc.CallOption) (*SyncMessageReply, error)
	// 查询单聊历史消息请求
	GetSingleHistoryMessage(ctx context.Context, in *GetSingleHistoryMessageRequest, opts ...grpc.CallOption) (*GetSingleHistoryMessageReply, error)
	// 查询群历史消息请求
	GetGroupHistoryMessage(ctx context.Context, in *GetGroupHistoryMessageRequest, opts ...grpc.CallOption) (*GetGroupHistoryMessageReply, error)
}

type TimelineEntry struct {
	Sequence int64  `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	Message  string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type TimelineHTTPClient interface {
	GetGroupHistoryMessage(ctx context.Context, req *GetGroupHistoryMessageRequest, opts ...http.CallOption) (rsp *GetGroupHistoryMessageReply, err error)
	GetSingleHistoryMessage(ctx context.Context, req *GetSingleHistoryMessageRequest, opts ...http.CallOption) (rsp *GetSingleHistoryMessageReply, err error)
	GetSyncMessage(ctx context.Context, req *SyncMessageRequest, opts ...http.CallOption) (rsp *SyncMessageReply, err error)
	Send(ctx context.Context, req *SendMessageRequest, opts ...http.CallOption) (rsp *SendMessageReply, err error)
	SendGroup(ctx context.Context, req *SendGroupRequest, opts ...http.CallOption) (rsp *SendGroupReply, err error)
}

type TimelineHTTPClientImpl struct {
	// contains filtered or unexported fields
}

type TimelineHTTPServer interface {
	GetGroupHistoryMessage(context.Context, *GetGroupHistoryMessageRequest) (*GetGroupHistoryMessageReply, error)
	GetSingleHistoryMessage(context.Context, *GetSingleHistoryMessageRequest) (*GetSingleHistoryMessageReply, error)
	GetSyncMessage(context.Context, *SyncMessageRequest) (*SyncMessageReply, error)
	Send(context.Context, *SendMessageRequest) (*SendMessageReply, error)
	SendGroup(context.Context, *SendGroupRequest) (*SendGroupReply, error)
}

type TimelineServer interface {
	// c2c 发送消息请求
	Send(context.Context, *SendMessageRequest) (*SendMessageReply, error)
	// c2g 发送消息请求
	SendGroup(context.Context, *SendGroupRequest) (*SendGroupReply, error)
	// 同步消息请求
	GetSyncMessage(context.Context, *SyncMessageRequest) (*SyncMessageReply, error)
	// 查询单聊历史消息请求
	GetSingleHistoryMessage(context.Context, *GetSingleHistoryMessageRequest) (*GetSingleHistoryMessageReply, error)
	// 查询群历史消息请求
	GetGroupHistoryMessage(context.Context, *GetGroupHistoryMessageRequest) (*GetGroupHistoryMessageReply, error)
	// contains filtered or unexported methods
}

type UnimplementedTimelineServer struct {
}

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