view

Documentation

Index

• Constants
• type BridgeActivities
  • func NewBridgeActivities(handle *rdb.Handle) *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 NewBridgePendingActivities(handle *rdb.Handle) *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

const TABLE_BRIDGE_ACTIVITIES = "view_bridge_activities"

const TABLE_BRIDGE_PENDING_ACTIVITIES = "view_bridge_pending_activities"

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 BridgeActivitiesFindByFilter

type BridgeActivitiesFindByFilter struct {
	MaybeLinkId        *string
	MaybeTransactionId *string
}

type BridgeActivitiesListAddressFilter

type BridgeActivitiesListAddressFilter struct {
	MaybeCronosAddress         *string
	MaybeCryptoOrgChainAddress *string
}

type BridgeActivitiesListFilter

type BridgeActivitiesListFilter struct {
	MaybeStatus      *types.Status
	MaybeIdGt        *string
	MaybeCreatedAtLt *utctime.UTCTime
	MaybeCreatedAtGt *utctime.UTCTime
	MaybeUpdatedAtGt *utctime.UTCTime
}

type BridgeActivitiesListOrder

type BridgeActivitiesListOrder struct {
	MaybeSourceBlockTime *view.ORDER
}

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 BridgeActivityReadRow struct {
	BridgeActivityInsertRow

	Id        int64            `json:"id"`
	UUID      string           `json:"uuid"`
	CreatedAt *utctime.UTCTime `json:"createdAt"`
	UpdatedAt *utctime.UTCTime `json:"updatedAt"`
}

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 BridgePendingActivitiesFilter

type BridgePendingActivitiesFilter struct {
	MaybeDirections  []types.Direction
	MaybeIsProcessed *bool
}

type BridgePendingActivitiesOrder

type BridgePendingActivitiesOrder struct {
	MaybeId *view.ORDER
}

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"`
}

type BridgePendingActivityReadRow

type BridgePendingActivityReadRow struct {
	BridgePendingActivityInsertRow

	Id        int64            `json:"id"`
	CreatedAt *utctime.UTCTime `json:"createdAt"`
	UpdatedAt *utctime.UTCTime `json:"updatedAt"`
}