Documentation
¶
Index ¶
- func RunMigrations(logger *zap.Logger, pgConnectionString string, downFirst bool) error
- type DBTX
- type DeleteRegisteredEndpointParams
- type EthActiveProposal
- type EthFundingRound
- type EthRegisteredEndpoint
- type EthServiceProvider
- type EthStaked
- type InsertActiveProposalParams
- type InsertRegisteredEndpointParams
- type InsertServiceProviderParams
- type Queries
- func (q *Queries) ClearActiveProposals(ctx context.Context) error
- func (q *Queries) ClearRegisteredEndpoints(ctx context.Context) error
- func (q *Queries) ClearServiceProviders(ctx context.Context) error
- func (q *Queries) ClearStaked(ctx context.Context) error
- func (q *Queries) DeleteActiveProposal(ctx context.Context, id int64) error
- func (q *Queries) DeleteRegisteredEndpoint(ctx context.Context, arg DeleteRegisteredEndpointParams) error
- func (q *Queries) GetActiveProposals(ctx context.Context) ([]EthActiveProposal, error)
- func (q *Queries) GetCountOfEndpointsWithDelegateWallet(ctx context.Context, delegateWallet string) (int64, error)
- func (q *Queries) GetLatestFundingRound(ctx context.Context) (EthFundingRound, error)
- func (q *Queries) GetRegisteredEndpoint(ctx context.Context, endpoint string) (EthRegisteredEndpoint, error)
- func (q *Queries) GetRegisteredEndpoints(ctx context.Context) ([]EthRegisteredEndpoint, error)
- func (q *Queries) GetRegisteredEndpointsForServiceProvider(ctx context.Context, owner string) ([]EthRegisteredEndpoint, error)
- func (q *Queries) GetServiceProvider(ctx context.Context, address string) (EthServiceProvider, error)
- func (q *Queries) GetServiceProviders(ctx context.Context) ([]EthServiceProvider, error)
- func (q *Queries) GetStakedAmountForServiceProvider(ctx context.Context, address string) (int64, error)
- func (q *Queries) InsertActiveProposal(ctx context.Context, arg InsertActiveProposalParams) error
- func (q *Queries) InsertRegisteredEndpoint(ctx context.Context, arg InsertRegisteredEndpointParams) error
- func (q *Queries) InsertServiceProvider(ctx context.Context, arg InsertServiceProviderParams) error
- func (q *Queries) UpsertServiceProvider(ctx context.Context, arg UpsertServiceProviderParams) error
- func (q *Queries) UpsertStaked(ctx context.Context, arg UpsertStakedParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type UpsertServiceProviderParams
- type UpsertStakedParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EthActiveProposal ¶
type EthActiveProposal struct {
ID int64 `json:"id"`
Proposer string `json:"proposer"`
SubmissionBlockNumber int64 `json:"submission_block_number"`
TargetContractRegistryKey string `json:"target_contract_registry_key"`
TargetContractAddress string `json:"target_contract_address"`
CallValue int64 `json:"call_value"`
FunctionSignature string `json:"function_signature"`
CallData string `json:"call_data"`
}
type EthFundingRound ¶
type EthRegisteredEndpoint ¶
type EthRegisteredEndpoint struct {
ID int32 `json:"id"`
ServiceType string `json:"service_type"`
Owner string `json:"owner"`
DelegateWallet string `json:"delegate_wallet"`
Endpoint string `json:"endpoint"`
Blocknumber int64 `json:"blocknumber"`
RegisteredAt pgtype.Timestamp `json:"registered_at"`
}
type EthServiceProvider ¶
type EthServiceProvider struct {
Address string `json:"address"`
DeployerStake int64 `json:"deployer_stake"`
DeployerCut int64 `json:"deployer_cut"`
ValidBounds bool `json:"valid_bounds"`
NumberOfEndpoints int32 `json:"number_of_endpoints"`
MinAccountStake int64 `json:"min_account_stake"`
MaxAccountStake int64 `json:"max_account_stake"`
}
type InsertActiveProposalParams ¶
type InsertActiveProposalParams struct {
ID int64 `json:"id"`
Proposer string `json:"proposer"`
SubmissionBlockNumber int64 `json:"submission_block_number"`
TargetContractRegistryKey string `json:"target_contract_registry_key"`
TargetContractAddress string `json:"target_contract_address"`
CallValue int64 `json:"call_value"`
FunctionSignature string `json:"function_signature"`
CallData string `json:"call_data"`
}
type InsertRegisteredEndpointParams ¶
type InsertRegisteredEndpointParams struct {
ID int32 `json:"id"`
ServiceType string `json:"service_type"`
Owner string `json:"owner"`
DelegateWallet string `json:"delegate_wallet"`
Endpoint string `json:"endpoint"`
Blocknumber int64 `json:"blocknumber"`
RegisteredAt pgtype.Timestamp `json:"registered_at"`
}
type InsertServiceProviderParams ¶
type InsertServiceProviderParams struct {
Address string `json:"address"`
DeployerStake int64 `json:"deployer_stake"`
DeployerCut int64 `json:"deployer_cut"`
ValidBounds bool `json:"valid_bounds"`
NumberOfEndpoints int32 `json:"number_of_endpoints"`
MinAccountStake int64 `json:"min_account_stake"`
MaxAccountStake int64 `json:"max_account_stake"`
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) ClearActiveProposals ¶
func (*Queries) ClearRegisteredEndpoints ¶
func (*Queries) ClearServiceProviders ¶
func (*Queries) DeleteActiveProposal ¶
func (*Queries) DeleteRegisteredEndpoint ¶
func (q *Queries) DeleteRegisteredEndpoint(ctx context.Context, arg DeleteRegisteredEndpointParams) error
func (*Queries) GetActiveProposals ¶
func (q *Queries) GetActiveProposals(ctx context.Context) ([]EthActiveProposal, error)
func (*Queries) GetCountOfEndpointsWithDelegateWallet ¶
func (*Queries) GetLatestFundingRound ¶
func (q *Queries) GetLatestFundingRound(ctx context.Context) (EthFundingRound, error)
func (*Queries) GetRegisteredEndpoint ¶
func (*Queries) GetRegisteredEndpoints ¶
func (q *Queries) GetRegisteredEndpoints(ctx context.Context) ([]EthRegisteredEndpoint, error)
func (*Queries) GetRegisteredEndpointsForServiceProvider ¶
func (*Queries) GetServiceProvider ¶
func (*Queries) GetServiceProviders ¶
func (q *Queries) GetServiceProviders(ctx context.Context) ([]EthServiceProvider, error)
func (*Queries) GetStakedAmountForServiceProvider ¶
func (*Queries) InsertActiveProposal ¶
func (q *Queries) InsertActiveProposal(ctx context.Context, arg InsertActiveProposalParams) error
func (*Queries) InsertRegisteredEndpoint ¶
func (q *Queries) InsertRegisteredEndpoint(ctx context.Context, arg InsertRegisteredEndpointParams) error
func (*Queries) InsertServiceProvider ¶
func (q *Queries) InsertServiceProvider(ctx context.Context, arg InsertServiceProviderParams) error
func (*Queries) UpsertServiceProvider ¶
func (q *Queries) UpsertServiceProvider(ctx context.Context, arg UpsertServiceProviderParams) error
func (*Queries) UpsertStaked ¶
func (q *Queries) UpsertStaked(ctx context.Context, arg UpsertStakedParams) error
type UpsertServiceProviderParams ¶
type UpsertServiceProviderParams struct {
Address string `json:"address"`
DeployerStake int64 `json:"deployer_stake"`
DeployerCut int64 `json:"deployer_cut"`
ValidBounds bool `json:"valid_bounds"`
NumberOfEndpoints int32 `json:"number_of_endpoints"`
MinAccountStake int64 `json:"min_account_stake"`
MaxAccountStake int64 `json:"max_account_stake"`
}
type UpsertStakedParams ¶
Click to show internal directories.
Click to hide internal directories.