dastard

package module

Go to main page

Versions in this module

v0

v0.3.3

May 28, 2024

v0.3.2

Feb 13, 2024

Changes in this version

+ var UpdateLogger *log.Logger

+ type AsciiBouncer struct

+ func (b *AsciiBouncer) String() string

type FrameTimingCorrepondence

+ LastFirmwareTimestamp packets.PacketTimestamp

+ LastSubframeCount FrameIndex

+ TimestampCountsPerSubframe uint64

v0.3.1

Feb 3, 2024

Changes in this version

type AbacoUnwrapOptions

+ InvertChan []int

+ type FrameTimingCorrepondence struct

+ CountsPerFrame uint64

+ LastFrameCount FrameIndex

+ LastTimestamp packets.PacketTimestamp

v0.3.0

Aug 10, 2023

Changes in this version

type AnySource

+ func (ds *AnySource) ArchiveDataBlock(N int, file *os.File, finalName string) error

type DataSource

+ ArchiveDataBlock func(int, *os.File, string) error

type SourceControl

+ func (s *SourceControl) StoreRawDataBlock(N int, reply *string) error

v0.2.19

May 26, 2023

v0.2.18

May 10, 2023

v0.2.17

Mar 7, 2023

v0.2.17-pre4

Mar 7, 2023

v0.2.17-pre3

Mar 7, 2023

v0.2.17-pre2

Mar 7, 2023

v0.2.17-pre

Mar 7, 2023

v0.2.16

Feb 28, 2023

Changes in this version

type TriggerState

+ AutoVetoRange RawType

v0.2.15

Jan 26, 2023

v0.2.14

Sep 26, 2022

v0.2.13

Sep 13, 2022

Changes in this version

+ type AbacoUnwrapOptions struct

+ Bias bool

+ PulseSign int

+ RescaleRaw bool

+ ResetAfter int

+ Unwrap bool

v0.2.12

Mar 19, 2022

Changes in this version

type AnySource

+ func (ds *AnySource) ChangeGroupTrigger(turnon bool, gts *GroupTriggerState) error

+ func (ds *AnySource) ComputeGroupTriggerState() GroupTriggerState

+ func (ds *AnySource) StopTriggerCoupling() error

type DataSource

+ ChangeGroupTrigger func(turnon bool, gts *GroupTriggerState) error

+ ComputeGroupTriggerState func() GroupTriggerState

+ StopTriggerCoupling func() error

type DataStreamProcessor

+ func (dsp *DataStreamProcessor) TriggerDataSecondary(secondaryTrigList []FrameIndex) (secRecords []*DataRecord)

+ func (dsp *DataStreamProcessor) TrimStream()

+ type EMTBackwardCompatibleRPCFields struct

+ EdgeMultiDisableZeroThreshold bool

+ EdgeMultiLevel int32

+ EdgeMultiMakeContaminatedRecords bool

+ EdgeMultiMakeShortRecords bool

+ EdgeMultiNoise bool

+ EdgeMultiVerifyNMonotone int

+ type EMTMode int

+ const EMTRecordsFullLengthIsolated

+ const EMTRecordsTwoFullLength

+ const EMTRecordsVariableLength

+ type EMTState struct

+ func (s EMTState) NToKeepOnTrim() int

+ type GroupTriggerState struct

+ Connections map[int][]int

+ type NextTriggerIndResult struct

+ type RecordSpec struct

type SourceControl

+ func (s *SourceControl) AddGroupTriggerCoupling(gts GroupTriggerState, reply *bool) error

+ func (s *SourceControl) DeleteGroupTriggerCoupling(gts *GroupTriggerState, reply *bool) error

+ func (s *SourceControl) StopTriggerCoupling(dummy *bool, reply *bool) error

type TriggerBroker

+ func (broker *TriggerBroker) Distribute(primaries map[int]triggerList) (map[int][]FrameIndex, error)

+ func (broker *TriggerBroker) GenerateTriggerMessages()

+ func (broker *TriggerBroker) SourcesForReceiver(receiver int) map[int]bool

+ func (broker *TriggerBroker) StopTriggerCoupling() error

v0.2.11

Oct 20, 2021

Changes in this version

type AbacoSourceConfig

+ Bias bool

+ PulseSign int

v0.2.10

May 27, 2021

Changes in this version

type AbacoSourceConfig

+ HostPortUDP []string

+ type AbacoUDPReceiver struct

+ func NewAbacoUDPReceiver(hostport string) (dev *AbacoUDPReceiver, err error)

+ func (device *AbacoUDPReceiver) ReadAllPackets() ([]*packets.Packet, error)

