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
- type Correlator
- type EventOp
- type EventProcessor
- type Op
- type OpArray
- type Pedestals
- type Player
- type RunObject
- type StreamOp
- type StreamProcessor
Constants ¶
This section is empty.
Variables ¶
View Source
var DetmapBox = packr.NewBox("../detmap/full")
View Source
var FlagSet = flag.NewFlagSet("", flag.ExitOnError)
Functions ¶
func AssembleFrame ¶
func AssembleFrame(event *proio.Event)
func CorrelateCmEvent ¶
func CorrelateCmEvent(event *proio.Event)
func CreateGcsReader ¶
func CreateGcsWriter ¶
func GetDetName ¶
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 KeepOnlyRawFrames ¶
func KeepOnlyRawFrames(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 ¶
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 ¶
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) RunCmdFlagParse ¶
func (ops OpArray) RunCmdFlagParse()
type Player ¶
type Player struct {
Speed float64
}
func (*Player) PlayCmStream ¶
func (p *Player) PlayCmStream(input <-chan *proio.Event, output chan<- *proio.Event)
type StreamOp ¶
type StreamOp struct { Description string StreamProcessor StreamProcessor MaxEventBuf int }
func (StreamOp) GetDescription ¶
type StreamProcessor ¶
type StreamProcessor func(<-chan *proio.Event, chan<- *proio.Event)
Click to show internal directories.
Click to hide internal directories.