subscribe

Documentation

Index

• Variables
• type Client
  • func (c *Client) Cancel()
  • func (c *Client) Quit() <-chan struct{}
  • func (c *Client) Updates() <-chan interface{}
• type Server
  • func NewServer() *Server
  • func (s *Server) SendUpdate(update interface{}) er.R
  • func (s *Server) Start() er.R
  • func (s *Server) Stop() er.R
  • func (s *Server) Subscribe() (*Client, er.R)
• type Subscription

Variables

var ErrServerShuttingDown = er.GenericErrorType.CodeWithDetail("ErrServerShuttingDown", "subscription server shutting down")

ErrServerShuttingDown is an error returned in case the server is in the process of shutting down.

Types

type Client

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

Client is used to get notified about updates the caller has subscribed to,

func (*Client) Cancel

func (c *Client) Cancel()

Cancel should be called in case the client no longer wants to subscribe for updates from the server.

func (*Client) Quit

func (c *Client) Quit() <-chan struct{}

Quit is a channel that will be closed in case the server decides to no longer deliver updates to this client.

func (*Client) Updates

func (c *Client) Updates() <-chan interface{}

Updates returns a read-only channel where the updates the client has subscribed to will be delivered.

type Server

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

Server is a struct that manages a set of subscriptions and their corresponding clients. Any update will be delivered to all active clients.

func NewServer

func NewServer() *Server

NewServer returns a new Server.

func (*Server) SendUpdate

func (s *Server) SendUpdate(update interface{}) er.R

SendUpdate is called to send the passed update to all currently active subscription clients.

func (*Server) Start

func (s *Server) Start() er.R

Start starts the Server, making it ready to accept subscriptions and updates.

func (*Server) Stop

func (s *Server) Stop() er.R

Stop stops the server.

func (*Server) Subscribe

func (s *Server) Subscribe() (*Client, er.R)

Subscribe returns a Client that will receive updates any time the Server is made aware of a new event.

type Subscription

type Subscription interface {
	// Updates returns a read-only channel where the updates the client has
	// subscribed to will be delivered.
	Updates() <-chan interface{}

	// Quit is a channel that will be closed in case the server decides to
	// no longer deliver updates to this client.
	Quit() <-chan struct{}

	// Cancel should be called in case the client no longer wants to
	// subscribe for updates from the server.
	Cancel()
}

Subscription is an interface implemented by subscriptions to a server providing updates.