service

package
v0.70.4 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Account 

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

func NewAccount 

func NewAccount(aStore AccountStore, bStore BalanceStore, log *logging.Logger) *Account

func (*Account) AddAccountBalance 

func (a *Account) AddAccountBalance(b entities.AccountBalance) error

func (*Account) Flush 

func (a *Account) Flush(ctx context.Context) error

func (*Account) GetAll 

func (a *Account) GetAll(ctx context.Context) ([]entities.Account, error)

func (*Account) GetByID 

func (a *Account) GetByID(ctx context.Context, id entities.AccountID) (entities.Account, error)

func (*Account) ObserveAccountBalances 

func (a *Account) ObserveAccountBalances(ctx context.Context, retries int, marketID string,
	partyID string, asset string, ty vega.AccountType,
) (accountCh <-chan []entities.AccountBalance, ref uint64)

func (*Account) Obtain 

func (a *Account) Obtain(ctx context.Context, acc *entities.Account) error

func (*Account) Query 

func (a *Account) Query(ctx context.Context, filter entities.AccountFilter) ([]entities.Account, error)

func (*Account) QueryAggregatedBalances 

func (a *Account) QueryAggregatedBalances(ctx context.Context, filter entities.AccountFilter, dateRange entities.DateRange, pagination entities.CursorPagination) (*[]entities.AggregatedBalance, entities.PageInfo, error)

func (*Account) QueryBalances 

func (a *Account) QueryBalances(ctx context.Context, filter entities.AccountFilter, pagination entities.CursorPagination) ([]entities.AccountBalance, entities.PageInfo, error)

type AccountSource 

type AccountSource interface {
	GetByID(ctx context.Context, id entities.AccountID) (entities.Account, error)
}

type AccountStore 

type AccountStore interface {
	GetByID(ctx context.Context, id entities.AccountID) (entities.Account, error)
	GetAll(ctx context.Context) ([]entities.Account, error)
	Obtain(ctx context.Context, a *entities.Account) error
	Query(ctx context.Context, filter entities.AccountFilter) ([]entities.Account, error)
	QueryBalances(ctx context.Context, filter entities.AccountFilter, pagination entities.CursorPagination) ([]entities.AccountBalance, entities.PageInfo, error)
}

type Asset 

type Asset struct{ *sqlstore.Assets }

func NewAsset 

func NewAsset(store *sqlstore.Assets) *Asset

type BalanceStore 

type BalanceStore interface {
	Flush(ctx context.Context) ([]entities.AccountBalance, error)
	Add(b entities.AccountBalance) error
	Query(ctx context.Context, filter entities.AccountFilter, dateRange entities.DateRange, pagination entities.CursorPagination) (*[]entities.AggregatedBalance, entities.PageInfo, error)
}

type Block 

type Block struct{ *sqlstore.Blocks }

func NewBlock 

func NewBlock(store *sqlstore.Blocks) *Block

type Chain 

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

func NewChain 

func NewChain(store ChainStore) *Chain

func (*Chain) GetChainID 

func (c *Chain) GetChainID() (string, error)

GetChainID returns the current chain ID stored in the database (if one is set). 

If one is not set, return empty string and no error. If an error occurs,
return empty string and an that error.

It caches the result of calling to the store, so that once we have successfully
retrieved a chain ID, we don't ask again.

func (*Chain) SetChainID 

func (c *Chain) SetChainID(chainID string) error

type ChainStore 

type ChainStore interface {
	Get(context.Context) (entities.Chain, error)
	Set(context.Context, entities.Chain) error
}

type Checkpoint 

type Checkpoint struct{ *sqlstore.Checkpoints }

func NewCheckpoint 

func NewCheckpoint(store *sqlstore.Checkpoints) *Checkpoint

type Config 

type Config struct {
	Level encoding.LogLevel `long:"log-level"`
}

Config represent the configuration of the candle package.

func NewDefaultConfig 

func NewDefaultConfig() Config

NewDefaultConfig creates an instance of the package specific configuration, given a pointer to a logger instance to be used for logging within the package.

type Delegation 

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

func NewDelegation 

func NewDelegation(store delegationStore, log *logging.Logger) *Delegation

func (*Delegation) Add 

func (d *Delegation) Add(ctx context.Context, delegation entities.Delegation) error

