Documentation ¶
Index ¶
- Constants
- type BridgeActivities
- func (view *BridgeActivities) FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)
- func (view *BridgeActivities) FindByLinkId(linkId string) (BridgeActivityReadRow, error)
- func (view *BridgeActivities) Insert(activity *BridgeActivityInsertRow) error
- func (view *BridgeActivities) List(addressFilter BridgeActivitiesListAddressFilter, ...) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
- func (view *BridgeActivities) ListByNetworkAddress(network string, address string, order BridgeActivitiesListOrder, ...) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
- func (view *BridgeActivities) Update(activity *BridgeActivityReadRow) error
- type BridgeActivitiesFindByFilter
- type BridgeActivitiesListAddressFilter
- type BridgeActivitiesListFilter
- type BridgeActivitiesListOrder
- type BridgeActivityInsertRow
- type BridgeActivityReadRow
- type BridgePendingActivities
- func (thisView *BridgePendingActivities) Insert(activity *BridgePendingActivityInsertRow) error
- func (thisView *BridgePendingActivities) List(filter BridgePendingActivitiesFilter, order BridgePendingActivitiesOrder) ([]BridgePendingActivityReadRow, error)
- func (thisView *BridgePendingActivities) ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)
- func (thisView *BridgePendingActivities) ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)
- func (thisView *BridgePendingActivities) UpdateToProcessed(id int64) error
- type BridgePendingActivitiesFilter
- type BridgePendingActivitiesOrder
- type BridgePendingActivityInsertRow
- type BridgePendingActivityReadRow
Constants ¶
View Source
const TABLE_BRIDGE_ACTIVITIES = "view_bridge_activities"
View Source
const TABLE_BRIDGE_PENDING_ACTIVITIES = "view_bridge_pending_activities"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BridgeActivities ¶
type BridgeActivities struct {
// contains filtered or unexported fields
}
func NewBridgeActivities ¶
func NewBridgeActivities(handle *rdb.Handle) *BridgeActivities
func (*BridgeActivities) FindBy ¶
func (view *BridgeActivities) FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)
func (*BridgeActivities) FindByLinkId ¶
func (view *BridgeActivities) FindByLinkId(linkId string) (BridgeActivityReadRow, error)
func (*BridgeActivities) Insert ¶
func (view *BridgeActivities) Insert(activity *BridgeActivityInsertRow) error
func (*BridgeActivities) List ¶
func (view *BridgeActivities) List( addressFilter BridgeActivitiesListAddressFilter, filter BridgeActivitiesListFilter, order BridgeActivitiesListOrder, pagination *pagination_interface.Pagination, ) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
func (*BridgeActivities) ListByNetworkAddress ¶
func (view *BridgeActivities) ListByNetworkAddress( network string, address string, order BridgeActivitiesListOrder, pagination *pagination_interface.Pagination, ) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
func (*BridgeActivities) Update ¶
func (view *BridgeActivities) Update(activity *BridgeActivityReadRow) error
type BridgeActivitiesListAddressFilter ¶ added in v1.0.1
type BridgeActivityInsertRow ¶
type BridgeActivityInsertRow struct { BridgeType types.BridgeType `json:"bridgeType"` SourceBlockHeight int64 `json:"sourceBlockHeight"` SourceBlockTime *utctime.UTCTime `json:"sourceBlockTime"` SourceTransactionId string `json:"sourceTransactionId"` SourceChain string `json:"sourceChain"` SourceAddress string `json:"sourceAddress"` MaybeSourceSmartContractAddress *string `json:"sourceSmartContractAddress"` MaybeDestinationBlockHeight *int64 `json:"destinationBlockHeight"` MaybeDestinationBlockTime *utctime.UTCTime `json:"destinationBlockTime"` MaybeDestinationTransactionId *string `json:"destinationTransactionId"` DestinationChain string `json:"destinationChain"` DestinationAddress string `json:"destinationAddress"` MaybeDestinationSmartContractAddress *string `json:"destinationSmartContractAddress"` MaybeChannelId *string `json:"channelId"` LinkId string `json:"-"` Amount coin.Int `json:"amount"` MaybeDenom *string `json:"denom"` MaybeBridgeFeeAmount *coin.Int `json:"bridgeFeeAmount"` MaybeBridgeFeeDenom *string `json:"bridgeFeeDenom"` Status types.Status `json:"status"` }
type BridgeActivityReadRow ¶
type BridgePendingActivities ¶
type BridgePendingActivities struct {
// contains filtered or unexported fields
}
func NewBridgePendingActivities ¶
func NewBridgePendingActivities(handle *rdb.Handle) *BridgePendingActivities
func (*BridgePendingActivities) Insert ¶
func (thisView *BridgePendingActivities) Insert(activity *BridgePendingActivityInsertRow) error
func (*BridgePendingActivities) List ¶
func (thisView *BridgePendingActivities) List( filter BridgePendingActivitiesFilter, order BridgePendingActivitiesOrder, ) ([]BridgePendingActivityReadRow, error)
func (*BridgePendingActivities) ListAllUnprocessedIncoming ¶
func (thisView *BridgePendingActivities) ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)
func (*BridgePendingActivities) ListAllUnprocessedOutgoing ¶
func (thisView *BridgePendingActivities) ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)
func (*BridgePendingActivities) UpdateToProcessed ¶
func (thisView *BridgePendingActivities) UpdateToProcessed(id int64) error
type BridgePendingActivityInsertRow ¶
type BridgePendingActivityInsertRow struct { BlockHeight int64 `json:"blockHeight"` BlockTime *utctime.UTCTime `json:"blockTime"` MaybeTransactionId *string `json:"maybeTransactionId"` BridgeType types.BridgeType `json:"bridgeType"` LinkId string `json:"linkId"` Direction types.Direction `json:"direction"` FromChainId string `json:"fromChainId"` MaybeFromAddress *string `json:"maybeFromAddress"` MaybeFromSmartContractAddress *string `json:"maybeFromSmartContractAddress"` ToChainId string `json:"toChainId"` ToAddress string `json:"toAddress"` MaybeToSmartContractAddress *string `json:"maybeToSmartContractAddress"` MaybeChannelId *string `json:"maybeChannelId"` Amount coin.Int `json:"amount"` MaybeDenom *string `json:"maybeDenom"` MaybeBridgeFeeAmount *coin.Int `json:"maybeBridgeFeeAmount"` MaybeBridgeFeeDenom *string `json:"maybeBridgeFeeDenom"` Status types.Status `json:"status"` IsProcessed bool `json:"isProcessed"` }
Click to show internal directories.
Click to hide internal directories.