|
|
@ -50,11 +50,6 @@ type conversationServer struct {
|
|
|
|
conversationNotificationSender *notification.ConversationNotificationSender
|
|
|
|
conversationNotificationSender *notification.ConversationNotificationSender
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func (c *conversationServer) GetConversationList(ctx context.Context, req *pbconversation.GetConversationListReq) (*pbconversation.GetConversationListResp, error) {
|
|
|
|
|
|
|
|
//TODO implement me
|
|
|
|
|
|
|
|
panic("implement me")
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
rdb, err := cache.NewRedis()
|
|
|
|
rdb, err := cache.NewRedis()
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|