Versions in this module Expand all Collapse all v0 v0.0.5 Nov 29, 2024 v0.0.1 Nov 26, 2024 Changes in this version + type PushServer struct + func NewPushServer(svc *push.Service, config config.Config) *PushServer + func (ps *PushServer) Channel(srv pushv1.PushService_ChannelServer) error + func (ps *PushServer) GetClientActiveDevices(ctx context.Context, req *pushv1.GetClientActiveDevicesRequest) (*pushv1.GetClientActiveDevicesResponse, error) + func (ps *PushServer) HandleReceivedPayload(ctx context.Context, srv pushv1.PushService_ChannelServer, ...) + func (ps *PushServer) SendEventToClientChannel(ctx context.Context, req *pushv1.SendEventToClientChannelRequest) (*pushv1.SendEventToClientChannelResponse, error) + func (ps *PushServer) SendEventToClientDeviceChannel(ctx context.Context, req *pushv1.SendEventToClientDeviceChannelRequest) (*pushv1.SendEventToClientDeviceChannelResponse, error) + func (ps *PushServer) SendEventToTopic(ctx context.Context, req *pushv1.SendEventToTopicRequest) (*pushv1.SendEventToTopicResponse, error) + func (ps *PushServer) SendEventToTopics(ctx context.Context, req *pushv1.SendEventToTopicsRequest) (*pushv1.SendEventToTopicsResponse, error) + type WebSocketServerWrapper struct + CancelFunc context.CancelFunc + Ctx context.Context + PushServer *PushServer + func (ws *WebSocketServerWrapper) Context() context.Context + func (ws *WebSocketServerWrapper) Recv() (*pushv1.ChannelRequest, error) + func (ws *WebSocketServerWrapper) RecvMsg(m any) error + func (ws *WebSocketServerWrapper) Send(resp *pushv1.ChannelResponse) error + func (ws *WebSocketServerWrapper) SendHeader(md metadata.MD) error + func (ws *WebSocketServerWrapper) SendMsg(m any) error + func (ws *WebSocketServerWrapper) SetHeader(md metadata.MD) error + func (ws *WebSocketServerWrapper) SetTrailer(md metadata.MD) + func (ws *WebSocketServerWrapper) WebSocketConnect(w http.ResponseWriter, r *http.Request)
Go to main page