core - Code Search

istioctl/pkg/version/version.go

// See the License for the specific language governing permissions and
// limitations under the License.

package version

import (
	"context"
	"encoding/json"
	"fmt"
	"os"

	core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
	discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3"
	statusv3 "github.com/envoyproxy/go-control-plane/envoy/service/status/v3"
	"github.com/spf13/cobra"

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Fri Mar 15 01:18:49 GMT 2024

- 8.3K bytes

- Viewed (0)

github.com/minio/minio

docs/debugging/s3-verify/main.go

		return false
	}

	core := minio.Core{Client: sclnt}
	sobj, _, _, err := core.GetObject(context.Background(), sourceBucket, srcCtnt.Key, opts)
	if err != nil {
		fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err)
		return false
	}

	tobj, _, _, err := core.GetObject(context.Background(), targetBucket, tgtCtnt.Key, opts)
	if err != nil {

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed Jun 22 15:12:47 GMT 2022

- 8.4K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/injector/injector-list_test.go

// See the License for the specific language governing permissions and
// limitations under the License.

package injector

import (
	"context"
	"fmt"
	"testing"

	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"

	"istio.io/api/annotation"
	"istio.io/api/label"
	"istio.io/istio/pkg/config/constants"
	"istio.io/istio/pkg/kube"

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Thu Jan 04 03:08:06 GMT 2024

- 2.9K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/fakes_test.go

// limitations under the License.

package nodeagent

import (
	"context"
	"embed"
	"io/fs"
	"sync/atomic"
	"syscall"

	corev1 "k8s.io/api/core/v1"

	"istio.io/istio/cni/pkg/iptables"
)

//go:embed testdata/cgroupns
var fakeProc embed.FS

type fakeZtunnel struct {
	deletedPods atomic.Int32
	addedPods   atomic.Int32
	addError    error
}

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Fri Apr 12 21:47:31 GMT 2024

- 3.9K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/internaldebug/internal-debug_test.go

	"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"
	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/cli-runtime/pkg/resource"
	"k8s.io/client-go/rest/fake"
	cmdtesting "k8s.io/kubectl/pkg/cmd/testing"
	cmdutil "k8s.io/kubectl/pkg/cmd/util"

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Fri Mar 15 08:28:50 GMT 2024

- 4.5K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/util/ambient/util.go

// See the License for the specific language governing permissions and
// limitations under the License.

package ambient

import (
	"context"
	"strings"

	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

	"istio.io/api/label"
	"istio.io/istio/pkg/config/constants"
	"istio.io/istio/pkg/kube"
)

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Thu Jan 04 03:08:06 GMT 2024

- 1.7K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/cni-watcher_test.go

// limitations under the License.

package nodeagent

import (
	"context"
	"encoding/json"
	"fmt"
	"net"
	"net/netip"
	"testing"

	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/types"

	"istio.io/istio/cni/pkg/util"
	"istio.io/istio/pkg/config/constants"
	"istio.io/istio/pkg/kube"

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Fri Feb 02 08:18:40 GMT 2024

- 5.4K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/cli/context.go

// See the License for the specific language governing permissions and
// limitations under the License.

package cli

import (
	corev1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/client-go/rest"

	"istio.io/istio/istioctl/pkg/util/handlers"
	"istio.io/istio/pkg/kube"
	"istio.io/istio/pkg/ptr"
)

type Context interface {

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Tue Apr 02 08:32:06 GMT 2024

- 6.4K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/cni-watcher.go

// limitations under the License.

package nodeagent

import (
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net"
	"net/http"
	"net/netip"
	"time"

	corev1 "k8s.io/api/core/v1"

	pconstants "istio.io/istio/cni/pkg/constants"
	"istio.io/istio/cni/pkg/pluginlistener"
)

// Just a composite of the CNI plugin add event struct + some extracted "args"
type CNIPluginAddEvent struct {

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Thu Feb 08 18:52:24 GMT 2024

- 6.1K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/plugin/plugin_test.go

// limitations under the License.

package plugin

import (
	"fmt"
	"net/http"
	"net/http/httptest"
	"reflect"
	"testing"

	"github.com/containernetworking/cni/pkg/skel"
	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"

	"istio.io/api/annotation"
	"istio.io/api/label"
	"istio.io/istio/pkg/config/constants"
	"istio.io/istio/pkg/kube"

Go

- Registered: Wed May 01 22:53:12 GMT 2024

- Last Modified: Sat Feb 10 00:31:55 GMT 2024

- 17.5K bytes

- Viewed (0)

Search Options