repository

Documentation

Index

• type BurnEvent
• type Fee
• type Message
• type Status
• type Transfer

Types

type BurnEvent

type BurnEvent interface {
	Create(id string, amount int64, recipient string) error
	UpdateStatusSubmitted(id, scheduleID, transactionId string) error
	UpdateStatusCompleted(txId string) error
	UpdateStatusFailed(txId string) error
	// Returns BurnEvent by its Id (represented in {ethTxHash}-{logIndex})
	Get(txId string) (*entity.BurnEvent, error)
}

type Fee

type Fee interface {
	// Returns Fee. Returns nil if not found
	Get(txId string) (*entity.Fee, error)
	Create(entity *entity.Fee) error
	UpdateStatusCompleted(txId string) error
	UpdateStatusFailed(txId string) error
}

type Message

type Message interface {
	Create(message *entity.Message) error
	Exist(transferID, signature, hash string) (bool, error)
	Get(transferID string) ([]entity.Message, error)
	GetMessageWith(transferID, signature, hash string) (*entity.Message, error)
}

type Status

type Status interface {
	GetLastFetchedTimestamp(entityID string) (int64, error)
	UpdateLastFetchedTimestamp(entityID string, timestamp int64) error
	CreateTimestamp(entityID string, timestamp int64) error
}

type Transfer

type Transfer interface {
	// Returns Transfer. Returns nil if not found
	GetByTransactionId(txId string) (*entity.Transfer, error)
	// Returns Transfer with preloaded Fee table. Returns nil if not found
	GetWithFee(txId string) (*entity.Transfer, error)
	GetWithPreloads(txId string) (*entity.Transfer, error)
	GetUnprocessedTransfers() ([]*entity.Transfer, error)

	Create(ct *transfer.Transfer) (*entity.Transfer, error)
	SaveRecoveredTxn(ct *transfer.Transfer) error
	UpdateStatusCompleted(txId string) error

	UpdateStatusSignatureSubmitted(txId string) error
	UpdateStatusSignatureMined(txId string) error
	UpdateStatusSignatureFailed(txId string) error
}