- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 447 for io (0.12 sec)
-
cni/pkg/nodeagent/net.go
"errors" "fmt" "net/netip" "golang.org/x/sys/unix" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" "istio.io/istio/cni/pkg/ipset" "istio.io/istio/cni/pkg/iptables" "istio.io/istio/cni/pkg/util" istiolog "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" dep "istio.io/istio/tools/istio-iptables/pkg/dependencies" )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/nodeagent/server_test.go
"errors" "net/netip" "sync/atomic" "testing" "time" "github.com/stretchr/testify/mock" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes/fake" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/test/util/assert" ) func TestMeshDataplaneAddsAnnotationOnAdd(t *testing.T) { pod := &corev1.Pod{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump.go
package mesh import ( "encoding/json" "fmt" "sort" "strings" "github.com/spf13/cobra" "sigs.k8s.io/yaml" "istio.io/istio/operator/pkg/manifest" "istio.io/istio/operator/pkg/tpath" "istio.io/istio/operator/pkg/util" "istio.io/istio/operator/pkg/util/clog" ) type profileDumpArgs struct { // inFilenames is an array of paths to the input IstioOperator CR files.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
// limitations under the License. package nodeagent import ( "testing" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "istio.io/istio/pkg/test/util/assert" ) func TestWithProcFs(t *testing.T) { n := NewPodNetnsProcFinder(fakeFs()) pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
"github.com/spf13/cobra" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" ) var fakeCACert = []byte("fake-CA-cert") var ( defaultYAML = `apiVersion: networking.istio.io/v1alpha3 kind: WorkloadGroup metadata:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/test-utils_test.go
// If the body is read in the handler the same request cannot be made use of. buf, err := io.ReadAll(anonReq.Body) if err != nil { t.Fatal(failTestStr(anonTestStr, err.Error())) } // creating 2 read closer (to set as request body) from the body content. readerOne := io.NopCloser(bytes.NewBuffer(buf)) readerTwo := io.NopCloser(bytes.NewBuffer(buf)) anonReq.Body = readerOne // call the HTTP handler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
internal/crypto/key.go
// system (crypto/rand) is used. func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) { if random == nil { random = rand.Reader } if len(extKey) != 32 { // safety check logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length")) } var nonce [32]byte if _, err := io.ReadFull(random, nonce[:]); err != nil { logger.CriticalIf(context.Background(), errOutOfEntropy) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
// limitations under the License. package configdump import ( "encoding/json" "fmt" "io" "text/tabwriter" "sigs.k8s.io/yaml" ) // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint type ConfigWriter struct { Stdout io.Writer ztunnelDump *ZtunnelDump FullDump []byte }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/object-api-utils.go
// properly, because we do not wish to create an object even if // client closed the stream prematurely. func newS2CompressReader(r io.Reader, on int64, encrypted bool) (rc io.ReadCloser, idx func() []byte) { pr, pw := io.Pipe() // Copy input to compressor opts := compressOpts if encrypted { // The values used for padding are not a security concern,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/bucket/bandwidth/reader.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package bandwidth import ( "context" "io" "math" ) // MonitoredReader represents a throttled reader subject to bandwidth monitoring type MonitoredReader struct { r io.Reader throttle *bucketThrottle ctx context.Context // request context
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0)