stream

Documentation

Index

• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) AddConnection(conn *websocket.Conn)
  • func (b *Broker) AddNext(pe pipeline.Pipeline)
  • func (b Broker) ListClients() []string
  • func (b *Broker) Next() pipeline.Pipeline
  • func (b *Broker) Publish(m *model.Message) error

Types

type Broker

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

Broker represents the message broker used for streaming data messages to clients.

func NewBroker

func NewBroker() *Broker

NewBroker creates a new Broker instance.

func (*Broker) AddConnection

func (b *Broker) AddConnection(conn *websocket.Conn)

AddConnection adds a new connection to the message broker.

func (*Broker) AddNext

func (b *Broker) AddNext(pe pipeline.Pipeline)

AddNext ...

func (Broker) ListClients

func (b Broker) ListClients() []string

ListClients lists clients connected via websocket streamer

func (*Broker) Next

func (b *Broker) Next() pipeline.Pipeline

Next ...

func (*Broker) Publish

func (b *Broker) Publish(m *model.Message) error

Publish ...