livelog

package

v0.7.3 Latest Latest Go to latest Published: Feb 1, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Details

View Source

const GlobalStream = 0

This section is empty.

func GlobalStreamHandler(c *gin.Context)

func Init()

type Line struct {
	Type      string      `json:"Type"`
	Message   interface{} `json:"Message"`
	Timestamp int64       `json:"Time"`
}

Line is a single line of the log.

func NewLine(messageType string, message interface{}) *Line

NewLine creates a line.

type Streamer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

var Stream *Streamer

func (s *Streamer) Create(id int64) error

Create adds a new log stream.

func (s *Streamer) Delete(id int64) error

Delete removes a log by id.

func (s *Streamer) Info() map[int64]int

Info returns the count of subscribers in each stream.

func (s *Streamer) Tail(ctx context.Context, id int64) (<-chan *Line, <-chan error)

Tail returns the end signal.

func (s *Streamer) Write(id int64, line *Line) error

Write adds a new line into stream.