func (*Delegation) Get 

func (d *Delegation) Get(ctx context.Context, partyID *string, nodeID *string, epoch *int64, p entities.Pagination) ([]entities.Delegation, entities.PageInfo, error)

func (*Delegation) GetAll 

func (d *Delegation) GetAll(ctx context.Context) ([]entities.Delegation, error)

func (*Delegation) GetDelegationSubscribersCount 

func (d *Delegation) GetDelegationSubscribersCount() int32

func (*Delegation) Observe 

func (d *Delegation) Observe(ctx context.Context, retries int, partyID, nodeID string) (rewardCh <-chan []entities.Delegation, ref uint64)

type Deposit 

type Deposit struct{ *sqlstore.Deposits }

func NewDeposit 

func NewDeposit(store *sqlstore.Deposits) *Deposit

type Epoch 

type Epoch struct{ *sqlstore.Epochs }

func NewEpoch 

func NewEpoch(store *sqlstore.Epochs) *Epoch

type EthereumKeyRotation 

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

func NewEthereumKeyRotation 

func NewEthereumKeyRotation(service ethereumKeyRotationsService, log *logging.Logger) *EthereumKeyRotation

func (*EthereumKeyRotation) Add 

func (e *EthereumKeyRotation) Add(ctx context.Context, kr entities.EthereumKeyRotation) error

func (*EthereumKeyRotation) List 

func (e *EthereumKeyRotation) List(ctx context.Context,
	nodeID entities.NodeID,
	pagination entities.CursorPagination,
) ([]entities.EthereumKeyRotation, entities.PageInfo, error)

type Governance 

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

func NewGovernance 

func NewGovernance(pStore ProposalStore, vStore VoteStore, log *logging.Logger) *Governance

func (*Governance) AddProposal 

func (g *Governance) AddProposal(ctx context.Context, p entities.Proposal) error

func (*Governance) AddVote 

func (g *Governance) AddVote(ctx context.Context, v entities.Vote) error

func (*Governance) GetByPartyConnection 

func (g *Governance) GetByPartyConnection(ctx context.Context, partyID string, pagination entities.CursorPagination) ([]entities.Vote, entities.PageInfo, error)

func (*Governance) GetConnection added in v0.63.0 

func (g *Governance) GetConnection(
	ctx context.Context,
	proposalID, partyID *string,
	pagination entities.CursorPagination,
) ([]entities.Vote, entities.PageInfo, error)

func (*Governance) GetNoVotesForProposal 

func (g *Governance) GetNoVotesForProposal(ctx context.Context, proposalID string) ([]entities.Vote, error)

func (*Governance) GetProposalByID 

func (g *Governance) GetProposalByID(ctx context.Context, id string) (entities.Proposal, error)

func (*Governance) GetProposalByReference 

func (g *Governance) GetProposalByReference(ctx context.Context, ref string) (entities.Proposal, error)

func (*Governance) GetProposals 

func (g *Governance) GetProposals(ctx context.Context, inState *entities.ProposalState, partyID *string, proposalType *entities.ProposalType,
	pagination entities.CursorPagination,
) ([]entities.Proposal, entities.PageInfo, error)

func (*Governance) GetVotes 

func (g *Governance) GetVotes(ctx context.Context, proposalID, partyID *string, value *entities.VoteValue) ([]entities.Vote, error)

func (*Governance) GetVotesByParty 

func (g *Governance) GetVotesByParty(ctx context.Context, partyID string) ([]entities.Vote, error)

func (*Governance) GetYesVotesForProposal 

func (g *Governance) GetYesVotesForProposal(ctx context.Context, proposalID string) ([]entities.Vote, error)

func (*Governance) ObservePartyVotes 

func (g *Governance) ObservePartyVotes(ctx context.Context, retries int, partyID string) (<-chan []entities.Vote, uint64)

func (*Governance) ObserveProposalVotes 

func (g *Governance) ObserveProposalVotes(ctx context.Context, retries int, proposalID string) (<-chan []entities.Vote, uint64)

func (*Governance) ObserveProposals 

func (g *Governance) ObserveProposals(ctx context.Context, retries int, partyID *string) (<-chan []entities.Proposal, uint64)

type KeyRotations 

type KeyRotations struct{ *sqlstore.KeyRotations }

func NewKeyRotations 

