diff --git a/satellite/satellitedb/dbx/gen/main.go b/satellite/satellitedb/dbx/gen/main.go index 43c27c145..38dcaa33d 100644 --- a/satellite/satellitedb/dbx/gen/main.go +++ b/satellite/satellitedb/dbx/gen/main.go @@ -35,7 +35,7 @@ func main() { fmt.Println("schema out", string(schemaOut)) log.Fatal(err) } - gogenArgs := append([]string{"golang", "-d=pgx", "-d=pgxcockroach", "-p=dbx", "-t=templates"}, files...) + gogenArgs := append([]string{"golang", "--rx=false", "-d=pgx", "-d=pgxcockroach", "-p=dbx", "-t=templates"}, files...) gogenOut, err := exec.Command("dbx", gogenArgs...).CombinedOutput() if err != nil { fmt.Println("gogen out", string(gogenOut)) diff --git a/satellite/satellitedb/dbx/satellitedb.dbx.go b/satellite/satellitedb/dbx/satellitedb.dbx.go index f6925615b..5dd86a82e 100644 --- a/satellite/satellitedb/dbx/satellitedb.dbx.go +++ b/satellite/satellitedb/dbx/satellitedb.dbx.go @@ -18,7 +18,6 @@ import ( "unicode" "github.com/jackc/pgx/v5/pgconn" - "storj.io/private/tagsql" ) @@ -207,10 +206,6 @@ func (obj *DB) Open(ctx context.Context) (*Tx, error) { }, nil } -func (obj *DB) NewRx() *Rx { - return &Rx{db: obj} -} - func DeleteAll(ctx context.Context, db *DB) (int64, error) { tx, err := db.Open(ctx) if err != nil { @@ -28331,2116 +28326,6 @@ func (obj *pgxcockroachImpl) deleteAll(ctx context.Context) (count int64, err er } -type Rx struct { - db *DB - tx *Tx -} - -func (rx *Rx) UnsafeTx(ctx context.Context) (unsafe_tx tagsql.Tx, err error) { - tx, err := rx.getTx(ctx) - if err != nil { - return nil, err - } - return tx.Tx, nil -} - -func (rx *Rx) getTx(ctx context.Context) (tx *Tx, err error) { - if rx.tx == nil { - if rx.tx, err = rx.db.Open(ctx); err != nil { - return nil, err - } - } - return rx.tx, nil -} - -func (rx *Rx) Rebind(s string) string { - return rx.db.Rebind(s) -} - -func (rx *Rx) Commit() (err error) { - if rx.tx != nil { - err = rx.tx.Commit() - rx.tx = nil - } - return err -} - -func (rx *Rx) Rollback() (err error) { - if rx.tx != nil { - err = rx.tx.Rollback() - rx.tx = nil - } - return err -} - -func (rx *Rx) All_AccountFreezeEvent_By_UserId(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field) ( - rows []*AccountFreezeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_AccountFreezeEvent_By_UserId(ctx, account_freeze_event_user_id) -} - -func (rx *Rx) All_BillingTransaction_By_UserId_And_Source_OrderBy_Desc_Timestamp(ctx context.Context, - billing_transaction_user_id BillingTransaction_UserId_Field, - billing_transaction_source BillingTransaction_Source_Field) ( - rows []*BillingTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_BillingTransaction_By_UserId_And_Source_OrderBy_Desc_Timestamp(ctx, billing_transaction_user_id, billing_transaction_source) -} - -func (rx *Rx) All_BillingTransaction_By_UserId_OrderBy_Desc_Timestamp(ctx context.Context, - billing_transaction_user_id BillingTransaction_UserId_Field) ( - rows []*BillingTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_BillingTransaction_By_UserId_OrderBy_Desc_Timestamp(ctx, billing_transaction_user_id) -} - -func (rx *Rx) All_BucketStorageTally_By_ProjectId_And_BucketName_And_IntervalStart_GreaterOrEqual_And_IntervalStart_LessOrEqual_OrderBy_Desc_IntervalStart(ctx context.Context, - bucket_storage_tally_project_id BucketStorageTally_ProjectId_Field, - bucket_storage_tally_bucket_name BucketStorageTally_BucketName_Field, - bucket_storage_tally_interval_start_greater_or_equal BucketStorageTally_IntervalStart_Field, - bucket_storage_tally_interval_start_less_or_equal BucketStorageTally_IntervalStart_Field) ( - rows []*BucketStorageTally, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_BucketStorageTally_By_ProjectId_And_BucketName_And_IntervalStart_GreaterOrEqual_And_IntervalStart_LessOrEqual_OrderBy_Desc_IntervalStart(ctx, bucket_storage_tally_project_id, bucket_storage_tally_bucket_name, bucket_storage_tally_interval_start_greater_or_equal, bucket_storage_tally_interval_start_less_or_equal) -} - -func (rx *Rx) All_BucketStorageTally_OrderBy_Desc_IntervalStart(ctx context.Context) ( - rows []*BucketStorageTally, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_BucketStorageTally_OrderBy_Desc_IntervalStart(ctx) -} - -func (rx *Rx) All_CoinpaymentsTransaction_By_UserId_OrderBy_Desc_CreatedAt(ctx context.Context, - coinpayments_transaction_user_id CoinpaymentsTransaction_UserId_Field) ( - rows []*CoinpaymentsTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_CoinpaymentsTransaction_By_UserId_OrderBy_Desc_CreatedAt(ctx, coinpayments_transaction_user_id) -} - -func (rx *Rx) All_NodeTags(ctx context.Context) ( - rows []*NodeTags, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_NodeTags(ctx) -} - -func (rx *Rx) All_NodeTags_By_NodeId(ctx context.Context, - node_tags_node_id NodeTags_NodeId_Field) ( - rows []*NodeTags, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_NodeTags_By_NodeId(ctx, node_tags_node_id) -} - -func (rx *Rx) All_Node_Id(ctx context.Context) ( - rows []*Id_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Node_Id(ctx) -} - -func (rx *Rx) All_Node_Id_Node_PieceCount_By_PieceCount_Not_Number(ctx context.Context) ( - rows []*Id_PieceCount_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Node_Id_Node_PieceCount_By_PieceCount_Not_Number(ctx) -} - -func (rx *Rx) All_Project(ctx context.Context) ( - rows []*Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Project(ctx) -} - -func (rx *Rx) All_ProjectInvitation_By_Email(ctx context.Context, - project_invitation_email ProjectInvitation_Email_Field) ( - rows []*ProjectInvitation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_ProjectInvitation_By_Email(ctx, project_invitation_email) -} - -func (rx *Rx) All_ProjectInvitation_By_ProjectId(ctx context.Context, - project_invitation_project_id ProjectInvitation_ProjectId_Field) ( - rows []*ProjectInvitation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_ProjectInvitation_By_ProjectId(ctx, project_invitation_project_id) -} - -func (rx *Rx) All_ProjectMember_By_MemberId(ctx context.Context, - project_member_member_id ProjectMember_MemberId_Field) ( - rows []*ProjectMember, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_ProjectMember_By_MemberId(ctx, project_member_member_id) -} - -func (rx *Rx) All_Project_By_CreatedAt_Less_OrderBy_Asc_CreatedAt(ctx context.Context, - project_created_at_less Project_CreatedAt_Field) ( - rows []*Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Project_By_CreatedAt_Less_OrderBy_Asc_CreatedAt(ctx, project_created_at_less) -} - -func (rx *Rx) All_Project_By_OwnerId_OrderBy_Asc_CreatedAt(ctx context.Context, - project_owner_id Project_OwnerId_Field) ( - rows []*Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Project_By_OwnerId_OrderBy_Asc_CreatedAt(ctx, project_owner_id) -} - -func (rx *Rx) All_Project_By_ProjectMember_MemberId_OrderBy_Asc_Project_Name(ctx context.Context, - project_member_member_id ProjectMember_MemberId_Field) ( - rows []*Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_Project_By_ProjectMember_MemberId_OrderBy_Asc_Project_Name(ctx, project_member_member_id) -} - -func (rx *Rx) All_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart(ctx context.Context, - storagenode_bandwidth_rollup_storagenode_id StoragenodeBandwidthRollup_StoragenodeId_Field, - storagenode_bandwidth_rollup_interval_start StoragenodeBandwidthRollup_IntervalStart_Field) ( - rows []*StoragenodeBandwidthRollup, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart(ctx, storagenode_bandwidth_rollup_storagenode_id, storagenode_bandwidth_rollup_interval_start) -} - -func (rx *Rx) All_StoragenodePayment_By_NodeId(ctx context.Context, - storagenode_payment_node_id StoragenodePayment_NodeId_Field) ( - rows []*StoragenodePayment, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodePayment_By_NodeId(ctx, storagenode_payment_node_id) -} - -func (rx *Rx) All_StoragenodePayment_By_NodeId_And_Period(ctx context.Context, - storagenode_payment_node_id StoragenodePayment_NodeId_Field, - storagenode_payment_period StoragenodePayment_Period_Field) ( - rows []*StoragenodePayment, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodePayment_By_NodeId_And_Period(ctx, storagenode_payment_node_id, storagenode_payment_period) -} - -func (rx *Rx) All_StoragenodePaystub_By_NodeId(ctx context.Context, - storagenode_paystub_node_id StoragenodePaystub_NodeId_Field) ( - rows []*StoragenodePaystub, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodePaystub_By_NodeId(ctx, storagenode_paystub_node_id) -} - -func (rx *Rx) All_StoragenodeStorageTally(ctx context.Context) ( - rows []*StoragenodeStorageTally, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodeStorageTally(ctx) -} - -func (rx *Rx) All_StoragenodeStorageTally_By_IntervalEndTime_GreaterOrEqual(ctx context.Context, - storagenode_storage_tally_interval_end_time_greater_or_equal StoragenodeStorageTally_IntervalEndTime_Field) ( - rows []*StoragenodeStorageTally, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StoragenodeStorageTally_By_IntervalEndTime_GreaterOrEqual(ctx, storagenode_storage_tally_interval_end_time_greater_or_equal) -} - -func (rx *Rx) All_StorjscanPayment_OrderBy_Asc_BlockNumber_Asc_LogIndex(ctx context.Context) ( - rows []*StorjscanPayment, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StorjscanPayment_OrderBy_Asc_BlockNumber_Asc_LogIndex(ctx) -} - -func (rx *Rx) All_StorjscanWallet(ctx context.Context) ( - rows []*StorjscanWallet, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_StorjscanWallet(ctx) -} - -func (rx *Rx) All_User_By_NormalizedEmail(ctx context.Context, - user_normalized_email User_NormalizedEmail_Field) ( - rows []*User, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_User_By_NormalizedEmail(ctx, user_normalized_email) -} - -func (rx *Rx) All_WebappSession_By_UserId(ctx context.Context, - webapp_session_user_id WebappSession_UserId_Field) ( - rows []*WebappSession, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.All_WebappSession_By_UserId(ctx, webapp_session_user_id) -} - -func (rx *Rx) Count_BucketMetainfo_Name_By_ProjectId(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Count_BucketMetainfo_Name_By_ProjectId(ctx, bucket_metainfo_project_id) -} - -func (rx *Rx) CreateNoReturn_BillingBalance(ctx context.Context, - billing_balance_user_id BillingBalance_UserId_Field, - billing_balance_balance BillingBalance_Balance_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_BillingBalance(ctx, billing_balance_user_id, billing_balance_balance) - -} - -func (rx *Rx) CreateNoReturn_OauthClient(ctx context.Context, - oauth_client_id OauthClient_Id_Field, - oauth_client_encrypted_secret OauthClient_EncryptedSecret_Field, - oauth_client_redirect_url OauthClient_RedirectUrl_Field, - oauth_client_user_id OauthClient_UserId_Field, - oauth_client_app_name OauthClient_AppName_Field, - oauth_client_app_logo_url OauthClient_AppLogoUrl_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_OauthClient(ctx, oauth_client_id, oauth_client_encrypted_secret, oauth_client_redirect_url, oauth_client_user_id, oauth_client_app_name, oauth_client_app_logo_url) - -} - -func (rx *Rx) CreateNoReturn_OauthCode(ctx context.Context, - oauth_code_client_id OauthCode_ClientId_Field, - oauth_code_user_id OauthCode_UserId_Field, - oauth_code_scope OauthCode_Scope_Field, - oauth_code_redirect_url OauthCode_RedirectUrl_Field, - oauth_code_challenge OauthCode_Challenge_Field, - oauth_code_challenge_method OauthCode_ChallengeMethod_Field, - oauth_code_code OauthCode_Code_Field, - oauth_code_created_at OauthCode_CreatedAt_Field, - oauth_code_expires_at OauthCode_ExpiresAt_Field, - optional OauthCode_Create_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_OauthCode(ctx, oauth_code_client_id, oauth_code_user_id, oauth_code_scope, oauth_code_redirect_url, oauth_code_challenge, oauth_code_challenge_method, oauth_code_code, oauth_code_created_at, oauth_code_expires_at, optional) - -} - -func (rx *Rx) CreateNoReturn_OauthToken(ctx context.Context, - oauth_token_client_id OauthToken_ClientId_Field, - oauth_token_user_id OauthToken_UserId_Field, - oauth_token_scope OauthToken_Scope_Field, - oauth_token_kind OauthToken_Kind_Field, - oauth_token_token OauthToken_Token_Field, - oauth_token_created_at OauthToken_CreatedAt_Field, - oauth_token_expires_at OauthToken_ExpiresAt_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_OauthToken(ctx, oauth_token_client_id, oauth_token_user_id, oauth_token_scope, oauth_token_kind, oauth_token_token, oauth_token_created_at, oauth_token_expires_at) - -} - -func (rx *Rx) CreateNoReturn_PeerIdentity(ctx context.Context, - peer_identity_node_id PeerIdentity_NodeId_Field, - peer_identity_leaf_serial_number PeerIdentity_LeafSerialNumber_Field, - peer_identity_chain PeerIdentity_Chain_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_PeerIdentity(ctx, peer_identity_node_id, peer_identity_leaf_serial_number, peer_identity_chain) - -} - -func (rx *Rx) CreateNoReturn_Revocation(ctx context.Context, - revocation_revoked Revocation_Revoked_Field, - revocation_api_key_id Revocation_ApiKeyId_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_Revocation(ctx, revocation_revoked, revocation_api_key_id) - -} - -func (rx *Rx) CreateNoReturn_StoragenodePayment(ctx context.Context, - storagenode_payment_node_id StoragenodePayment_NodeId_Field, - storagenode_payment_period StoragenodePayment_Period_Field, - storagenode_payment_amount StoragenodePayment_Amount_Field, - optional StoragenodePayment_Create_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_StoragenodePayment(ctx, storagenode_payment_node_id, storagenode_payment_period, storagenode_payment_amount, optional) - -} - -func (rx *Rx) CreateNoReturn_StorjscanPayment(ctx context.Context, - storjscan_payment_block_hash StorjscanPayment_BlockHash_Field, - storjscan_payment_block_number StorjscanPayment_BlockNumber_Field, - storjscan_payment_transaction StorjscanPayment_Transaction_Field, - storjscan_payment_log_index StorjscanPayment_LogIndex_Field, - storjscan_payment_from_address StorjscanPayment_FromAddress_Field, - storjscan_payment_to_address StorjscanPayment_ToAddress_Field, - storjscan_payment_token_value StorjscanPayment_TokenValue_Field, - storjscan_payment_usd_value StorjscanPayment_UsdValue_Field, - storjscan_payment_status StorjscanPayment_Status_Field, - storjscan_payment_timestamp StorjscanPayment_Timestamp_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_StorjscanPayment(ctx, storjscan_payment_block_hash, storjscan_payment_block_number, storjscan_payment_transaction, storjscan_payment_log_index, storjscan_payment_from_address, storjscan_payment_to_address, storjscan_payment_token_value, storjscan_payment_usd_value, storjscan_payment_status, storjscan_payment_timestamp) - -} - -func (rx *Rx) CreateNoReturn_StorjscanWallet(ctx context.Context, - storjscan_wallet_user_id StorjscanWallet_UserId_Field, - storjscan_wallet_wallet_address StorjscanWallet_WalletAddress_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_StorjscanWallet(ctx, storjscan_wallet_user_id, storjscan_wallet_wallet_address) - -} - -func (rx *Rx) CreateNoReturn_UserSettings(ctx context.Context, - user_settings_user_id UserSettings_UserId_Field, - optional UserSettings_Create_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.CreateNoReturn_UserSettings(ctx, user_settings_user_id, optional) - -} - -func (rx *Rx) Create_ApiKey(ctx context.Context, - api_key_id ApiKey_Id_Field, - api_key_project_id ApiKey_ProjectId_Field, - api_key_head ApiKey_Head_Field, - api_key_name ApiKey_Name_Field, - api_key_secret ApiKey_Secret_Field, - optional ApiKey_Create_Fields) ( - api_key *ApiKey, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_ApiKey(ctx, api_key_id, api_key_project_id, api_key_head, api_key_name, api_key_secret, optional) - -} - -func (rx *Rx) Create_BillingTransaction(ctx context.Context, - billing_transaction_user_id BillingTransaction_UserId_Field, - billing_transaction_amount BillingTransaction_Amount_Field, - billing_transaction_currency BillingTransaction_Currency_Field, - billing_transaction_description BillingTransaction_Description_Field, - billing_transaction_source BillingTransaction_Source_Field, - billing_transaction_status BillingTransaction_Status_Field, - billing_transaction_type BillingTransaction_Type_Field, - billing_transaction_metadata BillingTransaction_Metadata_Field, - billing_transaction_timestamp BillingTransaction_Timestamp_Field) ( - billing_transaction *BillingTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_BillingTransaction(ctx, billing_transaction_user_id, billing_transaction_amount, billing_transaction_currency, billing_transaction_description, billing_transaction_source, billing_transaction_status, billing_transaction_type, billing_transaction_metadata, billing_transaction_timestamp) - -} - -func (rx *Rx) Create_BucketMetainfo(ctx context.Context, - bucket_metainfo_id BucketMetainfo_Id_Field, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field, - bucket_metainfo_path_cipher BucketMetainfo_PathCipher_Field, - bucket_metainfo_default_segment_size BucketMetainfo_DefaultSegmentSize_Field, - bucket_metainfo_default_encryption_cipher_suite BucketMetainfo_DefaultEncryptionCipherSuite_Field, - bucket_metainfo_default_encryption_block_size BucketMetainfo_DefaultEncryptionBlockSize_Field, - bucket_metainfo_default_redundancy_algorithm BucketMetainfo_DefaultRedundancyAlgorithm_Field, - bucket_metainfo_default_redundancy_share_size BucketMetainfo_DefaultRedundancyShareSize_Field, - bucket_metainfo_default_redundancy_required_shares BucketMetainfo_DefaultRedundancyRequiredShares_Field, - bucket_metainfo_default_redundancy_repair_shares BucketMetainfo_DefaultRedundancyRepairShares_Field, - bucket_metainfo_default_redundancy_optimal_shares BucketMetainfo_DefaultRedundancyOptimalShares_Field, - bucket_metainfo_default_redundancy_total_shares BucketMetainfo_DefaultRedundancyTotalShares_Field, - optional BucketMetainfo_Create_Fields) ( - bucket_metainfo *BucketMetainfo, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_BucketMetainfo(ctx, bucket_metainfo_id, bucket_metainfo_project_id, bucket_metainfo_name, bucket_metainfo_path_cipher, bucket_metainfo_default_segment_size, bucket_metainfo_default_encryption_cipher_suite, bucket_metainfo_default_encryption_block_size, bucket_metainfo_default_redundancy_algorithm, bucket_metainfo_default_redundancy_share_size, bucket_metainfo_default_redundancy_required_shares, bucket_metainfo_default_redundancy_repair_shares, bucket_metainfo_default_redundancy_optimal_shares, bucket_metainfo_default_redundancy_total_shares, optional) - -} - -func (rx *Rx) Create_CoinpaymentsTransaction(ctx context.Context, - coinpayments_transaction_id CoinpaymentsTransaction_Id_Field, - coinpayments_transaction_user_id CoinpaymentsTransaction_UserId_Field, - coinpayments_transaction_address CoinpaymentsTransaction_Address_Field, - coinpayments_transaction_amount_numeric CoinpaymentsTransaction_AmountNumeric_Field, - coinpayments_transaction_received_numeric CoinpaymentsTransaction_ReceivedNumeric_Field, - coinpayments_transaction_status CoinpaymentsTransaction_Status_Field, - coinpayments_transaction_key CoinpaymentsTransaction_Key_Field, - coinpayments_transaction_timeout CoinpaymentsTransaction_Timeout_Field) ( - coinpayments_transaction *CoinpaymentsTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_CoinpaymentsTransaction(ctx, coinpayments_transaction_id, coinpayments_transaction_user_id, coinpayments_transaction_address, coinpayments_transaction_amount_numeric, coinpayments_transaction_received_numeric, coinpayments_transaction_status, coinpayments_transaction_key, coinpayments_transaction_timeout) - -} - -func (rx *Rx) Create_NodeEvent(ctx context.Context, - node_event_id NodeEvent_Id_Field, - node_event_email NodeEvent_Email_Field, - node_event_node_id NodeEvent_NodeId_Field, - node_event_event NodeEvent_Event_Field, - optional NodeEvent_Create_Fields) ( - node_event *NodeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_NodeEvent(ctx, node_event_id, node_event_email, node_event_node_id, node_event_event, optional) - -} - -func (rx *Rx) Create_Project(ctx context.Context, - project_id Project_Id_Field, - project_name Project_Name_Field, - project_description Project_Description_Field, - project_owner_id Project_OwnerId_Field, - optional Project_Create_Fields) ( - project *Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_Project(ctx, project_id, project_name, project_description, project_owner_id, optional) - -} - -func (rx *Rx) Create_ProjectMember(ctx context.Context, - project_member_member_id ProjectMember_MemberId_Field, - project_member_project_id ProjectMember_ProjectId_Field) ( - project_member *ProjectMember, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_ProjectMember(ctx, project_member_member_id, project_member_project_id) - -} - -func (rx *Rx) Create_RegistrationToken(ctx context.Context, - registration_token_secret RegistrationToken_Secret_Field, - registration_token_project_limit RegistrationToken_ProjectLimit_Field, - optional RegistrationToken_Create_Fields) ( - registration_token *RegistrationToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_RegistrationToken(ctx, registration_token_secret, registration_token_project_limit, optional) - -} - -func (rx *Rx) Create_Reputation(ctx context.Context, - reputation_id Reputation_Id_Field, - reputation_audit_history Reputation_AuditHistory_Field, - optional Reputation_Create_Fields) ( - reputation *Reputation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_Reputation(ctx, reputation_id, reputation_audit_history, optional) - -} - -func (rx *Rx) Create_ResetPasswordToken(ctx context.Context, - reset_password_token_secret ResetPasswordToken_Secret_Field, - reset_password_token_owner_id ResetPasswordToken_OwnerId_Field) ( - reset_password_token *ResetPasswordToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_ResetPasswordToken(ctx, reset_password_token_secret, reset_password_token_owner_id) - -} - -func (rx *Rx) Create_ReverificationAudits(ctx context.Context, - reverification_audits_node_id ReverificationAudits_NodeId_Field, - reverification_audits_stream_id ReverificationAudits_StreamId_Field, - reverification_audits_position ReverificationAudits_Position_Field, - reverification_audits_piece_num ReverificationAudits_PieceNum_Field, - optional ReverificationAudits_Create_Fields) ( - reverification_audits *ReverificationAudits, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_ReverificationAudits(ctx, reverification_audits_node_id, reverification_audits_stream_id, reverification_audits_position, reverification_audits_piece_num, optional) - -} - -func (rx *Rx) Create_StoragenodeBandwidthRollup(ctx context.Context, - storagenode_bandwidth_rollup_storagenode_id StoragenodeBandwidthRollup_StoragenodeId_Field, - storagenode_bandwidth_rollup_interval_start StoragenodeBandwidthRollup_IntervalStart_Field, - storagenode_bandwidth_rollup_interval_seconds StoragenodeBandwidthRollup_IntervalSeconds_Field, - storagenode_bandwidth_rollup_action StoragenodeBandwidthRollup_Action_Field, - storagenode_bandwidth_rollup_settled StoragenodeBandwidthRollup_Settled_Field, - optional StoragenodeBandwidthRollup_Create_Fields) ( - storagenode_bandwidth_rollup *StoragenodeBandwidthRollup, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_StoragenodeBandwidthRollup(ctx, storagenode_bandwidth_rollup_storagenode_id, storagenode_bandwidth_rollup_interval_start, storagenode_bandwidth_rollup_interval_seconds, storagenode_bandwidth_rollup_action, storagenode_bandwidth_rollup_settled, optional) - -} - -func (rx *Rx) Create_StripeCustomer(ctx context.Context, - stripe_customer_user_id StripeCustomer_UserId_Field, - stripe_customer_customer_id StripeCustomer_CustomerId_Field, - optional StripeCustomer_Create_Fields) ( - stripe_customer *StripeCustomer, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_StripeCustomer(ctx, stripe_customer_user_id, stripe_customer_customer_id, optional) - -} - -func (rx *Rx) Create_StripecoinpaymentsInvoiceProjectRecord(ctx context.Context, - stripecoinpayments_invoice_project_record_id StripecoinpaymentsInvoiceProjectRecord_Id_Field, - stripecoinpayments_invoice_project_record_project_id StripecoinpaymentsInvoiceProjectRecord_ProjectId_Field, - stripecoinpayments_invoice_project_record_storage StripecoinpaymentsInvoiceProjectRecord_Storage_Field, - stripecoinpayments_invoice_project_record_egress StripecoinpaymentsInvoiceProjectRecord_Egress_Field, - stripecoinpayments_invoice_project_record_period_start StripecoinpaymentsInvoiceProjectRecord_PeriodStart_Field, - stripecoinpayments_invoice_project_record_period_end StripecoinpaymentsInvoiceProjectRecord_PeriodEnd_Field, - stripecoinpayments_invoice_project_record_state StripecoinpaymentsInvoiceProjectRecord_State_Field, - optional StripecoinpaymentsInvoiceProjectRecord_Create_Fields) ( - stripecoinpayments_invoice_project_record *StripecoinpaymentsInvoiceProjectRecord, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_StripecoinpaymentsInvoiceProjectRecord(ctx, stripecoinpayments_invoice_project_record_id, stripecoinpayments_invoice_project_record_project_id, stripecoinpayments_invoice_project_record_storage, stripecoinpayments_invoice_project_record_egress, stripecoinpayments_invoice_project_record_period_start, stripecoinpayments_invoice_project_record_period_end, stripecoinpayments_invoice_project_record_state, optional) - -} - -func (rx *Rx) Create_StripecoinpaymentsTxConversionRate(ctx context.Context, - stripecoinpayments_tx_conversion_rate_tx_id StripecoinpaymentsTxConversionRate_TxId_Field, - stripecoinpayments_tx_conversion_rate_rate_numeric StripecoinpaymentsTxConversionRate_RateNumeric_Field) ( - stripecoinpayments_tx_conversion_rate *StripecoinpaymentsTxConversionRate, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_StripecoinpaymentsTxConversionRate(ctx, stripecoinpayments_tx_conversion_rate_tx_id, stripecoinpayments_tx_conversion_rate_rate_numeric) - -} - -func (rx *Rx) Create_User(ctx context.Context, - user_id User_Id_Field, - user_email User_Email_Field, - user_normalized_email User_NormalizedEmail_Field, - user_full_name User_FullName_Field, - user_password_hash User_PasswordHash_Field, - optional User_Create_Fields) ( - user *User, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_User(ctx, user_id, user_email, user_normalized_email, user_full_name, user_password_hash, optional) - -} - -func (rx *Rx) Create_ValueAttribution(ctx context.Context, - value_attribution_project_id ValueAttribution_ProjectId_Field, - value_attribution_bucket_name ValueAttribution_BucketName_Field, - optional ValueAttribution_Create_Fields) ( - value_attribution *ValueAttribution, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_ValueAttribution(ctx, value_attribution_project_id, value_attribution_bucket_name, optional) - -} - -func (rx *Rx) Create_WebappSession(ctx context.Context, - webapp_session_id WebappSession_Id_Field, - webapp_session_user_id WebappSession_UserId_Field, - webapp_session_ip_address WebappSession_IpAddress_Field, - webapp_session_user_agent WebappSession_UserAgent_Field, - webapp_session_expires_at WebappSession_ExpiresAt_Field) ( - webapp_session *WebappSession, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Create_WebappSession(ctx, webapp_session_id, webapp_session_user_id, webapp_session_ip_address, webapp_session_user_agent, webapp_session_expires_at) - -} - -func (rx *Rx) Delete_AccountFreezeEvent_By_UserId(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_AccountFreezeEvent_By_UserId(ctx, account_freeze_event_user_id) - -} - -func (rx *Rx) Delete_AccountFreezeEvent_By_UserId_And_Event(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field, - account_freeze_event_event AccountFreezeEvent_Event_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_AccountFreezeEvent_By_UserId_And_Event(ctx, account_freeze_event_user_id, account_freeze_event_event) -} - -func (rx *Rx) Delete_ApiKey_By_Id(ctx context.Context, - api_key_id ApiKey_Id_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_ApiKey_By_Id(ctx, api_key_id) -} - -func (rx *Rx) Delete_BucketMetainfo_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_BucketMetainfo_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Delete_GracefulExitSegmentTransfer_By_NodeId(ctx context.Context, - graceful_exit_segment_transfer_node_id GracefulExitSegmentTransfer_NodeId_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_GracefulExitSegmentTransfer_By_NodeId(ctx, graceful_exit_segment_transfer_node_id) - -} - -func (rx *Rx) Delete_GracefulExitSegmentTransfer_By_NodeId_And_FinishedAt_IsNot_Null(ctx context.Context, - graceful_exit_segment_transfer_node_id GracefulExitSegmentTransfer_NodeId_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_GracefulExitSegmentTransfer_By_NodeId_And_FinishedAt_IsNot_Null(ctx, graceful_exit_segment_transfer_node_id) - -} - -func (rx *Rx) Delete_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx context.Context, - graceful_exit_segment_transfer_node_id GracefulExitSegmentTransfer_NodeId_Field, - graceful_exit_segment_transfer_stream_id GracefulExitSegmentTransfer_StreamId_Field, - graceful_exit_segment_transfer_position GracefulExitSegmentTransfer_Position_Field, - graceful_exit_segment_transfer_piece_num GracefulExitSegmentTransfer_PieceNum_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx, graceful_exit_segment_transfer_node_id, graceful_exit_segment_transfer_stream_id, graceful_exit_segment_transfer_position, graceful_exit_segment_transfer_piece_num) -} - -func (rx *Rx) Delete_NodeEvent_By_CreatedAt_Less(ctx context.Context, - node_event_created_at_less NodeEvent_CreatedAt_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_NodeEvent_By_CreatedAt_Less(ctx, node_event_created_at_less) - -} - -func (rx *Rx) Delete_OauthClient_By_Id(ctx context.Context, - oauth_client_id OauthClient_Id_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_OauthClient_By_Id(ctx, oauth_client_id) -} - -func (rx *Rx) Delete_ProjectInvitation_By_ProjectId_And_Email(ctx context.Context, - project_invitation_project_id ProjectInvitation_ProjectId_Field, - project_invitation_email ProjectInvitation_Email_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_ProjectInvitation_By_ProjectId_And_Email(ctx, project_invitation_project_id, project_invitation_email) -} - -func (rx *Rx) Delete_ProjectMember_By_MemberId_And_ProjectId(ctx context.Context, - project_member_member_id ProjectMember_MemberId_Field, - project_member_project_id ProjectMember_ProjectId_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_ProjectMember_By_MemberId_And_ProjectId(ctx, project_member_member_id, project_member_project_id) -} - -func (rx *Rx) Delete_Project_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_Project_By_Id(ctx, project_id) -} - -func (rx *Rx) Delete_RepairQueue_By_UpdatedAt_Less(ctx context.Context, - repair_queue_updated_at_less RepairQueue_UpdatedAt_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_RepairQueue_By_UpdatedAt_Less(ctx, repair_queue_updated_at_less) - -} - -func (rx *Rx) Delete_ResetPasswordToken_By_Secret(ctx context.Context, - reset_password_token_secret ResetPasswordToken_Secret_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_ResetPasswordToken_By_Secret(ctx, reset_password_token_secret) -} - -func (rx *Rx) Delete_ReverificationAudits_By_NodeId_And_StreamId_And_Position(ctx context.Context, - reverification_audits_node_id ReverificationAudits_NodeId_Field, - reverification_audits_stream_id ReverificationAudits_StreamId_Field, - reverification_audits_position ReverificationAudits_Position_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_ReverificationAudits_By_NodeId_And_StreamId_And_Position(ctx, reverification_audits_node_id, reverification_audits_stream_id, reverification_audits_position) -} - -func (rx *Rx) Delete_StorjscanPayment_By_Status(ctx context.Context, - storjscan_payment_status StorjscanPayment_Status_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_StorjscanPayment_By_Status(ctx, storjscan_payment_status) - -} - -func (rx *Rx) Delete_User_By_Id(ctx context.Context, - user_id User_Id_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_User_By_Id(ctx, user_id) -} - -func (rx *Rx) Delete_WebappSession_By_Id(ctx context.Context, - webapp_session_id WebappSession_Id_Field) ( - deleted bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_WebappSession_By_Id(ctx, webapp_session_id) -} - -func (rx *Rx) Delete_WebappSession_By_UserId(ctx context.Context, - webapp_session_user_id WebappSession_UserId_Field) ( - count int64, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Delete_WebappSession_By_UserId(ctx, webapp_session_user_id) - -} - -func (rx *Rx) Find_AccountingTimestamps_Value_By_Name(ctx context.Context, - accounting_timestamps_name AccountingTimestamps_Name_Field) ( - row *Value_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Find_AccountingTimestamps_Value_By_Name(ctx, accounting_timestamps_name) -} - -func (rx *Rx) First_BillingTransaction_By_Source_And_Type_OrderBy_Desc_CreatedAt(ctx context.Context, - billing_transaction_source BillingTransaction_Source_Field, - billing_transaction_type BillingTransaction_Type_Field) ( - billing_transaction *BillingTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.First_BillingTransaction_By_Source_And_Type_OrderBy_Desc_CreatedAt(ctx, billing_transaction_source, billing_transaction_type) -} - -func (rx *Rx) First_NodeEvent_By_Email_And_Event_OrderBy_Desc_CreatedAt(ctx context.Context, - node_event_email NodeEvent_Email_Field, - node_event_event NodeEvent_Event_Field) ( - node_event *NodeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.First_NodeEvent_By_Email_And_Event_OrderBy_Desc_CreatedAt(ctx, node_event_email, node_event_event) -} - -func (rx *Rx) First_ReverificationAudits_By_NodeId_OrderBy_Asc_StreamId_Asc_Position(ctx context.Context, - reverification_audits_node_id ReverificationAudits_NodeId_Field) ( - reverification_audits *ReverificationAudits, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.First_ReverificationAudits_By_NodeId_OrderBy_Asc_StreamId_Asc_Position(ctx, reverification_audits_node_id) -} - -func (rx *Rx) First_StorjscanPayment_BlockNumber_By_Status_OrderBy_Desc_BlockNumber_Desc_LogIndex(ctx context.Context, - storjscan_payment_status StorjscanPayment_Status_Field) ( - row *BlockNumber_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.First_StorjscanPayment_BlockNumber_By_Status_OrderBy_Desc_BlockNumber_Desc_LogIndex(ctx, storjscan_payment_status) -} - -func (rx *Rx) Get_AccountFreezeEvent_By_UserId_And_Event(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field, - account_freeze_event_event AccountFreezeEvent_Event_Field) ( - account_freeze_event *AccountFreezeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_AccountFreezeEvent_By_UserId_And_Event(ctx, account_freeze_event_user_id, account_freeze_event_event) -} - -func (rx *Rx) Get_ApiKey_Project_PublicId_By_ApiKey_Head(ctx context.Context, - api_key_head ApiKey_Head_Field) ( - row *ApiKey_Project_PublicId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ApiKey_Project_PublicId_By_ApiKey_Head(ctx, api_key_head) -} - -func (rx *Rx) Get_ApiKey_Project_PublicId_By_ApiKey_Id(ctx context.Context, - api_key_id ApiKey_Id_Field) ( - row *ApiKey_Project_PublicId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ApiKey_Project_PublicId_By_ApiKey_Id(ctx, api_key_id) -} - -func (rx *Rx) Get_ApiKey_Project_PublicId_By_ApiKey_Name_And_ApiKey_ProjectId(ctx context.Context, - api_key_name ApiKey_Name_Field, - api_key_project_id ApiKey_ProjectId_Field) ( - row *ApiKey_Project_PublicId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ApiKey_Project_PublicId_By_ApiKey_Name_And_ApiKey_ProjectId(ctx, api_key_name, api_key_project_id) -} - -func (rx *Rx) Get_BillingBalance_Balance_By_UserId(ctx context.Context, - billing_balance_user_id BillingBalance_UserId_Field) ( - row *Balance_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BillingBalance_Balance_By_UserId(ctx, billing_balance_user_id) -} - -func (rx *Rx) Get_BillingTransaction_Metadata_By_Id(ctx context.Context, - billing_transaction_id BillingTransaction_Id_Field) ( - row *Metadata_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BillingTransaction_Metadata_By_Id(ctx, billing_transaction_id) -} - -func (rx *Rx) Get_BucketMetainfo_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - bucket_metainfo *BucketMetainfo, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BucketMetainfo_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Get_BucketMetainfo_CreatedAt_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - row *CreatedAt_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BucketMetainfo_CreatedAt_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Get_BucketMetainfo_Id_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - row *Id_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BucketMetainfo_Id_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Get_BucketMetainfo_Placement_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - row *Placement_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BucketMetainfo_Placement_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Get_BucketMetainfo_UserAgent_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - row *UserAgent_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_BucketMetainfo_UserAgent_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Get_GracefulExitProgress_By_NodeId(ctx context.Context, - graceful_exit_progress_node_id GracefulExitProgress_NodeId_Field) ( - graceful_exit_progress *GracefulExitProgress, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_GracefulExitProgress_By_NodeId(ctx, graceful_exit_progress_node_id) -} - -func (rx *Rx) Get_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx context.Context, - graceful_exit_segment_transfer_node_id GracefulExitSegmentTransfer_NodeId_Field, - graceful_exit_segment_transfer_stream_id GracefulExitSegmentTransfer_StreamId_Field, - graceful_exit_segment_transfer_position GracefulExitSegmentTransfer_Position_Field, - graceful_exit_segment_transfer_piece_num GracefulExitSegmentTransfer_PieceNum_Field) ( - graceful_exit_segment_transfer *GracefulExitSegmentTransfer, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx, graceful_exit_segment_transfer_node_id, graceful_exit_segment_transfer_stream_id, graceful_exit_segment_transfer_position, graceful_exit_segment_transfer_piece_num) -} - -func (rx *Rx) Get_NodeEvent_By_Id(ctx context.Context, - node_event_id NodeEvent_Id_Field) ( - node_event *NodeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_NodeEvent_By_Id(ctx, node_event_id) -} - -func (rx *Rx) Get_Node_By_Id(ctx context.Context, - node_id Node_Id_Field) ( - node *Node, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Node_By_Id(ctx, node_id) -} - -func (rx *Rx) Get_OauthClient_By_Id(ctx context.Context, - oauth_client_id OauthClient_Id_Field) ( - oauth_client *OauthClient, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_OauthClient_By_Id(ctx, oauth_client_id) -} - -func (rx *Rx) Get_OauthCode_By_Code_And_ClaimedAt_Is_Null(ctx context.Context, - oauth_code_code OauthCode_Code_Field) ( - oauth_code *OauthCode, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_OauthCode_By_Code_And_ClaimedAt_Is_Null(ctx, oauth_code_code) -} - -func (rx *Rx) Get_OauthToken_By_Kind_And_Token(ctx context.Context, - oauth_token_kind OauthToken_Kind_Field, - oauth_token_token OauthToken_Token_Field) ( - oauth_token *OauthToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_OauthToken_By_Kind_And_Token(ctx, oauth_token_kind, oauth_token_token) -} - -func (rx *Rx) Get_PeerIdentity_By_NodeId(ctx context.Context, - peer_identity_node_id PeerIdentity_NodeId_Field) ( - peer_identity *PeerIdentity, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_PeerIdentity_By_NodeId(ctx, peer_identity_node_id) -} - -func (rx *Rx) Get_PeerIdentity_LeafSerialNumber_By_NodeId(ctx context.Context, - peer_identity_node_id PeerIdentity_NodeId_Field) ( - row *LeafSerialNumber_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_PeerIdentity_LeafSerialNumber_By_NodeId(ctx, peer_identity_node_id) -} - -func (rx *Rx) Get_ProjectInvitation_By_ProjectId_And_Email(ctx context.Context, - project_invitation_project_id ProjectInvitation_ProjectId_Field, - project_invitation_email ProjectInvitation_Email_Field) ( - project_invitation *ProjectInvitation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ProjectInvitation_By_ProjectId_And_Email(ctx, project_invitation_project_id, project_invitation_email) -} - -func (rx *Rx) Get_Project_BandwidthLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *BandwidthLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_BandwidthLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_BandwidthLimit_Project_UsageLimit_Project_SegmentLimit_Project_RateLimit_Project_BurstLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *BandwidthLimit_UsageLimit_SegmentLimit_RateLimit_BurstLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_BandwidthLimit_Project_UsageLimit_Project_SegmentLimit_Project_RateLimit_Project_BurstLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - project *Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_By_PublicId(ctx context.Context, - project_public_id Project_PublicId_Field) ( - project *Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_By_PublicId(ctx, project_public_id) -} - -func (rx *Rx) Get_Project_MaxBuckets_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *MaxBuckets_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_MaxBuckets_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_Salt_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *Salt_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_Salt_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_SegmentLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *SegmentLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_SegmentLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_UsageLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *UsageLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_UsageLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_UserSpecifiedBandwidthLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *UserSpecifiedBandwidthLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_UserSpecifiedBandwidthLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_Project_UserSpecifiedUsageLimit_By_Id(ctx context.Context, - project_id Project_Id_Field) ( - row *UserSpecifiedUsageLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Project_UserSpecifiedUsageLimit_By_Id(ctx, project_id) -} - -func (rx *Rx) Get_RegistrationToken_By_OwnerId(ctx context.Context, - registration_token_owner_id RegistrationToken_OwnerId_Field) ( - registration_token *RegistrationToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_RegistrationToken_By_OwnerId(ctx, registration_token_owner_id) -} - -func (rx *Rx) Get_RegistrationToken_By_Secret(ctx context.Context, - registration_token_secret RegistrationToken_Secret_Field) ( - registration_token *RegistrationToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_RegistrationToken_By_Secret(ctx, registration_token_secret) -} - -func (rx *Rx) Get_Reputation_By_Id(ctx context.Context, - reputation_id Reputation_Id_Field) ( - reputation *Reputation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_Reputation_By_Id(ctx, reputation_id) -} - -func (rx *Rx) Get_ResetPasswordToken_By_OwnerId(ctx context.Context, - reset_password_token_owner_id ResetPasswordToken_OwnerId_Field) ( - reset_password_token *ResetPasswordToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ResetPasswordToken_By_OwnerId(ctx, reset_password_token_owner_id) -} - -func (rx *Rx) Get_ResetPasswordToken_By_Secret(ctx context.Context, - reset_password_token_secret ResetPasswordToken_Secret_Field) ( - reset_password_token *ResetPasswordToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ResetPasswordToken_By_Secret(ctx, reset_password_token_secret) -} - -func (rx *Rx) Get_StoragenodePaystub_By_NodeId_And_Period(ctx context.Context, - storagenode_paystub_node_id StoragenodePaystub_NodeId_Field, - storagenode_paystub_period StoragenodePaystub_Period_Field) ( - storagenode_paystub *StoragenodePaystub, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StoragenodePaystub_By_NodeId_And_Period(ctx, storagenode_paystub_node_id, storagenode_paystub_period) -} - -func (rx *Rx) Get_StorjscanWallet_UserId_By_WalletAddress(ctx context.Context, - storjscan_wallet_wallet_address StorjscanWallet_WalletAddress_Field) ( - row *UserId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StorjscanWallet_UserId_By_WalletAddress(ctx, storjscan_wallet_wallet_address) -} - -func (rx *Rx) Get_StorjscanWallet_WalletAddress_By_UserId(ctx context.Context, - storjscan_wallet_user_id StorjscanWallet_UserId_Field) ( - row *WalletAddress_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StorjscanWallet_WalletAddress_By_UserId(ctx, storjscan_wallet_user_id) -} - -func (rx *Rx) Get_StripeCustomer_CustomerId_By_UserId(ctx context.Context, - stripe_customer_user_id StripeCustomer_UserId_Field) ( - row *CustomerId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StripeCustomer_CustomerId_By_UserId(ctx, stripe_customer_user_id) -} - -func (rx *Rx) Get_StripeCustomer_PackagePlan_StripeCustomer_PurchasedPackageAt_By_UserId(ctx context.Context, - stripe_customer_user_id StripeCustomer_UserId_Field) ( - row *PackagePlan_PurchasedPackageAt_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StripeCustomer_PackagePlan_StripeCustomer_PurchasedPackageAt_By_UserId(ctx, stripe_customer_user_id) -} - -func (rx *Rx) Get_StripeCustomer_UserId_By_CustomerId(ctx context.Context, - stripe_customer_customer_id StripeCustomer_CustomerId_Field) ( - row *UserId_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StripeCustomer_UserId_By_CustomerId(ctx, stripe_customer_customer_id) -} - -func (rx *Rx) Get_StripecoinpaymentsInvoiceProjectRecord_By_ProjectId_And_PeriodStart_And_PeriodEnd(ctx context.Context, - stripecoinpayments_invoice_project_record_project_id StripecoinpaymentsInvoiceProjectRecord_ProjectId_Field, - stripecoinpayments_invoice_project_record_period_start StripecoinpaymentsInvoiceProjectRecord_PeriodStart_Field, - stripecoinpayments_invoice_project_record_period_end StripecoinpaymentsInvoiceProjectRecord_PeriodEnd_Field) ( - stripecoinpayments_invoice_project_record *StripecoinpaymentsInvoiceProjectRecord, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StripecoinpaymentsInvoiceProjectRecord_By_ProjectId_And_PeriodStart_And_PeriodEnd(ctx, stripecoinpayments_invoice_project_record_project_id, stripecoinpayments_invoice_project_record_period_start, stripecoinpayments_invoice_project_record_period_end) -} - -func (rx *Rx) Get_StripecoinpaymentsTxConversionRate_By_TxId(ctx context.Context, - stripecoinpayments_tx_conversion_rate_tx_id StripecoinpaymentsTxConversionRate_TxId_Field) ( - stripecoinpayments_tx_conversion_rate *StripecoinpaymentsTxConversionRate, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_StripecoinpaymentsTxConversionRate_By_TxId(ctx, stripecoinpayments_tx_conversion_rate_tx_id) -} - -func (rx *Rx) Get_UserSettings_By_UserId(ctx context.Context, - user_settings_user_id UserSettings_UserId_Field) ( - user_settings *UserSettings, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_UserSettings_By_UserId(ctx, user_settings_user_id) -} - -func (rx *Rx) Get_User_By_Id(ctx context.Context, - user_id User_Id_Field) ( - user *User, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_User_By_Id(ctx, user_id) -} - -func (rx *Rx) Get_User_By_NormalizedEmail_And_Status_Not_Number(ctx context.Context, - user_normalized_email User_NormalizedEmail_Field) ( - user *User, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_User_By_NormalizedEmail_And_Status_Not_Number(ctx, user_normalized_email) -} - -func (rx *Rx) Get_User_PaidTier_By_Id(ctx context.Context, - user_id User_Id_Field) ( - row *PaidTier_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_User_PaidTier_By_Id(ctx, user_id) -} - -func (rx *Rx) Get_User_ProjectLimit_By_Id(ctx context.Context, - user_id User_Id_Field) ( - row *ProjectLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_User_ProjectLimit_By_Id(ctx, user_id) -} - -func (rx *Rx) Get_User_ProjectStorageLimit_User_ProjectBandwidthLimit_User_ProjectSegmentLimit_By_Id(ctx context.Context, - user_id User_Id_Field) ( - row *ProjectStorageLimit_ProjectBandwidthLimit_ProjectSegmentLimit_Row, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_User_ProjectStorageLimit_User_ProjectBandwidthLimit_User_ProjectSegmentLimit_By_Id(ctx, user_id) -} - -func (rx *Rx) Get_ValueAttribution_By_ProjectId_And_BucketName(ctx context.Context, - value_attribution_project_id ValueAttribution_ProjectId_Field, - value_attribution_bucket_name ValueAttribution_BucketName_Field) ( - value_attribution *ValueAttribution, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_ValueAttribution_By_ProjectId_And_BucketName(ctx, value_attribution_project_id, value_attribution_bucket_name) -} - -func (rx *Rx) Get_WebappSession_By_Id(ctx context.Context, - webapp_session_id WebappSession_Id_Field) ( - webapp_session *WebappSession, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Get_WebappSession_By_Id(ctx, webapp_session_id) -} - -func (rx *Rx) Has_BucketMetainfo_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field) ( - has bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Has_BucketMetainfo_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name) -} - -func (rx *Rx) Has_NodeApiVersion_By_Id_And_ApiVersion_GreaterOrEqual(ctx context.Context, - node_api_version_id NodeApiVersion_Id_Field, - node_api_version_api_version_greater_or_equal NodeApiVersion_ApiVersion_Field) ( - has bool, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Has_NodeApiVersion_By_Id_And_ApiVersion_GreaterOrEqual(ctx, node_api_version_id, node_api_version_api_version_greater_or_equal) -} - -func (rx *Rx) Limited_BucketMetainfo_By_ProjectId_And_Name_GreaterOrEqual_OrderBy_Asc_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name_greater_or_equal BucketMetainfo_Name_Field, - limit int, offset int64) ( - rows []*BucketMetainfo, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Limited_BucketMetainfo_By_ProjectId_And_Name_GreaterOrEqual_OrderBy_Asc_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name_greater_or_equal, limit, offset) -} - -func (rx *Rx) Limited_BucketMetainfo_By_ProjectId_And_Name_Greater_OrderBy_Asc_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name_greater BucketMetainfo_Name_Field, - limit int, offset int64) ( - rows []*BucketMetainfo, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Limited_BucketMetainfo_By_ProjectId_And_Name_Greater_OrderBy_Asc_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name_greater, limit, offset) -} - -func (rx *Rx) Limited_Project_By_CreatedAt_Less_OrderBy_Asc_CreatedAt(ctx context.Context, - project_created_at_less Project_CreatedAt_Field, - limit int, offset int64) ( - rows []*Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Limited_Project_By_CreatedAt_Less_OrderBy_Asc_CreatedAt(ctx, project_created_at_less, limit, offset) -} - -func (rx *Rx) Limited_StoragenodePayment_By_NodeId_And_Period_OrderBy_Desc_Id(ctx context.Context, - storagenode_payment_node_id StoragenodePayment_NodeId_Field, - storagenode_payment_period StoragenodePayment_Period_Field, - limit int, offset int64) ( - rows []*StoragenodePayment, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Limited_StoragenodePayment_By_NodeId_And_Period_OrderBy_Desc_Id(ctx, storagenode_payment_node_id, storagenode_payment_period, limit, offset) -} - -func (rx *Rx) Limited_StorjscanPayment_By_ToAddress_OrderBy_Desc_BlockNumber_Desc_LogIndex(ctx context.Context, - storjscan_payment_to_address StorjscanPayment_ToAddress_Field, - limit int, offset int64) ( - rows []*StorjscanPayment, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Limited_StorjscanPayment_By_ToAddress_OrderBy_Desc_BlockNumber_Desc_LogIndex(ctx, storjscan_payment_to_address, limit, offset) -} - -func (rx *Rx) Paged_BucketBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual(ctx context.Context, - bucket_bandwidth_rollup_archive_interval_start_greater_or_equal BucketBandwidthRollupArchive_IntervalStart_Field, - limit int, start *Paged_BucketBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*BucketBandwidthRollupArchive, next *Paged_BucketBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_BucketBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual(ctx, bucket_bandwidth_rollup_archive_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) Paged_BucketBandwidthRollup_By_IntervalStart_GreaterOrEqual(ctx context.Context, - bucket_bandwidth_rollup_interval_start_greater_or_equal BucketBandwidthRollup_IntervalStart_Field, - limit int, start *Paged_BucketBandwidthRollup_By_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*BucketBandwidthRollup, next *Paged_BucketBandwidthRollup_By_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_BucketBandwidthRollup_By_IntervalStart_GreaterOrEqual(ctx, bucket_bandwidth_rollup_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) Paged_Node(ctx context.Context, - limit int, start *Paged_Node_Continuation) ( - rows []*Node, next *Paged_Node_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_Node(ctx, limit, start) -} - -func (rx *Rx) Paged_StoragenodeBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual(ctx context.Context, - storagenode_bandwidth_rollup_archive_interval_start_greater_or_equal StoragenodeBandwidthRollupArchive_IntervalStart_Field, - limit int, start *Paged_StoragenodeBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*StoragenodeBandwidthRollupArchive, next *Paged_StoragenodeBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_StoragenodeBandwidthRollupArchive_By_IntervalStart_GreaterOrEqual(ctx, storagenode_bandwidth_rollup_archive_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) Paged_StoragenodeBandwidthRollupPhase2_By_StoragenodeId_And_IntervalStart_GreaterOrEqual(ctx context.Context, - storagenode_bandwidth_rollup_phase2_storagenode_id StoragenodeBandwidthRollupPhase2_StoragenodeId_Field, - storagenode_bandwidth_rollup_phase2_interval_start_greater_or_equal StoragenodeBandwidthRollupPhase2_IntervalStart_Field, - limit int, start *Paged_StoragenodeBandwidthRollupPhase2_By_StoragenodeId_And_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*StoragenodeBandwidthRollupPhase2, next *Paged_StoragenodeBandwidthRollupPhase2_By_StoragenodeId_And_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_StoragenodeBandwidthRollupPhase2_By_StoragenodeId_And_IntervalStart_GreaterOrEqual(ctx, storagenode_bandwidth_rollup_phase2_storagenode_id, storagenode_bandwidth_rollup_phase2_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) Paged_StoragenodeBandwidthRollup_By_IntervalStart_GreaterOrEqual(ctx context.Context, - storagenode_bandwidth_rollup_interval_start_greater_or_equal StoragenodeBandwidthRollup_IntervalStart_Field, - limit int, start *Paged_StoragenodeBandwidthRollup_By_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*StoragenodeBandwidthRollup, next *Paged_StoragenodeBandwidthRollup_By_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_StoragenodeBandwidthRollup_By_IntervalStart_GreaterOrEqual(ctx, storagenode_bandwidth_rollup_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) Paged_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart_GreaterOrEqual(ctx context.Context, - storagenode_bandwidth_rollup_storagenode_id StoragenodeBandwidthRollup_StoragenodeId_Field, - storagenode_bandwidth_rollup_interval_start_greater_or_equal StoragenodeBandwidthRollup_IntervalStart_Field, - limit int, start *Paged_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart_GreaterOrEqual_Continuation) ( - rows []*StoragenodeBandwidthRollup, next *Paged_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart_GreaterOrEqual_Continuation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Paged_StoragenodeBandwidthRollup_By_StoragenodeId_And_IntervalStart_GreaterOrEqual(ctx, storagenode_bandwidth_rollup_storagenode_id, storagenode_bandwidth_rollup_interval_start_greater_or_equal, limit, start) -} - -func (rx *Rx) ReplaceNoReturn_AccountingTimestamps(ctx context.Context, - accounting_timestamps_name AccountingTimestamps_Name_Field, - accounting_timestamps_value AccountingTimestamps_Value_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.ReplaceNoReturn_AccountingTimestamps(ctx, accounting_timestamps_name, accounting_timestamps_value) - -} - -func (rx *Rx) ReplaceNoReturn_NodeApiVersion(ctx context.Context, - node_api_version_id NodeApiVersion_Id_Field, - node_api_version_api_version NodeApiVersion_ApiVersion_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.ReplaceNoReturn_NodeApiVersion(ctx, node_api_version_id, node_api_version_api_version) - -} - -func (rx *Rx) ReplaceNoReturn_NodeTags(ctx context.Context, - node_tags_node_id NodeTags_NodeId_Field, - node_tags_name NodeTags_Name_Field, - node_tags_value NodeTags_Value_Field, - node_tags_signed_at NodeTags_SignedAt_Field, - node_tags_signer NodeTags_Signer_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.ReplaceNoReturn_NodeTags(ctx, node_tags_node_id, node_tags_name, node_tags_value, node_tags_signed_at, node_tags_signer) - -} - -func (rx *Rx) ReplaceNoReturn_StoragenodePaystub(ctx context.Context, - storagenode_paystub_period StoragenodePaystub_Period_Field, - storagenode_paystub_node_id StoragenodePaystub_NodeId_Field, - storagenode_paystub_codes StoragenodePaystub_Codes_Field, - storagenode_paystub_usage_at_rest StoragenodePaystub_UsageAtRest_Field, - storagenode_paystub_usage_get StoragenodePaystub_UsageGet_Field, - storagenode_paystub_usage_put StoragenodePaystub_UsagePut_Field, - storagenode_paystub_usage_get_repair StoragenodePaystub_UsageGetRepair_Field, - storagenode_paystub_usage_put_repair StoragenodePaystub_UsagePutRepair_Field, - storagenode_paystub_usage_get_audit StoragenodePaystub_UsageGetAudit_Field, - storagenode_paystub_comp_at_rest StoragenodePaystub_CompAtRest_Field, - storagenode_paystub_comp_get StoragenodePaystub_CompGet_Field, - storagenode_paystub_comp_put StoragenodePaystub_CompPut_Field, - storagenode_paystub_comp_get_repair StoragenodePaystub_CompGetRepair_Field, - storagenode_paystub_comp_put_repair StoragenodePaystub_CompPutRepair_Field, - storagenode_paystub_comp_get_audit StoragenodePaystub_CompGetAudit_Field, - storagenode_paystub_surge_percent StoragenodePaystub_SurgePercent_Field, - storagenode_paystub_held StoragenodePaystub_Held_Field, - storagenode_paystub_owed StoragenodePaystub_Owed_Field, - storagenode_paystub_disposed StoragenodePaystub_Disposed_Field, - storagenode_paystub_paid StoragenodePaystub_Paid_Field, - storagenode_paystub_distributed StoragenodePaystub_Distributed_Field) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.ReplaceNoReturn_StoragenodePaystub(ctx, storagenode_paystub_period, storagenode_paystub_node_id, storagenode_paystub_codes, storagenode_paystub_usage_at_rest, storagenode_paystub_usage_get, storagenode_paystub_usage_put, storagenode_paystub_usage_get_repair, storagenode_paystub_usage_put_repair, storagenode_paystub_usage_get_audit, storagenode_paystub_comp_at_rest, storagenode_paystub_comp_get, storagenode_paystub_comp_put, storagenode_paystub_comp_get_repair, storagenode_paystub_comp_put_repair, storagenode_paystub_comp_get_audit, storagenode_paystub_surge_percent, storagenode_paystub_held, storagenode_paystub_owed, storagenode_paystub_disposed, storagenode_paystub_paid, storagenode_paystub_distributed) - -} - -func (rx *Rx) Replace_AccountFreezeEvent(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field, - account_freeze_event_event AccountFreezeEvent_Event_Field, - optional AccountFreezeEvent_Create_Fields) ( - account_freeze_event *AccountFreezeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Replace_AccountFreezeEvent(ctx, account_freeze_event_user_id, account_freeze_event_event, optional) - -} - -func (rx *Rx) Replace_ProjectInvitation(ctx context.Context, - project_invitation_project_id ProjectInvitation_ProjectId_Field, - project_invitation_email ProjectInvitation_Email_Field, - optional ProjectInvitation_Create_Fields) ( - project_invitation *ProjectInvitation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Replace_ProjectInvitation(ctx, project_invitation_project_id, project_invitation_email, optional) - -} - -func (rx *Rx) UpdateNoReturn_AccountingTimestamps_By_Name(ctx context.Context, - accounting_timestamps_name AccountingTimestamps_Name_Field, - update AccountingTimestamps_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_AccountingTimestamps_By_Name(ctx, accounting_timestamps_name, update) -} - -func (rx *Rx) UpdateNoReturn_ApiKey_By_Id(ctx context.Context, - api_key_id ApiKey_Id_Field, - update ApiKey_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_ApiKey_By_Id(ctx, api_key_id, update) -} - -func (rx *Rx) UpdateNoReturn_BillingTransaction_By_Id(ctx context.Context, - billing_transaction_id BillingTransaction_Id_Field, - update BillingTransaction_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_BillingTransaction_By_Id(ctx, billing_transaction_id, update) -} - -func (rx *Rx) UpdateNoReturn_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx context.Context, - graceful_exit_segment_transfer_node_id GracefulExitSegmentTransfer_NodeId_Field, - graceful_exit_segment_transfer_stream_id GracefulExitSegmentTransfer_StreamId_Field, - graceful_exit_segment_transfer_position GracefulExitSegmentTransfer_Position_Field, - graceful_exit_segment_transfer_piece_num GracefulExitSegmentTransfer_PieceNum_Field, - update GracefulExitSegmentTransfer_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_GracefulExitSegmentTransfer_By_NodeId_And_StreamId_And_Position_And_PieceNum(ctx, graceful_exit_segment_transfer_node_id, graceful_exit_segment_transfer_stream_id, graceful_exit_segment_transfer_position, graceful_exit_segment_transfer_piece_num, update) -} - -func (rx *Rx) UpdateNoReturn_NodeApiVersion_By_Id_And_ApiVersion_Less(ctx context.Context, - node_api_version_id NodeApiVersion_Id_Field, - node_api_version_api_version_less NodeApiVersion_ApiVersion_Field, - update NodeApiVersion_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_NodeApiVersion_By_Id_And_ApiVersion_Less(ctx, node_api_version_id, node_api_version_api_version_less, update) -} - -func (rx *Rx) UpdateNoReturn_Node_By_Id(ctx context.Context, - node_id Node_Id_Field, - update Node_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_Node_By_Id(ctx, node_id, update) -} - -func (rx *Rx) UpdateNoReturn_Node_By_Id_And_Disqualified_Is_Null_And_ExitFinishedAt_Is_Null(ctx context.Context, - node_id Node_Id_Field, - update Node_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_Node_By_Id_And_Disqualified_Is_Null_And_ExitFinishedAt_Is_Null(ctx, node_id, update) -} - -func (rx *Rx) UpdateNoReturn_OauthClient_By_Id(ctx context.Context, - oauth_client_id OauthClient_Id_Field, - update OauthClient_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_OauthClient_By_Id(ctx, oauth_client_id, update) -} - -func (rx *Rx) UpdateNoReturn_OauthCode_By_Code_And_ClaimedAt_Is_Null(ctx context.Context, - oauth_code_code OauthCode_Code_Field, - update OauthCode_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_OauthCode_By_Code_And_ClaimedAt_Is_Null(ctx, oauth_code_code, update) -} - -func (rx *Rx) UpdateNoReturn_OauthToken_By_Token_And_Kind(ctx context.Context, - oauth_token_token OauthToken_Token_Field, - oauth_token_kind OauthToken_Kind_Field, - update OauthToken_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_OauthToken_By_Token_And_Kind(ctx, oauth_token_token, oauth_token_kind, update) -} - -func (rx *Rx) UpdateNoReturn_PeerIdentity_By_NodeId(ctx context.Context, - peer_identity_node_id PeerIdentity_NodeId_Field, - update PeerIdentity_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_PeerIdentity_By_NodeId(ctx, peer_identity_node_id, update) -} - -func (rx *Rx) UpdateNoReturn_Reputation_By_Id(ctx context.Context, - reputation_id Reputation_Id_Field, - update Reputation_Update_Fields) ( - err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.UpdateNoReturn_Reputation_By_Id(ctx, reputation_id, update) -} - -func (rx *Rx) Update_AccountFreezeEvent_By_UserId_And_Event(ctx context.Context, - account_freeze_event_user_id AccountFreezeEvent_UserId_Field, - account_freeze_event_event AccountFreezeEvent_Event_Field, - update AccountFreezeEvent_Update_Fields) ( - account_freeze_event *AccountFreezeEvent, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_AccountFreezeEvent_By_UserId_And_Event(ctx, account_freeze_event_user_id, account_freeze_event_event, update) -} - -func (rx *Rx) Update_BillingBalance_By_UserId_And_Balance(ctx context.Context, - billing_balance_user_id BillingBalance_UserId_Field, - billing_balance_balance BillingBalance_Balance_Field, - update BillingBalance_Update_Fields) ( - billing_balance *BillingBalance, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_BillingBalance_By_UserId_And_Balance(ctx, billing_balance_user_id, billing_balance_balance, update) -} - -func (rx *Rx) Update_BucketMetainfo_By_ProjectId_And_Name(ctx context.Context, - bucket_metainfo_project_id BucketMetainfo_ProjectId_Field, - bucket_metainfo_name BucketMetainfo_Name_Field, - update BucketMetainfo_Update_Fields) ( - bucket_metainfo *BucketMetainfo, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_BucketMetainfo_By_ProjectId_And_Name(ctx, bucket_metainfo_project_id, bucket_metainfo_name, update) -} - -func (rx *Rx) Update_CoinpaymentsTransaction_By_Id(ctx context.Context, - coinpayments_transaction_id CoinpaymentsTransaction_Id_Field, - update CoinpaymentsTransaction_Update_Fields) ( - coinpayments_transaction *CoinpaymentsTransaction, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_CoinpaymentsTransaction_By_Id(ctx, coinpayments_transaction_id, update) -} - -func (rx *Rx) Update_Node_By_Id(ctx context.Context, - node_id Node_Id_Field, - update Node_Update_Fields) ( - node *Node, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_Node_By_Id(ctx, node_id, update) -} - -func (rx *Rx) Update_ProjectInvitation_By_ProjectId_And_Email(ctx context.Context, - project_invitation_project_id ProjectInvitation_ProjectId_Field, - project_invitation_email ProjectInvitation_Email_Field, - update ProjectInvitation_Update_Fields) ( - project_invitation *ProjectInvitation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_ProjectInvitation_By_ProjectId_And_Email(ctx, project_invitation_project_id, project_invitation_email, update) -} - -func (rx *Rx) Update_Project_By_Id(ctx context.Context, - project_id Project_Id_Field, - update Project_Update_Fields) ( - project *Project, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_Project_By_Id(ctx, project_id, update) -} - -func (rx *Rx) Update_RegistrationToken_By_Secret(ctx context.Context, - registration_token_secret RegistrationToken_Secret_Field, - update RegistrationToken_Update_Fields) ( - registration_token *RegistrationToken, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_RegistrationToken_By_Secret(ctx, registration_token_secret, update) -} - -func (rx *Rx) Update_Reputation_By_Id(ctx context.Context, - reputation_id Reputation_Id_Field, - update Reputation_Update_Fields) ( - reputation *Reputation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_Reputation_By_Id(ctx, reputation_id, update) -} - -func (rx *Rx) Update_Reputation_By_Id_And_AuditHistory(ctx context.Context, - reputation_id Reputation_Id_Field, - reputation_audit_history Reputation_AuditHistory_Field, - update Reputation_Update_Fields) ( - reputation *Reputation, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_Reputation_By_Id_And_AuditHistory(ctx, reputation_id, reputation_audit_history, update) -} - -func (rx *Rx) Update_StripeCustomer_By_UserId(ctx context.Context, - stripe_customer_user_id StripeCustomer_UserId_Field, - update StripeCustomer_Update_Fields) ( - stripe_customer *StripeCustomer, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_StripeCustomer_By_UserId(ctx, stripe_customer_user_id, update) -} - -func (rx *Rx) Update_StripecoinpaymentsInvoiceProjectRecord_By_Id(ctx context.Context, - stripecoinpayments_invoice_project_record_id StripecoinpaymentsInvoiceProjectRecord_Id_Field, - update StripecoinpaymentsInvoiceProjectRecord_Update_Fields) ( - stripecoinpayments_invoice_project_record *StripecoinpaymentsInvoiceProjectRecord, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_StripecoinpaymentsInvoiceProjectRecord_By_Id(ctx, stripecoinpayments_invoice_project_record_id, update) -} - -func (rx *Rx) Update_UserSettings_By_UserId(ctx context.Context, - user_settings_user_id UserSettings_UserId_Field, - update UserSettings_Update_Fields) ( - user_settings *UserSettings, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_UserSettings_By_UserId(ctx, user_settings_user_id, update) -} - -func (rx *Rx) Update_User_By_Id(ctx context.Context, - user_id User_Id_Field, - update User_Update_Fields) ( - user *User, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_User_By_Id(ctx, user_id, update) -} - -func (rx *Rx) Update_ValueAttribution_By_ProjectId_And_BucketName(ctx context.Context, - value_attribution_project_id ValueAttribution_ProjectId_Field, - value_attribution_bucket_name ValueAttribution_BucketName_Field, - update ValueAttribution_Update_Fields) ( - value_attribution *ValueAttribution, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_ValueAttribution_By_ProjectId_And_BucketName(ctx, value_attribution_project_id, value_attribution_bucket_name, update) -} - -func (rx *Rx) Update_WebappSession_By_Id(ctx context.Context, - webapp_session_id WebappSession_Id_Field, - update WebappSession_Update_Fields) ( - webapp_session *WebappSession, err error) { - var tx *Tx - if tx, err = rx.getTx(ctx); err != nil { - return - } - return tx.Update_WebappSession_By_Id(ctx, webapp_session_id, update) -} - type Methods interface { All_AccountFreezeEvent_By_UserId(ctx context.Context, account_freeze_event_user_id AccountFreezeEvent_UserId_Field) (