v1grpc

package
v1.3.0-20230627200035-... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CentrifugoApi_Batch_FullMethodName                 = "/centrifugal.centrifugo.api.CentrifugoApi/Batch"
	CentrifugoApi_Publish_FullMethodName               = "/centrifugal.centrifugo.api.CentrifugoApi/Publish"
	CentrifugoApi_Broadcast_FullMethodName             = "/centrifugal.centrifugo.api.CentrifugoApi/Broadcast"
	CentrifugoApi_Subscribe_FullMethodName             = "/centrifugal.centrifugo.api.CentrifugoApi/Subscribe"
	CentrifugoApi_Unsubscribe_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/Unsubscribe"
	CentrifugoApi_Disconnect_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/Disconnect"
	CentrifugoApi_Presence_FullMethodName              = "/centrifugal.centrifugo.api.CentrifugoApi/Presence"
	CentrifugoApi_PresenceStats_FullMethodName         = "/centrifugal.centrifugo.api.CentrifugoApi/PresenceStats"
	CentrifugoApi_History_FullMethodName               = "/centrifugal.centrifugo.api.CentrifugoApi/History"
	CentrifugoApi_HistoryRemove_FullMethodName         = "/centrifugal.centrifugo.api.CentrifugoApi/HistoryRemove"
	CentrifugoApi_Info_FullMethodName                  = "/centrifugal.centrifugo.api.CentrifugoApi/Info"
	CentrifugoApi_RPC_FullMethodName                   = "/centrifugal.centrifugo.api.CentrifugoApi/RPC"
	CentrifugoApi_Refresh_FullMethodName               = "/centrifugal.centrifugo.api.CentrifugoApi/Refresh"
	CentrifugoApi_Channels_FullMethodName              = "/centrifugal.centrifugo.api.CentrifugoApi/Channels"
	CentrifugoApi_Connections_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/Connections"
	CentrifugoApi_UpdateUserStatus_FullMethodName      = "/centrifugal.centrifugo.api.CentrifugoApi/UpdateUserStatus"
	CentrifugoApi_GetUserStatus_FullMethodName         = "/centrifugal.centrifugo.api.CentrifugoApi/GetUserStatus"
	CentrifugoApi_DeleteUserStatus_FullMethodName      = "/centrifugal.centrifugo.api.CentrifugoApi/DeleteUserStatus"
	CentrifugoApi_BlockUser_FullMethodName             = "/centrifugal.centrifugo.api.CentrifugoApi/BlockUser"
	CentrifugoApi_UnblockUser_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/UnblockUser"
	CentrifugoApi_RevokeToken_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/RevokeToken"
	CentrifugoApi_InvalidateUserTokens_FullMethodName  = "/centrifugal.centrifugo.api.CentrifugoApi/InvalidateUserTokens"
	CentrifugoApi_DeviceRegister_FullMethodName        = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceRegister"
	CentrifugoApi_DeviceUpdate_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceUpdate"
	CentrifugoApi_DeviceRemove_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceRemove"
	CentrifugoApi_DeviceList_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceList"
	CentrifugoApi_PushUserChannelList_FullMethodName   = "/centrifugal.centrifugo.api.CentrifugoApi/PushUserChannelList"
	CentrifugoApi_PushUserChannelUpdate_FullMethodName = "/centrifugal.centrifugo.api.CentrifugoApi/PushUserChannelUpdate"
	CentrifugoApi_SendPushNotification_FullMethodName  = "/centrifugal.centrifugo.api.CentrifugoApi/SendPushNotification"
)

Variables

