Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1171 - 1180 of 1,387 for funcs (0.04 sec)

  1. cmd/metrics-v3-cluster-usage.go

    		"Cluster object version count distribution", "range")
    )
    
    // loadClusterUsageObjectMetrics - reads cluster usage metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:11:42 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/erasure_test.go

    	{dataBlocks: 4, parityBlocks: 2, missingData: 2, missingParity: 2, reconstructParity: false, shouldFail: true},
    	{dataBlocks: 8, parityBlocks: 4, missingData: 2, missingParity: 2, reconstructParity: false, shouldFail: false},
    }
    
    func TestErasureEncodeDecode(t *testing.T) {
    	data := make([]byte, 256)
    	if _, err := io.ReadFull(rand.Reader, data); err != nil {
    		t.Fatalf("Failed to read random data: %v", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  3. cmd/os-dirent_ino.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    //go:build (linux || darwin) && !appengine
    // +build linux darwin
    // +build !appengine
    
    package cmd
    
    import "syscall"
    
    func direntInode(dirent *syscall.Dirent) uint64 {
    	return dirent.Ino
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 953 bytes
    - Viewed (0)
  4. internal/init/init.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 init
    
    import "os"
    
    func init() {
    	// All MinIO operations must be under UTC.
    	os.Setenv("TZ", "UTC")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 04 23:44:38 UTC 2022
    - 874 bytes
    - Viewed (0)
  5. schema/utils_test.go

    package schema
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestRemoveSettingFromTag(t *testing.T) {
    	tags := map[string]string{
    		`gorm:"before:value;column:db;after:value" other:"before:value;column:db;after:value"`:  `gorm:"before:value;after:value" other:"before:value;column:db;after:value"`,
    		`gorm:"before:value;column:db;" other:"before:value;column:db;after:value"`:             `gorm:"before:value;" other:"before:value;column:db;after:value"`,
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Jul 31 10:19:25 UTC 2020
    - 1.5K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/netns_linux_test.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import "testing"
    
    func TestOpenNetns(t *testing.T) {
    	ns, err := OpenNetns("/proc/self/ns/net")
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	// the inode for netns is proc dynamic, so it needs to be higher than
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 976 bytes
    - Viewed (0)
  7. cmd/bucket-replication-handlers.go

    // ----------
    // Add a replication configuration on the specified bucket as specified in https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutBucketReplication.html
    func (api objectAPIHandlers) PutBucketReplicationConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketReplicationConfig")
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  8. cni/pkg/pluginlistener/listener.go

    // limitations under the License.
    
    package pluginlistener
    
    import (
    	"fmt"
    	"net"
    	"os"
    	"path/filepath"
    
    	"istio.io/istio/pkg/log"
    )
    
    func NewListener(path string) (net.Listener, error) {
    	// Remove unix socket before use.
    	if err := os.Remove(path); err != nil && !os.IsNotExist(err) {
    		// Anything other than "file not found" is an error.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. tensorflow/c/eager/c_api_remote_function_test.cc

                                           bool remote_func_outputs = false,
                                           bool has_packed_input = false) {
      return TestRemoteExecuteSilentCopies(async, remote, /*func=*/true,
                                           heavy_load_on_streaming_rpc,
                                           remote_func_outputs, has_packed_input);
    }
    
    TEST(CAPI, RemoteExecuteSilentCopiesAsyncFunc) {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 3.6K bytes
    - Viewed (0)
  10. manifests/addons/dashboards/lib/lib-grid.libsonnet

    // This is forked from https://grafana.github.io/grafonnet/API/util.html#obj-grid
    // to allow automatic width to fill the grid
    {
      local root = self,
    
      local gridWidth = 24,
    
      '#makeGrid':: d.func.new(
        |||
          `makeGrid` returns an array of `panels` organized in a grid with equal width
          and `panelHeight`. Row panels are used as "linebreaks", if a Row panel is collapsed,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jun 04 18:05:06 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top