book - Code Search

cmd/user-provider-utils.go

// if validate is true, an error is returned if the user does not exist.
func getUserWithProvider(ctx context.Context, userProvider, user string, validate bool) (string, error) {
	switch userProvider {
	case madmin.BuiltinProvider:
		if validate {
			if _, ok := globalIAMSys.GetUser(ctx, user); !ok {
				return "", errNoSuchUser
			}
		}
		return user, nil

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 4.1K bytes

- Click Count (0)

github.com/minio/minio

internal/bucket/replication/filter.go

	Prefix  string
	And     And
	Tag     Tag

	// Caching tags, only once
	cachedTags map[string]string
}

// IsEmpty returns true if filter is not set
func (f Filter) IsEmpty() bool {
	return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == ""
}

// MarshalXML - produces the xml representation of the Filter struct
// only one of Prefix, And and Tag should be present in the output.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Wed Sep 28 18:25:46 GMT 2022

- 3.5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/response_model/tutorial003_05_py310.py

from fastapi import FastAPI, Response
from fastapi.responses import RedirectResponse

app = FastAPI()


@app.get("/portal", response_model=None)
async def get_portal(teleport: bool = False) -> Response | dict:
    if teleport:
        return RedirectResponse(url="https://www.youtube.com/watch?v=dQw4w9WgXcQ")

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Tue Jan 10 16:22:47 GMT 2023

- 373 bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

    @Override
    synchronized void addShutdownHook(Thread hook) {
      hooks.add(hook);
    }

    synchronized void shutdown() throws InterruptedException {
      for (Thread hook : hooks) {
        hook.start();
      }
      for (Thread hook : hooks) {
        hook.join();
      }
    }
  }

  /* Half of a 1-second timeout in nanoseconds */

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Fri Dec 12 00:25:21 GMT 2025

- 26.5K bytes

- Click Count (0)

github.com/minio/minio

cmd/signals.go

	// Custom exit function
	exit := func(success bool) {
		if globalLoggerOutput != nil {
			globalLoggerOutput.Close()
		}

		// If global profiler is set stop before we exit.
		globalProfilerMu.Lock()
		defer globalProfilerMu.Unlock()
		for _, p := range globalProfiler {
			p.Stop()
		}

		if success {
			os.Exit(0)
		}

		os.Exit(1)
	}

	stopProcess := func() bool {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Wed Sep 04 17:02:39 GMT 2024

- 3.2K bytes

- Click Count (0)

github.com/minio/minio

cmd/local-locker_test.go

							})
							if !ok || err != nil {
								t.Fatal("failed:", err, ok)
							}
						}
					}
					start := time.Now()
					l.expireOldLocks(time.Hour)
					t.Logf("Scan Took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
					if len(l.lockMap) != locks {
						t.Fatalf("objects deleted, want %d != got %d", locks, len(l.lockMap))
					}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 11.8K bytes

- Click Count (0)

github.com/go-gorm/gorm

tests/joins_test.go

	} else if len(users2) != len(users) {
		t.Fatalf("Failed to load join users, got: %v, expect: %v", len(users2), len(users))
	}

	sort.Slice(users2, func(i, j int) bool {
		return users2[i].ID > users2[j].ID
	})

	sort.Slice(users, func(i, j int) bool {
		return users[i].ID > users[j].ID
	})

	for idx, user := range users {
		CheckUser(t, user, users2[idx])
	}
}

func TestJoinConds(t *testing.T) {

Created: Sun Dec 28 09:35:17 GMT 2025

- Last Modified: Sun May 25 07:40:40 GMT 2025

- 15K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/custom_response/tutorial004_py39.py

app = FastAPI()


def generate_html_response():
    html_content = """
    <html>
        <head>
            <title>Some HTML in here</title>
        </head>
        <body>
            <h1>Look ma! HTML!</h1>
        </body>
    </html>
    """
    return HTMLResponse(content=html_content, status_code=200)


@app.get("/items/", response_class=HTMLResponse)
async def read_items():

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 491 bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_path.py


def test_path_bool_1():
    response = client.get("/path/bool/1")
    assert response.status_code == 200
    assert response.json() is True


def test_path_bool_0():
    response = client.get("/path/bool/0")
    assert response.status_code == 200
    assert response.json() is False


def test_path_bool_true():
    response = client.get("/path/bool/true")
    assert response.status_code == 200

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Dec 27 18:19:10 GMT 2025

- 20.5K bytes

- Click Count (2)

github.com/go-gorm/gorm

logger/sql.go

	"strings"
	"time"
	"unicode"

	"gorm.io/gorm/utils"
)

const (
	tmFmtWithMS = "2006-01-02 15:04:05.999"
	tmFmtZero   = "0000-00-00 00:00:00"
	nullStr     = "NULL"
)

func isPrintable(s string) bool {
	for _, r := range s {
		if !unicode.IsPrint(r) {
			return false
		}
	}
	return true
}

// A list of Go types that should be converted to SQL primitives

Created: Sun Dec 28 09:35:17 GMT 2025

- Last Modified: Thu Mar 21 08:00:02 GMT 2024

- 5K bytes

- Click Count (0)

Search Options