- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 1,423 for Func (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)