stream

package

v0.0.0-...-3936e01 Latest Latest Go to latest Published: May 18, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Data struct {
	Name      string  `json:"name"`
	Timestamp int64   `json:"ts"`
	Val       float64 `json:"val"`
}

func GetData() *Data

func (d *Data) String() string

type FollowStream interface {
	Follow(string, *Follower)
	Unfollow(string, *Follower)
}

type Follower struct {
	Pub  chan *Data
	Rate int64
}

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

func NewStreamer(handler FollowStream) *Streamer

func (s *Streamer) Handler(w http.ResponseWriter, r *http.Request)