recovery

type ParticipantRecoverable interface {
	Recoverable
	// RecoverParticipant is called for each active participant of this flow type
	RecoverParticipant(ctx context.Context, participantID string, participant interface{}, registry *RecoveryRegistry) error
	// GetFlowType returns the flow type this recoverable handles
	GetFlowType() models.FlowType
}

type Recoverable interface {
	// RecoverState is called during application startup to restore component state
	RecoverState(ctx context.Context, registry *RecoveryRegistry) error
}

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

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

type ResponseHandlerRecoveryCallback func(ResponseHandlerRecoveryInfo) error

type ResponseHandlerRecoveryInfo struct {
	PhoneNumber   string
	ParticipantID string
	FlowType      models.FlowType
	HandlerType   string
	TTL           time.Duration
}

type TimerRecoveryInfo struct {
	ParticipantID string
	FlowType      models.FlowType
	StateType     models.StateType
	DataKey       models.DataKey
	OriginalTTL   time.Duration
	CreatedAt     time.Time
}