- Sort Score
- Result 10 results
- Languages All
Results 1051 - 1060 of 1,384 for funcs (0.03 sec)
-
logger/sql_test.go
"gorm.io/gorm/logger" ) type JSON json.RawMessage func (j JSON) Value() (driver.Value, error) { if len(j) == 0 { return nil, nil } return json.RawMessage(j).MarshalJSON() } type ExampleStruct struct { Name string Val string } func (s ExampleStruct) Value() (driver.Value, error) { return json.Marshal(s) } func format(v []byte, escaper string) string {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Mar 21 08:00:02 UTC 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject_test.go
t.Fatal(err) } whs = append(whs, *wh) } for _, c := range cases { t.Run(c.name, func(t *testing.T) { checkResults := analyzeRunningWebhooks(whs, c.pod.Labels, c.ns.Labels) assert.Equal(t, c.expectedMessages, checkResults) }) } } var nsTestObject = func(namespace, injLabelValue, revLabelValue string) *corev1.Namespace { labels := map[string]string{} if injLabelValue != "" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 10.6K bytes - Viewed (0) -
internal/config/config_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 config import ( "testing" ) func TestKVFields(t *testing.T) { tests := []struct { input string keys []string expectedFields map[string]struct{} }{ // No keys present { input: "",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 18 22:55:17 UTC 2022 - 4.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/api/label" "istio.io/istio/cni/pkg/util" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/monitoring/monitortest" "istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 22.1K bytes - Viewed (0) -
clause/limit_test.go
package clause_test import ( "fmt" "testing" "gorm.io/gorm/clause" ) func TestLimit(t *testing.T) { limit0 := 0 limit10 := 10 limit50 := 50 limitNeg10 := -10 results := []struct { Clauses []clause.Interface Result string Vars []interface{} }{ { []clause.Interface{clause.Select{}, clause.From{}, clause.Limit{ Limit: &limit10, Offset: 20, }},
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 2.3K bytes - Viewed (0) -
internal/amztime/iso8601_time.go
) // ISO8601Format converts time 't' into ISO8601 time format expected in AWS S3 spec. // // This function is needed to avoid a Go's float64 precision bug, where Go avoids // padding the extra '0' before the timezone. func ISO8601Format(t time.Time) string { value := t.Format(iso8601TimeFormat) if len(value) < len(iso8601TimeFormat) { value = t.Format(iso8601TimeFormat[:len(iso8601TimeFormat)-1])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jan 16 23:38:33 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/disk/fdatasync_linux.go
// // The aim of fdatasync() is to reduce disk activity for applications that // do not require all metadata to be synchronized with the disk. func Fdatasync(f *os.File) error { return syscall.Fdatasync(int(f.Fd())) } // FadviseDontNeed invalidates page-cache func FadviseDontNeed(f *os.File) error { return unix.Fadvise(int(f.Fd()), 0, 0, unix.FADV_DONTNEED)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 29 23:40:28 UTC 2021 - 1.8K bytes - Viewed (0) -
internal/event/target/nsq_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package target import ( "testing" xnet "github.com/minio/pkg/v3/net" ) func TestNSQArgs_Validate(t *testing.T) { type fields struct { Enable bool NSQDAddress xnet.Host Topic string TLS struct { Enable bool SkipVerify bool } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/metrics-realtime.go
c "github.com/shirou/gopsutil/v3/cpu" "github.com/shirou/gopsutil/v3/load" ) type collectMetricsOpts struct { hosts map[string]struct{} disks map[string]struct{} jobID string depID string } func collectLocalMetrics(types madmin.MetricType, opts collectMetricsOpts) (m madmin.RealtimeMetrics) { if types == madmin.MetricsNone { return } byHostName := globalMinioAddr if len(opts.hosts) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:16:24 UTC 2024 - 6.3K bytes - Viewed (0) -
internal/http/check_port_linux.go
// It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{ Control: func(network, address string, c syscall.RawConn) error { c.Control(func(fdPtr uintptr) { if opts.Interface != "" { // When interface is specified look for specifically port availability on
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0)