worker

Documentation

Index

• Constants
• func PageCacheWorkflow(ctx temporalworkflow.Context, iteration int) error
• func Start(ctx context.Context, cfg Config) error
• type Activities
  • func (a *Activities) RefreshCaches(ctx context.Context) error
  • func (a *Activities) RefreshLatestCaches(ctx context.Context) error
• type Config

Constants

const (
	TaskQueue  = "api-page-cache"
	WorkflowID = "api-page-cache"
)

Functions

func PageCacheWorkflow

func PageCacheWorkflow(ctx temporalworkflow.Context, iteration int) error

PageCacheWorkflow is a long-running workflow that refreshes all page caches every 30s. It uses continue-as-new after 60 iterations (~30 min) to keep workflow history bounded.

func Start

func Start(ctx context.Context, cfg Config) error

Start connects to Temporal, registers workflows and activities, then runs the page cache worker. It blocks until ctx is cancelled or an error occurs.

Types

type Activities

type Activities struct {
	Log *slog.Logger
	API *handlers.API
	// contains filtered or unexported fields
}

Activities holds the logger and API deps for the refresh activity.

func (*Activities) RefreshCaches

func (a *Activities) RefreshCaches(ctx context.Context) error

RefreshCaches refreshes all page cache entries, writing results to Postgres.

func (*Activities) RefreshLatestCaches

func (a *Activities) RefreshLatestCaches(ctx context.Context) error

RefreshLatestCaches refreshes just the fast-cadence entries (latest slots slice).

type Config

type Config struct {
	Log *slog.Logger
	API *handlers.API
}

Config configures the page cache worker.