- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 57 for bytes (0.13 sec)
-
cni/pkg/plugin/cnieventclient.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package plugin import ( "bytes" "context" "encoding/json" "fmt" "net" "net/http" "time" "github.com/containernetworking/cni/pkg/skel" cniv1 "github.com/containernetworking/cni/pkg/types/100"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
EndpointVersion: "1", }, } cannedResponse, _ := json.Marshal(cannedResponseObj) cannedResponseMap := map[string][]byte{"onlyonepilot": cannedResponse} distributionTrackingDisabledResponse := xds.DistributionTrackingDisabledMessage distributionTrackingDisabledResponseMap := map[string][]byte{"onlyonepilot": []byte(distributionTrackingDisabledResponse)} cases := []execTestCase{ { execClientConfig: cannedResponseMap,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (1) -
istioctl/pkg/internaldebug/internal-debug_test.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package internaldebug import ( "bytes" "context" "fmt" "net/http" "strings" "testing" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "github.com/spf13/cobra" "google.golang.org/grpc"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics_test.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package metrics import ( "bytes" "context" "fmt" "regexp" "strings" "testing" "time" promv1 "github.com/prometheus/client_golang/api/prometheus/v1" prometheus_model "github.com/prometheus/common/model"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/routes/istio-gateway-http-route-prefix/configdump.json
} } ], "include_request_attempt_count": true } ], "validate_clusters": false, "max_direct_response_body_size_bytes": 1048576, "ignore_port_in_host_matching": true }, "last_updated": "2023-11-29T10:46:50.869Z" } ] } ]
Json - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 2.9K bytes - Viewed (0) -
istioctl/pkg/util/clusters/wrapper.go
type Wrapper struct { *admin.Clusters } // MarshalJSON is a custom marshaller to handle protobuf pain func (w *Wrapper) MarshalJSON() ([]byte, error) { return protomarshal.Marshal(w) } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error { cd := &admin.Clusters{} err := protomarshal.UnmarshalAllowUnknown(b, cd) *w = Wrapper{cd} return err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 1.2K bytes - Viewed (0) -
cni/pkg/install/binaries_test.go
srcDir := t.TempDir() for filename, contents := range c.srcFiles { file.WriteOrFail(t, filepath.Join(srcDir, filename), []byte(contents)) } targetDir := t.TempDir() for filename, contents := range c.existingFiles { file.WriteOrFail(t, filepath.Join(targetDir, filename), []byte(contents)) } binariesCopied, err := copyBinaries(srcDir, []string{targetDir}) if err != nil { t.Fatal(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jul 20 18:34:43 GMT 2023 - 2.3K bytes - Viewed (0) -
cni/pkg/util/podutil.go
"k8s.io/client-go/kubernetes" "istio.io/api/annotation" "istio.io/istio/pkg/config/constants" ) var annotationPatch = []byte(fmt.Sprintf( `{"metadata":{"annotations":{"%s":"%s"}}}`, constants.AmbientRedirection, constants.AmbientRedirectionEnabled, )) var annotationRemovePatch = []byte(fmt.Sprintf( `{"metadata":{"annotations":{"%s":null}}}`, constants.AmbientRedirection, ))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/plugin/plugin_dryrun_test.go
} if !reflect.DeepEqual(generatedRules, goldenRules) { t.Errorf("Unexpected IPtables rules generated, want \n%v \ngot \n%v", goldenRules, generatedRules) } }) } } func getRules(b []byte) map[string]string { // Separate content with "COMMIT" parts := strings.Split(string(b), "COMMIT") tables := make(map[string]string) for _, table := range parts {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 8.4K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
// Results is a map of podName to the results of the expected test on the pod Results map[string][]byte kube.CLIClient } func (c MockClient) NewPortForwarder(_, _, _ string, _, _ int) (kube.PortForwarder, error) { return MockPortForwarder{}, nil } func (c MockClient) AllDiscoveryDo(_ context.Context, _, _ string) (map[string][]byte, error) { return c.Results, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0)