Versions in this module Expand all Collapse all v0 v0.7.4 Apr 9, 2022 Changes in this version + const GlobalStream + func GlobalStreamHandler(c *gin.Context) + func Init() + type Line struct + Message interface{} + Timestamp int64 + Type string + func NewLine(messageType string, message interface{}) *Line + type Streamer struct + var Stream *Streamer + func (s *Streamer) Create(id int64) error + func (s *Streamer) Delete(id int64) error + func (s *Streamer) Info() map[int64]int + func (s *Streamer) Tail(ctx context.Context, id int64) (<-chan *Line, <-chan error) + func (s *Streamer) Write(id int64, line *Line) error
Go to main page