- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for encloses (0.32 sec)
-
internal/bucket/lifecycle/transition.go
return errTransitionDateNotMidnight } *tDate = TransitionDate{trnDate} return nil } // MarshalXML encodes expiration date if it is non-zero and encodes // empty string otherwise func (tDate TransitionDate) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error { if tDate.Time.IsZero() { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 10 17:07:49 GMT 2022 - 5.1K bytes - Viewed (0) -
internal/s3select/csv/record.go
other.csvRecord = other.csvRecord[:0] } other.columnNames = append(other.columnNames, r.columnNames...) other.csvRecord = append(other.csvRecord, r.csvRecord...) return other } // WriteCSV - encodes to CSV data. func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error { w := csv.NewWriter(writer) w.Comma = opts.FieldDelimiter w.AlwaysQuote = opts.AlwaysQuote w.Quote = opts.Quote
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0) -
internal/bucket/lifecycle/delmarker-expiration.go
if err != nil { return err } if dexp.Days <= 0 { return errInvalidDaysDelMarkerExpiration } *de = DelMarkerExpiration(dexp) return nil } // MarshalXML encodes a DelMarkerExpiration value into an XML element func (de DelMarkerExpiration) MarshalXML(enc *xml.Encoder, start xml.StartElement) error { if de.Empty() { return nil } type delMarkerExpiration DelMarkerExpiration
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 2.3K bytes - Viewed (0) -
internal/event/arn.go
func (arn ARN) String() string { if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" { return "" } return "arn:minio:sqs:" + arn.region + ":" + arn.TargetID.String() } // MarshalXML - encodes to XML data. func (arn ARN) MarshalXML(e *xml.Encoder, start xml.StartElement) error { return e.EncodeElement(arn.String(), start) } // UnmarshalXML - decodes XML data.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.1K bytes - Viewed (0) -
internal/http/check_port_linux.go
package http import ( "context" "net" "syscall" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
internal/dsync/locker.go
// * an error on failure of unlock request operation. ForceUnlock(ctx context.Context, args LockArgs) (bool, error) // Returns underlying endpoint of this lock client instance. String() string // Close closes any underlying connection to the service endpoint Close() error // Is the underlying connection online? (is always true for any local lockers) IsOnline() bool // Is the underlying locker local to this server?
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
internal/http/listener.go
WithReadDeadline(listener.opts.ClientReadTimeout). WithWriteDeadline(listener.opts.ClientWriteTimeout), result.err } case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/event/target/nsq.go
} return eErr } if err := target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
if !ok { dstRec = &Record{} } dstRec.columnNames = r.columnNames dstRec.csvRecord = csvRecord dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/admin-heal-ops.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)