Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for Darling (0.19 sec)

  1. docs/sts/custom-token-identity.go

    	if err != nil {
    		log.Fatalf("Error parsing sts endpoint: %v", err)
    	}
    	copts := &minio.Options{
    		Creds:  li,
    		Secure: stsEndpointURL.Scheme == "https",
    	}
    	minioClient, err := minio.New(stsEndpointURL.Host, copts)
    	if err != nil {
    		log.Fatalf("Error initializing client: ", err)
    	}
    
    	// Use minIO Client object normally like the regular client.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  2. docs/sts/assume-role.go

    	if err != nil {
    		log.Fatalf("Error initializing STS Identity: %v", err)
    	}
    
    	stsEndpointURL, err := url.Parse(stsEndpoint)
    	if err != nil {
    		log.Fatalf("Error parsing sts endpoint: %v", err)
    	}
    
    	opts := &minio.Options{
    		Creds:  li,
    		Secure: stsEndpointURL.Scheme == "https",
    	}
    
    	v, err := li.Get()
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 16:09:55 GMT 2024
    - 4K bytes
    - Viewed (1)
  3. internal/s3select/json/errors.go

    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errJSONParsingError(err error) *s3Error {
    	return &s3Error{
    		code:       "JSONParsingError",
    		message:    "Encountered an error parsing the JSON file. Check the file and try again.",
    		statusCode: 400,
    		cause:      err,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.6K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  5. cmd/object-api-deleteobject_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"crypto/md5"
    	"encoding/hex"
    	"strings"
    	"testing"
    )
    
    // Wrapper for calling DeleteObject tests for both Erasure multiple disks and single node setup.
    func TestDeleteObject(t *testing.T) {
    	ExecObjectLayerTest(t, testDeleteObject)
    }
    
    // Unit test for DeleteObject in general.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  6. cmd/object-api-getobjectinfo_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"testing"
    )
    
    // Wrapper for calling GetObjectInfo tests for both Erasure multiple disks and single node setup.
    func TestGetObjectInfo(t *testing.T) {
    	ExecObjectLayerTest(t, testGetObjectInfo)
    }
    
    // Testing GetObjectInfo().
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 5.6K bytes
    - Viewed (0)
  7. cmd/postpolicyform_test.go

    				t.Errorf("Expected success but failed with %s", err)
    			}
    			if !testCase.success && err == nil {
    				t.Errorf("Expected failed but succeeded")
    			}
    		})
    	}
    }
    
    // Test Post Policy parsing and checking conditions
    func TestPostPolicyForm(t *testing.T) {
    	pp := minio.NewPostPolicy()
    	pp.SetBucket("testbucket")
    	pp.SetContentType("image/jpeg")
    	pp.SetUserMetadata("uuid", "14365123651274")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 8.9K bytes
    - Viewed (0)
  8. internal/cachevalue/cache.go

    	// The returned value can no longer be modified once returned.
    	// Should be set before calling Get().
    	updateFn func() (T, error)
    
    	// ttl for a cached value.
    	ttl time.Duration
    
    	opts Opts
    
    	// Once can be used to initialize values for lazy initialization.
    	// Should be set before calling Get().
    	Once sync.Once
    
    	// Managed values.
    	valErr atomic.Pointer[struct {
    		v T
    		e error
    	}]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/error.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lifecycle
    
    import (
    	"fmt"
    )
    
    // Error is the generic type for any error happening during tag
    // parsing.
    type Error struct {
    	err error
    }
    
    // Errorf - formats according to a format specifier and returns
    // the string as a value that satisfies error of type tagging.Error
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 1.3K bytes
    - Viewed (0)
  10. internal/amztime/parse_test.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 amztime implements AWS specific time parsing and deviations
    package amztime
    
    import (
    	"errors"
    	"testing"
    	"time"
    )
    
    func TestParse(t *testing.T) {
    	type testCase struct {
    		expectedErr  error
    		expectedTime time.Time
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 07 14:24:54 GMT 2022
    - 1.6K bytes
    - Viewed (0)
Back to top