internalapi

package
v0.0.0-...-7710cd9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 27, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CounterService_CreateDialogCounters_FullMethodName       = "/counter.internalapi.CounterService/CreateDialogCounters"
	CounterService_IncreaseDialogCounters_FullMethodName     = "/counter.internalapi.CounterService/IncreaseDialogCounters"
	CounterService_FlushDialogCountersForUser_FullMethodName = "/counter.internalapi.CounterService/FlushDialogCountersForUser"
	CounterService_GetDialogCounterForUser_FullMethodName    = "/counter.internalapi.CounterService/GetDialogCounterForUser"
)

Variables

View Source 
var CounterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "counter.internalapi.CounterService",
	HandlerType: (*CounterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDialogCounters",
			Handler:    _CounterService_CreateDialogCounters_Handler,
		},
		{
			MethodName: "IncreaseDialogCounters",
			Handler:    _CounterService_IncreaseDialogCounters_Handler,
		},
		{
			MethodName: "FlushDialogCountersForUser",
			Handler:    _CounterService_FlushDialogCountersForUser_Handler,
		},
		{
			MethodName: "GetDialogCounterForUser",
			Handler:    _CounterService_GetDialogCounterForUser_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internalapi/counter_service.proto",
}

CounterService_ServiceDesc is the grpc.ServiceDesc for CounterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_internalapi_counter_service_proto protoreflect.FileDescriptor

Functions

func RegisterCounterServiceServer 

func RegisterCounterServiceServer(s grpc.ServiceRegistrar, srv CounterServiceServer)

Types

type CounterServiceClient 

