- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for orjson (0.21 sec)
-
internal/logger/target/console/console.go
func (c *Target) Send(e interface{}) error { entry, ok := e.(log.Entry) if !ok { return fmt.Errorf("Uexpected log entry structure %#v", e) } if logger.IsJSON() { logJSON, err := json.Marshal(&entry) if err != nil { return err } fmt.Fprintln(c.output, string(logJSON)) return nil } if entry.Level == logger.EventKind { fmt.Fprintln(c.output, entry.Message) return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
cmd += " --manifests=" + string(snapshotCharts) cmd += " --output " + odArgs.common.outputFormat gotJSON, err := runCommand(cmd) if err != nil { t.Fatal(err) } if refreshGoldenFiles() { t.Logf("Refreshing golden file for %s", goldenFilepath) if err := os.WriteFile(goldenFilepath, []byte(gotJSON), 0o644); err != nil { t.Error(err) } } wantJSON, err := readFile(goldenFilepath)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
docs/debugging/inspect/main.go
// Parse parameters switch { case *stdin: // Parse 'mc support inspect --json' output input := struct { File string `json:"file"` Key string `json:"key"` }{} got, err := io.ReadAll(os.Stdin) if err != nil { fatalErr(err) } fatalErr(json.Unmarshal(got, &input)) inputFileName = input.File *keyHex = input.Key case len(flag.Args()) == 1:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
ClientTLSKey string `json:"clientTLSKey"` } `json:"tls"` SASL struct { Enable bool `json:"enable"` User string `json:"username"` Password string `json:"password"` Mechanism string `json:"mechanism"` } `json:"sasl"` // Queue store QueueSize int `json:"queueSize"` QueueDir string `json:"queueDir"` // Custom logger
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
internal/logger/console.go
} else { message = fmt.Sprint(args...) } logJSON, err := json.Marshal(&log.Entry{ Level: ErrorKind, Message: message, Time: time.Now().UTC(), Trace: &log.Trace{Message: message, Source: []string{getSource(6)}}, }) if err != nil { panic(err) } fmt.Fprintln(Output, string(logJSON)) } func (i errorMsg) quiet(msg string, args ...interface{}) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/license-update.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "fmt" "math/rand" "time" "github.com/tidwall/gjson" ) const ( licUpdateCycle = 24 * time.Hour * 30 licRenewPath = "/api/cluster/renew-license" ) // initlicenseUpdateJob start the periodic license update job in the background.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
if err != nil { return "", err } var values struct { SidecarInjectorWebhook struct { Global struct { Proxy struct { LogLevel string `json:"logLevel"` } `json:"proxy"` } `json:"global"` } `json:"sidecarInjectorWebhook"` } if err := yaml.Unmarshal([]byte(valuesConfig), &values); err != nil { return "", fmt.Errorf("failed to parse values config: %v [%v]", err, valuesConfig) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
internal/logger/logger.go
jsonFlag = true quietFlag = true } // EnableAnonymous - turns anonymous flag // to avoid printing sensitive information. func EnableAnonymous() { anonFlag = true } // IsJSON - returns true if jsonFlag is true func IsJSON() bool { return jsonFlag } // IsQuiet - returns true if quietFlag is true func IsQuiet() bool { return quietFlag }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
RequestSubResource: "", Name: pod.Name, Namespace: deploymentNS, }, Response: nil, } revBytes, err := json.Marshal(rev) if err != nil { return nil, err } resp, err := client.Post(address, "application/json", bytes.NewBuffer(revBytes)) if err != nil { return nil, err } defer resp.Body.Close() body, err := io.ReadAll(resp.Body) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)