View Source 
var CentrifugoApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "centrifugal.centrifugo.api.CentrifugoApi",
	HandlerType: (*CentrifugoApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Batch",
			Handler:    _CentrifugoApi_Batch_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _CentrifugoApi_Publish_Handler,
		},
		{
			MethodName: "Broadcast",
			Handler:    _CentrifugoApi_Broadcast_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _CentrifugoApi_Subscribe_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _CentrifugoApi_Unsubscribe_Handler,
		},
		{
			MethodName: "Disconnect",
			Handler:    _CentrifugoApi_Disconnect_Handler,
		},
		{
			MethodName: "Presence",
			Handler:    _CentrifugoApi_Presence_Handler,
		},
		{
			MethodName: "PresenceStats",
			Handler:    _CentrifugoApi_PresenceStats_Handler,
		},
		{
			MethodName: "History",
			Handler:    _CentrifugoApi_History_Handler,
		},
		{
			MethodName: "HistoryRemove",
			Handler:    _CentrifugoApi_HistoryRemove_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _CentrifugoApi_Info_Handler,
		},
		{
			MethodName: "RPC",
			Handler:    _CentrifugoApi_RPC_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _CentrifugoApi_Refresh_Handler,
		},
		{
			MethodName: "Channels",
			Handler:    _CentrifugoApi_Channels_Handler,
		},
		{
			MethodName: "Connections",
			Handler:    _CentrifugoApi_Connections_Handler,
		},
		{
			MethodName: "UpdateUserStatus",
			Handler:    _CentrifugoApi_UpdateUserStatus_Handler,
		},
		{
			MethodName: "GetUserStatus",
			Handler:    _CentrifugoApi_GetUserStatus_Handler,
		},
		{
			MethodName: "DeleteUserStatus",
			Handler:    _CentrifugoApi_DeleteUserStatus_Handler,
		},
		{
			MethodName: "BlockUser",
			Handler:    _CentrifugoApi_BlockUser_Handler,
		},
		{
			MethodName: "UnblockUser",
			Handler:    _CentrifugoApi_UnblockUser_Handler,
		},
		{
			MethodName: "RevokeToken",
			Handler:    _CentrifugoApi_RevokeToken_Handler,
		},
		{
			MethodName: "InvalidateUserTokens",
			Handler:    _CentrifugoApi_InvalidateUserTokens_Handler,
		},
		{
			MethodName: "DeviceRegister",
			Handler:    _CentrifugoApi_DeviceRegister_Handler,
		},
		{
			MethodName: "DeviceUpdate",
			Handler:    _CentrifugoApi_DeviceUpdate_Handler,
		},
		{
			MethodName: "DeviceRemove",
			Handler:    _CentrifugoApi_DeviceRemove_Handler,
		},
		{
			MethodName: "DeviceList",
			Handler:    _CentrifugoApi_DeviceList_Handler,
		},
		{
			MethodName: "PushUserChannelList",
			Handler:    _CentrifugoApi_PushUserChannelList_Handler,
		},
		{
			MethodName: "PushUserChannelUpdate",
			Handler:    _CentrifugoApi_PushUserChannelUpdate_Handler,
		},
		{
			MethodName: "SendPushNotification",
			Handler:    _CentrifugoApi_SendPushNotification_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "centrifugo/api/v1/api.proto",
}

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

Functions

func RegisterCentrifugoApiServer 

func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

Types

type CentrifugoApiClient 

