bufio

Documentation

Overview

Package io provider buffered io to provide an efficient mecanism to accumulate data prior to physically persisting it.

Index

• func ListToArrayOfCalibrationReadBatch(head *container.ImmutableList, size int) []apimodel.DayOfCalibrationReads
• func ListToArrayOfExerciseBatch(head *container.ImmutableList, size int) []apimodel.DayOfExercises
• func ListToArrayOfGlucoseReadBatch(head *container.ImmutableList, size int) []apimodel.DayOfGlucoseReads
• func ListToArrayOfInjectionBatch(head *container.ImmutableList, size int) []apimodel.DayOfInjections
• func ListToArrayOfMealBatch(head *container.ImmutableList, size int) []apimodel.DayOfMeals
• type BufferedCalibrationBatchWriter
  • func NewCalibrationWriterSize(wr glukitio.CalibrationBatchWriter, flushSize int) *BufferedCalibrationBatchWriter
  • func (b *BufferedCalibrationBatchWriter) Flush() (w glukitio.CalibrationBatchWriter, err error)
  • func (b *BufferedCalibrationBatchWriter) WriteCalibrationBatch(p []apimodel.CalibrationRead) (glukitio.CalibrationBatchWriter, error)
  • func (b *BufferedCalibrationBatchWriter) WriteCalibrationBatches(p []apimodel.DayOfCalibrationReads) (glukitio.CalibrationBatchWriter, error)
• type BufferedExerciseBatchWriter
  • func NewExerciseWriterSize(wr glukitio.ExerciseBatchWriter, flushSize int) *BufferedExerciseBatchWriter
  • func (b *BufferedExerciseBatchWriter) Flush() (glukitio.ExerciseBatchWriter, error)
  • func (b *BufferedExerciseBatchWriter) WriteExerciseBatch(p []apimodel.Exercise) (glukitio.ExerciseBatchWriter, error)
  • func (b *BufferedExerciseBatchWriter) WriteExerciseBatches(p []apimodel.DayOfExercises) (glukitio.ExerciseBatchWriter, error)
