Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 710 for jconst (0.07 sec)

  1. cni/pkg/ipset/ipset.go

    package ipset
    
    import (
    	"errors"
    	"fmt"
    	"net/netip"
    )
    
    type IPSet struct {
    	V4Name string
    	V6Name string
    	Prefix string
    	Deps   NetlinkIpsetDeps
    }
    
    const (
    	V4Name = "%s-v4"
    	V6Name = "%s-v6"
    )
    
    type NetlinkIpsetDeps interface {
    	ipsetIPHashCreate(name string, v6 bool) error
    	destroySet(name string) error
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

         */
        private const val MAX_QUEUE_SIZE = 16L * 1024 * 1024 // 16 MiB.
    
        /**
         * The maximum amount of time after the client calls [close] to wait for a graceful shutdown. If
         * the server doesn't respond the web socket will be canceled.
         */
        const val CANCEL_AFTER_CLOSE_MILLIS = 60L * 1000
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. schema/field.go

    type (
    	// DataType GORM data type
    	DataType string
    	// TimeType GORM time type
    	TimeType int64
    )
    
    // GORM time types
    const (
    	UnixTime        TimeType = 1
    	UnixSecond      TimeType = 2
    	UnixMillisecond TimeType = 3
    	UnixNanosecond  TimeType = 4
    )
    
    // GORM fields types
    const (
    	Bool   DataType = "bool"
    	Int    DataType = "int"
    	Uint   DataType = "uint"
    	Float  DataType = "float"
    	String DataType = "string"
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  4. cmd/metrics-v3-replication.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 cmd
    
    import (
    	"context"
    )
    
    const (
    	replicationAverageActiveWorkers    = "average_active_workers"
    	replicationAverageQueuedBytes      = "average_queued_bytes"
    	replicationAverageQueuedCount      = "average_queued_count"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

          Thread {
            sleep(delayMillis)
            toInterrupt.interrupt()
          }
        interruptingCow.start()
      }
    
      companion object {
        // The size of the socket buffers in bytes.
        private const val SOCKET_BUFFER_SIZE = 256 * 1024
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. src/archive/tar/common.go

    type headerError []string
    
    func (he headerError) Error() string {
    	const prefix = "archive/tar: cannot encode header"
    	var ss []string
    	for _, s := range he {
    		if s != "" {
    			ss = append(ss, s)
    		}
    	}
    	if len(ss) == 0 {
    		return prefix
    	}
    	return fmt.Sprintf("%s: %v", prefix, strings.Join(ss, "; and "))
    }
    
    // Type flags for Header.Typeflag.
    const (
    	// Type '0' indicates a regular file.
    	TypeReg = '0'
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  7. src/bytes/buffer.go

    package bytes
    
    // Simple byte buffer for marshaling data.
    
    import (
    	"errors"
    	"io"
    	"unicode/utf8"
    )
    
    // smallBufferSize is an initial allocation minimal capacity.
    const smallBufferSize = 64
    
    // A Buffer is a variable-sized buffer of bytes with [Buffer.Read] and [Buffer.Write] methods.
    // The zero value for Buffer is an empty buffer ready to use.
    type Buffer struct {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. cmd/dynamic-timeouts.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"math"
    	"sync"
    	"sync/atomic"
    	"time"
    )
    
    const (
    	dynamicTimeoutIncreaseThresholdPct = 0.33 // Upper threshold for failures in order to increase timeout
    	dynamicTimeoutDecreaseThresholdPct = 0.10 // Lower threshold for failures in order to decrease timeout
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  9. internal/config/identity/openid/providercfg.go

    		RedirectURIDynamic: getCfgVal(RedirectURIDynamic) == config.EnableOn,
    		ClientID:           getCfgVal(ClientID),
    		ClientSecret:       getCfgVal(ClientSecret),
    		RolePolicy:         getCfgVal(RolePolicy),
    	}
    }
    
    const (
    	keyCloakVendor = "keycloak"
    )
    
    // initializeProvider initializes if any additional vendor specific information
    // was provided, initialization will return an error initial login fails.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/lex/lex.go

    	"text/scanner"
    
    	"cmd/internal/src"
    )
    
    // A ScanToken represents an input item. It is a simple wrapping of rune, as
    // returned by text/scanner.Scanner, plus a couple of extra values.
    type ScanToken rune
    
    const (
    	// Asm defines some two-character lexemes. We make up
    	// a rune/ScanToken value for them - ugly but simple.
    	LSH          ScanToken = -1000 - iota // << Left shift.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 4.1K bytes
    - Viewed (0)
Back to top