Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 714 for Contexto (0.1 sec)

  1. src/main/java/org/codelibs/fess/query/WildcardQueryCommand.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final String field = getSearchField(context.getDefaultField(), wildcardQuery.getField());
            if (Constants.DEFAULT_FIELD.equals(field)) {
                final String text = wildcardQuery.getTerm().text();
                context.addFieldLog(field, text);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. internal/kms/kms.go

    }
    
    func (c *kmsConn) Version(ctx context.Context) (string, error) {
    	resp, err := c.client.Version(ctx, &kms.VersionRequest{})
    	if len(resp) == 0 && err != nil {
    		return "", err
    	}
    	return resp[0].Version, nil
    }
    
    func (c *kmsConn) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    func (c *kmsConn) Status(ctx context.Context) (map[string]madmin.ItemState, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/query/FuzzyQueryCommand.java

                context.addFieldLog(field, text);
                context.addHighlightedQuery(text);
                return buildDefaultQueryBuilder(fessConfig, context,
                        (f, b) -> QueryBuilders.fuzzyQuery(f, text).fuzziness(Fuzziness.fromEdits(fuzzyQuery.getMaxEdits())).boost(b * boost)
                                .maxExpansions(fessConfig.getQueryFuzzyExpansionsAsInteger())
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java

            if (Constants.DEFAULT_FIELD.equals(field)) {
                context.addFieldLog(field, text);
                stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
                return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> buildMatchPhraseQuery(f, text).boost(b * boost));
            }
    
            if (isSearchField(field)) {
                context.addFieldLog(field, text);
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. cmd/lock-rest-server.go

    	success, err := l.ll.Lock(context.Background(), *args)
    	if err == nil && !success {
    		return l.makeResp(resp, errLockConflict)
    	}
    	return l.makeResp(resp, err)
    }
    
    // UnlockHandler - releases the acquired lock.
    func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. internal/event/target/elasticsearch.go

    type esClient interface {
    	isAtleastV7() bool
    	createIndex(ElasticsearchArgs) error
    	ping(context.Context, ElasticsearchArgs) (bool, error)
    	stop()
    	entryExists(context.Context, string, string) (bool, error)
    	removeEntry(context.Context, string, string) error
    	updateEntry(context.Context, string, string, event.Event) error
    	addEntry(context.Context, string, event.Event) error
    }
    
    // ElasticsearchArgs - Elasticsearch target arguments.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. cmd/peer-s3-server.go

    package cmd
    
    import (
    	"context"
    	"errors"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    const (
    	peerS3Bucket            = "bucket"
    	peerS3BucketDeleted     = "bucket-deleted"
    	peerS3BucketForceCreate = "force-create"
    	peerS3BucketForceDelete = "force-delete"
    )
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. cmd/lock-rest-client.go

    func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRUnlock, &args)
    }
    
    // Refresh calls Refresh REST API.
    func (c *lockRESTClient) Refresh(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRefresh, &args)
    }
    
    // Unlock calls write unlock RPC.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. tests/connpool_test.go

    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.ExecContext(ctx, query, args...)
    }
    
    func (c *wrapperTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    	c.conn.got = append(c.conn.got, query)
    	return c.Tx.QueryContext(ctx, query, args...)
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. callbacks/associations.go

    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, obj)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						} else if ref.PrimaryValue != "" {
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, ref.PrimaryValue))
    						} else {
    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, elem)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						}
    					}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Apr 11 03:06:13 UTC 2023
    - 14.3K bytes
    - Viewed (0)
Back to top