scheduler

Documentation

Overview

• scheduler.go: Orchestrates timed data fetching tasks using Google Cloud Scheduler.
• Usage:
• - Configures and initiates scheduled jobs that trigger data retrieval and processing tasks.
• - Ensures tasks are executed at specified intervals, handling retries and logging as necessary.
• - Utilizes cron syntax to define job schedules.

* Dependencies:

• - Requires external scheduling APIs or local cron services.
• - Interacts with client modules (e.g., satellite.go, weather.go, soil.go) to set up data fetch operations.
• - Uses service modules (e.g., imageservice.go, soildataservice.go) to process and store the fetched data.
• Author(s): Shannon Thompson
• Created on: 04/12/2024

Index

• type SchedulerClient
  • func NewSchedulerClient(ctx context.Context, cfg *config.Config) (*SchedulerClient, error)
  • func (sc *SchedulerClient) DeleteJob(ctx context.Context, jobName string) error
  • func (sc *SchedulerClient) SetupJobs(ctx context.Context) error

Types

type SchedulerClient

type SchedulerClient struct {
	Client *scheduler.CloudSchedulerClient
	Cfg    *config.Config
}

func NewSchedulerClient

func NewSchedulerClient(ctx context.Context, cfg *config.Config) (*SchedulerClient, error)

func (*SchedulerClient) DeleteJob

func (sc *SchedulerClient) DeleteJob(ctx context.Context, jobName string) error

func (*SchedulerClient) SetupJobs

func (sc *SchedulerClient) SetupJobs(ctx context.Context) error