view

package
v1.3.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 9, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

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 interface {
	FindByLinkId(linkId string) (BridgeActivityReadRow, error)
	FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)
	ListByChainAddress(
		chain string,
		address string,
		order BridgeActivitiesListOrder,
		pagination *pagination_interface.Pagination,
	) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
	List(
		addressFilter BridgeActivitiesListAddressFilter,
		filter BridgeActivitiesListFilter,
		order BridgeActivitiesListOrder,
		pagination *pagination_interface.Pagination,
	) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)
	Insert(activity *BridgeActivityInsertRow) error
	Update(activity *BridgeActivityReadRow) error
}

func NewBridgeActivitiesView added in v1.3.4 

func NewBridgeActivitiesView(handle *rdb.Handle) BridgeActivities

func NewMockBridgeActivitiesView added in v1.3.4 

func NewMockBridgeActivitiesView() BridgeActivities

type BridgeActivitiesFindByFilter 

type BridgeActivitiesFindByFilter struct {
	MaybeLinkId        *string
	MaybeTransactionId *string
}

type BridgeActivitiesListAddressFilter added in v1.0.1 

type BridgeActivitiesListAddressFilter = []BridgeActivitiesListAddressFilterCond

type BridgeActivitiesListAddressFilterCond added in v1.3.4 

type BridgeActivitiesListAddressFilterCond struct {
	Chain   string
	Address 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 BridgeActivitiesView added in v1.3.4 

type BridgeActivitiesView struct {
	// contains filtered or unexported fields
}

func (*BridgeActivitiesView) FindBy added in v1.3.4 

func (view *BridgeActivitiesView) FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)

func (*BridgeActivitiesView) FindByLinkId added in v1.3.4 

func (view *BridgeActivitiesView) FindByLinkId(linkId string) (BridgeActivityReadRow, error)

func (*BridgeActivitiesView) Insert added in v1.3.4 

func (view *BridgeActivitiesView) Insert(activity *BridgeActivityInsertRow) error

func (*BridgeActivitiesView) List added in v1.3.4 

func (view *BridgeActivitiesView) List(
	addressFilter BridgeActivitiesListAddressFilter,
	filter BridgeActivitiesListFilter,
	order BridgeActivitiesListOrder,
	pagination *pagination_interface.Pagination,
) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)

func (*BridgeActivitiesView) ListByChainAddress added in v1.3.4 

func (view *BridgeActivitiesView) ListByChainAddress(
	chain string,
	address string,
	order BridgeActivitiesListOrder,
	pagination *pagination_interface.Pagination,
) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)

func (*BridgeActivitiesView) Update added in v1.3.4 

func (view *BridgeActivitiesView) Update(activity *BridgeActivityReadRow) error

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 interface {
	ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)
	ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)
	List(
		filter BridgePendingActivitiesFilter,
		order BridgePendingActivitiesOrder,
	) ([]BridgePendingActivityReadRow, error)
	UpdateToProcessed(id int64) error
	Insert(activity *BridgePendingActivityInsertRow) error
}

func NewBridgePendingActivitiesView added in v1.3.4 

func NewBridgePendingActivitiesView(handle *rdb.Handle) BridgePendingActivities

func NewMockBridgePendingActivitiesView added in v1.3.4 

func NewMockBridgePendingActivitiesView() BridgePendingActivities

type BridgePendingActivitiesFilter 

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

type BridgePendingActivitiesOrder 

type BridgePendingActivitiesOrder struct {
	MaybeId *view.ORDER
}

type BridgePendingActivitiesView added in v1.3.4 

type BridgePendingActivitiesView struct {
	// contains filtered or unexported fields
}

func (*BridgePendingActivitiesView) Insert added in v1.3.4 

func (thisView *BridgePendingActivitiesView) Insert(activity *BridgePendingActivityInsertRow) error

func (*BridgePendingActivitiesView) List added in v1.3.4 

func (thisView *BridgePendingActivitiesView) List(
	filter BridgePendingActivitiesFilter,
	order BridgePendingActivitiesOrder,
) ([]BridgePendingActivityReadRow, error)

func (*BridgePendingActivitiesView) ListAllUnprocessedIncoming added in v1.3.4 

func (thisView *BridgePendingActivitiesView) ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)

func (*BridgePendingActivitiesView) ListAllUnprocessedOutgoing added in v1.3.4 

func (thisView *BridgePendingActivitiesView) ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)

func (*BridgePendingActivitiesView) UpdateToProcessed added in v1.3.4 

func (thisView *BridgePendingActivitiesView) 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"`
}

type BridgePendingActivityReadRow 

type BridgePendingActivityReadRow struct {
	BridgePendingActivityInsertRow

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

type MockBridgeActivitiesView added in v1.3.4 

type MockBridgeActivitiesView struct {
	mock.Mock
}

func (*MockBridgeActivitiesView) FindBy added in v1.3.4 

func (view *MockBridgeActivitiesView) FindBy(filter BridgeActivitiesFindByFilter) (BridgeActivityReadRow, error)

func (*MockBridgeActivitiesView) FindByLinkId added in v1.3.4 

func (view *MockBridgeActivitiesView) FindByLinkId(linkId string) (BridgeActivityReadRow, error)

func (*MockBridgeActivitiesView) Insert added in v1.3.4 

func (view *MockBridgeActivitiesView) Insert(activity *BridgeActivityInsertRow) error

func (*MockBridgeActivitiesView) List added in v1.3.4 

func (view *MockBridgeActivitiesView) List(
	addressFilter BridgeActivitiesListAddressFilter,
	filter BridgeActivitiesListFilter,
	order BridgeActivitiesListOrder,
	pagination *pagination_interface.Pagination,
) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)

func (*MockBridgeActivitiesView) ListByChainAddress added in v1.3.4 

func (view *MockBridgeActivitiesView) ListByChainAddress(
	chain string,
	address string,
	order BridgeActivitiesListOrder,
	pagination *pagination_interface.Pagination,
) ([]BridgeActivityReadRow, *pagination_interface.PaginationResult, error)

func (*MockBridgeActivitiesView) Update added in v1.3.4 

func (view *MockBridgeActivitiesView) Update(activity *BridgeActivityReadRow) error

type MockBridgePendingActivitiesView added in v1.3.4 

type MockBridgePendingActivitiesView struct {
	mock.Mock
}

func (*MockBridgePendingActivitiesView) Insert added in v1.3.4 

func (view *MockBridgePendingActivitiesView) Insert(activity *BridgePendingActivityInsertRow) error

func (*MockBridgePendingActivitiesView) List added in v1.3.4 

func (view *MockBridgePendingActivitiesView) List(
	filter BridgePendingActivitiesFilter,
	order BridgePendingActivitiesOrder,
) ([]BridgePendingActivityReadRow, error)

func (*MockBridgePendingActivitiesView) ListAllUnprocessedIncoming added in v1.3.4 

func (view *MockBridgePendingActivitiesView) ListAllUnprocessedIncoming() ([]BridgePendingActivityReadRow, error)

func (*MockBridgePendingActivitiesView) ListAllUnprocessedOutgoing added in v1.3.4 

func (view *MockBridgePendingActivitiesView) ListAllUnprocessedOutgoing() ([]BridgePendingActivityReadRow, error)

func (*MockBridgePendingActivitiesView) UpdateToProcessed added in v1.3.4 

func (view *MockBridgePendingActivitiesView) UpdateToProcessed(id int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.