- Sort Score
- Result 10 results
- Languages All
Results 921 - 930 of 1,387 for funcs (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)