- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 233 for Writer (0.17 sec)
-
cmd/storage-interface.go
DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/s3select/csv/args.go
QuoteCharacter string `xml:"QuoteCharacter"` QuoteEscapeCharacter string `xml:"QuoteEscapeCharacter"` unmarshaled bool } // IsEmpty - returns whether writer args is empty or not. func (args *WriterArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 5.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
}, }), }, want: "testdata/multiXdsStatusSinglePilot.txt", }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { got := &bytes.Buffer{} sw := XdsStatusWriter{Writer: got} input := map[string]*discovery.DiscoveryResponse{} for key, ss := range tt.input { input[key] = ss } err := sw.PrintAll(input) if tt.wantErr { assert.Error(t, err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 6.5K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
List(context.Background(), metav1.ListOptions{}) if err != nil { return err } if len(gws.Items) == 0 { fmt.Fprintln(writer, "No waypoints found.") return nil } w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0) slices.SortFunc(gws.Items, func(i, j gateway.Gateway) int { if r := cmp.Compare(i.Namespace, j.Namespace); r != 0 { return r }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
internal/logger/logger.go
InfoKind = madmin.LogKindInfo ) var ( // DisableErrorLog avoids printing error/event/info kind of logs DisableErrorLog = false // Output allows configuring custom writer, defaults to os.Stderr Output io.Writer = os.Stderr ) var trimStrings []string // TimeFormat - logging time format. const TimeFormat string = "15:04:05 MST 01/02/2006" var matchingFuncNames = [...]string{
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) -
cmd/main.go
for _, cmd := range closestCommands { console.Printf("\t‘%s’\n", cmd) } } os.Exit(1) } return app } func startupBanner(banner io.Writer) { CopyrightYear = strconv.Itoa(time.Now().Year()) fmt.Fprintln(banner, color.Blue("Copyright:")+color.Bold(" 2015-%s MinIO, Inc.", CopyrightYear)) fmt.Fprintln(banner, color.Blue("License:")+color.Bold(" "+MinioLicense))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/object-handlers_test.go
}, } // Iterating over the cases, fetching the object validating the response. for i, testCase := range testCases { // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for Get Object end point. req, err := newTestSignedRequestV4(http.MethodHead, getHeadObjectURL("", testCase.bucketName, testCase.objectName),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/notification.go
// DownloadProfilingData - download profiling data from all remote peers. func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) (profilingDataFound bool) { // Initialize a zip writer which will provide a zipped content // of profiling data of all nodes zipWriter := zip.NewWriter(writer) defer zipWriter.Close() for _, client := range sys.peerClients { if client == nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen.go
func (z *ServerSystemConfig) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "NEndpoints" err = en.Append(0x83, 0xaa, 0x4e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73) if err != nil { return } err = en.WriteInt(z.NEndpoints) if err != nil { err = msgp.WrapError(err, "NEndpoints") return } // write "CmdLines"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 24 21:36:44 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/batch-rotate_gen.go
// EncodeMsg implements msgp.Encodable func (z BatchJobKeyRotateEncryption) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Type" err = en.Append(0x83, 0xa4, 0x54, 0x79, 0x70, 0x65) if err != nil { return } err = en.WriteString(string(z.Type)) if err != nil { err = msgp.WrapError(err, "Type") return } // write "Key" err = en.Append(0xa3, 0x4b, 0x65, 0x79) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 27.1K bytes - Viewed (0)