blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-10 23:07:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: Replace GRPC with Dubbo-go in notification c

Browse Source
This commit is contained in:
sweep-ai[bot] 2023-10-14 08:12:09 +00:00 committed by GitHub
parent 51bea8f1f7
commit 74c114d030
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
pkg/rpcclient/notification/conversation.go Normal file
View File

@ -0,0 +1,26 @@
package notification
import (
"context"
"github.com/apache/dubbo-go"
pbconv "github.com/OpenIMSDK/protocol/conversation"
"github.com/openimsdk/open-im-server/v3/pkg/rpcclient"
)
type Conversation struct {
Client pbconv.ConversationClient
conn dubbo-go.ClientConnInterface
discov discoveryregistry.SvcDiscoveryRegistry
}
func (c *Conversation) SendMessage(ctx context.Context, req *pbconv.SendMessageReq) (*pbconv.SendMessageResp, error) {
return c.Client.SendMessage(ctx, req)
}
func (c *Conversation) GetConversation(ctx context.Context, req *pbconv.GetConversationReq) (*pbconv.GetConversationResp, error) {
return c.Client.GetConversation(ctx, req)
}
func (c *Conversation) DeleteConversation(ctx context.Context, req *pbconv.DeleteConversationReq) (*pbconv.DeleteConversationResp, error) {
return c.Client.DeleteConversation(ctx, req)
}