messageCenter/rpc/messagecenter/messagecenter/messagecenter.go

// Code generated by goctl. DO NOT EDIT!
// Source: messageCenter.proto

package messagecenter

import (
	"context"

	"github.com/zeromicro/go-zero/zrpc"
	"google.golang.org/grpc"
)

type (
	MessageCenter interface {
		//  查询数量
		Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error)
		//  获取消息
		GetLast(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetResp, error)
		//  用户列表查询
		UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error)
		//  聊天内容查询
		FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error)
	}

	defaultMessageCenter struct {
		cli zrpc.Client
	}
)

func NewMessageCenter(cli zrpc.Client) MessageCenter {
	return &defaultMessageCenter{
		cli: cli,
	}
}

//  查询数量
func (m *defaultMessageCenter) Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.Count(ctx, in, opts...)
}

//  获取消息
func (m *defaultMessageCenter) GetLast(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.GetLast(ctx, in, opts...)
}

//  用户列表查询
func (m *defaultMessageCenter) UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.UserList(ctx, in, opts...)
}

//  聊天内容查询
func (m *defaultMessageCenter) FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error) {
	client := NewMessageCenterClient(m.cli.Conn())
	return client.FindMessage(ctx, in, opts...)
}