+ type PacketProducer interface

+ ReadAllPackets func() ([]*packets.Packet, error)

type RoachSource

+ func (rs *RoachSource) PrepareChannels() error

v0.2.9

Mar 12, 2021

Changes in this version

+ var Build = BuildInfo

+ var DastardStartTime time.Time

+ var ProblemLogger *log.Logger

+ var PubRecordsChan chan []*DataRecord

+ var PubSummariesChan chan []*DataRecord

+ func CoreLoop(ds DataSource, queuedRequests chan func())

+ func RunClientUpdater(statusport int, abort <-chan struct{})

+ func RunRPCServer(portrpc int, block bool)

+ func Start(ds DataSource, queuedRequests chan func(), Npresamp int, Nsamples int) error

+ type AbacoBuffersType struct

+ type AbacoGroup struct

+ func NewAbacoGroup(index GroupIndex, unwrapEnable bool, unwrapReset int) *AbacoGroup

+ type AbacoRing struct

+ func NewAbacoRing(ringnum int) (dev *AbacoRing, err error)

+ func (device *AbacoRing) ReadAllPackets() ([]*packets.Packet, error)

+ type AbacoSource struct

+ Nrings int

+ func NewAbacoSource() (*AbacoSource, error)

+ func (as *AbacoSource) Configure(config *AbacoSourceConfig) (err error)

+ func (as *AbacoSource) Delete()

+ func (as *AbacoSource) PrepareChannels() error

+ func (as *AbacoSource) Sample() error

+ func (as *AbacoSource) StartRun() error

+ type AbacoSourceConfig struct

+ ActiveCards []int

+ AvailableCards []int

+ UnwrapResetSamp int

+ Unwrapping bool

+ type AnySource struct

+ func (ds *AnySource) ChanGroups() []GroupIndex

+ func (ds *AnySource) ChangeTriggerState(state *FullTriggerState) error

+ func (ds *AnySource) ChannelNames() []string

+ func (ds *AnySource) ChannelsWithProjectors() []int

+ func (ds *AnySource) ComputeFullTriggerState() []FullTriggerState

+ func (ds *AnySource) ComputeWritingState() WritingState

+ func (ds *AnySource) ConfigureMixFraction(mfo *MixFractionObject) ([]float64, error)

+ func (ds *AnySource) ConfigureProjectorsBases(channelIndex int, projectors *mat.Dense, basis *mat.Dense, ...) error

+ func (ds *AnySource) ConfigurePulseLengths(nsamp, npre int) error

+ func (ds *AnySource) GetState() SourceState

+ func (ds *AnySource) HandleDataDrop(droppedFrames, firstFramenum int) error

+ func (ds *AnySource) HandleExternalTriggers(externalTriggerRowcounts []int64) error

+ func (ds *AnySource) Nchan() int

+ func (ds *AnySource) PrepareChannels() error

+ func (ds *AnySource) PrepareRun(Npresamples int, Nsamples int) error

+ func (ds *AnySource) ProcessSegments(block *dataBlock) error

+ func (ds *AnySource) RunDoneActivate()

+ func (ds *AnySource) RunDoneDeactivate()

+ func (ds *AnySource) RunDoneWait()

+ func (ds *AnySource) Running() bool

+ func (ds *AnySource) SamplePeriod() time.Duration

+ func (ds *AnySource) SetCoupling(status CouplingStatus) error

+ func (ds *AnySource) SetExperimentStateLabel(timestamp time.Time, stateLabel string) error

+ func (ds *AnySource) SetStateInactive() error

+ func (ds *AnySource) SetStateStarting() error

+ func (ds *AnySource) ShouldAutoRestart() bool

+ func (ds *AnySource) Stop() error

+ func (ds *AnySource) VoltsPerArb() []float32

+ func (ds *AnySource) WriteControl(config *WriteControlConfig) error

+ func (ds *AnySource) WritingIsActive() bool

+ type BuffersChanType struct

+ type BuildInfo struct

+ Date string

+ Githash string

+ Version string

+ type ByGroup []GroupIndex

+ func (g ByGroup) Len() int

+ func (g ByGroup) Less(i, j int) bool

+ func (g ByGroup) Swap(i, j int)

+ type ClientUpdate struct

+ type CouplingStatus int

+ const ErrToFB

+ const FBToErr

+ const NoCoupling

+ type DataPublisher struct

+ LJH22 *ljh.Writer

+ LJH3 *ljh.Writer3

+ OFF *off.Writer

+ PubRecordsChan chan []*DataRecord

+ PubSummariesChan chan []*DataRecord

+ WritingPaused bool

+ func (dp *DataPublisher) Flush()

