- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 251 for io (0.21 sec)
-
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) -
cmd/handler-utils_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// limitations under the License. package nodeagent import ( "errors" "fmt" "path/filepath" "runtime" "sync" corev1 "k8s.io/api/core/v1" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/zdsapi" ) var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache") type PodNetnsCache interface {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
// limitations under the License. package compare import ( "bytes" "fmt" "github.com/pmezard/go-difflib/difflib" // Force import protos _ "istio.io/istio/pilot/pkg/xds/filters" "istio.io/istio/pkg/util/protomarshal" ) // ListenerDiff prints a diff between Istiod and Envoy listeners to the passed writer func (c *Comparator) ListenerDiff() error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
internal/config/heal/heal.go
) // Compression environment variables const ( Bitrot = "bitrotscan" Sleep = "max_sleep" IOCount = "max_io" DriveWorkers = "drive_workers" EnvBitrot = "MINIO_HEAL_BITROTSCAN" EnvSleep = "MINIO_HEAL_MAX_SLEEP" EnvIOCount = "MINIO_HEAL_MAX_IO" EnvDriveWorkers = "MINIO_HEAL_DRIVE_WORKERS" ) var configMutex sync.RWMutex // Config represents the heal settings.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
import ( "os" "path/filepath" "strings" "testing" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/rest" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/yaml" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/operator/pkg/util" "istio.io/istio/operator/pkg/util/clog" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/env" "istio.io/istio/pkg/test/util/assert" ) var (
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
cmd/erasure-utils.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 cmd import ( "context" "encoding/base64" "fmt" "io" "strings" "github.com/klauspost/reedsolomon" ) // getDataBlockLen - get length of data blocks from encoded blocks. func getDataBlockLen(enBlocks [][]byte, dataBlocks int) int { size := 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
cmd/bitrot.go
} } } } // Close all the writers. func closeBitrotWriters(ws []io.Writer) { for _, w := range ws { if w != nil { if bw, ok := w.(io.Closer); ok { bw.Close() } } } } // Returns hash sum for whole-bitrot, nil for streaming-bitrot. func bitrotWriterSum(w io.Writer) []byte { if bw, ok := w.(*wholeBitrotWriter); ok { return bw.Sum(nil) } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
cmd/warm-backend-azure.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/base64" "errors" "fmt" "io" "net/http" "net/url" "strings" "time" "github.com/Azure/azure-storage-blob-go/azblob" "github.com/Azure/go-autorest/autorest/adal" "github.com/Azure/go-autorest/autorest/azure"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
operator/cmd/mesh/operator-init.go
"github.com/spf13/cobra" "istio.io/api/operator/v1alpha1" "istio.io/istio/istioctl/pkg/cli" iopv1alpha1 "istio.io/istio/operator/pkg/apis/istio/v1alpha1" "istio.io/istio/operator/pkg/name" "istio.io/istio/operator/pkg/translate" operatorutil "istio.io/istio/operator/pkg/util" "istio.io/istio/operator/pkg/util/clog" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/kube"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0)