Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 714 for Contexto (0.13 sec)

  1. internal/s3select/jstream/decoder.go

    			continue
    		default:
    			return c
    		}
    	}
    	return 0
    }
    
    // create syntax errors at current position, with optional context
    func (d *Decoder) mkError(err DecoderError, context ...string) error {
    	if len(context) > 0 {
    		err.context = context[0]
    	}
    	err.atChar = d.cur()
    	err.pos[0] = d.lineNo + 1
    	err.pos[1] = int(d.pos - d.lineStart)
    	err.readerErr = d.readerErr
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. internal/event/config_test.go

    </QueueConfiguration>`)
    	queue3 := &Queue{}
    	if err := xml.Unmarshal(data, queue3); err != nil {
    		panic(err)
    	}
    
    	targetList1 := NewTargetList(context.Background())
    
    	targetList2 := NewTargetList(context.Background())
    	if err := targetList2.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	testCases := []struct {
    		queue      *Queue
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_unified_experimental_test.cc

       *     my_add2 = b + b
       *     return my_add1, my_add2
       *
       * Now we will execute this function with an eager context:
       *
       *   output1, output2 = two_adds(2.0, 3.0)
       *
       * and check that we got 5.0 and 6.0 as results.
       */
    
      // Build eager context.
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_ContextOptionsSetTfrt(opts, std::get<1>(GetParam()));
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  4. tests/scopes_test.go

    package tests_test
    
    import (
    	"context"
    	"testing"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func NameIn1And2(d *gorm.DB) *gorm.DB {
    	return d.Where("name in (?)", []string{"ScopeUser1", "ScopeUser2"})
    }
    
    func NameIn2And3(d *gorm.DB) *gorm.DB {
    	return d.Where("name in (?)", []string{"ScopeUser2", "ScopeUser3"})
    }
    
    func NameIn(names []string) func(d *gorm.DB) *gorm.DB {
    	return func(d *gorm.DB) *gorm.DB {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Fri Jan 12 08:42:21 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  5. cmd/metrics-v3-bucket-replication.go

    		bucketL)
    )
    
    // loadBucketReplicationMetrics - `BucketMetricsLoaderFn` for bucket replication metrics
    // such as latency and sent bytes.
    func loadBucketReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache, buckets []string) error {
    	if globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  6. internal/http/transports.go

    	return tr
    }
    
    // NewHTTPTransportWithClientCerts returns a new http configuration used for
    // communicating with client cert authentication.
    func (s ConnSettings) NewHTTPTransportWithClientCerts(ctx context.Context, clientCert, clientKey string) (*http.Transport, error) {
    	transport := s.NewHTTPTransportWithTimeout(1 * time.Minute)
    	if clientCert != "" && clientKey != "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. internal/etag/reader.go

    // MD5 checksum of the content read from r as ETag.
    //
    // If the provided etag is not nil the returned
    // Reader compares the etag with the computed
    // MD5 sum once the r returns io.EOF.
    func NewReader(ctx context.Context, r io.Reader, etag ETag, forceMD5 []byte) *Reader {
    	if er, ok := r.(*Reader); ok {
    		if er.readN == 0 && Equal(etag, er.checksum) {
    			return er
    		}
    	}
    	if len(forceMD5) != 0 {
    		return &Reader{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. cmd/metrics-realtime.go

    				FlushIOs:       st.FlushIOs,
    				FlushTicks:     st.FlushTicks,
    			}
    		}
    
    		metrics[d.Endpoint] = dm
    	}
    	return metrics
    }
    
    func collectRemoteMetrics(ctx context.Context, types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) {
    	if !globalIsDistErasure {
    		return
    	}
    	all := globalNotificationSys.GetMetrics(ctx, types, opts)
    	for _, remote := range all {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. docs/sts/custom-token-identity.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"context"
    	"flag"
    	"fmt"
    	"log"
    	"net/url"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	// LDAP integrated Minio endpoint
    	stsEndpoint string
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  10. architecture/standards/0001-use-architectural-decision-records.md

    # ADR-0001 - Use Architectural Decision Records
    
    ## Date
    
    2023-12-01
    
    ## Context
    
    In a distributed team with many subteams, the best solution to communicate decisions is to use a format accessible by everyone in charge of development.
    
    We use *Specification* and *Discovery* documents stored in Google Drive, but they present some downsides:
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Sat Mar 02 21:54:40 UTC 2024
    - 2.8K bytes
    - Viewed (0)
Back to top