+ func (dp *DataPublisher) HasLJH22() bool

+ func (dp *DataPublisher) HasLJH3() bool

+ func (dp *DataPublisher) HasOFF() bool

+ func (dp *DataPublisher) HasPubRecords() bool

+ func (dp *DataPublisher) HasPubSummaries() bool

+ func (dp *DataPublisher) PublishData(records []*DataRecord) error

+ func (dp *DataPublisher) RemoveLJH22()

+ func (dp *DataPublisher) RemoveLJH3()

+ func (dp *DataPublisher) RemoveOFF()

+ func (dp *DataPublisher) RemovePubRecords()

+ func (dp *DataPublisher) RemovePubSummaries()

+ func (dp *DataPublisher) SetLJH22(ChannelIndex int, Presamples int, Samples int, FramesPerSample int, ...)

+ func (dp *DataPublisher) SetLJH3(ChannelIndex int, Timebase float64, NumberOfRows int, NumberOfColumns int, ...)

+ func (dp *DataPublisher) SetOFF(ChannelIndex int, Presamples int, Samples int, FramesPerSample int, ...)

+ func (dp *DataPublisher) SetPause(pause bool)

+ func (dp *DataPublisher) SetPubRecords()

+ func (dp *DataPublisher) SetPubSummaries()

+ type DataRecord struct

+ type DataSegment struct

+ func NewDataSegment(data []RawType, framesPerSample int, firstFrame FrameIndex, ...) *DataSegment

+ func (seg *DataSegment) TimeOf(sampleNum int) time.Time

+ type DataSource interface

+ ChanGroups func() []GroupIndex

+ ChangeTriggerState func(*FullTriggerState) error

+ ChannelNames func() []string

+ ChannelsWithProjectors func() []int

+ ComputeFullTriggerState func() []FullTriggerState

+ ComputeWritingState func() WritingState

+ ConfigureMixFraction func(*MixFractionObject) ([]float64, error)

+ ConfigureProjectorsBases func(int, *mat.Dense, *mat.Dense, string) error

+ ConfigurePulseLengths func(int, int) error

+ GetState func() SourceState

+ Nchan func() int

+ PrepareChannels func() error

+ PrepareRun func(int, int) error

+ ProcessSegments func(*dataBlock) error

+ RunDoneActivate func()

+ RunDoneDeactivate func()

+ Running func() bool

+ Sample func() error

+ SamplePeriod func() time.Duration

+ SetCoupling func(CouplingStatus) error

+ SetExperimentStateLabel func(time.Time, string) error

+ SetStateInactive func() error

+ SetStateStarting func() error

+ ShouldAutoRestart func() bool

+ StartRun func() error

+ Stop func() error

+ VoltsPerArb func() []float32

+ WriteControl func(*WriteControlConfig) error

+ WritingIsActive func() bool

+ type DataStream struct

+ func NewDataStream(data []RawType, framesPerSample int, firstFrame FrameIndex, ...) *DataStream

+ func (stream *DataStream) AppendSegment(segment *DataSegment)

+ func (stream *DataStream) TrimKeepingN(N int) int

+ type DataStreamProcessor struct

+ Broker *TriggerBroker

+ ChannelNumber int

+ LastEdgeMultiTrigger FrameIndex

+ LastTrigger FrameIndex

+ NPresamples int

+ NSamples int

+ Name string

+ SampleRate float64

+ func NewDataStreamProcessor(channelIndex int, broker *TriggerBroker, NPresamples int, NSamples int) *DataStreamProcessor

+ func (dsp *DataStreamProcessor) AnalyzeData(records []*DataRecord)

+ func (dsp *DataStreamProcessor) ConfigurePulseLengths(nsamp, npre int)

+ func (dsp *DataStreamProcessor) ConfigureTrigger(state TriggerState)

+ func (dsp *DataStreamProcessor) DecimateData(segment *DataSegment)

+ func (dsp *DataStreamProcessor) HasProjectors() bool

+ func (dsp *DataStreamProcessor) SetProjectorsBasis(projectors *mat.Dense, basis *mat.Dense, modelDescription string) error

+ func (dsp *DataStreamProcessor) TriggerData() (records []*DataRecord, secondaries []*DataRecord)

+ type DecimateState struct

+ Decimate bool

+ DecimateAvgMode bool

+ DecimateLevel int

+ type ErroringSource struct

+ func NewErroringSource() *ErroringSource

+ func (es *ErroringSource) Sample() error

+ func (es *ErroringSource) StartRun() error

+ type FactorArgs struct

+ A int

+ B int

+ type FrameIdxSlice []FrameIndex

