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 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) DataSourceClient() dataSource.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 time zone offset is +14:00

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

const OffsetDuration = 30 * time.Minute // Duration between time zone 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.Data

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, dataSourceClient dataSource.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) DataSourceClient

func (r *Runner) DataSourceClient() dataSource.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