temporal

Documentation

Index

• func CreateCronStarter(deps cronStarterDeps) error
• func CreateWorker(deps workerDeps) error
• type CronStarter
• type CronWorker
• type ExchangeActivities
  • func CreateActivities(deps activityDeps) *ExchangeActivities
  • func (impl *ExchangeActivities) GetRates(ctx context.Context) (result *model.ExchangeRatesModel, err error)
  • func (impl *ExchangeActivities) UpdateRates(ctx context.Context, doc *model.ExchangeRateDocument) error
• type LazyWorker
• type UpdateRatesWorkflow
  • func CreateUpdateRatesWorkflow(deps updateRatesWorkflowDeps) *UpdateRatesWorkflow
  • func (impl *UpdateRatesWorkflow) UpdateRates(ctx workflow.Context) (err error)

Functions

func CreateCronStarter

func CreateCronStarter(deps cronStarterDeps) error

func CreateWorker

func CreateWorker(deps workerDeps) error

Types

type CronStarter

type CronStarter struct {
	WorkflowID string
	RunID      string
	// contains filtered or unexported fields
}

type CronWorker

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

type ExchangeActivities

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

func CreateActivities

func CreateActivities(deps activityDeps) *ExchangeActivities

func (*ExchangeActivities) GetRates

func (impl *ExchangeActivities) GetRates(ctx context.Context) (result *model.ExchangeRatesModel, err error)

func (*ExchangeActivities) UpdateRates

func (impl *ExchangeActivities) UpdateRates(ctx context.Context, doc *model.ExchangeRateDocument) error

type LazyWorker

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

type UpdateRatesWorkflow

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

func CreateUpdateRatesWorkflow

func CreateUpdateRatesWorkflow(deps updateRatesWorkflowDeps) *UpdateRatesWorkflow

func (*UpdateRatesWorkflow) UpdateRates

func (impl *UpdateRatesWorkflow) UpdateRates(ctx workflow.Context) (err error)