Search Options

Results per page
Sort
Preferred Languages
Advance

Results 831 - 840 of 1,423 for Func (0.02 sec)

  1. cmd/erasure-utils.go

    func getDataBlockLen(enBlocks [][]byte, dataBlocks int) int {
    	size := 0
    	// Figure out the data block length.
    	for _, block := range enBlocks[:dataBlocks] {
    		size += len(block)
    	}
    	return size
    }
    
    // Writes all the data blocks from encoded blocks until requested
    // outSize length. Provides a way to skip bytes until the offset.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. docs/sts/client-grants.go

    	clientID     string
    	clientSecret string
    )
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    	flag.StringVar(&idpEndpoint, "idp-ep", "http://localhost:8080/auth/realms/minio/protocol/openid-connect/token", "IDP token endpoint")
    	flag.StringVar(&clientID, "cid", "", "Client ID")
    	flag.StringVar(&clientSecret, "csec", "", "Client secret")
    }
    
    func getTokenExpiry() (*credentials.ClientGrantsToken, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/expiration_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lifecycle
    
    import (
    	"encoding/xml"
    	"fmt"
    	"testing"
    )
    
    // appropriate errors on validation
    func TestInvalidExpiration(t *testing.T) {
    	testCases := []struct {
    		inputXML    string
    		expectedErr error
    	}{
    		{ // Expiration with zero days
    			inputXML: ` <Expiration>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. cmd/object-api-options_test.go

    )
    
    // TestGetAndValidateAttributesOpts is currently minimal and covers a subset of getAndValidateAttributesOpts(),
    // it is intended to be expanded when the function is worked on in the future.
    func TestGetAndValidateAttributesOpts(t *testing.T) {
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	bucket := minioMetaBucket
    	ctx := context.Background()
    	testCases := []struct {
    		name            string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. docs/site-replication/gen-oidc-sts-cred.go

    import (
    	"context"
    	"fmt"
    	"log"
    	"net/http"
    	"os"
    
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    	cmd "github.com/minio/minio/cmd"
    )
    
    func main() {
    	ctx := context.Background()
    
    	endpoint := os.Getenv("MINIO_ENDPOINT")
    	if endpoint == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  6. cmd/bucket-versioning.go

    // part of a MinIO versioning configuration extension.
    func (sys *BucketVersioningSys) PrefixEnabled(bucket, prefix string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	return vc.PrefixEnabled(prefix)
    }
    
    // Suspended suspended versioning?
    func (sys *BucketVersioningSys) Suspended(bucket string) bool {
    	vc, err := sys.Get(bucket)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  7. cmd/dummy-data-generator_test.go

    			return 0, errors.New("Invalid offset")
    		}
    		d.idx = d.length + offset
    	}
    	return d.idx, nil
    }
    
    func TestDummyDataGenerator(t *testing.T) {
    	readAll := func(r io.Reader) string {
    		b, _ := io.ReadAll(r)
    		return string(b)
    	}
    	checkEq := func(a, b string) {
    		if a != b {
    			t.Fatalf("Unexpected equality failure")
    		}
    	}
    
    	checkEq(readAll(NewDummyDataGen(0, 0)), "")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. istioctl/pkg/util/handlers/handlers_test.go

    			}
    		}),
    	}
    	getFirstPodFunc = func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) (
    		*corev1.Pod, int, error,
    	) {
    		return attachPod(namespace), 1, nil
    	}
    	for _, tt := range tests {
    		t.Run(strings.Split(tt.name, ".")[0], func(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 09 18:17:49 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  9. tensorflow/c/c_api_function_test.cc

    }
    
    TEST_F(CApiFunctionTest, AddFunctionsThenMakeOneGradientOfAnother) {
      // Define the functions
      TF_Function* func;
      TF_Function* grad_func;
      DefineFunction("FooFunc", &func);
      DefineFunction("MyGrad", &grad_func);
    
      // Add functions individually
      TF_GraphCopyFunction(host_graph_, func, nullptr, s_);
      ASSERT_EQ(TF_OK, TF_GetCode(s_)) << TF_Message(s_);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Jul 20 22:08:54 UTC 2023
    - 63.6K bytes
    - Viewed (0)
  10. cmd/s3-zip-handlers.go

    )
    
    // splitZipExtensionPath splits the S3 path to the zip file and the path inside the zip:
    //
    //	e.g  /path/to/archive.zip/backup-2021/myimage.png => /path/to/archive.zip, backup/myimage.png
    func splitZipExtensionPath(input string) (zipPath, object string, err error) {
    	idx := strings.Index(input, archivePattern)
    	if idx < 0 {
    		// Should never happen
    		return "", "", errors.New("unable to parse zip path")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
Back to top