Documentation
¶
Index ¶
- Constants
- type Store
- func (s *Store) CountInProgress() (int64, error)
- func (s *Store) CreateEvent(event *store.Event) error
- func (s *Store) GetConfirmedEvents(currentBlock uint64, minBlockConfirmation uint64, limit int) ([]store.Event, error)
- func (s *Store) GetEvent(eventID string) (*store.Event, error)
- func (s *Store) ResetInProgressEventsToConfirmed() (int64, error)
- func (s *Store) UpdateBroadcastedTxHash(eventID, txHash string) error
- func (s *Store) UpdateStatus(eventID, status, errorMsg string) error
- func (s *Store) UpdateStatusAndBlockHeight(eventID, status string, blockHeight uint64) error
Constants ¶
const ( StatusConfirmed = "CONFIRMED" // StatusInProgress - TSS signing is in progress StatusInProgress = "IN_PROGRESS" // StatusBroadcasted - Transaction sent to external chain (for sign events) StatusBroadcasted = "BROADCASTED" // StatusCompleted - Successfully completed (key events: vote sent, sign events: confirmed) StatusCompleted = "COMPLETED" // StatusReverted - Event reverted StatusReverted = "REVERTED" // StatusExpired - Event expired (for key events) StatusExpired = "EXPIRED" )
Event statuses for TSS operations
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store provides database access for TSS events.
func (*Store) CountInProgress ¶ added in v0.0.14
CountInProgress returns the number of events with status IN_PROGRESS (TSS or broadcast in flight). Used by the coordinator to cap how many new events to fetch.
func (*Store) CreateEvent ¶
CreateEvent stores a new PCEvent. Returns error if event already exists.
func (*Store) GetConfirmedEvents ¶ added in v0.0.13
func (s *Store) GetConfirmedEvents(currentBlock uint64, minBlockConfirmation uint64, limit int) ([]store.Event, error)
GetConfirmedEvents returns confirmed events that are ready to be processed. Events are confirmed if they are at least `minBlockConfirmation` blocks behind the current block and not expired. If limit > 0, at most limit events are returned; otherwise all matching events are returned.
func (*Store) ResetInProgressEventsToConfirmed ¶ added in v0.0.13
ResetInProgressEventsToConfirmed resets all IN_PROGRESS events to CONFIRMED status. This should be called on node startup to handle cases where the node crashed while events were in progress, causing sessions to be lost from memory.
func (*Store) UpdateBroadcastedTxHash ¶ added in v0.0.13
UpdateBroadcastedTxHash updates the BroadcastedTxHash field for an event (used after broadcasting).
func (*Store) UpdateStatus ¶
UpdateStatus updates the status of an event. Note: errorMsg is logged but not stored (Event model doesn't have error_msg field).
Source Files