integrate

Documentation

Index

• func InjectErrors(sim model.SimContext, output model.DataSinkBytes, frequency float64) model.DataSinkBytes
• func MakeModelApp(missionStartTime model.VirtualTime, controller *component.SimController, ...) timesync.ProtocolImpl
• func MakePacketApp(missionStartTime model.VirtualTime, ...) timesync.ProtocolImpl
• func MakeTestApp() timesync.ProtocolImpl
• type InjectedSink
  • func (i *InjectedSink) Subscribe(callback func()) (cancel func())
  • func (i *InjectedSink) TryWrite(from []byte) int
• type ModelApp
  • func (t *ModelApp) Sync(pendingBytes int, nowRaw int64, writeData []byte) (expireAtRaw int64, readData []byte)
• type TestApp
  • func (t *TestApp) Sync(pendingBytes int, nowRaw int64, writeData []byte) (expireAtRaw int64, readData []byte)

Functions

func InjectErrors

func InjectErrors(sim model.SimContext, output model.DataSinkBytes, frequency float64) model.DataSinkBytes

func MakeModelApp

func MakeModelApp(missionStartTime model.VirtualTime, controller *component.SimController, source model.DataSourceBytes, sink model.DataSinkBytes, recorder *component.CSVByteRecorder) timesync.ProtocolImpl

func MakePacketApp

func MakePacketApp(missionStartTime model.VirtualTime, main func(model.SimContext, fwmodel.PacketSource, fwmodel.PacketSink, *component.CSVByteRecorder), injectErrors bool, recordPath string) timesync.ProtocolImpl

func MakeTestApp

func MakeTestApp() timesync.ProtocolImpl

Types

type InjectedSink

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

func (*InjectedSink) Subscribe

func (i *InjectedSink) Subscribe(callback func()) (cancel func())

func (*InjectedSink) TryWrite

func (i *InjectedSink) TryWrite(from []byte) int

type ModelApp

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

func (*ModelApp) Sync

func (t *ModelApp) Sync(pendingBytes int, nowRaw int64, writeData []byte) (expireAtRaw int64, readData []byte)

type TestApp

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

func (*TestApp) Sync

func (t *TestApp) Sync(pendingBytes int, nowRaw int64, writeData []byte) (expireAtRaw int64, readData []byte)