func NewKeyRotations(store *sqlstore.KeyRotations) *KeyRotations

type Ledger 

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

func NewLedger 

func NewLedger(store ledgerStore, log *logging.Logger) *Ledger

func (*Ledger) AddLedgerEntry 

func (l *Ledger) AddLedgerEntry(le entities.LedgerEntry) error

func (*Ledger) AddTransferResponse 

func (l *Ledger) AddTransferResponse(le *vega.LedgerMovement)

func (*Ledger) Export added in v0.67.0 

func (l *Ledger) Export(
	ctx context.Context,
	partyID, assetID string, dateRange entities.DateRange,
	pagination entities.CursorPagination,
) ([]byte, entities.PageInfo, error)

func (*Ledger) Flush 

func (l *Ledger) Flush(ctx context.Context) error

func (*Ledger) GetSubscribersCount 

func (l *Ledger) GetSubscribersCount() int32

func (*Ledger) Observe 

func (l *Ledger) Observe(ctx context.Context, retries int) (<-chan []*vega.LedgerMovement, uint64)

func (*Ledger) Query added in v0.58.0 

func (l *Ledger) Query(
	ctx context.Context,
	filter *entities.LedgerEntryFilter,
	dateRange entities.DateRange,
	pagination entities.CursorPagination,
) (*[]entities.AggregatedLedgerEntry, entities.PageInfo, error)

type LedgerEntriesStore added in v0.58.0 

type LedgerEntriesStore interface {
	Query(filter *entities.LedgerEntryFilter, dateRange entities.DateRange, pagination entities.CursorPagination) (*[]entities.AggregatedLedgerEntry, entities.PageInfo, error)
	Export(ctx context.Context, partyID, assetID string, dateRange entities.DateRange, pagination entities.CursorPagination) ([]byte, entities.PageInfo, error)
}

type LiquidityProvision 

type LiquidityProvision struct{ *sqlstore.LiquidityProvision }

func NewLiquidityProvision 

func NewLiquidityProvision(store *sqlstore.LiquidityProvision) *LiquidityProvision

type MarginLevelsStore 

type MarginLevelsStore interface {
	Add(marginLevel entities.MarginLevels) error
	Flush(ctx context.Context) ([]entities.MarginLevels, error)
	GetMarginLevelsByID(ctx context.Context, partyID, marketID string, pagination entities.OffsetPagination) ([]entities.MarginLevels, error)
	GetMarginLevelsByIDWithCursorPagination(ctx context.Context, partyID, marketID string, pagination entities.CursorPagination) ([]entities.MarginLevels, entities.PageInfo, error)
}

type MarketData 

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

func NewMarketData 

func NewMarketData(store MarketDataStore, log *logging.Logger) *MarketData

func (*MarketData) Add 

func (m *MarketData) Add(data *entities.MarketData) error

func (*MarketData) Flush 

func (m *MarketData) Flush(ctx context.Context) error

func (*MarketData) GetBetweenDatesByID 

func (m *MarketData) GetBetweenDatesByID(ctx context.Context, marketID string, start, end time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)

func (*MarketData) GetFromDateByID 

func (m *MarketData) GetFromDateByID(ctx context.Context, marketID string, start time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)

func (*MarketData) GetMarketDataByID 

func (m *MarketData) GetMarketDataByID(ctx context.Context, marketID string) (entities.MarketData, error)

func (*MarketData) GetMarketsData 

func (m *MarketData) GetMarketsData(ctx context.Context) ([]entities.MarketData, error)

func (*MarketData) GetToDateByID 

func (m *MarketData) GetToDateByID(ctx context.Context, marketID string, end time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)

func (*MarketData) Initialise 

func (m *MarketData) Initialise(ctx context.Context) error

func (*MarketData) ObserveMarketData 

func (m *MarketData) ObserveMarketData(
	ctx context.Context, retries int, marketID []string,
) (<-chan []*entities.MarketData, uint64)

type MarketDataStore 

type MarketDataStore interface {
	Add(data *entities.MarketData) error
	Flush(ctx context.Context) ([]*entities.MarketData, error)
	GetMarketDataByID(ctx context.Context, marketID string) (entities.MarketData, error)
	GetMarketsData(ctx context.Context) ([]entities.MarketData, error)
	GetBetweenDatesByID(ctx context.Context, marketID string, start, end time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)
	GetFromDateByID(ctx context.Context, marketID string, start time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)
	GetToDateByID(ctx context.Context, marketID string, end time.Time, pagination entities.Pagination) ([]entities.MarketData, entities.PageInfo, error)
}

