Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for keyHash (0.76 sec)

  1. internal/event/target/elasticsearch.go

    		var keyHash string
    		{
    			key := eventData.S3.Bucket.Name + "/" + objectName
    			if target.client.isAtleastV7() {
    				hh, _ := highwayhash.New(magicHighwayHash256Key) // New will never return error since key is 256 bit
    				hh.Write([]byte(key))
    				hashBytes := hh.Sum(nil)
    				keyHash = base64.URLEncoding.EncodeToString(hashBytes)
    			} else {
    				keyHash = key
    			}
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  2. cmd/iam.go

    	usersPrefix := strings.HasPrefix(event.keyPath, iamConfigUsersPrefix)
    	groupsPrefix := strings.HasPrefix(event.keyPath, iamConfigGroupsPrefix)
    	stsPrefix := strings.HasPrefix(event.keyPath, iamConfigSTSPrefix)
    	svcPrefix := strings.HasPrefix(event.keyPath, iamConfigServiceAccountsPrefix)
    	policyPrefix := strings.HasPrefix(event.keyPath, iamConfigPoliciesPrefix)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  3. cmd/iam-etcd-store.go

    	}
    	return err
    }
    
    func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent {
    	ch := make(chan iamWatchEvent)
    
    	// go routine to read events from the etcd watch channel and send them
    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    				select {
    				case <-ctx.Done():
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    	}
    	*d = doc
    	return nil
    }
    
    // key options
    type options struct {
    	ttl int64 // expiry in seconds
    }
    
    type iamWatchEvent struct {
    	isCreated bool // !isCreated implies a delete event.
    	keyPath   string
    }
    
    // iamCache contains in-memory cache of IAM data.
    type iamCache struct {
    	updatedAt time.Time
    
    	// map of policy names to policy definitions
    	iamPolicyDocsMap map[string]PolicyDoc
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. internal/s3select/sql/parser.go

    }
    
    // TableExpression represents the FROM clause
    type TableExpression struct {
    	Table *JSONPath `parser:"@@"`
    	As    string    `parser:"( \"AS\"? @Ident )?"`
    }
    
    // JSONPathElement represents a keypath component
    type JSONPathElement struct {
    	Key            *ObjectKey `parser:"  @@"`               // ['name'] and .name forms
    	Index          *int       `parser:"| \"[\" @Int \"]\""` // [3] form
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  6. internal/s3select/sql/analysis.go

    	errFunctionNotImplemented = errors.New("Function is not yet implemented")
    	errUnexpectedInvalidNode  = errors.New("Unexpected node value")
    	errInvalidKeypath         = errors.New("A provided keypath is invalid")
    )
    
    // qProp contains analysis info about an SQL term.
    type qProp struct {
    	isAggregation, isRowFunc bool
    
    	err error
    }
    
    // `combine` combines a pair of `qProp`s, so that errors are
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  7. internal/s3select/sql/statement.go

    		return errBadTableName(errors.New("table name must be `s3object`"))
    	}
    
    	if len(from.Table.PathExpr) > 0 {
    		if !from.Table.PathExpr[0].ArrayWildcard {
    			return errBadTableName(errors.New("keypath table name is invalid - please check the service documentation"))
    		}
    	}
    	return nil
    }
    
    func parseLimit(v *LitValue) (int64, error) {
    	switch {
    	case v == nil:
    		return -1, nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 09 17:19:11 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top