broadcasts

Documentation

Overview

Package broadcasts implements custom typed one-to-n facilities for broadcasting messages/calls to multiple subscribers. They loosely follow from luigi.Broadcasts but using concrete types instead of empty interfaces.

Index

• func NewAttendantsEmitter() (AttendantsEmitter, *AttendantsBroadcast)
• func NewEndpointsEmitter() (EndpointsEmitter, *EndpointsBroadcast)
• type AttendantsBroadcast
  • func (bcst *AttendantsBroadcast) Register(sink AttendantsEmitter) func()
• type AttendantsEmitter
• type EndpointsBroadcast
  • func (bcst *EndpointsBroadcast) Register(sink EndpointsEmitter) func()
• type EndpointsEmitter

Functions

func NewAttendantsEmitter

func NewAttendantsEmitter() (AttendantsEmitter, *AttendantsBroadcast)

NewAttendantsEmitter returns the Sink, to write to the broadcaster, and the new broadcast instance.

func NewEndpointsEmitter

func NewEndpointsEmitter() (EndpointsEmitter, *EndpointsBroadcast)

NewEndpointsEmitter returns the Sink, to write to the broadcaster, and the new broadcast instance.

Types

type AttendantsBroadcast

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

AttendantsBroadcast is an interface for registering one or more Sinks to recieve updates.

func (*AttendantsBroadcast) Register

func (bcst *AttendantsBroadcast) Register(sink AttendantsEmitter) func()

Register a Sink for updates to be sent. also returns

type AttendantsEmitter

type AttendantsEmitter interface {
	Joined(member refs.FeedRef) error
	Left(member refs.FeedRef) error

	io.Closer
}

type EndpointsBroadcast

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

EndpointsBroadcast is an interface for registering one or more Sinks to recieve updates.

func (*EndpointsBroadcast) Register

func (bcst *EndpointsBroadcast) Register(sink EndpointsEmitter) func()

Register a Sink for updates to be sent. also returns

type EndpointsEmitter

type EndpointsEmitter interface {
	Update(members []string) error
	io.Closer
}