Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 108 for podutil (0.12 sec)

  1. internal/ioutil/hardlimitreader.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 ioutil implements some I/O utility functions which are not covered
    // by the standard library.
    package ioutil
    
    import (
    	"errors"
    	"io"
    )
    
    // ErrOverread is returned to the reader when the hard limit of HardLimitReader is exceeded.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. istioctl/pkg/proxystatus/proxystatus_test.go

    	"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"
    
    	"istio.io/api/label"
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/xds"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/podcgroupns_test.go

    		},
    	} {
    		t.Run(tt.name, func(t *testing.T) {
    			podUID, containerID, err := getPodUIDAndContainerIDFromCGroups(makeCGroups(tt.cgroupPaths))
    
    			if tt.expectMsg != "" {
    				assert.Equal(t, tt.expectMsg, err.Error())
    				return
    			}
    			assert.Equal(t, tt.expectPodUID, podUID)
    			assert.Equal(t, tt.expectContainerID, containerID)
    		})
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/hash/reader_test.go

    			err:        ioutil.ErrOverread,
    		},
    		7: {
    			desc:       "Correct sha256, nested, truncated, swapped",
    			src:        mustReader(t, bytes.NewReader([]byte("abcd-more-stuff-to-be ignored")), 4, "", "", -1),
    			size:       4,
    			actualSize: -1,
    			sha256hex:  "88d4266fd4e6338d13b845fcf289579d209c897823b9217da3e161936f031589",
    			err:        ioutil.ErrOverread,
    		},
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  5. cmd/bitrot-streaming.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"hash"
    	"io"
    	"sync"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/ringbuffer"
    )
    
    // Calculates bitrot in chunks and writes the hash into the stream.
    type streamingBitrotWriter struct {
    	iow          io.WriteCloser
    	closeWithErr func(err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. api/go1.19.txt

    pkg go/doc, func ToText //deprecated #51082
    pkg io/ioutil, func NopCloser //deprecated #42026
    pkg io/ioutil, func ReadAll //deprecated #42026
    pkg io/ioutil, func ReadDir //deprecated #42026
    pkg io/ioutil, func ReadFile //deprecated #42026
    pkg io/ioutil, func TempDir //deprecated #42026
    pkg io/ioutil, func TempFile //deprecated #42026
    pkg io/ioutil, func WriteFile //deprecated #42026
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  7. internal/crypto/sse.go

    package crypto
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    
    	"github.com/minio/minio/internal/fips"
    	"github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/sio"
    )
    
    const (
    	// SealAlgorithm is the encryption/sealing algorithm used to derive & seal
    	// the key-encryption-key and to en/decrypt the object data.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  8. istioctl/pkg/kubeinject/kubeinject.go

    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/runtime/serializer"
    	v1 "k8s.io/client-go/kubernetes/typed/core/v1"
    	"k8s.io/kubectl/pkg/polymorphichelpers"
    	"k8s.io/kubectl/pkg/util/podutils"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/api/label"
    	meshconfig "istio.io/api/mesh/v1alpha1"
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/util"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  9. internal/ioutil/read_file_noatime_supported.go

    // GNU Affero General Public License for more details.
    //
    // 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 ioutil
    
    import (
    	"os"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 937 bytes
    - Viewed (0)
  10. internal/ioutil/append-file_nix.go

    // GNU Affero General Public License for more details.
    //
    // 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 ioutil
    
    import (
    	"io"
    	"os"
    )
    
    // AppendFile - appends the file "src" to the file "dst"
    func AppendFile(dst string, src string, osync bool) error {
    	flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE
    	if osync {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.3K bytes
    - Viewed (0)
Back to top