Search Options

Results per page
Sort
Preferred Languages
Advance

Results 811 - 820 of 1,425 for Func (0.04 sec)

  1. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    func (c *ConfigWriter) PrintVersionSummary() error {
    	// TODO
    	return nil
    }
    
    // PrintPodRootCAFromDynamicSecretDump prints just pod's root ca from dynamic secret config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) {
    	// TODO
    	return "", nil
    }
    
    func (c *ConfigWriter) tabwriter() *tabwriter.Writer {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 06 20:18:34 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    	}
    }
    
    func Test_localLocker_expireOldLocksExpire(t *testing.T) {
    	rng := rand.New(rand.NewSource(0))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2.go

    var metaDataPool = sync.Pool{New: func() interface{} { return make([]byte, 0, metaDataReadDefault) }}
    
    // metaDataPoolGet will return a byte slice with capacity at least metaDataReadDefault.
    // It will be length 0.
    func metaDataPoolGet() []byte {
    	return metaDataPool.Get().([]byte)[:0]
    }
    
    // metaDataPoolPut will put an unused small buffer back into the pool.
    func metaDataPoolPut(buf []byte) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  4. cmd/xl-storage-format-utils.go

    //
    // Note: Only the scanner requires fivs.Versions to have exclusively non-free versions. This is used while enforcing NewerNoncurrentVersions lifecycle element.
    func getFileInfoVersions(xlMetaBuf []byte, volume, path string, inclFreeVersions bool) (FileInfoVersions, error) {
    	fivs, err := getAllFileInfoVersions(xlMetaBuf, volume, path, true)
    	if err != nil {
    		return fivs, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/event/rulesmap_test.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 event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestRulesMapClone(t *testing.T) {
    	rulesMapCase1 := make(RulesMap)
    	rulesMapToAddCase1 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. istioctl/pkg/tag/tag.go

    without manual relabeling of the "istio.io/rev" tag.
    `,
    		Args: func(cmd *cobra.Command, args []string) error {
    			if len(args) != 0 {
    				return fmt.Errorf("unknown subcommand %q", args[0])
    			}
    			return nil
    		},
    		RunE: func(cmd *cobra.Command, args []string) error {
    			cmd.HelpFunc()(cmd, args)
    			return nil
    		},
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 15:40:30 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  7. cmd/mrf_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *PartialOperation) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. cmd/sftp-server.go

    }
    
    func sshPubKeyAuth(c ssh.ConnMetadata, key ssh.PublicKey) (*ssh.Permissions, error) {
    	return authenticateSSHConnection(c, key, nil)
    }
    
    func sshPasswordAuth(c ssh.ConnMetadata, pass []byte) (*ssh.Permissions, error) {
    	return authenticateSSHConnection(c, nil, pass)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
  9. tests/migrate_test.go

    		checkMyIndex = func(t *testing.T) {
    			checkColumnType(t, "name", true)
    			checkIndex(t, []gorm.Index{uniqueConstraintIndex, myIndex})
    		}
    		checkMulIndex = func(t *testing.T) {
    			checkColumnType(t, "name", false)
    			checkColumnType(t, "nick_name", false)
    			checkIndex(t, []gorm.Index{mulIndex})
    		}
    	} else {
    		checkNotUnique = func(t *testing.T) { checkColumnType(t, "name", false) }
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
  10. internal/dsync/lock-args_gen.go

    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z LockResp) Msgsize() (s int) {
    	s = 1 + 5 + msgp.Uint8Size + 4 + msgp.StringPrefixSize + len(z.Err)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ResponseCode) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top