testutil

Documentation

Index

• func NewFloat64Segment(cpk cesium.ChannelKey, factory func(n int)) cesium.Segment
• func RandFloat64Slice(n int) []float64
• func RandomFloat64Bytes(n int) []byte
• func RandomFloat64Segment(n int) []byte
• func WriteFloat64Slice(s []float64) (*bytes.Buffer, error)
• type Device
  • func (d *Device) Start() error
  • func (d *Device) Stop() error
• type DeviceFactory
  • func (f DeviceFactory) New(dt cesium.Density, dr cesium.DataRate, fi cesium.TimeSpan) *Device

Functions

func NewFloat64Segment

func NewFloat64Segment(cpk cesium.ChannelKey, factory func(n int)) cesium.Segment

func RandFloat64Slice

func RandFloat64Slice(n int) []float64

func RandomFloat64Bytes

func RandomFloat64Bytes(n int) []byte

func RandomFloat64Segment

func RandomFloat64Segment(n int) []byte

func WriteFloat64Slice

func WriteFloat64Slice(s []float64) (*bytes.Buffer, error)

Types

type Device

type Device struct {
	Ctx           context.Context
	DB            cesium.DB
	DataType      cesium.Density
	DataRate      cesium.DataRate
	FlushInterval cesium.TimeSpan
	// contains filtered or unexported fields
}

func (*Device) Start

func (d *Device) Start() error

func (*Device) Stop

func (d *Device) Stop() error

type DeviceFactory

type DeviceFactory struct {
	Ctx context.Context
	DB  cesium.DB
}

func (DeviceFactory) New

func (f DeviceFactory) New(dt cesium.Density, dr cesium.DataRate, fi cesium.TimeSpan) *Device