type MarketDepth 

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

func NewMarketDepth 

func NewMarketDepth(orderStore OrderStore, logger *logging.Logger) *MarketDepth

func (*MarketDepth) AddOrder 

func (m *MarketDepth) AddOrder(order *types.Order, vegaTime time.Time, sequenceNumber uint64)

func (*MarketDepth) GetAllOrders 

func (m *MarketDepth) GetAllOrders(market string) map[string]*types.Order

func (*MarketDepth) GetBestAskPrice 

func (m *MarketDepth) GetBestAskPrice(market string) *num.Uint

GetBestAskPrice returns the highest bid price in the book.

func (*MarketDepth) GetBestBidPrice 

func (m *MarketDepth) GetBestBidPrice(market string) *num.Uint

GetBestBidPrice returns the highest bid price in the book.

func (*MarketDepth) GetBuyPriceLevels 

func (m *MarketDepth) GetBuyPriceLevels(market string) int

GetBuyPriceLevels returns the number of non empty buy price levels.

func (*MarketDepth) GetMarketDepth 

func (m *MarketDepth) GetMarketDepth(market string, limit uint64) *types.MarketDepth

GetMarketDepth builds up the structure to be sent out to any market depth listeners.

func (*MarketDepth) GetOrderCount 

func (m *MarketDepth) GetOrderCount(market string) int64

GetOrderCount returns the number of live orders for the given market.

func (*MarketDepth) GetOrderCountAtPrice 

func (m *MarketDepth) GetOrderCountAtPrice(market string, side types.Side, price uint64) uint64

GetOrderCountAtPrice returns the number of orders at the given price level.

func (*MarketDepth) GetPriceLevels 

func (m *MarketDepth) GetPriceLevels(market string) int

GetPriceLevels returns the number of non empty price levels.

func (*MarketDepth) GetSellPriceLevels 

func (m *MarketDepth) GetSellPriceLevels(market string) int

GetSellPriceLevels returns the number of non empty sell price levels.

func (*MarketDepth) GetTotalVolume 

func (m *MarketDepth) GetTotalVolume(market string) int64

GetTotalVolume returns the total volume in the order book.

func (*MarketDepth) GetVolumeAtPrice 

func (m *MarketDepth) GetVolumeAtPrice(market string, side types.Side, price uint64) uint64

GetVolumeAtPrice returns the order volume at the given price level.

func (*MarketDepth) Initialise 

func (m *MarketDepth) Initialise(ctx context.Context) error

func (*MarketDepth) ObserveDepth 

func (m *MarketDepth) ObserveDepth(ctx context.Context, retries int, marketIds []string) (<-chan []*types.MarketDepth, uint64)

func (*MarketDepth) ObserveDepthUpdates 

func (m *MarketDepth) ObserveDepthUpdates(ctx context.Context, retries int, marketIds []string) (<-chan []*types.MarketDepthUpdate, uint64)

func (*MarketDepth) PublishAtEndOfBlock added in v0.68.0 

func (m *MarketDepth) PublishAtEndOfBlock()

type MarketStore 

type MarketStore interface {
	Upsert(ctx context.Context, market *entities.Market) error
	GetByID(ctx context.Context, marketID string) (entities.Market, error)
	GetAllPaged(ctx context.Context, marketID string, pagination entities.CursorPagination, includeSettled bool) ([]entities.Market, entities.PageInfo, error)
}

type Markets 

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

func NewMarkets 

func NewMarkets(store MarketStore) *Markets

func (*Markets) GetAllPaged 

func (m *Markets) GetAllPaged(ctx context.Context, marketID string, pagination entities.CursorPagination, includeSettled bool) ([]entities.Market, entities.PageInfo, error)

func (*Markets) GetByID 

func (m *Markets) GetByID(ctx context.Context, marketID string) (entities.Market, error)

func (*Markets) GetMarketScalingFactor added in v0.69.0 

func (m *Markets) GetMarketScalingFactor(ctx context.Context, marketID string) (num.Decimal, bool)

func (*Markets) Initialise 