type CentrifugoApiClient interface {
	Batch(ctx context.Context, in *v1.BatchRequest, opts ...grpc.CallOption) (*v1.BatchResponse, error)
	Publish(ctx context.Context, in *v1.PublishRequest, opts ...grpc.CallOption) (*v1.PublishResponse, error)
	Broadcast(ctx context.Context, in *v1.BroadcastRequest, opts ...grpc.CallOption) (*v1.BroadcastResponse, error)
	Subscribe(ctx context.Context, in *v1.SubscribeRequest, opts ...grpc.CallOption) (*v1.SubscribeResponse, error)
	Unsubscribe(ctx context.Context, in *v1.UnsubscribeRequest, opts ...grpc.CallOption) (*v1.UnsubscribeResponse, error)
	Disconnect(ctx context.Context, in *v1.DisconnectRequest, opts ...grpc.CallOption) (*v1.DisconnectResponse, error)
	Presence(ctx context.Context, in *v1.PresenceRequest, opts ...grpc.CallOption) (*v1.PresenceResponse, error)
	PresenceStats(ctx context.Context, in *v1.PresenceStatsRequest, opts ...grpc.CallOption) (*v1.PresenceStatsResponse, error)
	History(ctx context.Context, in *v1.HistoryRequest, opts ...grpc.CallOption) (*v1.HistoryResponse, error)
	HistoryRemove(ctx context.Context, in *v1.HistoryRemoveRequest, opts ...grpc.CallOption) (*v1.HistoryRemoveResponse, error)
	Info(ctx context.Context, in *v1.InfoRequest, opts ...grpc.CallOption) (*v1.InfoResponse, error)
	RPC(ctx context.Context, in *v1.RPCRequest, opts ...grpc.CallOption) (*v1.RPCResponse, error)
	Refresh(ctx context.Context, in *v1.RefreshRequest, opts ...grpc.CallOption) (*v1.RefreshResponse, error)
	Channels(ctx context.Context, in *v1.ChannelsRequest, opts ...grpc.CallOption) (*v1.ChannelsResponse, error)
	Connections(ctx context.Context, in *v1.ConnectionsRequest, opts ...grpc.CallOption) (*v1.ConnectionsResponse, error)
	UpdateUserStatus(ctx context.Context, in *v1.UpdateUserStatusRequest, opts ...grpc.CallOption) (*v1.UpdateUserStatusResponse, error)
	GetUserStatus(ctx context.Context, in *v1.GetUserStatusRequest, opts ...grpc.CallOption) (*v1.GetUserStatusResponse, error)
	DeleteUserStatus(ctx context.Context, in *v1.DeleteUserStatusRequest, opts ...grpc.CallOption) (*v1.DeleteUserStatusResponse, error)
	BlockUser(ctx context.Context, in *v1.BlockUserRequest, opts ...grpc.CallOption) (*v1.BlockUserResponse, error)
	UnblockUser(ctx context.Context, in *v1.UnblockUserRequest, opts ...grpc.CallOption) (*v1.UnblockUserResponse, error)
	RevokeToken(ctx context.Context, in *v1.RevokeTokenRequest, opts ...grpc.CallOption) (*v1.RevokeTokenResponse, error)
	InvalidateUserTokens(ctx context.Context, in *v1.InvalidateUserTokensRequest, opts ...grpc.CallOption) (*v1.InvalidateUserTokensResponse, error)
	DeviceRegister(ctx context.Context, in *v1.DeviceRegisterRequest, opts ...grpc.CallOption) (*v1.DeviceRegisterResponse, error)
	DeviceUpdate(ctx context.Context, in *v1.DeviceUpdateRequest, opts ...grpc.CallOption) (*v1.DeviceUpdateResponse, error)
	DeviceRemove(ctx context.Context, in *v1.DeviceRemoveRequest, opts ...grpc.CallOption) (*v1.DeviceRemoveResponse, error)
	DeviceList(ctx context.Context, in *v1.DeviceListRequest, opts ...grpc.CallOption) (*v1.DeviceListResponse, error)
	PushUserChannelList(ctx context.Context, in *v1.PushUserChannelListRequest, opts ...grpc.CallOption) (*v1.PushUserChannelListResponse, error)
	PushUserChannelUpdate(ctx context.Context, in *v1.PushUserChannelUpdateRequest, opts ...grpc.CallOption) (*v1.PushUserChannelUpdateResponse, error)
	SendPushNotification(ctx context.Context, in *v1.SendPushNotificationRequest, opts ...grpc.CallOption) (*v1.SendPushNotificationResponse, error)
}

CentrifugoApiClient is the client API for CentrifugoApi 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 NewCentrifugoApiClient 

func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient

type CentrifugoApiServer 

