extensions

type AppDatabaseTableRow struct {
	TableName               string
	PrimaryKeyColumnToValue map[string]string
	OtherColumnToValue      map[string]string
}

type AppDatabaseTableRowSelect struct {
	ColumnToValue map[string]string
}

type AsyncStateExecutionRow struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
	StateId                  string
	StateIdSequence          int32

	Status data_models.StateExecutionStatus

	WaitUntilCommands       types.JSONText
	WaitUntilCommandResults types.JSONText

	PreviousVersion int32 // for conditional check

	LastFailure types.JSONText

	Input types.JSONText
	Info  types.JSONText
}

type AsyncStateExecutionRowForUpdate struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	StateId         string
	StateIdSequence int32

	Status data_models.StateExecutionStatus

	WaitUntilCommands       types.JSONText
	WaitUntilCommandResults types.JSONText

	LastFailure types.JSONText

	PreviousVersion int32 // for conditional check
}

type AsyncStateExecutionRowForUpdateWithoutCommands struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	StateId         string
	StateIdSequence int32

	Status data_models.StateExecutionStatus

	LastFailure types.JSONText

	PreviousVersion int32 // for conditional check
}

type AsyncStateExecutionSelectFilter struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	StateId         string
	StateIdSequence int32
}

type ErrorChecker interface {
	IsDupEntryError(err error) bool
	IsNotFoundError(err error) bool
	IsTimeoutError(err error) bool
	IsThrottlingError(err error) bool
	IsConditionalUpdateFailure(err error) bool
}

type ExecutionVisibilityRow struct {
	Namespace                string
	ProcessId                string
	ProcessExecutionId       uuid.UUID
	ProcessExecutionIdString string
	ProcessTypeName          string
	Status                   data_models.ProcessExecutionStatus
	StartTime                time.Time
	CloseTime                time.Time
}

type ImmediateTaskRangeDeleteFilter struct {
	ShardId int32

	MinTaskSequenceInclusive int64
	MaxTaskSequenceInclusive int64
}

type ImmediateTaskRow struct {
	ShardId      int32
	TaskSequence int64

	TaskType data_models.ImmediateTaskType

	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
	StateId                  string
	StateIdSequence          int32

	Info types.JSONText
}

type ImmediateTaskRowDeleteFilter struct {
	ShardId      int32
	TaskSequence int64

	OptionalPartitionKey *data_models.PartitionKey
}

type ImmediateTaskRowForInsert struct {
	ShardId  int32
	TaskType data_models.ImmediateTaskType

	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
	// StateId and StateIdSequence will be "" and 0 when TaskType is persistence.ImmediateTaskTypeNewLocalQueueMessages
	StateId         string
	StateIdSequence int32

	Info types.JSONText
}

type LatestProcessExecutionRow struct {
	Namespace          string
	ProcessId          string
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
}

type LocalAttributeRow struct {
	ProcessExecutionId       uuid.UUID
	ProcessExecutionIdString string
	Key                      string
	Value                    types.JSONText
}

type LocalQueueMessageRow struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	QueueName string

	DedupId uuid.UUID
	// See the top of the file for why we need this field
	DedupIdString string

	Payload types.JSONText
}

type ProcessExecutionRow struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	ShardId int32

	Status                 data_models.ProcessExecutionStatus
	HistoryEventIdSequence int32

	StateExecutionSequenceMaps types.JSONText
	StateExecutionLocalQueues  types.JSONText

	Namespace string

	ProcessId                 string
	StartTime                 time.Time
	TimeoutSeconds            int32
	Info                      types.JSONText
	GracefulCompleteRequested bool
}

type ProcessExecutionRowForUpdate struct {
	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string

	ShardId int32

	Status                 data_models.ProcessExecutionStatus
	HistoryEventIdSequence int32

	StateExecutionSequenceMaps types.JSONText
	StateExecutionLocalQueues  types.JSONText

	GracefulCompleteRequested bool
}

type SQLAdminDBSession interface {
	CreateDatabase(ctx context.Context, database string) error
	DropDatabase(ctx context.Context, database string) error
	ExecuteSchemaDDL(ctx context.Context, ddlQuery string) error
	Close() error
}

type SQLDBExtension interface {
	// StartDBSession starts the session for regular business logic
	StartDBSession(cfg *config.SQL) (SQLDBSession, error)
	// StartAdminDBSession starts the session for admin operation like DDL
	StartAdminDBSession(cfg *config.SQL) (SQLAdminDBSession, error)
}

type SQLDBSession interface {
	ErrorChecker
	StartTransaction(ctx context.Context, opts *sql.TxOptions) (SQLTransaction, error)
	Close() error
	// contains filtered or unexported methods
}

type SQLTransaction interface {
	Commit() error
	Rollback() error
	// contains filtered or unexported methods
}

type TimerTaskRangeSelectFilter struct {
	ShardId int32

	MaxFireTimeUnixSecondsInclusive int64
	PageSize                        int32
}

type TimerTaskRow struct {
	ShardId             int32
	FireTimeUnixSeconds int64
	TaskSequence        int64

	TaskType data_models.TimerTaskType

	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
	StateId                  string
	StateIdSequence          int32

	Info types.JSONText
}

type TimerTaskRowDeleteFilter struct {
	ShardId             int32
	FireTimeUnixSeconds int64
	TaskSequence        int64

	OptionalPartitionKey *data_models.PartitionKey
}

type TimerTaskRowForInsert struct {
	ShardId             int32
	FireTimeUnixSeconds int64
	TaskType            data_models.TimerTaskType

	ProcessExecutionId uuid.UUID
	// See the top of the file for why we need this field
	ProcessExecutionIdString string
	StateId                  string
	StateIdSequence          int32

	Info types.JSONText
}

type TimerTaskSelectByTimestampsFilter struct {
	ShardId int32

	FireTimeUnixSeconds      []int64
	MinTaskSequenceInclusive int64
}