func (m *Markets) Initialise(ctx context.Context) error

func (*Markets) Upsert 

func (m *Markets) Upsert(ctx context.Context, market *entities.Market) error

type MultiSig 

type MultiSig struct {
	*sqlstore.ERC20MultiSigSignerEvent
}

func NewMultiSig 

func NewMultiSig(store *sqlstore.ERC20MultiSigSignerEvent) *MultiSig

type NetworkLimits 

type NetworkLimits struct{ *sqlstore.NetworkLimits }

func NewNetworkLimits 

func NewNetworkLimits(store *sqlstore.NetworkLimits) *NetworkLimits

type NetworkParameter 

type NetworkParameter struct{ *sqlstore.NetworkParameters }

func NewNetworkParameter 

func NewNetworkParameter(store *sqlstore.NetworkParameters) *NetworkParameter

type Node 

type Node struct{ *sqlstore.Node }

func NewNode 

func NewNode(store *sqlstore.Node) *Node

type Notary 

type Notary struct{ *sqlstore.Notary }

func NewNotary 

func NewNotary(store *sqlstore.Notary) *Notary

type OracleData 

type OracleData struct{ *sqlstore.OracleData }

func NewOracleData 

func NewOracleData(store *sqlstore.OracleData) *OracleData

type OracleSpec 

type OracleSpec struct{ *sqlstore.OracleSpec }

func NewOracleSpec 

func NewOracleSpec(store *sqlstore.OracleSpec) *OracleSpec

type Order 

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

func NewOrder 

func NewOrder(store orderStore, log *logging.Logger) *Order

func (*Order) Add 

func (o *Order) Add(order entities.Order) error

func (*Order) Flush 

func (o *Order) Flush(ctx context.Context) error

func (*Order) GetAll 

func (o *Order) GetAll(ctx context.Context) ([]entities.Order, error)

func (*Order) GetByMarketAndID added in v0.68.0 

func (o *Order) GetByMarketAndID(ctx context.Context, marketIDstr string, orderIDs []string) ([]entities.Order, error)

func (*Order) GetLiveOrders 

func (o *Order) GetLiveOrders(ctx context.Context) ([]entities.Order, error)

func (*Order) GetOrder 

func (o *Order) GetOrder(ctx context.Context, orderID string, version *int32) (entities.Order, error)

func (*Order) ListOrderVersions 

func (o *Order) ListOrderVersions(ctx context.Context, orderID string, p entities.CursorPagination) ([]entities.Order, entities.PageInfo, error)

func (*Order) ListOrders 

func (o *Order) ListOrders(ctx context.Context, p entities.CursorPagination, filter entities.OrderFilter,
) ([]entities.Order, entities.PageInfo, error)

func (*Order) ObserveOrders 

func (o *Order) ObserveOrders(ctx context.Context, retries int, markets []string, parties []string, includeLiquidity bool) (<-chan []entities.Order, uint64)

type OrderStore 

type OrderStore interface {
	GetLiveOrders(ctx context.Context) ([]entities.Order, error)
}

type Party 

type Party struct{ *sqlstore.Parties }

func NewParty 

func NewParty(store *sqlstore.Parties) *Party

type Position 

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

func NewPosition 

func NewPosition(store PositionStore, log *logging.Logger) *Position

func (*Position) Add 

func (p *Position) Add(ctx context.Context, pos entities.Position) error

func (*Position) Flush 

func (p *Position) Flush(ctx context.Context) error

func (*Position) GetAll 

func (p *Position) GetAll(ctx context.Context) ([]entities.Position, error)

func (*Position) GetByMarket 

func (p *Position) GetByMarket(ctx context.Context, marketID string) ([]entities.Position, error)

func (*Position) GetByMarketAndParties added in v0.68.0 

func (p *Position) GetByMarketAndParties(ctx context.Context, marketID string, partyIDs []string) ([]entities.Position, error)

func (*Position) GetByMarketAndParty 

func (p *Position) GetByMarketAndParty(ctx context.Context, marketID string, partyID string) (entities.Position, error)

func (*Position) GetByParty 

func (p *Position) GetByParty(ctx context.Context, partyID entities.PartyID) ([]entities.Position, error)

func (*Position) GetByPartyConnection 

