fetch

Documentation

Index

• Constants
• func NewTaskCreate(providerSessionID string, dataSourceID string) (*task.TaskCreate, error)
• func TaskName(providerSessionID string) string
• type BySystemTime
  • func (b BySystemTime) Len() int
  • func (b BySystemTime) Less(left int, right int) bool
  • func (b BySystemTime) Swap(left int, right int)
• type DeviceInfo
  • func NewDeviceInfo() *DeviceInfo
  • func NewDeviceInfoFromDataSet(dataSet *data.DataSet) (*DeviceInfo, error)
  • func NewDeviceInfoFromDevice(device *dexcom.Device) (*DeviceInfo, error)
  • func NewDeviceInfoFromMultiple() *DeviceInfo
  • func (d *DeviceInfo) IsEmpty() bool
  • func (d *DeviceInfo) IsG5Mobile() bool
  • func (d *DeviceInfo) Merge(deviceInfo *DeviceInfo) (*DeviceInfo, error)
• type Runner
  • func NewRunner(logger log.Logger, versionReporter version.Reporter, authClient auth.Client, ...) (*Runner, error)
  • func (r *Runner) AuthClient() auth.Client
  • func (r *Runner) CanRunTask(tsk *task.Task) bool
  • func (r *Runner) DataClient() dataClient.Client
  • func (r *Runner) DexcomClient() dexcom.Client
  • func (r *Runner) Logger() log.Logger
  • func (r *Runner) Run(ctx context.Context, tsk *task.Task)
  • func (r *Runner) VersionReporter() version.Reporter
• type TaskRunner
  • func NewTaskRunner(rnnr *Runner, tsk *task.Task) (*TaskRunner, error)
  • func (t *TaskRunner) Run(ctx context.Context) error

Constants

const (
	AvailableAfterDurationMaximum = 75 * time.Minute
	AvailableAfterDurationMinimum = 45 * time.Minute
	DataSetSize                   = 2000
	TaskDurationMaximum           = 5 * time.Minute
)

const DailyDuration = 24 * time.Hour

const DailyOffsets = DailyDuration / OffsetDuration

const DatasetClientName = Type

const DatasetClientVersion = "1.0.0"

const MaximumOffsets = (14 * time.Hour) / OffsetDuration // Maximum timezone offset is +14:00

const MinimumOffsets = (-12 * time.Hour) / OffsetDuration // Minimum timezone offset is -12:00

const OffsetDuration = 30 * time.Minute // Duration between timezone offsets we scan for

const Type = "org.tidepool.oauth.dexcom.fetch"

Functions

func NewTaskCreate

func NewTaskCreate(providerSessionID string, dataSourceID string) (*task.TaskCreate, error)

func TaskName

func TaskName(providerSessionID string) string

Types

type BySystemTime

type BySystemTime []data.Datum

func (BySystemTime) Len

func (b BySystemTime) Len() int

func (BySystemTime) Less

func (b BySystemTime) Less(left int, right int) bool

func (BySystemTime) Swap

func (b BySystemTime) Swap(left int, right int)

type DeviceInfo

type DeviceInfo struct {
	DeviceID           string
	DeviceModel        string
	DeviceSerialNumber string
}

func NewDeviceInfo

func NewDeviceInfo() *DeviceInfo

func NewDeviceInfoFromDataSet

func NewDeviceInfoFromDataSet(dataSet *data.DataSet) (*DeviceInfo, error)

func NewDeviceInfoFromDevice

func NewDeviceInfoFromDevice(device *dexcom.Device) (*DeviceInfo, error)

func NewDeviceInfoFromMultiple

func NewDeviceInfoFromMultiple() *DeviceInfo

func (*DeviceInfo) IsEmpty

func (d *DeviceInfo) IsEmpty() bool

func (*DeviceInfo) IsG5Mobile

func (d *DeviceInfo) IsG5Mobile() bool

func (*DeviceInfo) Merge

func (d *DeviceInfo) Merge(deviceInfo *DeviceInfo) (*DeviceInfo, error)

type Runner

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

func NewRunner

func NewRunner(logger log.Logger, versionReporter version.Reporter, authClient auth.Client, dataClient dataClient.Client, dexcomClient dexcom.Client) (*Runner, error)

func (*Runner) AuthClient

func (r *Runner) AuthClient() auth.Client

func (*Runner) CanRunTask

func (r *Runner) CanRunTask(tsk *task.Task) bool

func (*Runner) DataClient

func (r *Runner) DataClient() dataClient.Client

func (*Runner) DexcomClient

func (r *Runner) DexcomClient() dexcom.Client

func (*Runner) Logger

func (r *Runner) Logger() log.Logger

func (*Runner) Run

func (r *Runner) Run(ctx context.Context, tsk *task.Task)

func (*Runner) VersionReporter

func (r *Runner) VersionReporter() version.Reporter

type TaskRunner

type TaskRunner struct {
	*Runner
	// contains filtered or unexported fields
}

func NewTaskRunner

func NewTaskRunner(rnnr *Runner, tsk *task.Task) (*TaskRunner, error)

func (*TaskRunner) Run

func (t *TaskRunner) Run(ctx context.Context) error