type CentrifugoApiServer interface {
	Batch(context.Context, *v1.BatchRequest) (*v1.BatchResponse, error)
	Publish(context.Context, *v1.PublishRequest) (*v1.PublishResponse, error)
	Broadcast(context.Context, *v1.BroadcastRequest) (*v1.BroadcastResponse, error)
	Subscribe(context.Context, *v1.SubscribeRequest) (*v1.SubscribeResponse, error)
	Unsubscribe(context.Context, *v1.UnsubscribeRequest) (*v1.UnsubscribeResponse, error)
	Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)
	Presence(context.Context, *v1.PresenceRequest) (*v1.PresenceResponse, error)
	PresenceStats(context.Context, *v1.PresenceStatsRequest) (*v1.PresenceStatsResponse, error)
	History(context.Context, *v1.HistoryRequest) (*v1.HistoryResponse, error)
	HistoryRemove(context.Context, *v1.HistoryRemoveRequest) (*v1.HistoryRemoveResponse, error)
	Info(context.Context, *v1.InfoRequest) (*v1.InfoResponse, error)
	RPC(context.Context, *v1.RPCRequest) (*v1.RPCResponse, error)
	Refresh(context.Context, *v1.RefreshRequest) (*v1.RefreshResponse, error)
	Channels(context.Context, *v1.ChannelsRequest) (*v1.ChannelsResponse, error)
	Connections(context.Context, *v1.ConnectionsRequest) (*v1.ConnectionsResponse, error)
	UpdateUserStatus(context.Context, *v1.UpdateUserStatusRequest) (*v1.UpdateUserStatusResponse, error)
	GetUserStatus(context.Context, *v1.GetUserStatusRequest) (*v1.GetUserStatusResponse, error)
	DeleteUserStatus(context.Context, *v1.DeleteUserStatusRequest) (*v1.DeleteUserStatusResponse, error)
	BlockUser(context.Context, *v1.BlockUserRequest) (*v1.BlockUserResponse, error)
	UnblockUser(context.Context, *v1.UnblockUserRequest) (*v1.UnblockUserResponse, error)
	RevokeToken(context.Context, *v1.RevokeTokenRequest) (*v1.RevokeTokenResponse, error)
	InvalidateUserTokens(context.Context, *v1.InvalidateUserTokensRequest) (*v1.InvalidateUserTokensResponse, error)
	DeviceRegister(context.Context, *v1.DeviceRegisterRequest) (*v1.DeviceRegisterResponse, error)
	DeviceUpdate(context.Context, *v1.DeviceUpdateRequest) (*v1.DeviceUpdateResponse, error)
	DeviceRemove(context.Context, *v1.DeviceRemoveRequest) (*v1.DeviceRemoveResponse, error)
	DeviceList(context.Context, *v1.DeviceListRequest) (*v1.DeviceListResponse, error)
	PushUserChannelList(context.Context, *v1.PushUserChannelListRequest) (*v1.PushUserChannelListResponse, error)
	PushUserChannelUpdate(context.Context, *v1.PushUserChannelUpdateRequest) (*v1.PushUserChannelUpdateResponse, error)
	SendPushNotification(context.Context, *v1.SendPushNotificationRequest) (*v1.SendPushNotificationResponse, error)
}

CentrifugoApiServer is the server API for CentrifugoApi service. All implementations should embed UnimplementedCentrifugoApiServer for forward compatibility

type UnimplementedCentrifugoApiServer 

type UnimplementedCentrifugoApiServer struct {
}

UnimplementedCentrifugoApiServer should be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoApiServer) Batch 

func (UnimplementedCentrifugoApiServer) Batch(context.Context, *v1.BatchRequest) (*v1.BatchResponse, error)

func (UnimplementedCentrifugoApiServer) BlockUser 

func (UnimplementedCentrifugoApiServer) BlockUser(context.Context, *v1.BlockUserRequest) (*v1.BlockUserResponse, error)

func (UnimplementedCentrifugoApiServer) Broadcast 

func (UnimplementedCentrifugoApiServer) Broadcast(context.Context, *v1.BroadcastRequest) (*v1.BroadcastResponse, error)

func (UnimplementedCentrifugoApiServer) Channels 

func (UnimplementedCentrifugoApiServer) Channels(context.Context, *v1.ChannelsRequest) (*v1.ChannelsResponse, error)

func (UnimplementedCentrifugoApiServer) Connections 

func (UnimplementedCentrifugoApiServer) Connections(context.Context, *v1.ConnectionsRequest) (*v1.ConnectionsResponse, error)

func (UnimplementedCentrifugoApiServer) DeleteUserStatus 