+ func (p FrameIdxSlice) Len() int

+ func (p FrameIdxSlice) Less(i, j int) bool

+ func (p FrameIdxSlice) Swap(i, j int)

+ type FrameIndex int64

+ type FullTriggerState struct

+ ChannelIndices []int

+ type GroupIndex struct

+ Firstchan int

+ Nchan int

+ type Heartbeat struct

+ DataMB float64

+ HWactualMB float64

+ Running bool

+ Time float64

+ type LanceroDastardOutputJSON struct

+ AvailableCards []int

+ BAD16CardDelay int

+ ClockMHz int

+ Lsync int

+ Nsamp int

+ PropagationDelay int

+ SequenceLength int

+ Settle int

+ type LanceroDevice struct

+ type LanceroSource struct

+ Mix []*Mix

+ func NewLanceroSource() (*LanceroSource, error)

+ func (ls *LanceroSource) Configure(config *LanceroSourceConfig) (err error)

+ func (ls *LanceroSource) ConfigureMixFraction(mfo *MixFractionObject) ([]float64, error)

+ func (ls *LanceroSource) Delete()

+ func (ls *LanceroSource) PrepareChannels() error

+ func (ls *LanceroSource) Sample() error

+ func (ls *LanceroSource) SetCoupling(status CouplingStatus) error

+ func (ls *LanceroSource) StartRun() error

+ type LanceroSourceConfig struct

+ ActiveCards []int

+ CardDelay []int

+ ChanSepCards int

+ ChanSepColumns int

+ DastardOutput LanceroDastardOutputJSON

+ FiberMask uint32

+ FirstRow int

+ ShouldAutoRestart bool

+ type Map struct

+ Filename string

+ Pixels []Pixel

+ Spacing int

+ type MapServer struct

+ Map *Map

+ func (ms *MapServer) Load(filename *string, reply *bool) error

+ func (ms *MapServer) Unload(zero *int, reply *bool) error

+ type Mix struct

+ func (m *Mix) MixRetardFb(fbs *[]RawType, errs *[]RawType)

+ type MixFractionObject struct

+ ChannelIndices []int

+ MixFractions []float64

+ type PhaseUnwrapper struct

+ func NewPhaseUnwrapper(fractionBits, lowBitsToDrop uint, enable bool, resetAfter int) *PhaseUnwrapper

+ func (u *PhaseUnwrapper) UnwrapInPlace(data *[]RawType)

+ type Pixel struct

+ Name string

+ X int

+ Y int

+ type Portnumbers struct

+ RPC int

+ SecondaryTrigs int

+ Status int

+ Summaries int

+ Trigs int

+ var Ports Portnumbers

+ type ProjectorsBasisObject struct

+ BasisBase64 string

+ ChannelIndex int

+ ModelDescription string

+ ProjectorsBase64 string

+ type RawType uint16

+ type RecordSlice []*DataRecord

+ func (p RecordSlice) Len() int

+ func (p RecordSlice) Less(i, j int) bool

+ func (p RecordSlice) Swap(i, j int)

+ type RoachDevice struct

+ func NewRoachDevice(host string, rate float64) (dev *RoachDevice, err error)

+ type RoachSource struct

+ Ndevices int

+ func NewRoachSource() (*RoachSource, error)

+ func (rs *RoachSource) Configure(config *RoachSourceConfig) (err error)

+ func (rs *RoachSource) Delete()

+ func (rs *RoachSource) Sample() error

+ func (rs *RoachSource) StartRun() error

+ type RoachSourceConfig struct

+ HostPort []string

+ Rates []float64

+ type RowColCode uint64

+ type ServerStatus struct

+ ChanGroups []GroupIndex

+ ChannelsWithProjectors []int

+ Nchannels int

+ Npresamp int

+ Nsamples int

+ Running bool

+ SamplePeriod time.Duration

+ SourceName string

+ type SimPulseSource struct

+ func NewSimPulseSource() *SimPulseSource

+ func (sps *SimPulseSource) Configure(config *SimPulseSourceConfig) error

+ func (sps *SimPulseSource) Sample() error

+ func (sps *SimPulseSource) StartRun() error

+ type SimPulseSourceConfig struct

+ Amplitudes []float64

+ Nchan int

+ Nsamp int

+ Pedestal float64

+ SampleRate float64

+ type SizeObject struct

+ Npre int

+ Nsamp int

+ type SourceControl struct

+ ActiveSource DataSource

+ func NewSourceControl() *SourceControl

+ func (s *SourceControl) ConfigureAbacoSource(args *AbacoSourceConfig, reply *bool) error

