Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 81 for Larsen (0.14 sec)

  1. internal/event/arn.go

    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	parsedARN, err := parseARN(s)
    	if err != nil {
    		return err
    	}
    
    	*arn = *parsedARN
    	return nil
    }
    
    // parseARN - parses string to ARN.
    func parseARN(s string) (*ARN, error) {
    	// ARN must be in the format of arn:minio:sqs:<REGION>:<ID>:<TYPE>
    	if !strings.HasPrefix(s, "arn:minio:sqs:") {
    		return nil, &ErrInvalidARN{s}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.1K bytes
    - Viewed (0)
  2. cmd/copy-part-range.go

    		return
    	default:
    		apiErr := errorCodes.ToAPIErr(ErrInvalidCopyPartRangeSource)
    		apiErr.Description = err.Error()
    		writeErrorResponse(ctx, w, apiErr, url)
    		return
    	}
    }
    
    // Parses x-amz-copy-source-range for CopyObjectPart API. Its behavior
    // is different from regular HTTP range header. It only supports the
    // form `bytes=first-last` where first and last are zero-based byte
    // offsets. See
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Jun 18 03:27:04 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  3. cni/pkg/plugin/sidecar_iptables_linux.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    // This is a sample chained plugin that supports multiple CNI versions. It
    // parses prevResult according to the cniVersion
    package plugin
    
    import (
    	"fmt"
    
    	"github.com/containernetworking/plugins/pkg/ns"
    
    	"istio.io/istio/pkg/log"
    	"istio.io/istio/tools/istio-iptables/pkg/cmd"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 17:36:41 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  4. cmd/server-main_test.go

    			}
    			if !testcase.expectedErr && err != nil {
    				t.Error("expected success, got failure", err)
    			}
    			if err == nil {
    				if len(sctx.Layout.pools) != 2 {
    					t.Error("expected parsed pools to be 2, not", len(sctx.Layout.pools))
    				}
    				if sctx.Layout.pools[0].cmdline != testcase.hash {
    					t.Error("expected hash", testcase.hash, "got", sctx.Layout.pools[0].cmdline)
    				}
    			}
    		})
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Dec 07 09:33:56 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. internal/config/certs.go

    // ParsePublicCertFile - parses public cert into its *x509.Certificate equivalent.
    func ParsePublicCertFile(certFile string) (x509Certs []*x509.Certificate, err error) {
    	// Read certificate file.
    	var data []byte
    	if data, err = os.ReadFile(certFile); err != nil {
    		return nil, err
    	}
    
    	// Trimming leading and tailing white spaces.
    	data = bytes.TrimSpace(data)
    
    	// Parse all certs in the chain.
    	current := data
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  6. internal/config/identity/tls/config.go

    }
    
    const (
    	defaultExpiry time.Duration = 1 * time.Hour
    	minExpiry     time.Duration = 15 * time.Minute
    	maxExpiry     time.Duration = 365 * 24 * time.Hour
    )
    
    // GetExpiryDuration - return parsed expiry duration.
    func (l Config) GetExpiryDuration(dsecs string) (time.Duration, error) {
    	if dsecs == "" {
    		return defaultExpiry, nil
    	}
    
    	d, err := strconv.Atoi(dsecs)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  7. cmd/bucket-quota.go

    		}
    	}
    
    	if len(dui.BucketsUsage) > 0 {
    		bui, ok := dui.BucketsUsage[bucket]
    		if ok {
    			return bui, nil
    		}
    	}
    	return BucketUsageInfo{}, nil
    }
    
    // parseBucketQuota parses BucketQuota from json
    func parseBucketQuota(bucket string, data []byte) (quotaCfg *madmin.BucketQuota, err error) {
    	quotaCfg = &madmin.BucketQuota{}
    	if err = json.Unmarshal(data, quotaCfg); err != nil {
    		return quotaCfg, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  8. internal/config/compress/compress.go

    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   Extensions,
    			Value: DefaultExtensions,
    		},
    		config.KV{
    			Key:   MimeTypes,
    			Value: DefaultMimeTypes,
    		},
    	}
    )
    
    // Parses the given compression exclude list `extensions` or `content-types`.
    func parseCompressIncludes(include string) ([]string, error) {
    	includes := strings.Split(include, config.ValueSeparator)
    	for _, e := range includes {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 5K bytes
    - Viewed (0)
  9. internal/s3select/csv/reader.go

    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/kms/single-key.go

    	"github.com/minio/kms-go/kes"
    	"github.com/minio/minio/internal/hash/sha256"
    )
    
    // Parse parses s as single-key KMS. The given string
    // is expected to have the following format:
    //
    //	<key-id>:<base64-key>
    //
    // The returned KMS implementation uses the parsed
    // key ID and key to derive new DEKs and decrypt ciphertext.
    func Parse(s string) (KMS, error) {
    	v := strings.SplitN(s, ":", 2)
    	if len(v) != 2 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 7.9K bytes
    - Viewed (0)
Back to top