- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 507 for Spring (0.15 sec)
-
internal/config/identity/openid/provider/keycloak.go
// Token - parses the output from IDP id_token. type Token struct { AccessToken string `json:"access_token"` Expiry int `json:"expires_in"` } // KeycloakProvider implements Provider interface for KeyCloak Identity Provider. type KeycloakProvider struct { sync.Mutex oeConfig DiscoveryDoc client http.Client adminURL string realm string // internal value refreshed accessToken Token }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
internal/s3select/json/errors.go
package json type s3Error struct { code string message string statusCode int cause error } func (err *s3Error) Cause() error { return err.cause } func (err *s3Error) ErrorCode() string { return err.code } func (err *s3Error) ErrorMessage() string { return err.message } func (err *s3Error) HTTPStatusCode() int {
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) -
cmd/bitrot-whole.go
func newWholeBitrotWriter(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, shardSize int64) io.WriteCloser { return &wholeBitrotWriter{disk, volume, filePath, shardSize, algo.New()} } // Implementation to verify bitrot for the whole file. type wholeBitrotReader struct { disk StorageAPI volume string filePath string verifier *BitrotVerifier // Holds the bit-rot info
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/event/rules.go
return pattern } // Rules - event rules type Rules map[string]TargetIDSet // Add - adds pattern and target ID. func (rules Rules) Add(pattern string, targetID TargetID) { rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern]) } // MatchSimple - returns true one of the matching object name in rules. func (rules Rules) MatchSimple(objectName string) bool { for pattern := range rules {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/s3select/sql/parser_test.go
) id := Identifier{} validCases := []string{ "a", "_a", "abc_a", "a2", `"abc"`, `"abc\a""ac"`, } for i, tc := range validCases { err := p.ParseString(tc, &id) if err != nil { t.Fatalf("%d: %v", i, err) } // repr.Println(id, repr.Indent(" "), repr.OmitEmpty(true)) } invalidCases := []string{ "+a", "-a", "1a", `"ab`, `abc"`,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
type Algorithm string // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string if err := d.DecodeElement(&s, &start); err != nil { return err } switch s { case string(AES256): *alg = AES256 case string(AWSKms): *alg = AWSKms default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) { x.Client, err = x.HashGeneratorFcn.NewClient(userName, password, authzID) if err != nil { return err } x.ClientConversation = x.Client.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication
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) -
docs/sts/assume-role.go
var ( // Minio endpoint (for STS API) stsEndpoint string // User account credentials minioUsername string minioPassword string // Display credentials flag displayCreds bool // Credential expiry duration expiryDuration time.Duration // Bucket to list bucketToList string // Session policy file (FIXME: add support in minio-go) sessionPolicyFile string ) func init() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/signature-v4-utils.go
if stype == serviceSTS { payload, err := io.ReadAll(io.LimitReader(r.Body, stsRequestBodyLimit)) if err != nil { logger.CriticalIf(GlobalContext, err) } sum256 := sha256.Sum256(payload) r.Body = io.NopCloser(bytes.NewReader(payload)) return hex.EncodeToString(sum256[:]) } var ( defaultSha256Cksum string v []string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
internal/s3select/simdj/record.go
} // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) { elem := r.object.FindKey(name, nil) if elem == nil { return nil, nil } return iterToValue(elem.Iter) } func iterToValue(iter simdjson.Iter) (*sql.Value, error) { switch iter.Type() { case simdjson.TypeString: v, err := iter.String() if err != nil { return nil, err } return sql.FromString(v), nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 5.4K bytes - Viewed (0)