Versions in this module Expand all Collapse all v0 v0.2.1 Oct 30, 2019 Changes in this version + type Error interface + Error func() string + ErrorCode func() int + type ID string + func NewID() ID + type Notifier struct + func NotifierFromContext(ctx context.Context) (*Notifier, bool) + func (n *Notifier) Closed() <-chan interface{} + func (n *Notifier) CreateSubscription() *Subscription + func (n *Notifier) Notify(id ID, data interface{}) error + type RpcApi struct + Namespace string + Service interface{} + Version string + type Server struct + func NewServer(cors []string, addr string) *Server + func (srv *Server) ListenAndServe() + func (srv *Server) RegisterApis(apis []RpcApi) + type Subscription struct + ID ID + func (s *Subscription) Err() <-chan error