stream

Documentation

Index

• Constants
• type GadgetStream
  • func NewGadgetStream() *GadgetStream
  • func (g *GadgetStream) Close()
  • func (g *GadgetStream) Publish(line string)
  • func (g *GadgetStream) Subscribe() chan TimestampedLine
  • func (g *GadgetStream) Unsubscribe(ch chan TimestampedLine)
• type TimestampedLine

Constants

const (
	HistorySize    = 100
	SubChannelSize = 250
)

Types

type GadgetStream

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

func NewGadgetStream

func NewGadgetStream() *GadgetStream

func (*GadgetStream) Close

func (g *GadgetStream) Close()

func (*GadgetStream) Publish

func (g *GadgetStream) Publish(line string)

func (*GadgetStream) Subscribe

func (g *GadgetStream) Subscribe() chan TimestampedLine

func (*GadgetStream) Unsubscribe

func (g *GadgetStream) Unsubscribe(ch chan TimestampedLine)

type TimestampedLine

type TimestampedLine struct {
	Line      string
	Timestamp time.Time
	EventLost bool
}