buffered

Documentation

Overview

package buffered implements an event dispatcher with buffering semantics

Index

• type Dispatcher
  • func New() *Dispatcher
  • func (r *Dispatcher) Chan() <-chan *installpb.ProgressResponse
  • func (r *Dispatcher) Close()
  • func (r *Dispatcher) Send(event dispatcher.Event)

Types

type Dispatcher

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

Dispatcher is a buffering progress event dispatcher. It will buffer events if the receiving side is slow or unavailable until it has reconnected.

func New

func New() *Dispatcher

New creates an event dispatcher with internal message buffer to collect messages that it failed to send to the client. The messages are resent whenever the client reconnects.

func (*Dispatcher) Chan

func (r *Dispatcher) Chan() <-chan *installpb.ProgressResponse

Chan returns the channel that receives events

func (*Dispatcher) Close

func (r *Dispatcher) Close()

Close stops the dispatcher internal processes Implements EventDispatcher

func (*Dispatcher) Send

func (r *Dispatcher) Send(event dispatcher.Event)

Send publishes the specified event. Implements EventDispatcher