type CounterServiceClient interface {
	CreateDialogCounters(ctx context.Context, in *CreateDialogCountersRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	IncreaseDialogCounters(ctx context.Context, in *IncreaseDialogCountersRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	FlushDialogCountersForUser(ctx context.Context, in *FlushDialogCountersForUserRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetDialogCounterForUser(ctx context.Context, in *GetDialogCounterForUserRequest, opts ...grpc.CallOption) (*GetDialogCounterForUserResponse, error)
}

CounterServiceClient is the client API for CounterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCounterServiceClient 

func NewCounterServiceClient(cc grpc.ClientConnInterface) CounterServiceClient

type CounterServiceServer 

type CounterServiceServer interface {
	CreateDialogCounters(context.Context, *CreateDialogCountersRequest) (*emptypb.Empty, error)
	IncreaseDialogCounters(context.Context, *IncreaseDialogCountersRequest) (*emptypb.Empty, error)
	FlushDialogCountersForUser(context.Context, *FlushDialogCountersForUserRequest) (*emptypb.Empty, error)
	GetDialogCounterForUser(context.Context, *GetDialogCounterForUserRequest) (*GetDialogCounterForUserResponse, error)
	// contains filtered or unexported methods
}

CounterServiceServer is the server API for CounterService service. All implementations must embed UnimplementedCounterServiceServer for forward compatibility

type CreateDialogCountersRequest 

type CreateDialogCountersRequest struct {
	DialogId     string   `protobuf:"bytes,1,opt,name=dialog_id,json=dialogId,proto3" json:"dialog_id,omitempty"`
	Participants []string `protobuf:"bytes,2,rep,name=participants,proto3" json:"participants,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDialogCountersRequest) Descriptor deprecated 

func (*CreateDialogCountersRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateDialogCountersRequest.ProtoReflect.Descriptor instead.

func (*CreateDialogCountersRequest) GetDialogId 

func (x *CreateDialogCountersRequest) GetDialogId() string

func (*CreateDialogCountersRequest) GetParticipants 

func (x *CreateDialogCountersRequest) GetParticipants() []string

func (*CreateDialogCountersRequest) ProtoMessage 

func (*CreateDialogCountersRequest) ProtoMessage()

func (*CreateDialogCountersRequest) ProtoReflect 

func (x *CreateDialogCountersRequest) ProtoReflect() protoreflect.Message

func (*CreateDialogCountersRequest) Reset 

func (x *CreateDialogCountersRequest) Reset()

func (*CreateDialogCountersRequest) String 

func (x *CreateDialogCountersRequest) String() string

type FlushDialogCountersForUserRequest 

type FlushDialogCountersForUserRequest struct {
	DialogId string `protobuf:"bytes,1,opt,name=dialog_id,json=dialogId,proto3" json:"dialog_id,omitempty"`
	UserId   string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushDialogCountersForUserRequest) Descriptor deprecated 

func (*FlushDialogCountersForUserRequest) Descriptor() ([]byte, []int)

Deprecated: Use FlushDialogCountersForUserRequest.ProtoReflect.Descriptor instead.

func (*FlushDialogCountersForUserRequest) GetDialogId 

func (x *FlushDialogCountersForUserRequest) GetDialogId() string

func (*FlushDialogCountersForUserRequest) GetUserId 

func (x *FlushDialogCountersForUserRequest) GetUserId() string

func (*FlushDialogCountersForUserRequest) ProtoMessage 

func (*FlushDialogCountersForUserRequest) ProtoMessage()

func (*FlushDialogCountersForUserRequest) ProtoReflect 

func (x *FlushDialogCountersForUserRequest) ProtoReflect() protoreflect.Message

func (*FlushDialogCountersForUserRequest) Reset 

func (x *FlushDialogCountersForUserRequest) Reset()

func (*FlushDialogCountersForUserRequest) String 

func (x *FlushDialogCountersForUserRequest) String() string

type GetDialogCounterForUserRequest 

type GetDialogCounterForUserRequest struct {
	DialogId string `protobuf:"bytes,1,opt,name=dialog_id,json=dialogId,proto3" json:"dialog_id,omitempty"`
	UserId   string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDialogCounterForUserRequest) Descriptor deprecated 

func (*GetDialogCounterForUserRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDialogCounterForUserRequest.ProtoReflect.Descriptor instead.

func (*GetDialogCounterForUserRequest) GetDialogId 

func (x *GetDialogCounterForUserRequest) GetDialogId() string

func (*GetDialogCounterForUserRequest) GetUserId 

func (x *GetDialogCounterForUserRequest) GetUserId() string

func (*GetDialogCounterForUserRequest) ProtoMessage 

func (*GetDialogCounterForUserRequest) ProtoMessage()

func (*GetDialogCounterForUserRequest) ProtoReflect 

func (x *GetDialogCounterForUserRequest) ProtoReflect() protoreflect.Message

func (*GetDialogCounterForUserRequest) Reset 

func (x *GetDialogCounterForUserRequest) Reset()

func (*GetDialogCounterForUserRequest) String 

func (x *GetDialogCounterForUserRequest) String() string

type GetDialogCounterForUserResponse 

type GetDialogCounterForUserResponse struct {
	Counter int64 `protobuf:"varint,1,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDialogCounterForUserResponse) Descriptor deprecated 

func (*GetDialogCounterForUserResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDialogCounterForUserResponse.ProtoReflect.Descriptor instead.

func (*GetDialogCounterForUserResponse) GetCounter 

func (x *GetDialogCounterForUserResponse) GetCounter() int64

func (*GetDialogCounterForUserResponse) ProtoMessage 

func (*GetDialogCounterForUserResponse) ProtoMessage()

func (*GetDialogCounterForUserResponse) ProtoReflect 

func (x *GetDialogCounterForUserResponse) ProtoReflect() protoreflect.Message

func (*GetDialogCounterForUserResponse) Reset 

func (x *GetDialogCounterForUserResponse) Reset()

func (*GetDialogCounterForUserResponse) String 

func (x *GetDialogCounterForUserResponse) String() string

type IncreaseDialogCountersRequest 

type IncreaseDialogCountersRequest struct {
	DialogId    string   `protobuf:"bytes,1,opt,name=dialog_id,json=dialogId,proto3" json:"dialog_id,omitempty"`
	SenderId    string   `protobuf:"bytes,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	FollowersId []string `protobuf:"bytes,3,rep,name=followers_id,json=followersId,proto3" json:"followers_id,omitempty"`
	// contains filtered or unexported fields
}

func (*IncreaseDialogCountersRequest) Descriptor deprecated 

func (*IncreaseDialogCountersRequest) Descriptor() ([]byte, []int)

Deprecated: Use IncreaseDialogCountersRequest.ProtoReflect.Descriptor instead.

func (*IncreaseDialogCountersRequest) GetDialogId 

func (x *IncreaseDialogCountersRequest) GetDialogId() string

func (*IncreaseDialogCountersRequest) GetFollowersId 

func (x *IncreaseDialogCountersRequest) GetFollowersId() []string

func (*IncreaseDialogCountersRequest) GetSenderId 

func (x *IncreaseDialogCountersRequest) GetSenderId() string

func (*IncreaseDialogCountersRequest) ProtoMessage 

func (*IncreaseDialogCountersRequest) ProtoMessage()

func (*IncreaseDialogCountersRequest) ProtoReflect 

func (x *IncreaseDialogCountersRequest) ProtoReflect() protoreflect.Message

func (*IncreaseDialogCountersRequest) Reset 

func (x *IncreaseDialogCountersRequest) Reset()

func (*IncreaseDialogCountersRequest) String 

func (x *IncreaseDialogCountersRequest) String() string

type UnimplementedCounterServiceServer 

type UnimplementedCounterServiceServer struct {
}

UnimplementedCounterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCounterServiceServer) CreateDialogCounters 

func (UnimplementedCounterServiceServer) CreateDialogCounters(context.Context, *CreateDialogCountersRequest) (*emptypb.Empty, error)

func (UnimplementedCounterServiceServer) FlushDialogCountersForUser 

func (UnimplementedCounterServiceServer) FlushDialogCountersForUser(context.Context, *FlushDialogCountersForUserRequest) (*emptypb.Empty, error)

func (UnimplementedCounterServiceServer) GetDialogCounterForUser 

func (UnimplementedCounterServiceServer) GetDialogCounterForUser(context.Context, *GetDialogCounterForUserRequest) (*GetDialogCounterForUserResponse, error)

func (UnimplementedCounterServiceServer) IncreaseDialogCounters 

func (UnimplementedCounterServiceServer) IncreaseDialogCounters(context.Context, *IncreaseDialogCountersRequest) (*emptypb.Empty, error)

type UnsafeCounterServiceServer 

type UnsafeCounterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCounterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CounterServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.