- Sort Score
- Result 10 results
- Languages All
Results 831 - 840 of 1,387 for funcs (0.03 sec)
-
cmd/erasure-utils.go
func getDataBlockLen(enBlocks [][]byte, dataBlocks int) int { size := 0 // Figure out the data block length. for _, block := range enBlocks[:dataBlocks] { size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
docs/sts/client-grants.go
clientID string clientSecret string ) func init() { flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint") flag.StringVar(&idpEndpoint, "idp-ep", "http://localhost:8080/auth/realms/minio/protocol/openid-connect/token", "IDP token endpoint") flag.StringVar(&clientID, "cid", "", "Client ID") flag.StringVar(&clientSecret, "csec", "", "Client secret") } func getTokenExpiry() (*credentials.ClientGrantsToken, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 3.3K bytes - Viewed (0) -
internal/bucket/lifecycle/expiration_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package lifecycle import ( "encoding/xml" "fmt" "testing" ) // appropriate errors on validation func TestInvalidExpiration(t *testing.T) { testCases := []struct { inputXML string expectedErr error }{ { // Expiration with zero days inputXML: ` <Expiration>
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Feb 21 20:28:34 UTC 2024 - 4.1K bytes - Viewed (0) -
cmd/bucket-versioning.go
// part of a MinIO versioning configuration extension. func (sys *BucketVersioningSys) PrefixEnabled(bucket, prefix string) bool { vc, err := sys.Get(bucket) if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.PrefixEnabled(prefix) } // Suspended suspended versioning? func (sys *BucketVersioningSys) Suspended(bucket string) bool { vc, err := sys.Get(bucket) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 2.6K bytes - Viewed (0) -
internal/grid/grid_types_test.go
type testRequest struct { Num int String string } type testResponse struct { OrgNum int OrgString string Embedded testRequest } func newTestRequest() *testRequest { return &testRequest{} } func newTestResponse() *testResponse { return &testResponse{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 1.1K bytes - Viewed (0) -
internal/disk/fdatasync_unix.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 29 23:40:28 UTC 2021 - 1.1K bytes - Viewed (0) -
internal/disk/fdatasync_unsupported.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package disk import ( "os" ) // Fdatasync is a no-op func Fdatasync(f *os.File) error { return nil } // FadviseDontNeed is a no-op func FadviseDontNeed(f *os.File) error { return nil
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 29 23:40:28 UTC 2021 - 1K bytes - Viewed (0) -
cmd/dummy-data-generator_test.go
return 0, errors.New("Invalid offset") } d.idx = d.length + offset } return d.idx, nil } func TestDummyDataGenerator(t *testing.T) { readAll := func(r io.Reader) string { b, _ := io.ReadAll(r) return string(b) } checkEq := func(a, b string) { if a != b { t.Fatalf("Unexpected equality failure") } } checkEq(readAll(NewDummyDataGen(0, 0)), "")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 4.7K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
} }), } getFirstPodFunc = func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) ( *corev1.Pod, int, error, ) { return attachPod(namespace), 1, nil } for _, tt := range tests { t.Run(strings.Split(tt.name, ".")[0], func(t *testing.T) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jun 09 18:17:49 UTC 2023 - 6.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/SearchEngineUtil.java
private SearchEngineUtil() { } public static OutputStream getXContentBuilderOutputStream(final XContentBuilderCallback func, final MediaType mediaType) { try (final XContentBuilder builder = func.apply(mediaType.contentBuilder(), ToXContent.EMPTY_PARAMS)) { builder.flush(); return builder.getOutputStream(); } catch (final IOException e) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 2.9K bytes - Viewed (0)