tailly_subscribers/proto/subscribe.pb.go
admin 38d91d9f10
All checks were successful
continuous-integration/drone/push Build is passing
v.0.1 Создан микросервис подписок/подписчиков
2025-08-26 09:50:45 +03:00

1305 lines
42 KiB
Go
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.6
// protoc v3.21.12
// source: subscribe.proto
package proto
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type GetCountRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetCountRequest) Reset() {
*x = GetCountRequest{}
mi := &file_subscribe_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetCountRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetCountRequest) ProtoMessage() {}
func (x *GetCountRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetCountRequest.ProtoReflect.Descriptor instead.
func (*GetCountRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{0}
}
func (x *GetCountRequest) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
// Ответ с количеством
type GetCountResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetCountResponse) Reset() {
*x = GetCountResponse{}
mi := &file_subscribe_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetCountResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetCountResponse) ProtoMessage() {}
func (x *GetCountResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetCountResponse.ProtoReflect.Descriptor instead.
func (*GetCountResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{1}
}
func (x *GetCountResponse) GetCount() int32 {
if x != nil {
return x.Count
}
return 0
}
// Запрос на подписку
type FollowRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
FollowerId int32 `protobuf:"varint,1,opt,name=follower_id,json=followerId,proto3" json:"follower_id,omitempty"` // ID пользователя, который подписывается
FollowingId int32 `protobuf:"varint,2,opt,name=following_id,json=followingId,proto3" json:"following_id,omitempty"` // ID пользователя, на которого подписываются
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FollowRequest) Reset() {
*x = FollowRequest{}
mi := &file_subscribe_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FollowRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FollowRequest) ProtoMessage() {}
func (x *FollowRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use FollowRequest.ProtoReflect.Descriptor instead.
func (*FollowRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{2}
}
func (x *FollowRequest) GetFollowerId() int32 {
if x != nil {
return x.FollowerId
}
return 0
}
func (x *FollowRequest) GetFollowingId() int32 {
if x != nil {
return x.FollowingId
}
return 0
}
// Ответ на подписку
type FollowResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // Успешность операции
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // Сообщение (например, об ошибке)
SubscriptionId int32 `protobuf:"varint,3,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"` // ID созданной подписки
NotificationId int32 `protobuf:"varint,4,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"` // ID созданного уведомления
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FollowResponse) Reset() {
*x = FollowResponse{}
mi := &file_subscribe_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FollowResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FollowResponse) ProtoMessage() {}
func (x *FollowResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use FollowResponse.ProtoReflect.Descriptor instead.
func (*FollowResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{3}
}
func (x *FollowResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *FollowResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *FollowResponse) GetSubscriptionId() int32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
func (x *FollowResponse) GetNotificationId() int32 {
if x != nil {
return x.NotificationId
}
return 0
}
// Запрос на отписку
type UnfollowRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
FollowerId int32 `protobuf:"varint,1,opt,name=follower_id,json=followerId,proto3" json:"follower_id,omitempty"`
FollowingId int32 `protobuf:"varint,2,opt,name=following_id,json=followingId,proto3" json:"following_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UnfollowRequest) Reset() {
*x = UnfollowRequest{}
mi := &file_subscribe_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UnfollowRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UnfollowRequest) ProtoMessage() {}
func (x *UnfollowRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UnfollowRequest.ProtoReflect.Descriptor instead.
func (*UnfollowRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{4}
}
func (x *UnfollowRequest) GetFollowerId() int32 {
if x != nil {
return x.FollowerId
}
return 0
}
func (x *UnfollowRequest) GetFollowingId() int32 {
if x != nil {
return x.FollowingId
}
return 0
}
// Ответ на отписку
type UnfollowResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UnfollowResponse) Reset() {
*x = UnfollowResponse{}
mi := &file_subscribe_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UnfollowResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UnfollowResponse) ProtoMessage() {}
func (x *UnfollowResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UnfollowResponse.ProtoReflect.Descriptor instead.
func (*UnfollowResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{5}
}
func (x *UnfollowResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *UnfollowResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
// Запрос на получение подписчиков
type GetFollowersRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // ID пользователя, чьих подписчиков запрашиваем
Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // Лимит (для пагинации)
Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // Смещение (для пагинации)
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowersRequest) Reset() {
*x = GetFollowersRequest{}
mi := &file_subscribe_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowersRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowersRequest) ProtoMessage() {}
func (x *GetFollowersRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowersRequest.ProtoReflect.Descriptor instead.
func (*GetFollowersRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{6}
}
func (x *GetFollowersRequest) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
func (x *GetFollowersRequest) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
func (x *GetFollowersRequest) GetOffset() int32 {
if x != nil {
return x.Offset
}
return 0
}
// Ответ с подписчиками
type GetFollowersResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Followers []*GetFollowersResponse_Follower `protobuf:"bytes,1,rep,name=followers,proto3" json:"followers,omitempty"` // Список подписчиков
TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // Общее количество подписчиков
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowersResponse) Reset() {
*x = GetFollowersResponse{}
mi := &file_subscribe_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowersResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowersResponse) ProtoMessage() {}
func (x *GetFollowersResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowersResponse.ProtoReflect.Descriptor instead.
func (*GetFollowersResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{7}
}
func (x *GetFollowersResponse) GetFollowers() []*GetFollowersResponse_Follower {
if x != nil {
return x.Followers
}
return nil
}
func (x *GetFollowersResponse) GetTotalCount() int32 {
if x != nil {
return x.TotalCount
}
return 0
}
// Запрос на получение подписок
type GetFollowingRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // ID пользователя, чьи подписки запрашиваем
Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowingRequest) Reset() {
*x = GetFollowingRequest{}
mi := &file_subscribe_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowingRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowingRequest) ProtoMessage() {}
func (x *GetFollowingRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowingRequest.ProtoReflect.Descriptor instead.
func (*GetFollowingRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{8}
}
func (x *GetFollowingRequest) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
func (x *GetFollowingRequest) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
func (x *GetFollowingRequest) GetOffset() int32 {
if x != nil {
return x.Offset
}
return 0
}
// Ответ с подписками
type GetFollowingResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Following []*GetFollowingResponse_Following `protobuf:"bytes,1,rep,name=following,proto3" json:"following,omitempty"` // Список подписок
TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // Общее количество подписок
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowingResponse) Reset() {
*x = GetFollowingResponse{}
mi := &file_subscribe_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowingResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowingResponse) ProtoMessage() {}
func (x *GetFollowingResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowingResponse.ProtoReflect.Descriptor instead.
func (*GetFollowingResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{9}
}
func (x *GetFollowingResponse) GetFollowing() []*GetFollowingResponse_Following {
if x != nil {
return x.Following
}
return nil
}
func (x *GetFollowingResponse) GetTotalCount() int32 {
if x != nil {
return x.TotalCount
}
return 0
}
// Запрос на проверку подписки
type IsFollowingRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
FollowerId int32 `protobuf:"varint,1,opt,name=follower_id,json=followerId,proto3" json:"follower_id,omitempty"`
FollowingId int32 `protobuf:"varint,2,opt,name=following_id,json=followingId,proto3" json:"following_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *IsFollowingRequest) Reset() {
*x = IsFollowingRequest{}
mi := &file_subscribe_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *IsFollowingRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*IsFollowingRequest) ProtoMessage() {}
func (x *IsFollowingRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use IsFollowingRequest.ProtoReflect.Descriptor instead.
func (*IsFollowingRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{10}
}
func (x *IsFollowingRequest) GetFollowerId() int32 {
if x != nil {
return x.FollowerId
}
return 0
}
func (x *IsFollowingRequest) GetFollowingId() int32 {
if x != nil {
return x.FollowingId
}
return 0
}
// Ответ на проверку подписки
type IsFollowingResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
IsFollowing bool `protobuf:"varint,1,opt,name=is_following,json=isFollowing,proto3" json:"is_following,omitempty"` // true - подписан, false - не подписан
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *IsFollowingResponse) Reset() {
*x = IsFollowingResponse{}
mi := &file_subscribe_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *IsFollowingResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*IsFollowingResponse) ProtoMessage() {}
func (x *IsFollowingResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use IsFollowingResponse.ProtoReflect.Descriptor instead.
func (*IsFollowingResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{11}
}
func (x *IsFollowingResponse) GetIsFollowing() bool {
if x != nil {
return x.IsFollowing
}
return false
}
// Запрос на получение уведомлений
type GetNotificationsRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // ID пользователя, чьи уведомления запрашиваем
UnreadOnly bool `protobuf:"varint,2,opt,name=unread_only,json=unreadOnly,proto3" json:"unread_only,omitempty"` // Только непрочитанные
Limit int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
Offset int32 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetNotificationsRequest) Reset() {
*x = GetNotificationsRequest{}
mi := &file_subscribe_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetNotificationsRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetNotificationsRequest) ProtoMessage() {}
func (x *GetNotificationsRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetNotificationsRequest.ProtoReflect.Descriptor instead.
func (*GetNotificationsRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{12}
}
func (x *GetNotificationsRequest) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
func (x *GetNotificationsRequest) GetUnreadOnly() bool {
if x != nil {
return x.UnreadOnly
}
return false
}
func (x *GetNotificationsRequest) GetLimit() int32 {
if x != nil {
return x.Limit
}
return 0
}
func (x *GetNotificationsRequest) GetOffset() int32 {
if x != nil {
return x.Offset
}
return 0
}
// Ответ с уведомлениями
type GetNotificationsResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Notifications []*GetNotificationsResponse_Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
TotalCount int32 `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
UnreadCount int32 `protobuf:"varint,3,opt,name=unread_count,json=unreadCount,proto3" json:"unread_count,omitempty"` // Количество непрочитанных уведомлений
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetNotificationsResponse) Reset() {
*x = GetNotificationsResponse{}
mi := &file_subscribe_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetNotificationsResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetNotificationsResponse) ProtoMessage() {}
func (x *GetNotificationsResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetNotificationsResponse.ProtoReflect.Descriptor instead.
func (*GetNotificationsResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{13}
}
func (x *GetNotificationsResponse) GetNotifications() []*GetNotificationsResponse_Notification {
if x != nil {
return x.Notifications
}
return nil
}
func (x *GetNotificationsResponse) GetTotalCount() int32 {
if x != nil {
return x.TotalCount
}
return 0
}
func (x *GetNotificationsResponse) GetUnreadCount() int32 {
if x != nil {
return x.UnreadCount
}
return 0
}
// Запрос на пометку уведомления как прочитанного
type MarkNotificationReadRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
NotificationId int32 `protobuf:"varint,1,opt,name=notification_id,json=notificationId,proto3" json:"notification_id,omitempty"`
UserId int32 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // Для проверки прав
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *MarkNotificationReadRequest) Reset() {
*x = MarkNotificationReadRequest{}
mi := &file_subscribe_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *MarkNotificationReadRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*MarkNotificationReadRequest) ProtoMessage() {}
func (x *MarkNotificationReadRequest) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use MarkNotificationReadRequest.ProtoReflect.Descriptor instead.
func (*MarkNotificationReadRequest) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{14}
}
func (x *MarkNotificationReadRequest) GetNotificationId() int32 {
if x != nil {
return x.NotificationId
}
return 0
}
func (x *MarkNotificationReadRequest) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
// Ответ на пометку уведомления
type MarkNotificationReadResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *MarkNotificationReadResponse) Reset() {
*x = MarkNotificationReadResponse{}
mi := &file_subscribe_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *MarkNotificationReadResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*MarkNotificationReadResponse) ProtoMessage() {}
func (x *MarkNotificationReadResponse) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use MarkNotificationReadResponse.ProtoReflect.Descriptor instead.
func (*MarkNotificationReadResponse) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{15}
}
func (x *MarkNotificationReadResponse) GetSuccess() bool {
if x != nil {
return x.Success
}
return false
}
func (x *MarkNotificationReadResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type GetFollowersResponse_Follower struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
Avatar string `protobuf:"bytes,3,opt,name=avatar,proto3" json:"avatar,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowersResponse_Follower) Reset() {
*x = GetFollowersResponse_Follower{}
mi := &file_subscribe_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowersResponse_Follower) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowersResponse_Follower) ProtoMessage() {}
func (x *GetFollowersResponse_Follower) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowersResponse_Follower.ProtoReflect.Descriptor instead.
func (*GetFollowersResponse_Follower) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{7, 0}
}
func (x *GetFollowersResponse_Follower) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
func (x *GetFollowersResponse_Follower) GetUsername() string {
if x != nil {
return x.Username
}
return ""
}
func (x *GetFollowersResponse_Follower) GetAvatar() string {
if x != nil {
return x.Avatar
}
return ""
}
type GetFollowingResponse_Following struct {
state protoimpl.MessageState `protogen:"open.v1"`
UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
Avatar string `protobuf:"bytes,3,opt,name=avatar,proto3" json:"avatar,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetFollowingResponse_Following) Reset() {
*x = GetFollowingResponse_Following{}
mi := &file_subscribe_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetFollowingResponse_Following) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetFollowingResponse_Following) ProtoMessage() {}
func (x *GetFollowingResponse_Following) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetFollowingResponse_Following.ProtoReflect.Descriptor instead.
func (*GetFollowingResponse_Following) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{9, 0}
}
func (x *GetFollowingResponse_Following) GetUserId() int32 {
if x != nil {
return x.UserId
}
return 0
}
func (x *GetFollowingResponse_Following) GetUsername() string {
if x != nil {
return x.Username
}
return ""
}
func (x *GetFollowingResponse_Following) GetAvatar() string {
if x != nil {
return x.Avatar
}
return ""
}
type GetNotificationsResponse_Notification struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
SubscriptionId int32 `protobuf:"varint,2,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
FollowerId int32 `protobuf:"varint,3,opt,name=follower_id,json=followerId,proto3" json:"follower_id,omitempty"`
FollowerUsername string `protobuf:"bytes,4,opt,name=follower_username,json=followerUsername,proto3" json:"follower_username,omitempty"`
FollowerAvatar string `protobuf:"bytes,5,opt,name=follower_avatar,json=followerAvatar,proto3" json:"follower_avatar,omitempty"`
IsRead bool `protobuf:"varint,6,opt,name=is_read,json=isRead,proto3" json:"is_read,omitempty"`
CreatedAt string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
ExpiresAt string `protobuf:"bytes,8,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetNotificationsResponse_Notification) Reset() {
*x = GetNotificationsResponse_Notification{}
mi := &file_subscribe_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetNotificationsResponse_Notification) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetNotificationsResponse_Notification) ProtoMessage() {}
func (x *GetNotificationsResponse_Notification) ProtoReflect() protoreflect.Message {
mi := &file_subscribe_proto_msgTypes[18]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetNotificationsResponse_Notification.ProtoReflect.Descriptor instead.
func (*GetNotificationsResponse_Notification) Descriptor() ([]byte, []int) {
return file_subscribe_proto_rawDescGZIP(), []int{13, 0}
}
func (x *GetNotificationsResponse_Notification) GetId() int32 {
if x != nil {
return x.Id
}
return 0
}
func (x *GetNotificationsResponse_Notification) GetSubscriptionId() int32 {
if x != nil {
return x.SubscriptionId
}
return 0
}
func (x *GetNotificationsResponse_Notification) GetFollowerId() int32 {
if x != nil {
return x.FollowerId
}
return 0
}
func (x *GetNotificationsResponse_Notification) GetFollowerUsername() string {
if x != nil {
return x.FollowerUsername
}
return ""
}
func (x *GetNotificationsResponse_Notification) GetFollowerAvatar() string {
if x != nil {
return x.FollowerAvatar
}
return ""
}
func (x *GetNotificationsResponse_Notification) GetIsRead() bool {
if x != nil {
return x.IsRead
}
return false
}
func (x *GetNotificationsResponse_Notification) GetCreatedAt() string {
if x != nil {
return x.CreatedAt
}
return ""
}
func (x *GetNotificationsResponse_Notification) GetExpiresAt() string {
if x != nil {
return x.ExpiresAt
}
return ""
}
var File_subscribe_proto protoreflect.FileDescriptor
const file_subscribe_proto_rawDesc = "" +
"\n" +
"\x0fsubscribe.proto\x12\x05proto\"*\n" +
"\x0fGetCountRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\"(\n" +
"\x10GetCountResponse\x12\x14\n" +
"\x05count\x18\x01 \x01(\x05R\x05count\"S\n" +
"\rFollowRequest\x12\x1f\n" +
"\vfollower_id\x18\x01 \x01(\x05R\n" +
"followerId\x12!\n" +
"\ffollowing_id\x18\x02 \x01(\x05R\vfollowingId\"\x96\x01\n" +
"\x0eFollowResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\x12'\n" +
"\x0fsubscription_id\x18\x03 \x01(\x05R\x0esubscriptionId\x12'\n" +
"\x0fnotification_id\x18\x04 \x01(\x05R\x0enotificationId\"U\n" +
"\x0fUnfollowRequest\x12\x1f\n" +
"\vfollower_id\x18\x01 \x01(\x05R\n" +
"followerId\x12!\n" +
"\ffollowing_id\x18\x02 \x01(\x05R\vfollowingId\"F\n" +
"\x10UnfollowResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"\\\n" +
"\x13GetFollowersRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\x12\x14\n" +
"\x05limit\x18\x02 \x01(\x05R\x05limit\x12\x16\n" +
"\x06offset\x18\x03 \x01(\x05R\x06offset\"\xd4\x01\n" +
"\x14GetFollowersResponse\x12B\n" +
"\tfollowers\x18\x01 \x03(\v2$.proto.GetFollowersResponse.FollowerR\tfollowers\x12\x1f\n" +
"\vtotal_count\x18\x02 \x01(\x05R\n" +
"totalCount\x1aW\n" +
"\bFollower\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\x12\x1a\n" +
"\busername\x18\x02 \x01(\tR\busername\x12\x16\n" +
"\x06avatar\x18\x03 \x01(\tR\x06avatar\"\\\n" +
"\x13GetFollowingRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\x12\x14\n" +
"\x05limit\x18\x02 \x01(\x05R\x05limit\x12\x16\n" +
"\x06offset\x18\x03 \x01(\x05R\x06offset\"\xd6\x01\n" +
"\x14GetFollowingResponse\x12C\n" +
"\tfollowing\x18\x01 \x03(\v2%.proto.GetFollowingResponse.FollowingR\tfollowing\x12\x1f\n" +
"\vtotal_count\x18\x02 \x01(\x05R\n" +
"totalCount\x1aX\n" +
"\tFollowing\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\x12\x1a\n" +
"\busername\x18\x02 \x01(\tR\busername\x12\x16\n" +
"\x06avatar\x18\x03 \x01(\tR\x06avatar\"X\n" +
"\x12IsFollowingRequest\x12\x1f\n" +
"\vfollower_id\x18\x01 \x01(\x05R\n" +
"followerId\x12!\n" +
"\ffollowing_id\x18\x02 \x01(\x05R\vfollowingId\"8\n" +
"\x13IsFollowingResponse\x12!\n" +
"\fis_following\x18\x01 \x01(\bR\visFollowing\"\x81\x01\n" +
"\x17GetNotificationsRequest\x12\x17\n" +
"\auser_id\x18\x01 \x01(\x05R\x06userId\x12\x1f\n" +
"\vunread_only\x18\x02 \x01(\bR\n" +
"unreadOnly\x12\x14\n" +
"\x05limit\x18\x03 \x01(\x05R\x05limit\x12\x16\n" +
"\x06offset\x18\x04 \x01(\x05R\x06offset\"\xca\x03\n" +
"\x18GetNotificationsResponse\x12R\n" +
"\rnotifications\x18\x01 \x03(\v2,.proto.GetNotificationsResponse.NotificationR\rnotifications\x12\x1f\n" +
"\vtotal_count\x18\x02 \x01(\x05R\n" +
"totalCount\x12!\n" +
"\funread_count\x18\x03 \x01(\x05R\vunreadCount\x1a\x95\x02\n" +
"\fNotification\x12\x0e\n" +
"\x02id\x18\x01 \x01(\x05R\x02id\x12'\n" +
"\x0fsubscription_id\x18\x02 \x01(\x05R\x0esubscriptionId\x12\x1f\n" +
"\vfollower_id\x18\x03 \x01(\x05R\n" +
"followerId\x12+\n" +
"\x11follower_username\x18\x04 \x01(\tR\x10followerUsername\x12'\n" +
"\x0ffollower_avatar\x18\x05 \x01(\tR\x0efollowerAvatar\x12\x17\n" +
"\ais_read\x18\x06 \x01(\bR\x06isRead\x12\x1d\n" +
"\n" +
"created_at\x18\a \x01(\tR\tcreatedAt\x12\x1d\n" +
"\n" +
"expires_at\x18\b \x01(\tR\texpiresAt\"_\n" +
"\x1bMarkNotificationReadRequest\x12'\n" +
"\x0fnotification_id\x18\x01 \x01(\x05R\x0enotificationId\x12\x17\n" +
"\auser_id\x18\x02 \x01(\x05R\x06userId\"R\n" +
"\x1cMarkNotificationReadResponse\x12\x18\n" +
"\asuccess\x18\x01 \x01(\bR\asuccess\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage2\xb6\x05\n" +
"\x10SubscribeService\x129\n" +
"\n" +
"FollowUser\x12\x14.proto.FollowRequest\x1a\x15.proto.FollowResponse\x12?\n" +
"\fUnfollowUser\x12\x16.proto.UnfollowRequest\x1a\x17.proto.UnfollowResponse\x12G\n" +
"\fGetFollowers\x12\x1a.proto.GetFollowersRequest\x1a\x1b.proto.GetFollowersResponse\x12G\n" +
"\fGetFollowing\x12\x1a.proto.GetFollowingRequest\x1a\x1b.proto.GetFollowingResponse\x12D\n" +
"\vIsFollowing\x12\x19.proto.IsFollowingRequest\x1a\x1a.proto.IsFollowingResponse\x12_\n" +
"\x1cGetSubscriptionNotifications\x12\x1e.proto.GetNotificationsRequest\x1a\x1f.proto.GetNotificationsResponse\x12a\n" +
"\x16MarkNotificationAsRead\x12\".proto.MarkNotificationReadRequest\x1a#.proto.MarkNotificationReadResponse\x12D\n" +
"\x11GetFollowersCount\x12\x16.proto.GetCountRequest\x1a\x17.proto.GetCountResponse\x12D\n" +
"\x11GetFollowingCount\x12\x16.proto.GetCountRequest\x1a\x17.proto.GetCountResponseB\tZ\a.;protob\x06proto3"
var (
file_subscribe_proto_rawDescOnce sync.Once
file_subscribe_proto_rawDescData []byte
)
func file_subscribe_proto_rawDescGZIP() []byte {
file_subscribe_proto_rawDescOnce.Do(func() {
file_subscribe_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_subscribe_proto_rawDesc), len(file_subscribe_proto_rawDesc)))
})
return file_subscribe_proto_rawDescData
}
var file_subscribe_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
var file_subscribe_proto_goTypes = []any{
(*GetCountRequest)(nil), // 0: proto.GetCountRequest
(*GetCountResponse)(nil), // 1: proto.GetCountResponse
(*FollowRequest)(nil), // 2: proto.FollowRequest
(*FollowResponse)(nil), // 3: proto.FollowResponse
(*UnfollowRequest)(nil), // 4: proto.UnfollowRequest
(*UnfollowResponse)(nil), // 5: proto.UnfollowResponse
(*GetFollowersRequest)(nil), // 6: proto.GetFollowersRequest
(*GetFollowersResponse)(nil), // 7: proto.GetFollowersResponse
(*GetFollowingRequest)(nil), // 8: proto.GetFollowingRequest
(*GetFollowingResponse)(nil), // 9: proto.GetFollowingResponse
(*IsFollowingRequest)(nil), // 10: proto.IsFollowingRequest
(*IsFollowingResponse)(nil), // 11: proto.IsFollowingResponse
(*GetNotificationsRequest)(nil), // 12: proto.GetNotificationsRequest
(*GetNotificationsResponse)(nil), // 13: proto.GetNotificationsResponse
(*MarkNotificationReadRequest)(nil), // 14: proto.MarkNotificationReadRequest
(*MarkNotificationReadResponse)(nil), // 15: proto.MarkNotificationReadResponse
(*GetFollowersResponse_Follower)(nil), // 16: proto.GetFollowersResponse.Follower
(*GetFollowingResponse_Following)(nil), // 17: proto.GetFollowingResponse.Following
(*GetNotificationsResponse_Notification)(nil), // 18: proto.GetNotificationsResponse.Notification
}
var file_subscribe_proto_depIdxs = []int32{
16, // 0: proto.GetFollowersResponse.followers:type_name -> proto.GetFollowersResponse.Follower
17, // 1: proto.GetFollowingResponse.following:type_name -> proto.GetFollowingResponse.Following
18, // 2: proto.GetNotificationsResponse.notifications:type_name -> proto.GetNotificationsResponse.Notification
2, // 3: proto.SubscribeService.FollowUser:input_type -> proto.FollowRequest
4, // 4: proto.SubscribeService.UnfollowUser:input_type -> proto.UnfollowRequest
6, // 5: proto.SubscribeService.GetFollowers:input_type -> proto.GetFollowersRequest
8, // 6: proto.SubscribeService.GetFollowing:input_type -> proto.GetFollowingRequest
10, // 7: proto.SubscribeService.IsFollowing:input_type -> proto.IsFollowingRequest
12, // 8: proto.SubscribeService.GetSubscriptionNotifications:input_type -> proto.GetNotificationsRequest
14, // 9: proto.SubscribeService.MarkNotificationAsRead:input_type -> proto.MarkNotificationReadRequest
0, // 10: proto.SubscribeService.GetFollowersCount:input_type -> proto.GetCountRequest
0, // 11: proto.SubscribeService.GetFollowingCount:input_type -> proto.GetCountRequest
3, // 12: proto.SubscribeService.FollowUser:output_type -> proto.FollowResponse
5, // 13: proto.SubscribeService.UnfollowUser:output_type -> proto.UnfollowResponse
7, // 14: proto.SubscribeService.GetFollowers:output_type -> proto.GetFollowersResponse
9, // 15: proto.SubscribeService.GetFollowing:output_type -> proto.GetFollowingResponse
11, // 16: proto.SubscribeService.IsFollowing:output_type -> proto.IsFollowingResponse
13, // 17: proto.SubscribeService.GetSubscriptionNotifications:output_type -> proto.GetNotificationsResponse
15, // 18: proto.SubscribeService.MarkNotificationAsRead:output_type -> proto.MarkNotificationReadResponse
1, // 19: proto.SubscribeService.GetFollowersCount:output_type -> proto.GetCountResponse
1, // 20: proto.SubscribeService.GetFollowingCount:output_type -> proto.GetCountResponse
12, // [12:21] is the sub-list for method output_type
3, // [3:12] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
}
func init() { file_subscribe_proto_init() }
func file_subscribe_proto_init() {
if File_subscribe_proto != nil {
return
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_subscribe_proto_rawDesc), len(file_subscribe_proto_rawDesc)),
NumEnums: 0,
NumMessages: 19,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_subscribe_proto_goTypes,
DependencyIndexes: file_subscribe_proto_depIdxs,
MessageInfos: file_subscribe_proto_msgTypes,
}.Build()
File_subscribe_proto = out.File
file_subscribe_proto_goTypes = nil
file_subscribe_proto_depIdxs = nil
}