func (UnimplementedCentrifugoApiServer) DeleteUserStatus(context.Context, *v1.DeleteUserStatusRequest) (*v1.DeleteUserStatusResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceList 

func (UnimplementedCentrifugoApiServer) DeviceList(context.Context, *v1.DeviceListRequest) (*v1.DeviceListResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceRegister 

func (UnimplementedCentrifugoApiServer) DeviceRegister(context.Context, *v1.DeviceRegisterRequest) (*v1.DeviceRegisterResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceRemove 

func (UnimplementedCentrifugoApiServer) DeviceRemove(context.Context, *v1.DeviceRemoveRequest) (*v1.DeviceRemoveResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceUpdate 

func (UnimplementedCentrifugoApiServer) DeviceUpdate(context.Context, *v1.DeviceUpdateRequest) (*v1.DeviceUpdateResponse, error)

func (UnimplementedCentrifugoApiServer) Disconnect 

func (UnimplementedCentrifugoApiServer) Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)

func (UnimplementedCentrifugoApiServer) GetUserStatus 

func (UnimplementedCentrifugoApiServer) GetUserStatus(context.Context, *v1.GetUserStatusRequest) (*v1.GetUserStatusResponse, error)

func (UnimplementedCentrifugoApiServer) History 

func (UnimplementedCentrifugoApiServer) History(context.Context, *v1.HistoryRequest) (*v1.HistoryResponse, error)

func (UnimplementedCentrifugoApiServer) HistoryRemove 

func (UnimplementedCentrifugoApiServer) HistoryRemove(context.Context, *v1.HistoryRemoveRequest) (*v1.HistoryRemoveResponse, error)

func (UnimplementedCentrifugoApiServer) Info 

func (UnimplementedCentrifugoApiServer) Info(context.Context, *v1.InfoRequest) (*v1.InfoResponse, error)

func (UnimplementedCentrifugoApiServer) InvalidateUserTokens 

func (UnimplementedCentrifugoApiServer) InvalidateUserTokens(context.Context, *v1.InvalidateUserTokensRequest) (*v1.InvalidateUserTokensResponse, error)

func (UnimplementedCentrifugoApiServer) Presence 

func (UnimplementedCentrifugoApiServer) Presence(context.Context, *v1.PresenceRequest) (*v1.PresenceResponse, error)

func (UnimplementedCentrifugoApiServer) PresenceStats 

func (UnimplementedCentrifugoApiServer) PresenceStats(context.Context, *v1.PresenceStatsRequest) (*v1.PresenceStatsResponse, error)

func (UnimplementedCentrifugoApiServer) Publish 

func (UnimplementedCentrifugoApiServer) Publish(context.Context, *v1.PublishRequest) (*v1.PublishResponse, error)

func (UnimplementedCentrifugoApiServer) PushUserChannelList 

func (UnimplementedCentrifugoApiServer) PushUserChannelList(context.Context, *v1.PushUserChannelListRequest) (*v1.PushUserChannelListResponse, error)

func (UnimplementedCentrifugoApiServer) PushUserChannelUpdate 

func (UnimplementedCentrifugoApiServer) PushUserChannelUpdate(context.Context, *v1.PushUserChannelUpdateRequest) (*v1.PushUserChannelUpdateResponse, error)

func (UnimplementedCentrifugoApiServer) RPC 

func (UnimplementedCentrifugoApiServer) RPC(context.Context, *v1.RPCRequest) (*v1.RPCResponse, error)

func (UnimplementedCentrifugoApiServer) Refresh 

func (UnimplementedCentrifugoApiServer) Refresh(context.Context, *v1.RefreshRequest) (*v1.RefreshResponse, error)

func (UnimplementedCentrifugoApiServer) RevokeToken 

func (UnimplementedCentrifugoApiServer) RevokeToken(context.Context, *v1.RevokeTokenRequest) (*v1.RevokeTokenResponse, error)

func (UnimplementedCentrifugoApiServer) SendPushNotification 

func (UnimplementedCentrifugoApiServer) SendPushNotification(context.Context, *v1.SendPushNotificationRequest) (*v1.SendPushNotificationResponse, error)

func (UnimplementedCentrifugoApiServer) Subscribe 

func (UnimplementedCentrifugoApiServer) Subscribe(context.Context, *v1.SubscribeRequest) (*v1.SubscribeResponse, error)

func (UnimplementedCentrifugoApiServer) UnblockUser 

func (UnimplementedCentrifugoApiServer) UnblockUser(context.Context, *v1.UnblockUserRequest) (*v1.UnblockUserResponse, error)

func (UnimplementedCentrifugoApiServer) Unsubscribe 

func (UnimplementedCentrifugoApiServer) Unsubscribe(context.Context, *v1.UnsubscribeRequest) (*v1.UnsubscribeResponse, error)

func (UnimplementedCentrifugoApiServer) UpdateUserStatus 

func (UnimplementedCentrifugoApiServer) UpdateUserStatus(context.Context, *v1.UpdateUserStatusRequest) (*v1.UpdateUserStatusResponse, error)

type UnsafeCentrifugoApiServer 

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

UnsafeCentrifugoApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CentrifugoApiServer 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.