Search Options

Results per page
Sort
Preferred Languages
Advance

Results 921 - 930 of 1,425 for Func (0.03 sec)

  1. cni/pkg/log/uds_test.go

    	"os"
    	"path/filepath"
    	"strings"
    	"testing"
    	"time"
    
    	"istio.io/istio/cni/pkg/constants"
    	istiolog "istio.io/istio/pkg/log"
    	"istio.io/istio/pkg/ptr"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. cmd/batch-handlers_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"slices"
    	"testing"
    
    	"gopkg.in/yaml.v3"
    )
    
    func TestBatchJobPrefix_UnmarshalYAML(t *testing.T) {
    	type args struct {
    		yamlStr string
    	}
    	type PrefixTemp struct {
    		Prefix BatchJobPrefix `yaml:"prefix"`
    	}
    	tests := []struct {
    		name    string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. internal/amztime/iso8601_time_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 amztime
    
    import (
    	"testing"
    	"time"
    )
    
    func TestISO8601Format(t *testing.T) {
    	testCases := []struct {
    		date           time.Time
    		expectedOutput string
    	}{
    		{
    			date:           time.Date(2009, time.November, 13, 4, 51, 1, 940303531, time.UTC),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Dec 12 18:28:30 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  4. internal/crypto/metadata_test.go

    	}, // 7
    }
    
    func TestCreateMultipartMetadata(t *testing.T) {
    	metadata := CreateMultipartMetadata(nil)
    	if v, ok := metadata[MetaMultipart]; !ok || v != "" {
    		t.Errorf("Metadata is missing the correct value for '%s': got '%s' - want '%s'", MetaMultipart, v, "")
    	}
    }
    
    func TestSSECParseMetadata(t *testing.T) {
    	for i, test := range ssecParseMetadataTests {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. src/bufio/scan.go

    )
    
    // NewScanner returns a new [Scanner] to read from r.
    // The split function defaults to [ScanLines].
    func NewScanner(r io.Reader) *Scanner {
    	return &Scanner{
    		r:            r,
    		split:        ScanLines,
    		maxTokenSize: MaxScanTokenSize,
    	}
    }
    
    // Err returns the first non-EOF error that was encountered by the [Scanner].
    func (s *Scanner) Err() error {
    	if s.err == io.EOF {
    		return nil
    	}
    	return s.err
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 23 09:06:30 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  6. misc/go_android_exec/main.go

    	if err != nil {
    		return 0, fmt.Errorf("adb exec-out %s: %v", args, err)
    	}
    	return exitCode, err2
    }
    
    func adb(args ...string) error {
    	if out, err := adbCmd(args...).CombinedOutput(); err != nil {
    		fmt.Fprintf(os.Stderr, "adb %s\n%s", strings.Join(args, " "), out)
    		return err
    	}
    	return nil
    }
    
    func adbCmd(args ...string) *exec.Cmd {
    	if flags := os.Getenv("GOANDROID_ADB_FLAGS"); flags != "" {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  7. clause/update.go

    package clause
    
    type Update struct {
    	Modifier string
    	Table    Table
    }
    
    // Name update clause name
    func (update Update) Name() string {
    	return "UPDATE"
    }
    
    // Build build update clause
    func (update Update) Build(builder Builder) {
    	if update.Modifier != "" {
    		builder.WriteString(update.Modifier)
    		builder.WriteByte(' ')
    	}
    
    	if update.Table.Name == "" {
    		builder.WriteQuoted(currentTable)
    	} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 09 09:07:00 UTC 2020
    - 737 bytes
    - Viewed (0)
  8. istioctl/pkg/util/ambient/util.go

    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    
    	"istio.io/api/annotation"
    	"istio.io/api/label"
    	"istio.io/istio/pkg/config/constants"
    	"istio.io/istio/pkg/kube"
    )
    
    func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool {
    	isZtunnel := strings.HasPrefix(podName, "ztunnel")
    	if client == nil {
    		return isZtunnel
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/secret_test.go

    import (
    	"bytes"
    	"fmt"
    	"io"
    	"os"
    	"testing"
    
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestSDSWriter_ValidCert(t *testing.T) {
    	testCases := []struct{ sds string }{
    		{sds: "istio"},
    		{sds: "spire"},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.sds, func(t *testing.T) {
    			configDumpFile, err := os.Open(fmt.Sprintf("testdata/secret/%s/config_dump.json", tc.sds))
    			if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. cmd/object-api-interface.go

    // CheckPreconditionFn returns true if precondition check failed.
    type CheckPreconditionFn func(o ObjectInfo) bool
    
    // EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any
    type EvalMetadataFn func(o *ObjectInfo, gerr error) (ReplicateDecision, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top