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.