Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewTransaction (0.17 sec)

  1. pkg/proxy/nftables/proxier.go

    	var encounteredError bool
    
    	for _, family := range []knftables.Family{knftables.IPv4Family, knftables.IPv6Family} {
    		nft, err := knftables.New(family, kubeProxyTable)
    		if err == nil {
    			tx := nft.NewTransaction()
    			tx.Delete(&knftables.Table{})
    			err = nft.Run(ctx, tx)
    		}
    		if err != nil && !knftables.IsNotFound(err) {
    			logger.Error(err, "Error cleaning up nftables rules")
    			encounteredError = true
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     * completes before closing starts, rather than once it has finished.
     *
     * <pre>{@code
     * FluentFuture<UserName> userName =
     *     ClosingFuture.submit(
     *             closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:37:15 UTC 2024
    - 98.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ClosingFuture.java

     * completes before closing starts, rather than once it has finished.
     *
     * <pre>{@code
     * FluentFuture<UserName> userName =
     *     ClosingFuture.submit(
     *             closer -> closer.eventuallyClose(database.newTransaction(), closingExecutor),
     *             executor)
     *         .transformAsync((closer, transaction) -> transaction.queryClosingFuture("..."), executor)
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 98.7K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/helpers_test.go

    		t.Errorf("found no diff in inputs that should have been different")
    	}
    }
    
    func Test_diffNFTablesChain(t *testing.T) {
    	fake := knftables.NewFake(knftables.IPv4Family, "testing")
    	tx := fake.NewTransaction()
    
    	tx.Add(&knftables.Table{})
    	tx.Add(&knftables.Chain{
    		Name: "mark-masq-chain",
    	})
    	tx.Add(&knftables.Chain{
    		Name: "masquerade-chain",
    	})
    	tx.Add(&knftables.Chain{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 09:57:47 UTC 2024
    - 48.5K bytes
    - Viewed (0)
Back to top