Method Subscribe

notice/server.go:47–50

Subscribe subscribe a Notifer.

(c context.Context, req *meta.SubscribeRequest)

// Subscribe subscribe a Notifer.
func (n *Notifer) Subscribe(c context.Context, req *meta.SubscribeRequest) (*meta.SubscribeResponse, error) {
	n.broker.Subscribe(req.ID, req.Host)
	return &meta.SubscribeResponse{}, nil
}

// UnSubscribe unsubscribe a Notifer.
func (n *Notifer) UnSubscribe(_ context.Context, req *meta.UnSubscribeRequest) (*meta.UnSubscribeResponse, error) {