Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 596 for pkg (0.02 sec)

  1. istioctl/pkg/util/proto/messageslice.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package proto
    
    import (
    	"bytes"
    
    	"google.golang.org/protobuf/proto"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // MessageSlice allows us to marshal slices of protobuf messages like clusters/listeners/routes/endpoints correctly
    type MessageSlice []proto.Message
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 19 21:53:59 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/podcgroupns.go

    package nodeagent
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"io/fs"
    	"path"
    	"regexp"
    	"strings"
    	"unicode"
    
    	corev1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/types"
    
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/util/sets"
    )
    
    type PodToNetns map[string]WorkloadInfo
    
    func (p PodToNetns) Close() {
    	for _, wl := range p {
    		wl.Netns.Close()
    	}
    }
    
    type PodNetnsFinder interface {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  3. .generated_files

    #
    
    file-prefix	zz_generated.
    
    file-name	types.generated.go
    file-name	generated.pb.go
    file-name	generated.proto
    file-name	types_swagger_doc_generated.go
    
    path-prefix	vendor/
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 04 23:47:25 UTC 2022
    - 750 bytes
    - Viewed (0)
  4. cmd/object-lambda-handlers.go

    	"net/http"
    	"net/url"
    	"time"
    
    	"github.com/klauspost/compress/gzhttp"
    	"github.com/lithammer/shortuuid/v4"
    	miniogo "github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    
    	"github.com/minio/minio/internal/auth"
    	levent "github.com/minio/minio/internal/config/lambda/event"
    	"github.com/minio/minio/internal/hash/sha256"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	"github.com/minio/pkg/v3/certs"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    // Webhook constants
    const (
    	WebhookEndpoint   = "endpoint"
    	WebhookAuthToken  = "auth_token"
    	WebhookQueueDir   = "queue_dir"
    	WebhookQueueLimit = "queue_limit"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. cni/pkg/plugin/plugin_cni_conformance.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package plugin
    
    import (
    	"testing"
    
    	"github.com/containernetworking/cni/pkg/types"
    )
    
    // Validate k8sArgs struct works for unmarshalling kubelet args
    // This is important for CNI plugin conformance
    func TestLoadArgs(t *testing.T) {
    	kubeletArgs := "IgnoreUnknown=1;K8S_POD_NAMESPACE=istio-system;" +
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed May 29 21:50:09 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  7. internal/http/transports.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"crypto/tls"
    	"crypto/x509"
    	"net/http"
    	"syscall"
    	"time"
    
    	"github.com/minio/pkg/v3/certs"
    )
    
    // tlsClientSessionCacheSize is the cache size for client sessions.
    var tlsClientSessionCacheSize = 100
    
    const (
    	WriteBufferSize = 64 << 10 // WriteBufferSize 64KiB moving up from 4KiB default
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/util.go

    package tag
    
    import (
    	"context"
    	"fmt"
    
    	"github.com/hashicorp/go-multierror"
    	admitv1 "k8s.io/api/admissionregistration/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/client-go/kubernetes"
    
    	"istio.io/api/label"
    	"istio.io/istio/istioctl/pkg/util"
    )
    
    func GetRevisionWebhooks(ctx context.Context, client kubernetes.Interface) ([]admitv1.MutatingWebhookConfiguration, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. istioctl/pkg/util/configdump/wrapper.go

    	"google.golang.org/protobuf/reflect/protoreflect"
    	"google.golang.org/protobuf/reflect/protoregistry"
    	"google.golang.org/protobuf/types/known/emptypb"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    type resolver struct {
    	*protoregistry.Types
    }
    
    var nonStrictResolver = &resolver{protoregistry.GlobalTypes}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  10. internal/rest/client.go

    // Unwrap returns the error wrapped in NetworkError.
    func (n *NetworkError) Unwrap() error {
    	return n.Err
    }
    
    // Client - http based RPC client.
    type Client struct {
    	connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
    	_         int32 // For 64 bits alignment
    	lastConn  int64
    
    	// HealthCheckFn is the function set to test for health.
    	// If not set the client will not keep track of health.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top