state

Documentation

Index

• type State
  • func New() *State
  • func (s *State) GetStream(name string) *Stream
  • func (s *State) RemoveStream(name string)
  • func (s *State) SetStream(name string, stream *Stream)
  • func (s *State) Shutdown()
• type Stream
  • func NewStream() *Stream
  • func (s *Stream) GetCurrentViewers(timeout time.Duration) int
  • func (s *Stream) GetUptime() time.Duration
• type Viewer

Types

type State

type State struct {
	Conf *config.Conf

	CloseChan chan bool

	StreamsMutex sync.Mutex
	Streams      map[string]*Stream
}

func New

func New() *State

func (*State) GetStream

func (s *State) GetStream(name string) *Stream

func (*State) RemoveStream

func (s *State) RemoveStream(name string)

func (*State) SetStream

func (s *State) SetStream(name string, stream *Stream)

func (*State) Shutdown

func (s *State) Shutdown()

type Stream

type Stream struct {
	sync.Mutex
	Viewers   map[string]*Viewer
	StartTime time.Time
}

func NewStream

func NewStream() *Stream

func (*Stream) GetCurrentViewers

func (s *Stream) GetCurrentViewers(timeout time.Duration) int

func (*Stream) GetUptime

func (s *Stream) GetUptime() time.Duration

type Viewer

type Viewer struct {
	FirstSeen time.Time
	LastSeen  time.Time
	Ip        string
}