fetch

Documentation

Index

• Constants
• Variables
• 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 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 AvailableAfterDuration = time.Hour

const DailyDuration = 24 * time.Hour

const DailyOffsets = DailyDuration / OffsetDuration

const DataSetSize = 2000

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"

Variables

var InitialDataTime = time.Unix(1420070400, 0) // 2015-01-01T00:00:00Z

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 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