Search Options

Results per page
Sort
Preferred Languages
Advance

Results 921 - 930 of 1,387 for funcs (0.04 sec)

  1. internal/s3select/sql/jsonpath_test.go

    )
    
    func getJSONStructs(b []byte) ([]interface{}, error) {
    	dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS().MaxDepth(100)
    	var result []interface{}
    	for parsedVal := range dec.Stream() {
    		result = append(result, parsedVal.Value)
    	}
    	if err := dec.Err(); err != nil {
    		return nil, err
    	}
    	return result, nil
    }
    
    func TestJsonpathEval(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. callbacks/helper_test.go

    				Values:  [][]interface{}{{true}},
    			},
    		},
    	}
    
    	for _, tc := range testCase {
    		t.Run(tc.name, func(t *testing.T) {
    			actual := ConvertMapToValuesForCreate(&gorm.Statement{}, tc.input)
    			if !reflect.DeepEqual(actual, tc.expect) {
    				t.Errorf("expect %v got %v", tc.expect, actual)
    			}
    		})
    	}
    }
    
    func TestConvertSliceOfMapToValuesForCreate(t *testing.T) {
    	testCase := []struct {
    		name   string
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 05 02:22:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. internal/logger/audit.go

    // SetAuditEntry sets Audit info in the context.
    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/endpoint-ellipses_test.go

    			}
    		})
    	}
    }
    
    func TestGetDivisibleSize(t *testing.T) {
    	testCases := []struct {
    		totalSizes []uint64
    		result     uint64
    	}{
    		{[]uint64{24, 32, 16}, 8},
    		{[]uint64{32, 8, 4}, 4},
    		{[]uint64{8, 8, 8}, 8},
    		{[]uint64{24}, 24},
    	}
    
    	for _, testCase := range testCases {
    		testCase := testCase
    		t.Run("", func(t *testing.T) {
    			gotGCD := getDivisibleSize(testCase.totalSizes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  10. 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)
Back to top