seg

Documentation

Index

• func GenSlice[T any](n int, fac func(int) T) []T
• func New(c cesium.Channel, fac DataFactory, start cesium.TimeStamp, ...) cesium.Segment
• func NewSet(c cesium.Channel, fac DataFactory, start cesium.TimeStamp, ...) []cesium.Segment
• type DataFactory
  • func DataTypeFactory(dt cesium.Density) DataFactory
• type MultiSequentialFactory
  • func (m *MultiSequentialFactory) Next() (s []cesium.Segment)
  • func (m *MultiSequentialFactory) NextN(n int) (s []cesium.Segment)
• type RandomFloat64Factory
  • func (s *RandomFloat64Factory) Generate(n int) []byte
• type SequentialFactory
  • func NewSequentialFactory(fac DataFactory, span cesium.TimeSpan, c ...cesium.Channel) SequentialFactory
• type SequentialFloat64Factory
  • func (s *SequentialFloat64Factory) Generate(n int) []byte
• type StreamCreate
  • func (sc *StreamCreate) CloseAndWait() error
  • func (sc *StreamCreate) Create() cesium.CreateRequest
  • func (sc *StreamCreate) CreateCRequestsOfN(c, n int) []cesium.CreateRequest
  • func (sc *StreamCreate) CreateN(n int) cesium.CreateRequest
• type StreamRetrieve
  • func (sr StreamRetrieve) All() []cesium.Segment

Functions

func GenSlice

func GenSlice[T any](n int, fac func(int) T) []T

func New

func New(c cesium.Channel, fac DataFactory, start cesium.TimeStamp, span cesium.TimeSpan) cesium.Segment

func NewSet

func NewSet(c cesium.Channel, fac DataFactory, start cesium.TimeStamp, span cesium.TimeSpan, n int) []cesium.Segment

Types

type DataFactory

type DataFactory interface {
	Generate(n int) []byte
}

func DataTypeFactory

func DataTypeFactory(dt cesium.Density) DataFactory

type MultiSequentialFactory

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

func (*MultiSequentialFactory) Next

func (m *MultiSequentialFactory) Next() (s []cesium.Segment)

func (*MultiSequentialFactory) NextN

func (m *MultiSequentialFactory) NextN(n int) (s []cesium.Segment)

type RandomFloat64Factory

type RandomFloat64Factory struct {
	Cache bool
	// contains filtered or unexported fields
}

func (*RandomFloat64Factory) Generate

func (s *RandomFloat64Factory) Generate(n int) []byte

type SequentialFactory

type SequentialFactory interface {
	Next() []cesium.Segment
	NextN(n int) []cesium.Segment
}

func NewSequentialFactory

func NewSequentialFactory(fac DataFactory, span cesium.TimeSpan, c ...cesium.Channel) SequentialFactory

type SequentialFloat64Factory

type SequentialFloat64Factory struct {
	Cache bool
	// contains filtered or unexported fields
}

func (*SequentialFloat64Factory) Generate

func (s *SequentialFloat64Factory) Generate(n int) []byte

type StreamCreate

type StreamCreate struct {
	SequentialFactory
	Req chan<- cesium.CreateRequest
	Res <-chan cesium.CreateResponse
}

func (*StreamCreate) CloseAndWait

func (sc *StreamCreate) CloseAndWait() error

func (*StreamCreate) Create

func (sc *StreamCreate) Create() cesium.CreateRequest

func (*StreamCreate) CreateCRequestsOfN

func (sc *StreamCreate) CreateCRequestsOfN(c, n int) []cesium.CreateRequest

func (*StreamCreate) CreateN

func (sc *StreamCreate) CreateN(n int) cesium.CreateRequest

type StreamRetrieve

type StreamRetrieve struct {
	Res <-chan cesium.RetrieveResponse
}

func (StreamRetrieve) All

func (sr StreamRetrieve) All() []cesium.Segment