+ func (s *SourceControl) ConfigureLanceroSource(args *LanceroSourceConfig, reply *bool) error

+ func (s *SourceControl) ConfigureMixFraction(mfo *MixFractionObject, reply *bool) error

+ func (s *SourceControl) ConfigureProjectorsBasis(pbo *ProjectorsBasisObject, reply *bool) error

+ func (s *SourceControl) ConfigurePulseLengths(sizes SizeObject, reply *bool) error

+ func (s *SourceControl) ConfigureRoachSource(args *RoachSourceConfig, reply *bool) error

+ func (s *SourceControl) ConfigureSimPulseSource(args *SimPulseSourceConfig, reply *bool) error

+ func (s *SourceControl) ConfigureTriangleSource(args *TriangleSourceConfig, reply *bool) error

+ func (s *SourceControl) ConfigureTriggers(state *FullTriggerState, reply *bool) error

+ func (s *SourceControl) CoupleErrToFB(couple *bool, reply *bool) error

+ func (s *SourceControl) CoupleFBToErr(couple *bool, reply *bool) error

+ func (s *SourceControl) Multiply(args *FactorArgs, reply *int) error

+ func (s *SourceControl) ReadComment(zero *int, reply *string) error

+ func (s *SourceControl) SendAllStatus(dummy *string, reply *bool) error

+ func (s *SourceControl) SetExperimentStateLabel(config *StateLabelConfig, reply *bool) error

+ func (s *SourceControl) Start(sourceName *string, reply *bool) error

+ func (s *SourceControl) Stop(dummy *string, reply *bool) error

+ func (s *SourceControl) WaitForStopTestingOnly(dummy *string, reply *bool) error

+ func (s *SourceControl) WriteComment(comment *string, reply *bool) error

+ func (s *SourceControl) WriteControl(config *WriteControlConfig, reply *bool) error

+ type SourceState int

+ const Active

+ const Inactive

+ const Starting

+ const Stopping

+ type StateLabelConfig struct

+ Label string

+ WaitForError bool

+ type TriangleSource struct

+ func NewTriangleSource() *TriangleSource

+ func (ts *TriangleSource) Configure(config *TriangleSourceConfig) error

+ func (ts *TriangleSource) Sample() error

+ func (ts *TriangleSource) StartRun() error

+ type TriangleSourceConfig struct

+ Max RawType

+ Min RawType

+ Nchan int

+ SampleRate float64

+ type TriggerBroker struct

+ PrimaryTrigs chan triggerList

+ SecondaryTrigs []chan []FrameIndex

+ func NewTriggerBroker(nchan int) *TriggerBroker

+ func (broker *TriggerBroker) AddConnection(source, receiver int) error

+ func (broker *TriggerBroker) Connections(receiver int) map[int]bool

+ func (broker *TriggerBroker) DeleteConnection(source, receiver int) error

+ func (broker *TriggerBroker) Run()

+ func (broker *TriggerBroker) Stop()

+ type TriggerCounter struct

+ func NewTriggerCounter(channelIndex int, stepDuration time.Duration) TriggerCounter

+ type TriggerRateMessage struct

+ CountsSeen []int

+ Duration time.Duration

+ HiTime time.Time

+ type TriggerState struct

+ AutoDelay time.Duration

+ AutoTrigger bool

+ EdgeFalling bool

+ EdgeLevel int32

+ EdgeMulti bool

+ EdgeMultiDisableZeroThreshold bool

+ EdgeMultiLevel int32

+ EdgeMultiMakeContaminatedRecords bool

+ EdgeMultiMakeShortRecords bool

+ EdgeMultiNoise bool

+ EdgeMultiVerifyNMonotone int

+ EdgeRising bool

+ EdgeTrigger bool

+ LevelLevel RawType

+ LevelRising bool

+ LevelTrigger bool

+ type WriteControlConfig struct

+ MapInternalOnly *Map

+ Path string

+ Request string

+ WriteLJH22 bool

+ WriteLJH3 bool

+ WriteOFF bool

+ type WritingState struct

+ Active bool

+ BasePath string

+ DataDropFilename string

+ ExperimentStateFilename string

+ ExperimentStateLabel string

+ ExperimentStateLabelUnixNano int64

+ ExternalTriggerFilename string

+ FilenamePattern string

+ Paused bool

+ func (ws *WritingState) ComputeState() WritingState

+ func (ws *WritingState) IsActive() bool

+ func (ws *WritingState) SetExperimentStateLabel(timestamp time.Time, stateLabel string) error

+ func (ws *WritingState) Start(filenamePattern, path string) error

+ func (ws *WritingState) Stop() error

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