- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 193 for url (0.44 sec)
-
docs/sts/client-grants.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package main import ( "bytes" "context" "crypto/tls" "encoding/json" "flag" "fmt" "log" "net/http" "net/url" "strings" minio "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials" ) // JWTToken - parses the output from IDP id_token. type JWTToken struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 3.3K bytes - Viewed (0) -
cmd/handler-utils.go
switch { case strings.HasPrefix(r.URL.Path, peerRESTPrefix): writeErrorResponseString(r.Context(), w, APIError{ Code: "XMinioPeerVersionMismatch", Description: desc, HTTPStatusCode: http.StatusUpgradeRequired, }, r.URL) case strings.HasPrefix(r.URL.Path, storageRESTPrefix): writeErrorResponseString(r.Context(), w, APIError{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
internal/event/target/amqp.go
"github.com/rabbitmq/amqp091-go" ) // AMQPArgs - AMQP target arguments. type AMQPArgs struct { Enable bool `json:"enable"` URL xnet.URL `json:"url"` Exchange string `json:"exchange"` RoutingKey string `json:"routingKey"` ExchangeType string `json:"exchangeType"` DeliveryMode uint8 `json:"deliveryMode"` Mandatory bool `json:"mandatory"`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
return } if globalSiteReplicationSys.isEnabled() && logger.GetReqInfo(ctx).Cred.AccessKey != globalActiveCred.AccessKey { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrReplicationDenyEditError), r.URL) return } if versioned := globalBucketVersioningSys.Enabled(bucket); !versioned { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrReplicationNeedsVersioningError), r.URL) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 28 04:08:53 GMT 2023 - 23.2K bytes - Viewed (0) -
cmd/endpoint_test.go
{ ":1234", []string{"/d1", "/d2", "/d3", "/d4"}, ":1234", Endpoints{ Endpoint{URL: &url.URL{Path: mustAbs("/d1")}, IsLocal: true}, Endpoint{URL: &url.URL{Path: mustAbs("/d2")}, IsLocal: true}, Endpoint{URL: &url.URL{Path: mustAbs("/d3")}, IsLocal: true}, Endpoint{URL: &url.URL{Path: mustAbs("/d4")}, IsLocal: true}, }, ErasureSetupType, nil, },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Jan 13 07:53:03 GMT 2024 - 18.9K bytes - Viewed (1) -
cmd/signature-v4.go
// types. // - Based on Authorization header. // - Based on Query parameters. // - Based on Form POST policy. package cmd import ( "bytes" "crypto/subtle" "encoding/hex" "net/http" "net/url" "sort" "strconv" "strings" "time" "github.com/minio/minio-go/v7/pkg/s3utils" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/auth" "github.com/minio/minio/internal/hash/sha256"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/batch-handlers.go
writeErrorResponseJSON(ctx, w, toAPIError(ctx, errInvalidArgument), r.URL) return } req := &BatchJobRequest{} if err := req.load(ctx, objectAPI, pathJoin(batchJobPrefix, jobID)); err != nil { if !errors.Is(err, errNoSuchJob) { batchLogIf(ctx, err) } writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } buf, err := yaml.Marshal(req) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
package dsync import ( "bytes" "context" "errors" "net/http" "net/url" "time" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/rest" ) // ReconnectRESTClient is a wrapper type for rest.Client which provides reconnect on first failure. type ReconnectRESTClient struct { u *url.URL rest *rest.Client }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
Name: slp.scope, StackTraceLevel: slp.logLevel, } scopeInfos = append(scopeInfos, si) } return scopeInfos, nil } type ControlzClient struct { baseURL *url.URL httpClient *http.Client } func (c *ControlzClient) GetScopes() ([]*ScopeInfo, error) { var scopeInfos []*ScopeInfo resp, err := c.httpClient.Get(c.baseURL.String()) if err != nil { return nil, err
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
return } z, ok := objectAPI.(*erasureServerPools) if !ok || len(z.serverPools) == 1 { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } if z.IsDecommissionRunning() { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errDecommissionAlreadyRunning), r.URL) return } if z.IsRebalanceStarted() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0)