func (p *Position) GetByPartyConnection(ctx context.Context, partyIDs []entities.PartyID, marketIDs []entities.MarketID, pagination entities.CursorPagination) ([]entities.Position, entities.PageInfo, error)

func (*Position) Observe 

func (p *Position) Observe(ctx context.Context, retries int, partyID, marketID string) (<-chan []entities.Position, uint64)

type PositionStore 

type PositionStore interface {
	Flush(ctx context.Context) ([]entities.Position, error)
	Add(ctx context.Context, p entities.Position) error
	GetByMarketAndParty(ctx context.Context, marketID string, partyID string) (entities.Position, error)
	GetByMarketAndParties(ctx context.Context, marketIDRaw string, partyIDsRaw []string) ([]entities.Position, error)
	GetByMarket(ctx context.Context, marketID string) ([]entities.Position, error)
	GetByParty(ctx context.Context, partyID string) ([]entities.Position, error)
	GetByPartyConnection(ctx context.Context, partyID []string, marketID []string, pagination entities.CursorPagination) ([]entities.Position, entities.PageInfo, error)
	GetAll(ctx context.Context) ([]entities.Position, error)
}

type ProposalStore 

type ProposalStore interface {
	Add(ctx context.Context, p entities.Proposal) error
	GetByID(ctx context.Context, id string) (entities.Proposal, error)
	GetByReference(ctx context.Context, ref string) (entities.Proposal, error)
	Get(ctx context.Context, inState *entities.ProposalState, partyIDStr *string, proposalType *entities.ProposalType,
		pagination entities.CursorPagination) ([]entities.Proposal, entities.PageInfo, error)
}

type ProtocolUpgrade added in v0.59.0 

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

func NewProtocolUpgrade added in v0.59.0 

func NewProtocolUpgrade(pupStore pupStore, log *logging.Logger) *ProtocolUpgrade

func (*ProtocolUpgrade) AddProposal added in v0.61.0 

func (p *ProtocolUpgrade) AddProposal(ctx context.Context, pup entities.ProtocolUpgradeProposal) error

func (*ProtocolUpgrade) GetProtocolUpgradeStarted added in v0.59.0 

func (p *ProtocolUpgrade) GetProtocolUpgradeStarted() bool

func (*ProtocolUpgrade) ListProposals added in v0.61.0 

func (p *ProtocolUpgrade) ListProposals(ctx context.Context,
	status *entities.ProtocolUpgradeProposalStatus,
	approvedBy *string,
	pagination entities.CursorPagination,
) ([]entities.ProtocolUpgradeProposal, entities.PageInfo, error)

func (*ProtocolUpgrade) SetProtocolUpgradeStarted added in v0.59.0 

func (p *ProtocolUpgrade) SetProtocolUpgradeStarted()

type Reward 

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

func NewReward 

func NewReward(store rewardStore, log *logging.Logger) *Reward

func (*Reward) Add 

func (r *Reward) Add(ctx context.Context, reward entities.Reward) error

func (*Reward) GetAll 

func (r *Reward) GetAll(ctx context.Context) ([]entities.Reward, error)

func (*Reward) GetByCursor 

func (r *Reward) GetByCursor(ctx context.Context, partyID, assetID *string, fromEpoch, toEpoch *uint64, p entities.CursorPagination) ([]entities.Reward, entities.PageInfo, error)

func (*Reward) GetEpochRewardSummaries added in v0.65.0 

func (r *Reward) GetEpochRewardSummaries(ctx context.Context, filter entities.RewardSummaryFilter, p entities.CursorPagination) ([]entities.EpochRewardSummary, entities.PageInfo, error)

func (*Reward) GetRewardSubscribersCount 

func (r *Reward) GetRewardSubscribersCount() int32

func (*Reward) GetSummaries 

func (r *Reward) GetSummaries(ctx context.Context, partyID *string, assetID *string) ([]entities.RewardSummary, error)

func (*Reward) Observe 

func (r *Reward) Observe(ctx context.Context, retries int, assetID, partyID string) (rewardCh <-chan []entities.Reward, ref uint64)

type Risk 

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

func NewRisk 

func NewRisk(mlStore MarginLevelsStore, accountSource AccountSource, log *logging.Logger) *Risk

func (*Risk) Add 

func (r *Risk) Add(marginLevel entities.MarginLevels) error

func (*Risk) Flush 

