Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 1,423 for Func (0.03 sec)

  1. internal/bucket/replication/and.go

    }
    
    var errDuplicateTagKey = Errorf("Duplicate Tag Keys are not allowed")
    
    // isEmpty returns true if Tags field is null
    func (a And) isEmpty() bool {
    	return len(a.Tags) == 0 && a.Prefix == ""
    }
    
    // Validate - validates the And field
    func (a And) Validate() error {
    	if a.ContainsDuplicateTag() {
    		return errDuplicateTagKey
    	}
    	for _, t := range a.Tags {
    		if err := t.Validate(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/cluster.go

    	cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3"
    
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    )
    
    // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it
    func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) {
    	clusterDump, err := w.GetClusterConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	dac := clusterDump.GetDynamicActiveClusters()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  3. clause/from.go

    package clause
    
    // From from clause
    type From struct {
    	Tables []Table
    	Joins  []Join
    }
    
    // Name from clause name
    func (from From) Name() string {
    	return "FROM"
    }
    
    // Build build from clause
    func (from From) Build(builder Builder) {
    	if len(from.Tables) > 0 {
    		for idx, table := range from.Tables {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    
    			builder.WriteQuoted(table)
    		}
    	} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jul 15 02:25:10 UTC 2020
    - 630 bytes
    - Viewed (0)
  4. cmd/batch-replicate_gen.go

    func (z BatchJobReplicateCredentials) Msgsize() (s int) {
    	s = 1 + 10 + msgp.StringPrefixSize + len(z.AccessKey) + 10 + msgp.StringPrefixSize + len(z.SecretKey) + 13 + msgp.StringPrefixSize + len(z.SessionToken)
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobReplicateFlags) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 40.7K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetidset_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 TestTargetIDSetClone(t *testing.T) {
    	testCases := []struct {
    		set           TargetIDSet
    		targetIDToAdd TargetID
    	}{
    		{NewTargetIDSet(), TargetID{"1", "webhook"}},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    					secret.Identity, t, secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom))
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func valueOrNA(value string) string {
    	if value == "" {
    		return "NA"
    	}
    	return value
    }
    
    func certNotExpired(cert *Cert) bool {
    	// case where cert state is in either Initializing or Unavailable state
    	if cert.ExpirationTime == "" && cert.ValidFrom == "" {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 25 16:38:16 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. cmd/batch-handlers_gen.go

    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z BatchJobPrefix) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0003 := range z {
    		o = msgp.AppendString(o, z[zb0003])
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BatchJobPrefix) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0002 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. src/arena/arena_test.go

    	n int
    }
    type T2 [1 << 20]byte // 1MiB
    
    func TestSmoke(t *testing.T) {
    	a := arena.NewArena()
    	defer a.Free()
    
    	tt := arena.New[T1](a)
    	tt.n = 1
    
    	ts := arena.MakeSlice[T1](a, 99, 100)
    	if len(ts) != 99 {
    		t.Errorf("Slice() len = %d, want 99", len(ts))
    	}
    	if cap(ts) != 100 {
    		t.Errorf("Slice() cap = %d, want 100", cap(ts))
    	}
    	ts[1].n = 42
    }
    
    func TestSmokeLarge(t *testing.T) {
    	a := arena.NewArena()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 12 20:23:36 UTC 2022
    - 742 bytes
    - Viewed (0)
  9. cmd/object-lambda-handlers.go

    // if the text is unknown.
    func StatusCode(text string) int {
    	if code, ok := statusTextToCode[text]; ok {
    		return code
    	}
    	return -1
    }
    
    func fwdHeadersToS3(h http.Header, w http.ResponseWriter) {
    	const trim = "x-amz-fwd-header-"
    	for k, v := range h {
    		if stringsHasPrefixFold(k, trim) {
    			w.Header()[k[len(trim):]] = v
    		}
    	}
    }
    
    func fwdStatusToAPIError(resp *http.Response) *APIError {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. api/go1.20.txt

    pkg syscall (freebsd-riscv64), func CloseOnExec(int) #53466
    pkg syscall (freebsd-riscv64), func CmsgLen(int) int #53466
    pkg syscall (freebsd-riscv64), func CmsgSpace(int) int #53466
    pkg syscall (freebsd-riscv64), func Connect(int, Sockaddr) error #53466
    pkg syscall (freebsd-riscv64), func Dup(int) (int, error) #53466
    pkg syscall (freebsd-riscv64), func Dup2(int, int) error #53466
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 21:23:32 UTC 2023
    - 602.6K bytes
    - Viewed (0)
Back to top