Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,214 for Func (0.03 sec)

  1. callbacks/update.go

    					called = true
    					db.AddError(i.BeforeUpdate(tx))
    				}
    			}
    
    			return called
    		})
    	}
    }
    
    // Update update hook
    func Update(config *Config) func(db *gorm.DB) {
    	supportReturning := utils.Contains(config.UpdateClauses, "RETURNING")
    
    	return func(db *gorm.DB) {
    		if db.Error != nil {
    			return
    		}
    
    		if db.Statement.Schema != nil {
    			for _, c := range db.Statement.Schema.UpdateClauses {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. internal/event/target/webhook.go

    }
    
    // ID - returns target ID.
    func (target *WebhookTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *WebhookTarget) Name() string {
    	return target.ID().String()
    }
    
    // IsActive - Return true if target is up and active
    func (target *WebhookTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    }
    
    type localPeerS3Client struct {
    	node  Node
    	pools []int
    }
    
    func (l *localPeerS3Client) GetHost() string {
    	return l.node.Host
    }
    
    func (l *localPeerS3Client) SetPools(p []int) {
    	l.pools = make([]int, len(p))
    	copy(l.pools, p)
    }
    
    func (l localPeerS3Client) GetPools() []int {
    	return l.pools
    }
    
    func (l localPeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v1_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgChecksumInfo(b *testing.B) {
    	v := ChecksumInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgChecksumInfo(b *testing.B) {
    	v := ChecksumInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils.go

    }
    
    // Empty returns true if no targets with resync decision present
    func (r ResyncDecision) Empty() bool {
    	return r.targets == nil
    }
    
    func (r ResyncDecision) mustResync() bool {
    	for _, v := range r.targets {
    		if v.Replicate {
    			return true
    		}
    	}
    	return false
    }
    
    func (r ResyncDecision) mustResyncTarget(tgtArn string) bool {
    	if r.targets == nil {
    		return false
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/endtoend_test.go

    		}
    	}
    }
    
    func TestGoBuildErrors(t *testing.T) {
    	testErrors(t, "amd64", "buildtagerror")
    }
    
    func TestGenericErrors(t *testing.T) {
    	testErrors(t, "amd64", "duperror")
    }
    
    func TestARMErrors(t *testing.T) {
    	testErrors(t, "arm", "armerror")
    }
    
    func TestARM64EndToEnd(t *testing.T) {
    	testEndToEnd(t, "arm64", "arm64")
    }
    
    func TestARM64Encoder(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *KafkaTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *KafkaTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *KafkaTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. internal/event/target/postgresql.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *PostgreSQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *PostgreSQLTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *PostgreSQLTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/lex/stack.go

    		tok = s.Next()
    	}
    	return tok
    }
    
    func (s *Stack) Text() string {
    	return s.tr[len(s.tr)-1].Text()
    }
    
    func (s *Stack) File() string {
    	return s.Base().Filename()
    }
    
    func (s *Stack) Base() *src.PosBase {
    	return s.tr[len(s.tr)-1].Base()
    }
    
    func (s *Stack) SetBase(base *src.PosBase) {
    	s.tr[len(s.tr)-1].SetBase(base)
    }
    
    func (s *Stack) Line() int {
    	return s.tr[len(s.tr)-1].Line()
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jan 09 22:33:23 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  10. cmd/global-heal.go

    	jt, _ := workers.New(int(numHealers))
    
    	healEntryDone := func(name string) healEntryResult {
    		return healEntryResult{
    			entryDone: true,
    			name:      name,
    		}
    	}
    
    	healEntrySuccess := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes:   sz,
    			success: true,
    		}
    	}
    
    	healEntryFailure := func(sz uint64) healEntryResult {
    		return healEntryResult{
    			bytes: sz,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top