func (r *Risk) Flush(ctx context.Context) error

func (*Risk) GetMarginLevelsByID 

func (r *Risk) GetMarginLevelsByID(ctx context.Context, partyID, marketID string, pagination entities.OffsetPagination) ([]entities.MarginLevels, error)

func (*Risk) GetMarginLevelsByIDWithCursorPagination 

func (r *Risk) GetMarginLevelsByIDWithCursorPagination(ctx context.Context, partyID, marketID string, pagination entities.CursorPagination) ([]entities.MarginLevels, entities.PageInfo, error)

func (*Risk) ObserveMarginLevels 

func (r *Risk) ObserveMarginLevels(
	ctx context.Context, retries int, partyID, marketID string,
) (accountCh <-chan []entities.MarginLevels, ref uint64)

type RiskFactor 

type RiskFactor struct{ *sqlstore.RiskFactors }

func NewRiskFactor 

func NewRiskFactor(store *sqlstore.RiskFactors) *RiskFactor

type SnapshotData added in v0.65.0 

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

func NewSnapshotData added in v0.65.0 

func NewSnapshotData(snapStore snapStore) *SnapshotData

func (*SnapshotData) AddSnapshot added in v0.65.0 

func (s *SnapshotData) AddSnapshot(ctx context.Context, snap entities.CoreSnapshotData) error

func (*SnapshotData) ListSnapshots added in v0.65.0 

func (s *SnapshotData) ListSnapshots(ctx context.Context, pagination entities.CursorPagination) ([]entities.CoreSnapshotData, entities.PageInfo, error)

type StakeLinking 

type StakeLinking struct{ *sqlstore.StakeLinking }

func NewStakeLinking 

func NewStakeLinking(store *sqlstore.StakeLinking) *StakeLinking

type Trade 

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

func NewTrade 

func NewTrade(store tradeStore, log *logging.Logger) *Trade

func (*Trade) Add 

func (t *Trade) Add(trade *entities.Trade) error

func (*Trade) Flush 

func (t *Trade) Flush(ctx context.Context) error

func (*Trade) GetByMarket 

func (t *Trade) GetByMarket(ctx context.Context, market string, p entities.OffsetPagination) ([]entities.Trade, error)

func (*Trade) GetByOrderID 

func (t *Trade) GetByOrderID(ctx context.Context, order string, market *string, pagination entities.OffsetPagination) ([]entities.Trade, error)

func (*Trade) GetByParty 

func (t *Trade) GetByParty(ctx context.Context, party string, market *string, pagination entities.OffsetPagination) ([]entities.Trade, error)

func (*Trade) List 

func (t *Trade) List(ctx context.Context,
	marketID entities.MarketID,
	partyID entities.PartyID,
	orderID entities.OrderID,
	pagination entities.CursorPagination,
	dateRange entities.DateRange,
) ([]entities.Trade, entities.PageInfo, error)

func (*Trade) Observe 

func (t *Trade) Observe(ctx context.Context, retries int, marketID *string, partyID *string) (<-chan []*entities.Trade, uint64)

type Transfer 

type Transfer struct{ *sqlstore.Transfers }

func NewTransfer 

func NewTransfer(store *sqlstore.Transfers) *Transfer

type VoteStore 

type VoteStore interface {
	Add(ctx context.Context, v entities.Vote) error
	GetYesVotesForProposal(ctx context.Context, proposalIDStr string) ([]entities.Vote, error)
	GetNoVotesForProposal(ctx context.Context, proposalIDStr string) ([]entities.Vote, error)
	GetByParty(ctx context.Context, partyIDStr string) ([]entities.Vote, error)
	GetByPartyConnection(ctx context.Context, partyIDStr string, pagination entities.CursorPagination) ([]entities.Vote, entities.PageInfo, error)
	Get(ctx context.Context, proposalID, partyID *string, value *entities.VoteValue) ([]entities.Vote, error)
	GetConnection(
		ctx context.Context,
		proposalIDStr, partyIDStr *string,
		pagination entities.CursorPagination,
	) ([]entities.Vote, entities.PageInfo, error)
}

type Withdrawal 

type Withdrawal struct{ *sqlstore.Withdrawals }

func NewWithdrawal 

func NewWithdrawal(store *sqlstore.Withdrawals) *Withdrawal

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.