livelog

Documentation

Index

• Constants
• func GlobalStreamHandler(c *gin.Context)
• func Init()
• type Line
  • func NewLine(messageType string, message interface{}) *Line
• type 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

Constants

const GlobalStream = 0

Functions

func GlobalStreamHandler

func GlobalStreamHandler(c *gin.Context)

func Init

func Init()

Types

type Line

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

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

NewLine creates a line.

type Streamer

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

var Stream *Streamer

func (*Streamer) Create

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

Create adds a new log stream.

func (*Streamer) Delete

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

Delete removes a log by id.

func (*Streamer) Info

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

Info returns the count of subscribers in each stream.

func (*Streamer) Tail

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

Tail returns the end signal.

func (*Streamer) Write

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

Write adds a new line into stream.