• type BufferedGlucoseReadBatchWriter
  • func NewGlucoseReadWriterSize(wr glukitio.GlucoseReadBatchWriter, flushSize int) *BufferedGlucoseReadBatchWriter
  • func (b *BufferedGlucoseReadBatchWriter) Flush() (w glukitio.GlucoseReadBatchWriter, err error)
  • func (b *BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatch(p []apimodel.GlucoseRead) (glukitio.GlucoseReadBatchWriter, error)
  • func (b *BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatches(p []apimodel.DayOfGlucoseReads) (glukitio.GlucoseReadBatchWriter, error)
• type BufferedInjectionBatchWriter
  • func NewInjectionWriterSize(wr glukitio.InjectionBatchWriter, flushSize int) *BufferedInjectionBatchWriter
  • func (b *BufferedInjectionBatchWriter) Flush() (glukitio.InjectionBatchWriter, error)
  • func (b *BufferedInjectionBatchWriter) WriteInjectionBatch(p []apimodel.Injection) (glukitio.InjectionBatchWriter, error)
  • func (b *BufferedInjectionBatchWriter) WriteInjectionBatches(p []apimodel.DayOfInjections) (glukitio.InjectionBatchWriter, error)
• type BufferedMealBatchWriter
  • func NewMealWriterSize(wr glukitio.MealBatchWriter, flushSize int) *BufferedMealBatchWriter
  • func (b *BufferedMealBatchWriter) Flush() (glukitio.MealBatchWriter, error)
  • func (b *BufferedMealBatchWriter) WriteMealBatch(p []apimodel.Meal) (glukitio.MealBatchWriter, error)
  • func (b *BufferedMealBatchWriter) WriteMealBatches(p []apimodel.DayOfMeals) (glukitio.MealBatchWriter, error)

Functions

func ListToArrayOfCalibrationReadBatch

func ListToArrayOfCalibrationReadBatch(head *container.ImmutableList, size int) []apimodel.DayOfCalibrationReads

func ListToArrayOfExerciseBatch

func ListToArrayOfExerciseBatch(head *container.ImmutableList, size int) []apimodel.DayOfExercises

func ListToArrayOfGlucoseReadBatch

func ListToArrayOfGlucoseReadBatch(head *container.ImmutableList, size int) []apimodel.DayOfGlucoseReads

func ListToArrayOfInjectionBatch

func ListToArrayOfInjectionBatch(head *container.ImmutableList, size int) []apimodel.DayOfInjections

func ListToArrayOfMealBatch

func ListToArrayOfMealBatch(head *container.ImmutableList, size int) []apimodel.DayOfMeals

Types

type BufferedCalibrationBatchWriter

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

func NewCalibrationWriterSize

func NewCalibrationWriterSize(wr glukitio.CalibrationBatchWriter, flushSize int) *BufferedCalibrationBatchWriter

NewCalibrationWriterSize returns a new Writer whose Buffer has the specified size.

func (*BufferedCalibrationBatchWriter) Flush

func (b *BufferedCalibrationBatchWriter) Flush() (w glukitio.CalibrationBatchWriter, err error)

Flush writes any buffered data to the underlying glukitio.Writer.

func (*BufferedCalibrationBatchWriter) WriteCalibrationBatch

func (b *BufferedCalibrationBatchWriter) WriteCalibrationBatch(p []apimodel.CalibrationRead) (glukitio.CalibrationBatchWriter, error)

WriteCalibration writes a single apimodel.DayOfCalibrationReads

func (*BufferedCalibrationBatchWriter) WriteCalibrationBatches

func (b *BufferedCalibrationBatchWriter) WriteCalibrationBatches(p []apimodel.DayOfCalibrationReads) (glukitio.CalibrationBatchWriter, error)

WriteCalibrationBatches writes the contents of p into the buffer. It returns the number of batches written. If nn < len(p), it also returns an error explaining why the write is short.

type BufferedExerciseBatchWriter

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

func NewExerciseWriterSize

func NewExerciseWriterSize(wr glukitio.ExerciseBatchWriter, flushSize int) *BufferedExerciseBatchWriter

NewExerciseWriterSize returns a new Writer whose buffer has the specified size.

func (*BufferedExerciseBatchWriter) Flush

func (b *BufferedExerciseBatchWriter) Flush() (glukitio.ExerciseBatchWriter, error)

Flush writes any buffered data to the underlying glukitio.Writer.

func (*BufferedExerciseBatchWriter) WriteExerciseBatch

func (b *BufferedExerciseBatchWriter) WriteExerciseBatch(p []apimodel.Exercise) (glukitio.ExerciseBatchWriter, error)

WriteExercise writes a single apimodel.DayOfExercises

func (*BufferedExerciseBatchWriter) WriteExerciseBatches

func (b *BufferedExerciseBatchWriter) WriteExerciseBatches(p []apimodel.DayOfExercises) (glukitio.ExerciseBatchWriter, error)

WriteExerciseBatches writes the contents of p into the buffer. It returns the number of batches written. If nn < len(p), it also returns an error explaining why the write is short.

type BufferedGlucoseReadBatchWriter

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

func NewGlucoseReadWriterSize

func NewGlucoseReadWriterSize(wr glukitio.GlucoseReadBatchWriter, flushSize int) *BufferedGlucoseReadBatchWriter

NewGlucoseReadWriterSize returns a new Writer whose Buffer has the specified size.

func (*BufferedGlucoseReadBatchWriter) Flush

func (b *BufferedGlucoseReadBatchWriter) Flush() (w glukitio.GlucoseReadBatchWriter, err error)

Flush writes any Buffered data to the underlying glukitio.Writer.

func (*BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatch

func (b *BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatch(p []apimodel.GlucoseRead) (glukitio.GlucoseReadBatchWriter, error)

WriteGlucose writes a single apimodel.DayOfGlucoseReads

func (*BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatches

func (b *BufferedGlucoseReadBatchWriter) WriteGlucoseReadBatches(p []apimodel.DayOfGlucoseReads) (glukitio.GlucoseReadBatchWriter, error)

WriteGlucoseReadBatches writes the contents of p into the Buffer. It returns the number of batches written. If nn < len(p), it also returns an error explaining why the write is short.

type BufferedInjectionBatchWriter

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

func NewInjectionWriterSize

func NewInjectionWriterSize(wr glukitio.InjectionBatchWriter, flushSize int) *BufferedInjectionBatchWriter

NewInjectionWriterSize returns a new Writer whose buffer has the specified size.

func (*BufferedInjectionBatchWriter) Flush

func (b *BufferedInjectionBatchWriter) Flush() (glukitio.InjectionBatchWriter, error)

Flush writes any buffered data to the underlying glukitio.Writer.

func (*BufferedInjectionBatchWriter) WriteInjectionBatch

func (b *BufferedInjectionBatchWriter) WriteInjectionBatch(p []apimodel.Injection) (glukitio.InjectionBatchWriter, error)

WriteInjection writes a single apimodel.DayOfInjections

func (*BufferedInjectionBatchWriter) WriteInjectionBatches

func (b *BufferedInjectionBatchWriter) WriteInjectionBatches(p []apimodel.DayOfInjections) (glukitio.InjectionBatchWriter, error)

WriteInjectionBatches writes the contents of p into the buffer. It returns the number of batches written. If nn < len(p), it also returns an error explaining why the write is short.

type BufferedMealBatchWriter

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

func NewMealWriterSize

func NewMealWriterSize(wr glukitio.MealBatchWriter, flushSize int) *BufferedMealBatchWriter

NewMealWriterSize returns a new Writer whose buffer has the specified size.

func (*BufferedMealBatchWriter) Flush

func (b *BufferedMealBatchWriter) Flush() (glukitio.MealBatchWriter, error)

Flush writes any buffered data to the underlying glukitio.Writer.

func (*BufferedMealBatchWriter) WriteMealBatch

func (b *BufferedMealBatchWriter) WriteMealBatch(p []apimodel.Meal) (glukitio.MealBatchWriter, error)

WriteMeal writes a single apimodel.DayOfMeals

func (*BufferedMealBatchWriter) WriteMealBatches

func (b *BufferedMealBatchWriter) WriteMealBatches(p []apimodel.DayOfMeals) (glukitio.MealBatchWriter, error)

WriteMealBatches writes the contents of p into the buffer. It returns the number of batches written. If nn < len(p), it also returns an error explaining why the write is short.