live

package
Version: v0.0.0-...-6df0fc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2020 License: BSD-3-Clause Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var RunDateFormat = "2006_Jan2_15_04_05_UTC"
View Source
var Store = sessions.NewCookieStore([]byte(os.Getenv("SESSION_KEY")))
View Source
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)

Directories

Path Synopsis
handlers

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL