stream

Documentation

Index

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

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 Record

func (*GadgetStream) Unsubscribe

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

type Record

type Record struct {
	Line      string
	EventLost bool
}