bus

Documentation

Index

• type PubSub
  • func NewPubSub(cqlC *cassandra.Client) *PubSub
  • func (hub *PubSub) Start(scaler int)
  • func (hub *PubSub) UpgradeProtocoll(w http.ResponseWriter, r *http.Request) error

Types

type PubSub

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

func NewPubSub

func NewPubSub(cqlC *cassandra.Client) *PubSub

NewPubSub returns a new instance of a PubSub

func (*PubSub) Start

func (hub *PubSub) Start(scaler int)

Start starts N hub to listen to incoming events and handle protocoll upgrades

func (*PubSub) UpgradeProtocoll

func (hub *PubSub) UpgradeProtocoll(w http.ResponseWriter, r *http.Request) error

UpgradeProtocoll hajiecks the ResponseWriter and upgrdares the http protocoll to a ws if successful starts the listener on the connection.