- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 1,387 for funcs (0.02 sec)
-
internal/etag/reader.go
} // Write - implement hash.Hash Write func (u UUIDHash) Write(p []byte) (n int, err error) { return len(p), nil } // Sum - implement md5.Sum func (u UUIDHash) Sum(b []byte) []byte { return u.uuid } // Reset - implement hash.Hash Reset func (u UUIDHash) Reset() { return } // Size - implement hash.Hash Size func (u UUIDHash) Size() int { return len(u.uuid) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 4.8K bytes - Viewed (0) -
internal/event/targetlist_test.go
sendErr bool closeErr bool } func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting. func (target ExampleTarget) Save(eventData Event) error { return target.send(eventData) } // Store - Returns a nil store. func (target ExampleTarget) Store() TargetStore { return nil } func (target ExampleTarget) send(eventData Event) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
json.NewEncoder(w).Encode(res) return } func main() { flag.Parse() serveFunc := func() error { return http.ListenAndServe(":8080", nil) } if certFile != "" || keyFile != "" { if certFile == "" || keyFile == "" { log.Fatal("Please provide both a key file and a cert file to enable TLS.") } serveFunc = func() error { return http.ListenAndServeTLS(":8080", certFile, keyFile, nil)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 08 17:15:20 UTC 2024 - 2.7K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug_test.go
args: []string{"adsz"}, expectedString: "", }, } multixds.GetXdsResponse = func(_ *discovery.DiscoveryRequest, _ string, _ string, _ clioptions.CentralControlPlaneOptions, _ []grpc.DialOption, ) (*discovery.DiscoveryResponse, error) { return &discovery.DiscoveryResponse{}, nil } t.Cleanup(func() { multixds.GetXdsResponse = xds.GetXdsResponse }) for i, c := range cases {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 4.5K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p1/golden.txt
pkg p1, const StrConst = "foo" pkg p1, const StrConst ideal-string pkg p1, func Bar(int8, int16, int64) pkg p1, func Bar1(int8, int16, int64) uint64 pkg p1, func Bar2(int8, int16, int64) (uint8, uint64) pkg p1, func BarE() Error pkg p1, func Now() Time pkg p1, func PlainFunc(int, int, string) (*B, error) pkg p1, func TakesFunc(func(int) int) pkg p1, method (*B) JustOnB() pkg p1, method (*B) OnBothTandBPtr()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 3.6K bytes - Viewed (0) -
src/archive/zip/reader.go
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Sat Aug 03 01:05:29 UTC 2024 - 28.1K bytes - Viewed (0) -
cmd/local-locker_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 *localLockMap) DecodeMsg(dc *msgp.Reader) (err error) { var zb0004 uint32 zb0004, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } if (*z) == nil { (*z) = make(localLockMap, zb0004) } else if len((*z)) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
) func md5Header(data []byte) map[string]string { return map[string]string{"etag": getMD5Hash(data)} } // Wrapper for calling PutObject tests for both Erasure multiple disks and single node setup. func TestObjectAPIPutObjectSingle(t *testing.T) { ExecExtendedObjectLayerTest(t, testObjectAPIPutObject) } // Tests validate correctness of PutObject.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
} ps.Unlock() close(doneCh2) } type maskString string func (m maskString) Mask() uint64 { return 1 } func TestPubSub(t *testing.T) { ps := New[Maskable, Maskable](1) ch1 := make(chan Maskable, 1) doneCh1 := make(chan struct{}) defer close(doneCh1) if err := ps.Subscribe(MaskAll, ch1, doneCh1, func(entry Maskable) bool { return true }); err != nil { t.Fatalf("unexpected error: %v", err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 5.8K bytes - Viewed (0) -
internal/grid/grid_types_msgp_test.go
o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z testRequest) Msgsize() (s int) { s = 1 + 4 + msgp.IntSize + 7 + msgp.StringPrefixSize + len(z.String) return } // DecodeMsg implements msgp.Decodable func (z *testResponse) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 8.1K bytes - Viewed (0)