Search Options

Results per page
Sort
Preferred Languages
Advance

Results 961 - 970 of 1,605 for var1 (0.06 sec)

  1. internal/logger/logrotate.go

    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    var stdErrEnc = json.NewEncoder(os.Stderr)
    
    func (w *Writer) listen() {
    	for {
    		var r io.Reader = w.pr
    		if w.opts.MaximumFileSize > 0 {
    			r = io.LimitReader(w.pr, w.opts.MaximumFileSize)
    		}
    		if _, err := io.Copy(w.f, r); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. cmd/batch-expire_test.go

      
      retry:
        attempts: 10 # number of retries for the job before giving up
        delay: 500ms # least amount of delay between each retry
    `
    	var job BatchJobRequest
    	err := yaml.Unmarshal([]byte(expireYaml), &job)
    	if err != nil {
    		t.Fatal("Failed to parse batch-job-expire yaml", err)
    	}
    	if !slices.Equal(job.Expire.Prefix.F(), []string{"myprefix"}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/consolelogger.go

    	if !sys.HasLogListeners() {
    		logger.AddSystemTarget(GlobalContext, sys)
    	}
    
    	cnt := 0
    	// by default send all console logs in the ring buffer unless node or limit query parameters
    	// are set.
    	var lastN []log.Info
    	if last > defaultLogBufferCount || last <= 0 {
    		last = defaultLogBufferCount
    	}
    
    	lastN = make([]log.Info, last)
    	sys.RLock()
    	sys.logBuf.Do(func(p interface{}) {
    		if p != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. callbacks/create_test.go

    package callbacks
    
    import (
    	"reflect"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	"gorm.io/gorm/schema"
    )
    
    var schemaCache = &sync.Map{}
    
    func TestConvertToCreateValues_DestType_Slice(t *testing.T) {
    	type user struct {
    		ID    int `gorm:"primaryKey"`
    		Name  string
    		Email string `gorm:"default:(-)"`
    		Age   int    `gorm:"default:(-)"`
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:48:42 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  5. istioctl/pkg/workload/workload_test.go

    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/pilot/test/util"
    	"istio.io/istio/pkg/config/constants"
    	"istio.io/istio/pkg/kube"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    var fakeCACert = []byte("fake-CA-cert")
    
    var (
    	defaultYAML = `apiVersion: networking.istio.io/v1
    kind: WorkloadGroup
    metadata:
      name: foo
      namespace: bar
    spec:
      metadata: {}
      template:
        serviceAccount: default
    `
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. okhttp-android/src/test/kotlin/okhttp3/android/ShadowDnsResolver.kt

    import org.robolectric.annotation.Implementation
    import org.robolectric.annotation.Implements
    import org.robolectric.shadow.api.Shadow
    
    @Implements(DnsResolver::class)
    class ShadowDnsResolver {
      var responder: (Request) -> Unit = {
        it.callback.onAnswer(listOf(), 0)
      }
    
      data class Request(
        val network: Network?,
        val domain: String,
        val nsType: Int,
        val flags: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 22 20:07:09 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  7. cmd/tier_test.go

    	expFailure := 5
    	for i := 0; i < expSuccess; i++ {
    		globalTierMetrics.logSuccess(tier)
    	}
    	for i := 0; i < expFailure; i++ {
    		globalTierMetrics.logFailure(tier)
    	}
    	metrics := globalTierMetrics.Report()
    	var succ, fail float64
    	for _, metric := range metrics {
    		switch metric.Description.Name {
    		case tierRequestsSuccess:
    			succ += metric.Value
    		case tierRequestsFailure:
    			fail += metric.Value
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 21 04:13:40 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  8. src/main/webapp/WEB-INF/view/admin/reqheader/admin_reqheader_details.jsp

                                            <th><la:message
                                                    key="labels.reqheader_web_crawling_config"/></th>
                                            <td><c:forEach var="item" items="${webConfigItems}">
                                                <c:if test="${webConfigId==item.value}">${f:h(item.label)}</c:if>
                                            </c:forEach> <la:hidden property="webConfigId"/></td>
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 13 07:47:04 UTC 2020
    - 4.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/-MediaTypeCommon.kt

      val type = typeSubtype.groupValues[1].lowercase()
      val subtype = typeSubtype.groupValues[2].lowercase()
    
      val parameterNamesAndValues = mutableListOf<String>()
      var s = typeSubtype.range.last + 1
      while (s < length) {
        val parameter = PARAMETER.matchAtPolyfill(this, s)
        require(parameter != null) {
          "Parameter is not formatted correctly: \"${substring(s)}\" for: \"$this\""
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt

    import java.util.concurrent.atomic.AtomicInteger
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    
    @Timeout(30)
    class CustomDispatcherTest {
      private lateinit var mockWebServer: MockWebServer
    
      @BeforeEach
      fun setUp(mockWebServer: MockWebServer) {
        this.mockWebServer = mockWebServer
      }
    
      @Test
      fun simpleDispatch() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top