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

package bxsubscribe

import (
	"context"

	"jyBXSubscribe/rpc/type/bxsubscribe"

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

type (
	CityList               = bxsubscribe.CityList
	Items                  = bxsubscribe.Items
	Keys                   = bxsubscribe.Keys
	SomeInfo               = bxsubscribe.SomeInfo
	SomeInfoReq            = bxsubscribe.SomeInfoReq
	SomeInfoResp           = bxsubscribe.SomeInfoResp
	StatusResp             = bxsubscribe.StatusResp
	SubscribeData          = bxsubscribe.SubscribeData
	SubscribeInfo          = bxsubscribe.SubscribeInfo
	SubscribeInfosReq      = bxsubscribe.SubscribeInfosReq
	SubscribeInfosResp     = bxsubscribe.SubscribeInfosResp
	UpdateSubScribeInfoReq = bxsubscribe.UpdateSubScribeInfoReq

	Bxsubscribe interface {
		// 获取订阅推送列表
		GetSubList(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*SubscribeInfosResp, error)
		// 获取订阅推送相关信息
		GetSubSomeInfo(ctx context.Context, in *SomeInfoReq, opts ...grpc.CallOption) (*SomeInfoResp, error)
		// 修改订阅信息接口
		UpdateSubScribeInfo(ctx context.Context, in *UpdateSubScribeInfoReq, opts ...grpc.CallOption) (*StatusResp, error)
	}

	defaultBxsubscribe struct {
		cli zrpc.Client
	}
)

func NewBxsubscribe(cli zrpc.Client) Bxsubscribe {
	return &defaultBxsubscribe{
		cli: cli,
	}
}

// 获取订阅推送列表
func (m *defaultBxsubscribe) GetSubList(ctx context.Context, in *SubscribeInfosReq, opts ...grpc.CallOption) (*SubscribeInfosResp, error) {
	client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
	return client.GetSubList(ctx, in, opts...)
}

// 获取订阅推送相关信息
func (m *defaultBxsubscribe) GetSubSomeInfo(ctx context.Context, in *SomeInfoReq, opts ...grpc.CallOption) (*SomeInfoResp, error) {
	client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
	return client.GetSubSomeInfo(ctx, in, opts...)
}

// 修改订阅信息接口
func (m *defaultBxsubscribe) UpdateSubScribeInfo(ctx context.Context, in *UpdateSubScribeInfoReq, opts ...grpc.CallOption) (*StatusResp, error) {
	client := bxsubscribe.NewBxsubscribeClient(m.cli.Conn())
	return client.UpdateSubScribeInfo(ctx, in, opts...)
}