Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)
- type CentrifugoApiClient
- type CentrifugoApiServer
- type UnimplementedCentrifugoApiServer
- func (UnimplementedCentrifugoApiServer) Batch(context.Context, *v1.BatchRequest) (*v1.BatchResponse, error)
- func (UnimplementedCentrifugoApiServer) BlockUser(context.Context, *v1.BlockUserRequest) (*v1.BlockUserResponse, error)
- func (UnimplementedCentrifugoApiServer) Broadcast(context.Context, *v1.BroadcastRequest) (*v1.BroadcastResponse, error)
- func (UnimplementedCentrifugoApiServer) Channels(context.Context, *v1.ChannelsRequest) (*v1.ChannelsResponse, error)
- func (UnimplementedCentrifugoApiServer) Connections(context.Context, *v1.ConnectionsRequest) (*v1.ConnectionsResponse, error)
- func (UnimplementedCentrifugoApiServer) DeleteUserStatus(context.Context, *v1.DeleteUserStatusRequest) (*v1.DeleteUserStatusResponse, error)
- func (UnimplementedCentrifugoApiServer) DeviceList(context.Context, *v1.DeviceListRequest) (*v1.DeviceListResponse, error)
- func (UnimplementedCentrifugoApiServer) DeviceRegister(context.Context, *v1.DeviceRegisterRequest) (*v1.DeviceRegisterResponse, error)
- func (UnimplementedCentrifugoApiServer) DeviceRemove(context.Context, *v1.DeviceRemoveRequest) (*v1.DeviceRemoveResponse, error)
- func (UnimplementedCentrifugoApiServer) DeviceUpdate(context.Context, *v1.DeviceUpdateRequest) (*v1.DeviceUpdateResponse, error)
- func (UnimplementedCentrifugoApiServer) Disconnect(context.Context, *v1.DisconnectRequest) (*v1.DisconnectResponse, error)
- func (UnimplementedCentrifugoApiServer) GetUserStatus(context.Context, *v1.GetUserStatusRequest) (*v1.GetUserStatusResponse, error)
- func (UnimplementedCentrifugoApiServer) History(context.Context, *v1.HistoryRequest) (*v1.HistoryResponse, error)
- func (UnimplementedCentrifugoApiServer) HistoryRemove(context.Context, *v1.HistoryRemoveRequest) (*v1.HistoryRemoveResponse, error)
- func (UnimplementedCentrifugoApiServer) Info(context.Context, *v1.InfoRequest) (*v1.InfoResponse, error)
- func (UnimplementedCentrifugoApiServer) InvalidateUserTokens(context.Context, *v1.InvalidateUserTokensRequest) (*v1.InvalidateUserTokensResponse, error)
- func (UnimplementedCentrifugoApiServer) Presence(context.Context, *v1.PresenceRequest) (*v1.PresenceResponse, error)
- func (UnimplementedCentrifugoApiServer) PresenceStats(context.Context, *v1.PresenceStatsRequest) (*v1.PresenceStatsResponse, error)
- func (UnimplementedCentrifugoApiServer) Publish(context.Context, *v1.PublishRequest) (*v1.PublishResponse, error)
- func (UnimplementedCentrifugoApiServer) PushUserChannelList(context.Context, *v1.PushUserChannelListRequest) (*v1.PushUserChannelListResponse, error)
- func (UnimplementedCentrifugoApiServer) PushUserChannelUpdate(context.Context, *v1.PushUserChannelUpdateRequest) (*v1.PushUserChannelUpdateResponse, error)
- func (UnimplementedCentrifugoApiServer) RPC(context.Context, *v1.RPCRequest) (*v1.RPCResponse, error)
- func (UnimplementedCentrifugoApiServer) Refresh(context.Context, *v1.RefreshRequest) (*v1.RefreshResponse, error)
- func (UnimplementedCentrifugoApiServer) RevokeToken(context.Context, *v1.RevokeTokenRequest) (*v1.RevokeTokenResponse, error)
- func (UnimplementedCentrifugoApiServer) SendPushNotification(context.Context, *v1.SendPushNotificationRequest) (*v1.SendPushNotificationResponse, error)
- func (UnimplementedCentrifugoApiServer) Subscribe(context.Context, *v1.SubscribeRequest) (*v1.SubscribeResponse, error)
- func (UnimplementedCentrifugoApiServer) UnblockUser(context.Context, *v1.UnblockUserRequest) (*v1.UnblockUserResponse, error)
- func (UnimplementedCentrifugoApiServer) Unsubscribe(context.Context, *v1.UnsubscribeRequest) (*v1.UnsubscribeResponse, error)
- func (UnimplementedCentrifugoApiServer) UpdateUserStatus(context.Context, *v1.UpdateUserStatusRequest) (*v1.UpdateUserStatusResponse, error)
- type UnsafeCentrifugoApiServer
Constants ¶
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 ¶
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.golang.ir/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.