Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1061 - 1070 of 1,423 for Func (0.03 sec)

  1. internal/config/dns/etcd_dns_test.go

    		}
    	}
    }
    
    func TestPath(t *testing.T) {
    	for _, path := range []string{"mydns", "skydns"} {
    		result := msgPath("service.staging.skydns.local.", path)
    		if result != etcdPathSeparator+path+"/local/skydns/staging/service" {
    			t.Errorf("Failure to get domain's path with prefix: %s", result)
    		}
    	}
    }
    
    func TestUnPath(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/VirtualHostHelper.java

                return value;
            });
        }
    
        protected <T> T processVirtualHost(final Function<String, T> func, final T defaultValue) {
            final Tuple3<String, String, String>[] vHosts = ComponentUtil.getFessConfig().getVirtualHosts();
            return LaRequestUtil.getOptionalRequest().map(req -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle-audit.go

    	lcEventSrc_s3PutObject
    	lcEventSrc_s3CopyObject
    	lcEventSrc_s3CompleteMultipartUpload
    )
    
    //revive:enable:var-naming
    type lcAuditEvent struct {
    	lifecycle.Event
    	source lcEventSrc
    }
    
    func (lae lcAuditEvent) Tags() map[string]string {
    	event := lae.Event
    	src := lae.source
    	const (
    		ilmSrc                     = "ilm-src"
    		ilmAction                  = "ilm-action"
    		ilmDue                     = "ilm-due"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. tests/update_has_many_test.go

    package tests_test
    
    import (
    	"testing"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestUpdateHasManyAssociations(t *testing.T) {
    	user := *GetUser("update-has-many", Config{})
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	user.Pets = []*Pet{{Name: "pet1"}, {Name: "pet2"}}
    	if err := DB.Save(&user).Error; err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 2K bytes
    - Viewed (0)
  5. istioctl/pkg/authz/analyzer.go

    func NewAnalyzer(envoyConfig *configdump.Wrapper) (*Analyzer, error) {
    	listeners, err := envoyConfig.GetDynamicListenerDump(true)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get dynamic listener dump: %s", err)
    	}
    
    	return &Analyzer{listenerDump: listeners}, nil
    }
    
    // Print print the analysis results.
    func (a *Analyzer) Print(writer io.Writer) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 13 01:59:17 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  6. cmd/listen-notification-handlers.go

    	"github.com/minio/minio/internal/grid"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    func (api objectAPIHandlers) ListenNotificationHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "ListenNotification")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. src/cmd/asm/main.go

    	"cmd/asm/internal/arch"
    	"cmd/asm/internal/asm"
    	"cmd/asm/internal/flags"
    	"cmd/asm/internal/lex"
    
    	"cmd/internal/bio"
    	"cmd/internal/obj"
    	"cmd/internal/objabi"
    	"cmd/internal/telemetry/counter"
    )
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("asm: ")
    	counter.Open()
    
    	buildcfg.Check()
    	GOARCH := buildcfg.GOARCH
    
    	flags.Parse()
    	counter.Inc("asm/invocations")
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. internal/grid/README.md

    The server handler function has this signature: `type SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)`.
    
    Sample handler:
    ```go
        handler :=  func(payload []byte) ([]byte, *grid.RemoteErr) {
            // Do something with payload
            return []byte("response"), nil
        }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. internal/crypto/sse-kms.go

    	S3KMS = ssekms{}
    
    	_ Type = S3KMS
    )
    
    // String returns the SSE domain as string. For SSE-KMS the
    // domain is "SSE-KMS".
    func (ssekms) String() string { return "SSE-KMS" }
    
    // IsRequested returns true if the HTTP headers contains
    // at least one SSE-KMS header.
    func (ssekms) IsRequested(h http.Header) bool {
    	if _, ok := h[xhttp.AmzServerSideEncryptionKmsID]; ok {
    		return true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  10. callbacks/transaction.go

    import (
    	"gorm.io/gorm"
    )
    
    func BeginTransaction(db *gorm.DB) {
    	if !db.Config.SkipDefaultTransaction && db.Error == nil {
    		if tx := db.Begin(); tx.Error == nil {
    			db.Statement.ConnPool = tx.Statement.ConnPool
    			db.InstanceSet("gorm:started_transaction", true)
    		} else if tx.Error == gorm.ErrInvalidTransaction {
    			tx.Error = nil
    		} else {
    			db.Error = tx.Error
    		}
    	}
    }
    
    func CommitOrRollbackTransaction(db *gorm.DB) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Nov 29 01:33:20 UTC 2021
    - 675 bytes
    - Viewed (0)
Back to top