data

Documentation

Index

• Variables
• func AssembleFrame(event *proio.Event)
• func CmMerge(input <-chan *proio.Event, output chan<- *proio.Event)
• func CorrelateCmEvent(event *proio.Event)
• func CreateGcsReader(ctx context.Context, bucket, name string, credentials []byte) (*proio.Reader, error)
• func CreateGcsWriter(ctx context.Context, bucket, name string, credentials []byte) (*proio.Writer, error)
• func GetDetName(uid uint64) string
• func GetHpsConfig(uid uint64) *detmapmodel.HpsConfig
• func GetImageConfigs(uid uint64) []*detmapmodel.DetectorConfig_ImageConfig
• func GetMode(uid uint64) detmapmodel.HpsConfig_Mode
• func GetReader(ctx context.Context, urlString, credentials string) (reader *proio.Reader, err error)
• func GetWriter(ctx context.Context, urlString, credentials string) (writer *proio.Writer, err error)
• func KeepOnlyRawFrames(event *proio.Event)
• func MapEvent(event *proio.Event)
• func RemoveLooseSamples(event *proio.Event)
• type BeamReconstruction
  • func NewBeamReconstruction(uid uint64) *BeamReconstruction
  • func (r *BeamReconstruction) FillBeamInfo(event *proio.Event)
• type Correlator
  • func (c *Correlator) CorrelateCmEvent(input <-chan *proio.Event, output chan<- *proio.Event)
• type EventOp
  • func (o EventOp) GetDescription() string
  • func (o EventOp) Run(input <-chan *proio.Event) <-chan *proio.Event
• type EventProcessor
• type Op
• type OpArray
  • func (ops OpArray) GetReader() *proio.Reader
  • func (ops OpArray) Run(stream <-chan *proio.Event) <-chan *proio.Event
  • func (ops OpArray) RunCmd()
  • func (ops OpArray) RunCmdFlagParse()
  • func (ops OpArray) Sink(stream <-chan *proio.Event)
• type Pedestals
  • func (p *Pedestals) Subtract(input <-chan *proio.Event, output chan<- *proio.Event)
• type Player
  • func (p *Player) PlayCmStream(input <-chan *proio.Event, output chan<- *proio.Event)
• type RunObject
  • func ListGcsRuns(ctx context.Context, bucket, prefix string, credentials []byte) ([]*RunObject, error)
  • func ListResourceRuns(ctx context.Context, urlString, credentials string) (runs []*RunObject, err error)
• type StreamOp
  • func (o StreamOp) GetDescription() string
  • func (o StreamOp) Run(input <-chan *proio.Event) <-chan *proio.Event
• type StreamProcessor

Variables

var DetmapBox = packr.NewBox("../detmap/full")

var FlagSet = flag.NewFlagSet("", flag.ExitOnError)

Functions

func AssembleFrame

func AssembleFrame(event *proio.Event)

func CmMerge

func CmMerge(input <-chan *proio.Event, output chan<- *proio.Event)

func CorrelateCmEvent

func CorrelateCmEvent(event *proio.Event)

func CreateGcsReader

func CreateGcsReader(ctx context.Context, bucket, name string, credentials []byte) (*proio.Reader, error)

func CreateGcsWriter

func CreateGcsWriter(ctx context.Context, bucket, name string, credentials []byte) (*proio.Writer, error)

func GetDetName

func GetDetName(uid uint64) string

func GetHpsConfig

func GetHpsConfig(uid uint64) *detmapmodel.HpsConfig

func GetImageConfigs

func GetImageConfigs(uid uint64) []*detmapmodel.DetectorConfig_ImageConfig

func GetMode

func GetMode(uid uint64) detmapmodel.HpsConfig_Mode

func GetReader

func GetReader(ctx context.Context, urlString, credentials string) (reader *proio.Reader, err error)

func GetWriter

func GetWriter(ctx context.Context, urlString, credentials string) (writer *proio.Writer, err error)

func KeepOnlyRawFrames

func KeepOnlyRawFrames(event *proio.Event)

func MapEvent

func MapEvent(event *proio.Event)

func RemoveLooseSamples

func RemoveLooseSamples(event *proio.Event)

Types

type BeamReconstruction

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

func NewBeamReconstruction

func NewBeamReconstruction(uid uint64) *BeamReconstruction

func (*BeamReconstruction) FillBeamInfo

func (r *BeamReconstruction) FillBeamInfo(event *proio.Event)

type Correlator

type Correlator struct {
	NFrames int
	Default float32
}

func (*Correlator) CorrelateCmEvent

func (c *Correlator) CorrelateCmEvent(input <-chan *proio.Event, output chan<- *proio.Event)

type EventOp

type EventOp struct {
	Description    string
	EventProcessor EventProcessor
	Concurrency    int
	MaxEventBuf    int
}

func (EventOp) GetDescription

func (o EventOp) GetDescription() string

func (EventOp) Run

func (o EventOp) Run(input <-chan *proio.Event) <-chan *proio.Event

type EventProcessor

type EventProcessor func(*proio.Event)

type Op

type Op interface {
	GetDescription() string
	Run(input <-chan *proio.Event) <-chan *proio.Event
}

type OpArray

type OpArray []Op

func (OpArray) GetReader

func (ops OpArray) GetReader() *proio.Reader

func (OpArray) Run

func (ops OpArray) Run(stream <-chan *proio.Event) <-chan *proio.Event

func (OpArray) RunCmd

func (ops OpArray) RunCmd()

func (OpArray) RunCmdFlagParse

func (ops OpArray) RunCmdFlagParse()

func (OpArray) Sink

func (ops OpArray) Sink(stream <-chan *proio.Event)

type Pedestals

type Pedestals struct {
	Alpha   float64
	CovFrac float64
	// contains filtered or unexported fields
}

func (*Pedestals) Subtract

func (p *Pedestals) Subtract(input <-chan *proio.Event, output chan<- *proio.Event)

type Player

type Player struct {
	Speed float64
}

func (*Player) PlayCmStream

func (p *Player) PlayCmStream(input <-chan *proio.Event, output chan<- *proio.Event)

type RunObject

type RunObject struct {
	Name string
}

func ListGcsRuns

func ListGcsRuns(ctx context.Context, bucket, prefix string, credentials []byte) ([]*RunObject, error)

func ListResourceRuns

func ListResourceRuns(ctx context.Context, urlString, credentials string) (runs []*RunObject, err error)

type StreamOp

type StreamOp struct {
	Description     string
	StreamProcessor StreamProcessor
	MaxEventBuf     int
}

func (StreamOp) GetDescription

func (o StreamOp) GetDescription() string

func (StreamOp) Run

func (o StreamOp) Run(input <-chan *proio.Event) <-chan *proio.Event

type StreamProcessor

type StreamProcessor func(<-chan *proio.Event, chan<- *proio.Event)