minit - Code Search

schema/serializer.go

func GetSerializer(name string) (serializer SerializerInterface, ok bool) {
	v, ok := serializerMap.Load(strings.ToLower(name))
	if ok {
		serializer, ok = v.(SerializerInterface)
	}
	return serializer, ok
}

func init() {
	RegisterSerializer("json", JSONSerializer{})
	RegisterSerializer("unixtime", UnixSecondSerializer{})
	RegisterSerializer("gob", GobSerializer{})
}

// Serializer field value serializer
type serializer struct {

Registered: Sun Nov 03 09:35:10 UTC 2024

- Last Modified: Thu Jun 20 08:45:38 UTC 2024

- 4.6K bytes

- Viewed (0)

github.com/go-gorm/gorm

utils/utils.go

package utils

import (
	"database/sql/driver"
	"fmt"
	"path/filepath"
	"reflect"
	"runtime"
	"strconv"
	"strings"
	"unicode"
)

var gormSourceDir string

func init() {
	_, file, _, _ := runtime.Caller(0)
	// compatible solution to get gorm source directory with various operating systems
	gormSourceDir = sourceDir(file)
}

func sourceDir(file string) string {
	dir := filepath.Dir(file)

Registered: Sun Nov 03 09:35:10 UTC 2024

- Last Modified: Thu Aug 22 11:03:42 UTC 2024

- 4.1K bytes

- Viewed (0)

github.com/istio/istio

bin/build_ztunnel.sh

# limitations under the License.

set -o errexit
set -o nounset
set -o pipefail

if [[ "${TARGET_OUT_LINUX:-}" == "" ]]; then
  echo "Environment variables not set. Make sure you run through the makefile (\`make init\`) rather than directly."
  exit 1
fi

# Gets the download command supported by the system (currently either curl or wget)
DOWNLOAD_COMMAND=""
function set_download_command () {
  # Try curl.

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Tue Apr 02 21:46:06 UTC 2024

- 5K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/internaldebug/internal-debug_test.go

				strings.Join(c.args, " "), output)
		}
	} else {
		if fErr != nil {
			t.Fatalf("Unwanted exception for 'istioctl %s': %v", strings.Join(c.args, " "), fErr)
		}
	}
}

func init() {
	cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory {
		tf := cmdtesting.NewTestFactory()
		_, _, codec := cmdtesting.NewExternalScheme()
		tf.UnstructuredClient = &fake.RESTClient{

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Fri Mar 15 08:28:50 UTC 2024

- 4.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/hash/Striped64.java

      } else if (busy == 0 && cells == as && casBusy()) {
        boolean init = false;
        try { // Initialize table
          if (cells == as) {
            Cell[] rs = new Cell[2];
            rs[h & 1] = new Cell(x);
            cells = rs;
            init = true;
          }
        } finally {
          busy = 0;
        }
        if (init) break;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Jun 14 17:55:55 UTC 2024

- 11.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbFileInputStream.java

        this.unsharedFile = false;
        this.smb2 = th.isSMB2();
        try {
            init(th);
        }
        catch ( CIFSException e ) {
            throw SmbException.wrap(e);
        }
    }


    /**
     * @param f
     * @param th
     * @throws SmbException
     */
    private void init ( SmbTreeHandleInternal th ) throws CIFSException {
        if ( this.smb2 ) {

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun May 17 08:55:14 UTC 2020

- 13.2K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/plugin/plugin.go

	if k8sErr != nil {
		log.Errorf("Failed to get %s/%s pod info: %v", podNamespace, podName, k8sErr)
		return k8sErr
	}

	// Check if istio-init container is present; in that case exclude pod
	if pi.Containers.Contains(ISTIOINIT) {
		log.Infof("excluded due to being already injected with istio-init container")
		return nil
	}

	if val, ok := pi.ProxyEnvironments["DISABLE_ENVOY"]; ok {

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Wed Aug 14 19:36:19 UTC 2024

- 10.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/collect/CompactLinkedHashSet.java

  private transient int lastEntry;

  CompactLinkedHashSet() {
    super();
  }

  CompactLinkedHashSet(int expectedSize) {
    super(expectedSize);
  }

  @Override
  void init(int expectedSize) {
    super.init(expectedSize);
    this.firstEntry = ENDPOINT;
    this.lastEntry = ENDPOINT;
  }

  @Override
  int allocArrays() {
    int expectedSize = super.allocArrays();

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jul 09 00:15:47 UTC 2024

- 9.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/log/admin_log.jsp

            key="labels.log_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
        <jsp:param name="menuCategoryType" value="log"/>

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Wed Feb 12 20:25:27 UTC 2020

- 4K bytes

- Viewed (0)

github.com/gradle/gradle

.teamcity/src/main/kotlin/configurations/TestPerformanceTest.kt

import jetbrains.buildServer.configs.kotlin.BuildSteps
import model.CIBuildModel
import model.Stage

class TestPerformanceTest(model: CIBuildModel, stage: Stage) : OsAwareBaseGradleBuildType(os = Os.LINUX, stage, init = {
    val os = Os.LINUX
    val buildTypeThis = this
    val testProject = "smallJavaMultiProject"

    fun BuildSteps.gradleStep(tasks: List<String>) {
        gradleWrapper {
            name = "GRADLE_RUNNER"

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Thu Jul 18 07:02:47 UTC 2024

- 3.1K bytes

- Viewed (0)

Search Options