core: Index | Files

package pubsub

import ""


Package Files


type Service Uses

type Service struct {
    // contains filtered or unexported fields

func NewService Uses

func NewService() *Service

func (*Service) Cleanup Uses

func (s *Service) Cleanup() error

Cleanup cleans up internal caches of subscribers. Visible for testing only.

func (*Service) Publish Uses

func (s *Service) Publish(name string, message interface{})

func (*Service) Subscribe Uses

func (s *Service) Subscribe(name string) *Subscriber

type Subscriber Uses

type Subscriber struct {
    // contains filtered or unexported fields

func (*Subscriber) Close Uses

func (s *Subscriber) Close() error

func (*Subscriber) IsClosed Uses

func (s *Subscriber) IsClosed() bool

func (*Subscriber) Wait Uses

func (s *Subscriber) Wait() <-chan interface{}

Package pubsub imports 6 packages (graph) and is imported by 7 packages. Updated 2019-04-05. Refresh now. Tools for package owners.