live

Documentation

Index

• Variables
• func BuildCmOpArray(namespace, stream string, client *redis.Client, addr string, uid uint64) data.OpArray
• func BuildOpArray(namespace, stream string, client *redis.Client, addr string, uid uint64) data.OpArray
• func BuildPlayer(namespace, stream string, client *redis.Client, addr string, uid uint64) data.OpArray
• func CmGenerateSources(m *StreamManager, event *proio.Event)
• type SetStringer
• type ShowInfo
• type ShowType
• type SourceInfo
• type SourceType
• type Status
  • func (s *Status) SetString(key, value string)
• type StreamManager
  • func (m *StreamManager) GetSourceInfo(source string) *SourceInfo
  • func (m *StreamManager) HandleSource(sourceInfo *SourceInfo, t SourceType, value ...interface{})
  • func (m *StreamManager) Manage(input <-chan *proio.Event, output chan<- *proio.Event)

Variables

var RunDateFormat = "2006_Jan2_15_04_05_UTC"

var Store = sessions.NewCookieStore([]byte(os.Getenv("SESSION_KEY")))

var WebdataBox = packr.NewBox("webdata")

Functions

func BuildCmOpArray

func BuildCmOpArray(namespace, stream string, client *redis.Client, addr string, uid uint64) data.OpArray

func BuildOpArray

func BuildOpArray(
	namespace, stream string,
	client *redis.Client,
	addr string,
	uid uint64,
) data.OpArray

func BuildPlayer

func BuildPlayer(
	namespace, stream string,
	client *redis.Client,
	addr string,
	uid uint64,
) data.OpArray

func CmGenerateSources

func CmGenerateSources(m *StreamManager, event *proio.Event)

Types

type SetStringer

type SetStringer interface {
	SetString(key, value string)
}

type ShowInfo

type ShowInfo struct {
	Show          interface{}
	Cancel        context.CancelFunc
	SampleChannel chan<- interface{}
}

type ShowType

type ShowType int

const (
	Projection ShowType = iota
	RollXY
	XY
	Hist2D
)

type SourceInfo

type SourceInfo struct {
	Name        string
	ShowIds     []uuid.UUID
	CompatShows []ShowType
	Type        SourceType
}

type SourceType

type SourceType int

const (
	Normal SourceType = iota
	Advanced
)

type Status

type Status struct {
	Keys       []string
	StringData map[string]string
}

func (*Status) SetString

func (s *Status) SetString(key, value string)

type StreamManager

type StreamManager struct {
	Namespace       string
	Name            string
	Redis           *redis.Client
	Addr            string
	InitShows       func(*StreamManager)
	GenerateSources func(*StreamManager, *proio.Event)
	CleanupRunData  []data.EventProcessor
	Metadata        map[string]string
	// contains filtered or unexported fields
}

func (*StreamManager) GetSourceInfo

func (m *StreamManager) GetSourceInfo(source string) *SourceInfo

func (*StreamManager) HandleSource

func (m *StreamManager) HandleSource(sourceInfo *SourceInfo, t SourceType, value ...interface{})

func (*StreamManager) Manage

func (m *StreamManager) Manage(input <-chan *proio.Event, output chan<- *proio.Event)