Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterWorkflowsAndActivities ¶
RegisterWorkflowsAndActivities registers all workflows and activities with a Temporal worker.
Types ¶
type APIKeyProvider ¶
APIKeyProvider provides headers for API key authentication
func (*APIKeyProvider) GetHeaders ¶
GetHeaders implements client.HeadersProvider
type Service ¶
type Service struct {
service.ServiceParams
// contains filtered or unexported fields
}
Service handles Temporal workflow operations
func NewService ¶
func NewService(client *TemporalClient, cfg *config.TemporalConfig, log *logger.Logger, params service.ServiceParams) (*Service, error)
NewService creates a new Temporal service
func (*Service) StartBillingWorkflow ¶
func (s *Service) StartBillingWorkflow(ctx context.Context, input models.BillingWorkflowInput) (*models.BillingWorkflowResult, error)
StartBillingWorkflow starts a billing workflow
func (*Service) StartPlanPriceSync ¶ added in v1.0.23
func (s *Service) StartPlanPriceSync(ctx context.Context, planID string) (*dto.SyncPlanPricesResponse, error)
StartPlanPriceSync starts a price sync workflow for a plan
type TemporalClient ¶
TemporalClient wraps the Temporal SDK client for application use.
func NewTemporalClient ¶
func NewTemporalClient(cfg *config.TemporalConfig, log *logger.Logger) (*TemporalClient, error)
NewTemporalClient creates a new Temporal client using the given configuration.
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker manages the Temporal worker instance.
func NewWorker ¶
func NewWorker(client *TemporalClient, cfg config.TemporalConfig, log *logger.Logger) *Worker
NewWorker creates a new Temporal worker and registers workflows and activities.
func (*Worker) RegisterWithLifecycle ¶
RegisterWithLifecycle registers the worker with the fx lifecycle.
Source Files
Directories