saga

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

type CompensationHandler interface {
	Compensate(ctx context.Context, data map[string]interface{}) error
	GetName() string
}

type Compensator interface {
	CompensateStep(ctx context.Context, instance *SagaInstance, step *SagaStep) (*SagaStepResult, error)
	GetCompensationHandler(compensation string) (CompensationHandler, error)
}

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

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

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

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

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

type Orchestrator interface {
	ExecuteStep(ctx context.Context, instance *SagaInstance, step *SagaStep) (*SagaStepResult, error)
	GetStepHandler(action string) (StepHandler, error)
}

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

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

type RetryPolicy struct {
	MaxAttempts int           `json:"max_attempts"`
	Delay       time.Duration `json:"delay"`
	Backoff     string        `json:"backoff"` // linear, exponential
}

type SagaConfig struct {
	TimeoutDuration     time.Duration `json:"timeout_duration"`
	RetryAttempts       int           `json:"retry_attempts"`
	RetryDelay          time.Duration `json:"retry_delay"`
	CompensationTimeout time.Duration `json:"compensation_timeout"`
	EnableMetrics       bool          `json:"enable_metrics"`
	BatchSize           int           `json:"batch_size"`
}

type SagaDefinition struct {
	Name  string     `json:"name"`
	Steps []SagaStep `json:"steps"`
}

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

type SagaFilter struct {
	SagaType      string     `json:"saga_type,omitempty"`
	Status        SagaStatus `json:"status,omitempty"`
	TenantID      string     `json:"tenant_id,omitempty"`
	CorrelationID string     `json:"correlation_id,omitempty"`
	CreatedBy     string     `json:"created_by,omitempty"`
	StartedAfter  *time.Time `json:"started_after,omitempty"`
	StartedBefore *time.Time `json:"started_before,omitempty"`
}

type SagaInstance struct {
	ID               string     `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
	SagaType         string     `gorm:"type:varchar(255);not null;index" json:"saga_type"`
	Status           SagaStatus `gorm:"type:varchar(50);not null" json:"status"`
	CurrentStep      int        `gorm:"not null;default:0" json:"current_step"`
	Data             string     `gorm:"type:jsonb" json:"data"`
	CompletedSteps   string     `gorm:"type:jsonb" json:"completed_steps"`
	FailedSteps      string     `gorm:"type:jsonb" json:"failed_steps"`
	CompensatedSteps string     `gorm:"type:jsonb" json:"compensated_steps"`
	StartedAt        time.Time  `gorm:"not null" json:"started_at"`
	CompletedAt      *time.Time `json:"completed_at,omitempty"`
	LastError        string     `json:"last_error,omitempty"`
	TenantID         string     `gorm:"type:uuid;index" json:"tenant_id"`
	CorrelationID    string     `gorm:"type:uuid;index" json:"correlation_id"`
	CreatedBy        string     `gorm:"type:uuid" json:"created_by"`
	UpdatedAt        time.Time  `gorm:"autoUpdateTime" json:"updated_at"`
}

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

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

type SagaRepositoryConfig struct {
	TableName       string        `json:"table_name"`
	RetentionPeriod time.Duration `json:"retention_period"`
	EnableMetrics   bool          `json:"enable_metrics"`
}

type SagaStatistics struct {
	FromDate               time.Time            `json:"from_date"`
	ToDate                 time.Time            `json:"to_date"`
	TotalCount             int64                `json:"total_count"`
	StatusCounts           map[SagaStatus]int64 `json:"status_counts"`
	TypeCounts             map[string]int64     `json:"type_counts"`
	AverageDurationSeconds float64              `json:"average_duration_seconds"`
}

type SagaStatus string

type SagaStep struct {
	Name         string                 `json:"name"`
	Action       string                 `json:"action"`
	Compensation string                 `json:"compensation"`
	Parameters   map[string]interface{} `json:"parameters"`
	Timeout      time.Duration          `json:"timeout"`
	RetryPolicy  RetryPolicy            `json:"retry_policy"`
	DependsOn    []string               `json:"depends_on"`
	Critical     bool                   `json:"critical"`
}

type SagaStepResult struct {
	StepName    string                 `json:"step_name"`
	Success     bool                   `json:"success"`
	Error       error                  `json:"error,omitempty"`
	Data        map[string]interface{} `json:"data,omitempty"`
	Compensated bool                   `json:"compensated"`
	Duration    time.Duration          `json:"duration"`
	Attempt     int                    `json:"attempt"`
}

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

type StepHandler interface {
	Execute(ctx context.Context, data map[string]interface{}) (map[string]interface{}, error)
	GetName() string
}