api_notification

Documentation

Index

• type Server
  • func New(notificationEngine *engines.NotificationEngine) *Server
  • func (s *Server) Watch(ctx context.Context, req *connect.Request[emptypb.Empty], ...) error

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func New

func New(notificationEngine *engines.NotificationEngine) *Server

func (*Server) Watch

func (s *Server) Watch(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[notificationv1.WatchResponse],
) error