Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1051 - 1060 of 1,384 for funcs (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top